OwlCyberSecurity - MANAGER
Edit File: sql_tables.pyc
� *��ac @ s8 d Z d d l m Z d d l m Z m Z d d l m Z d d l m Z m Z d d l m Z d d l m Z d d l m Z m Z m Z d d l m Z d d l m Z d d l Z d d l Z d d � Z d d � Z d � Z e � Z e j j e j _ e j j e j _ e j j e j _ e j! j" e j! _ e j! j# e j! _ e j! j$ e j! _ e j% j& e j% _ e j% j' e j% _ e j% j$ e j% _ e j( j e j( _ e j( j e j( _ e j( j) e j( _* e j+ j# e j+ _ e j+ j$ e j+ _ e j+ j, e j+ _* e j- j. e j- _ e j- j. e j- _ e j/ j0 e j/ _1 e j/ j2 e j/ _3 e j/ j e j/ _4 e j5 j6 e j5 _1 e j5 j7 e j5 _3 e j5 j$ e j5 _4 d � Z8 d � Z9 d � Z: d � Z; e: e j< j= e j< j> � Z? e? d � Z@ e? d � ZA e? d � ZB e? d � ZC e? d � ZD e: e jE j= e jE j> � ZF eF d � ZG eF d � ZH eF d � ZI e: e jJ j= e jJ j> � ZK eK d � ZL eK d � ZM eK d � ZN eK d � ZO eK d � ZP e: e jQ j= e jQ j> � ZR eR d � ZS eR d � ZT e: e jU j= e jU j> � ZV eV d! � ZW eV d" � ZX eV d# � ZY e: e jZ j= e jZ j> � Z[ e[ d$ � Z\ e[ d" � Z] e[ d# � Z^ e[ d% � Z_ e[ d& � Z` e[ d' � Za e[ d( � Zb e[ d) � Zc e: e jd j= e jd j> � Ze ee d* � Zf ee d' � Zg ee d+ � Zh ee d, � Zi e; e jj j= e jj j> � \ Zk Zl d- em f d. � � YZn i d/ d0 6d1 d2 6d3 d4 6d5 d6 6Zo d7 � Zp eq d8 � Zr e d9 � Zs et d: k r4d d lu Zu ev eu jw � d; k r�eu jw d< n d Zx e ex � \ Zy Zz Z{ d= j| ey j} � GHez j~ � r�d> j| ez j} � n d? GHd@ j| e{ j} � GHe{ j dA � �0 Z� e ey � Z es e� dB e �e e� ez � Wd QXdC GHn d S(D s SQL Table definitions. i����( t getModule( t SchemaSyntaxt QueryGenerator( t NO_DEFAULT( t Sequencet ProcedureCall( t schemaFromPath( t FixedPlaceholder( t ORACLE_DIALECTt POSTGRES_DIALECTt DatabaseType( t Insert( t ORACLE_TABLE_NAME_MAXNc C s? | d k r� t t � j j d � j d � } t t � j j d � j d j t � � } t t � j j d � j d j t � � } n� t t � j j d � j d � j t � j d | f � } t t � j j d � j d � j t � j d | f � } t t � j j d � j d � j t � j d | f � } | | | f S( s� Find the set of files to process, either the current set if C{version} is L{None}, otherwise look for the specific version. @param version: version identifier (e.g., "v1", "v2" etc) @type version: L{str} t sql_schemas current.sqls current-{}-extras.sqls current-{}.sqlt olds %s.sqls {}-extras.sqls {}.sqlN( t NoneR t __name__t filePatht siblingt childt formatR R ( t versiont currentObjt extrasObjt outObj( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt _schemaFiles$ s !*-:::c C s, | d k r t � d } n t t | � � S( s. Generate the global L{SchemaSyntax}. i N( R R R R ( t pathObj( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt _populateSchema8 s c C sH | j � rD | j d j t j d � | j � j � � � d � n d S( sQ If an extras file exists, add its entire content to the output stream.. s c S s | j d � S( Ns -- Extra schema to add( t startswith( t x( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt <lambda>H t N( t existst writet joint itertoolst dropwhilet getContentt splitlines( t outt extras( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt _schemaExtrasB s c K sc i } xV | j � D]H \ } } | j g | j � D]" \ } } d | | f | f ^ q2 � q W| S( sz Combine two table dictionaries used in a join to produce a single dictionary that can be used in formatting. s %s:%s( t itemst update( t kwt resultt tableRolet tableDictionaryt kt v( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt _combineq s 7c C s� i } | j j | d <t j j d � j | d <x( | D] } | j j | d | j j <q6 Wx4 | j � j � D] \ } } | j j | d | <qm W| S( s� Construct a dictionary of strings from a L{TableSyntax} for those queries that are still constructed via string interpolation. t namet REVISION_SEQt sequencet column_( t modelR3 t schemat sequenceNamedt columnAliasesR* ( t tableSyntaxR- t columnSyntaxt aliast realColumnSyntax( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt _S} s c s � � f d � } | S( sC Get a constant value from the rows defined in the schema. c sK xD � j j j D]3 } � j | k r | � j | k r | � j Sq Wd S( N( R7 t tablet schemaRows( R3 t row( t nameColumnt valueColumn( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt get� s "( ( RC RD RE ( ( RC RD s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt _schemaConstants� s c C s� i } i } xh | j j j D]W } | j | k r | j | k r | | j | | | j <| | j | | | j <q q W| | f S( so Generate two dicts that map back and forth between SQL enum values and their programmatic values. ( R7 R@ RA ( RC RD t toSQLt fromSQLRB ( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt _schemaConstantsMaps� s t normalt externalt purgingt migratingt disabledt inboxt trasht invitedt acceptedt declinedt invalidt deletedt opaquet transparentt nonet readR! t ownt directt indirectt groupt group_readt group_writet persont resourcet locationt SchemaBrokenc B s e Z d Z RS( s8 The schema is broken and cannot be translated. ( R t __module__t __doc__( ( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyRc s t nclobt textt integert booleant nvarchar2t varchart nchart charc C sE t | t t f � r7 d j d | j d d � d g � St | � Sd S( s$ Quote an object for inclusion into an SQL string. @note: Do not use this function with untrusted input, as it may be a security risk. This is only for translating local, trusted input from the schema. @return: the translated SQL string. @rtype: C{str} R t 's ''N( t isinstancet strt unicodeR" t replace( R ( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt _quoted s "c C s� t t t d � t d � � } | r3 d � | _ n t | d � rW | j | g � } n | j | � } t g | j D] } t | � ^ qs � } | j | } | S( s� Statically generate some SQL from some DAL syntax objects, interpolating any parameters into the body of the string. @note: Do not use this function with untrusted input, as it may be a security risk. This is only for translating local, trusted input from the schema. @param sql: something from L{twext.enterprise.dal}, either a top-level statement like L{Insert} or L{Select}, or a fragment such as an expression. @param doquote: Force all identifiers to be double-quoted, whether they conflict with database identifiers or not, for consistency. @return: the generated SQL string. @rtype: C{str} t pyformats %sc S s t S( N( t True( R3 ( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyR 8 R t subSQL( R R R R t shouldQuotet hasattrRv RG t tuplet parametersRs Rg ( t sqlt doquotet qgent fragmentt paramt paramsR- ( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt _staticSQL# s ( c s� x+ | j j D] } � j d | j f � q W� j d � x�| D]x} t | j j � t k r| t d | j j f � � n � j d | j j t f � t } xg| D]_} | r� t } n � j d � t | j j � t k r� t d | j j f � � n | j j j } t j | | � } � j d | j j | f � | j j j rj� j d | j j j f � n | j g | j j k r�� j d � n | j j } | t k rHt | t � sH� j d � | d, k r�� j d � qEt | t � r� j d � qE| t k rd } n | t k r+d } n � j d t | � � qHn | j j � rt| d- k rt� j d � n | j g t | j j � � k r�� j d � n | j j d, k r�� j d | j j j f � n | j j d, k r� � j d | j j f � q� q� W� f d � } | j j } | d, k rSt | � d k rS| d | � n x< | j j � D]+ } t | � d k r�qcn | d | � qcWxy | j j D]k } | j d k r�� j d � | j d, k r�� j d | j f � n � j d t | j t � � q�q�W� j d! � xw | j j D]i } t g | j � D]$ \ } } t | | j � | f ^ q>� } � j t t! | � � � � j d" � q(W� j t | j j � r�d n d# � qB Wx� | j j" D]� } d$ | j d% t# t$ j% | j � j& � � d& f } | j' j d' } � j d( | | f � � j d) j( g | j) D] } d* j* | j � ^ qA� � � j d! � q�Wx- | j j+ D] } � j d+ j* | j � � q�Wd, S(. s� When run as a script, translate the schema to another dialect. Currently only postgres and oracle are supported, and native format is postgres, so emit in oracle format. s create sequence %s; s s Table name too long: %ss create table %s ( s , s Column name too long: %ss "%s" %ss (%s)s primary keys defaults nulls% CURRENT_TIMESTAMP at time zone 'UTC'i i t Rk Rf Rm Rl t nvarcharRj s not nulls uniques references %ss on delete %sc s; � j d � � j d | d j d � | D� � f � d S( Ns , s %s(%s)s , c s s | ] } d | j d Vq d S( t "N( R3 ( t .0t col( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pys <genexpr>� s ( R! R" ( R3 t cols( R' ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt writeConstraint� s s primary key s unique t CHECKs , s constraint "%s" s check (%s)s ); s ; s s %s_%si i i s create index %s on %s ( s , s "{}"s -- Skipped Function {} N( Rk Rf Rm Rl R� Rj (, R7 t sequencesR! R3 t lenR Rc Ru t Falset typet _translatedTypesRE t lengtht primaryKeyt defaultR Ro R R R t reprt canBeNullt listt uniquest referencest deleteActiont constraintsR� t expressionRA t dictR* t getattrR t indexesRp t hashlibt md5t hexdigestR@ R" t columnsR t functions( R' R8 R5 R@ t firstt columnt typeNameR� R� t pkt uniqueColumnst checkConstraintRB t cmodelt valt cmapt indext shortIndexNamet shortTableNamet function( ( R' s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt _translateSchemaB s� ! ! 7) &8t __main__i i s Reading from {}s Extras from {}s No extrass Writing to {}t wR8 t Done(� Re t twisted.python.modulesR t twext.enterprise.dal.syntaxR R t twext.enterprise.dal.modelR R R t twext.enterprise.dal.parseschemaR R t twext.enterprise.ienterpriseR R R R R R� R# R R R R) R8 t CALENDAR_BINDt CALENDAR_RESOURCE_NAMEt RESOURCE_NAMEt CALENDAR_RESOURCE_IDt RESOURCE_IDt CALENDAR_HOME_RESOURCE_IDt HOME_RESOURCE_IDt SHARED_ADDRESSBOOK_BINDt ADDRESSBOOK_RESOURCE_NAMEt OWNER_HOME_RESOURCE_IDt ADDRESSBOOK_HOME_RESOURCE_IDt SHARED_GROUP_BINDt GROUP_ADDRESSBOOK_NAMEt GROUP_RESOURCE_IDt CALENDAR_OBJECT_REVISIONSt CALENDAR_NAMEt COLLECTION_NAMEt ADDRESSBOOK_OBJECT_REVISIONSt ADDRESSBOOK_NAMEt NOTIFICATION_OBJECT_REVISIONSt NOTIFICATION_HOME_RESOURCE_IDt CALENDAR_OBJECTt ICALENDAR_TEXTt TEXTt ICALENDAR_UIDt UIDt PARENT_RESOURCE_IDt ADDRESSBOOK_OBJECTt VCARD_TEXTt VCARD_UIDR2 R? RF RI t HOME_STATUSt DESCRIPTIONt IDt _homeStatust _HOME_STATUS_NORMALt _HOME_STATUS_EXTERNALt _HOME_STATUS_PURGINGt _HOME_STATUS_MIGRATINGt _HOME_STATUS_DISABLEDt CHILD_TYPEt _childTypet _CHILD_TYPE_NORMALt _CHILD_TYPE_INBOXt _CHILD_TYPE_TRASHt CALENDAR_BIND_STATUSt _bindStatust _BIND_STATUS_INVITEDt _BIND_STATUS_ACCEPTEDt _BIND_STATUS_DECLINEDt _BIND_STATUS_INVALIDt _BIND_STATUS_DELETEDt CALENDAR_TRANSPt _transpValuest _TRANSP_OPAQUEt _TRANSP_TRANSPARENTt CALENDAR_OBJ_ATTACHMENTS_MODEt _attachmentsModet _ATTACHMENTS_MODE_NONEt _ATTACHMENTS_MODE_READt _ATTACHMENTS_MODE_WRITEt CALENDAR_BIND_MODEt _bindModet _BIND_MODE_OWNt _BIND_MODE_READt _BIND_MODE_WRITEt _BIND_MODE_DIRECTt _BIND_MODE_INDIRECTt _BIND_MODE_GROUPt _BIND_MODE_GROUP_READt _BIND_MODE_GROUP_WRITEt ADDRESSBOOK_OBJECT_KINDt _addressBookObjectKindt _ABO_KIND_PERSONt _ABO_KIND_GROUPt _ABO_KIND_RESOURCEt _ABO_KIND_LOCATIONt SCHEDULE_ACTIONt scheduleActionToSQLt scheduleActionFromSQLt ExceptionRc R� Rs R� R� R� R t sysR� t argvR t currentR( R' R t pathR t opent outfd( ( ( s4 /opt/cpanel-ccs/txdav/common/datastore/sql_tables.pyt <module> s� y (#