| Server IP : 180.180.241.3 / Your IP : 216.73.216.252 Web Server : Microsoft-IIS/7.5 System : Windows NT NETWORK-NHRC 6.1 build 7601 (Windows Server 2008 R2 Standard Edition Service Pack 1) i586 User : IUSR ( 0) PHP Version : 5.3.28 Disable Function : NONE MySQL : ON | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /Program Files (x86)/MySQL/MySQL Workbench 6.1 CE/modules/ |
Upload File : |
,2Sc @ s d d l m Z d d l m Z d d l m Z d d l Z e d d d d d d
Z d e f d YZ e j e j
j d
Z e j e j
e j f d Z e j e j e j d Z e j e j e j
j d Z e j e j e j
j e j d Z e j e j e j
j d Z e j e j e j
j d Z e j e j d Z e j e j
d Z e j e j
j e j
j d Z e j e j
e j
j d Z e j e j
e j
j e j d Z e j e j
e j
j e j e j d Z e j e j
e j
j e j e j d Z e j e j
e j
j e j e j d Z e j e j
e j
j e j e j d Z! e j e j
e j
j e j e j d Z" e j e j
j# e j
j e j e j
e j f e j$ d Z% e j e j e j
j e j
j# d Z& e j e j
j# e j
j e j d Z' e j e j e j
j e j
j( d! Z) e j e j e j
j e j
j( d" Z* e j e j e j
j e j
j( d# Z+ e j e j e j
j e j
j( d$ Z, e j e j e j
j e j
j( d% Z- d S(& i( t Sql92ReverseEngineering( t DefineModule( t find_object_with_nameNt namet DbPostgresqlREt authors Oracle Corp.t versions 1.0t PostgresqlReverseEngineeringc B s e Z e d Z e d Z e d Z e d Z e d Z e d Z e d Z e d Z
RS( c C s d S( Nt
Postgresql( ( t cls( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyt getTargetDBMSName s c C s | j | j d S( NR ( t _connectionst __id__( R t
connection( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyt
serverVersion s c C s t t | j | | } | r
| j | d j d } t j d d | j | f g | j d j d j d D] } t
| ^ q} d d g } t j j } | d \ | _
| _ | _ | _ | | j | j d <| j
d
k r
t d | q
n | S( Ns select version()i s
PostgreSQL REs Connected to %s, %s
i t ,t .i R i sZ PostgreSQL version %s is not a supported migration source.
At least version 8 is required.( t superR t connectt
execute_queryt fetchonet grtt log_infoR t splitt rstript intt classest
GrtVersiont majorNumbert minorNumbert
releaseNumbert buildNumberR R t RuntimeError( R R
t passwordt rt vert nt ver_partsR ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR $ s F"c C s> g t t | j | | D] } | j d k r | ^ q S( s; Returns a list of schemata for the given connection object.t INFORMATION_SCHEMAt
PG_CATALOG( R& R' ( R R t getSchemaNamest upper( R R
t catalog_namet schema_name( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR( 3 s "c C s$ | j j d | j } d } | j | | j } x | D] \ } | j | | | j | f j \ } } } }
} } }
t j j } | | _ | | _ t
| | _ t
| | _ t
| | _
t
|
| _ t
| | _ t | | _ t
|
| _ | j j | q? Wd S( Ns SELECT c.relname
FROM pg_catalog.pg_class c JOIN pg_catalog.pg_namespace n
ON (c.relnamespace = n.oid)
WHERE n.nspname = '%s' AND c.relkind in ('S', 's')sf SELECT min_value, max_value, start_value,
increment_by, last_value, is_cycled, cache_value
FROM %s.%s( t sequencest
remove_allR R t fetchallR R R t db_Sequencet ownert strt minValuet maxValuet
startValuet incrementByt
lastNumberR t cycleFlagt cacheSizet append( R R
t schemat seq_names_queryt seq_details_queryt sequence_namest seq_namet min_valuet max_valuet start_valuet increment_byt
last_valuet is_cycledt ncachet sequence( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyt reverseEngineerSequences= s"
: c C s
| j } t | j d k rK t j d d | j | j | j f d Sd | j | j f } d } | j | | j } x| D]\ } } } }
} t j j
} | | _ d | _ | | _ | r d n d | _
g | j D] }
t |
^ q } |
t | k r>t j d | j d | j | f q n x | j | | | | j | j f D] \ } t | j | } | rt j j } | d
| | _ | | _ | j j | qdt j d | j d | j | | | j f qdqdW| j | q Wd S( Ni s %s: reverseEngineerTableIndicessT Reverse engineer of table %s.%s was attempted but the table has no columns attributei s` SELECT c2.relname, i.indisunique::int, i.indisclustered::int, i.indnatts, i.indkey
FROM pg_catalog.pg_class c, pg_catalog.pg_class c2, pg_catalog.pg_namespace n, pg_catalog.pg_index i
WHERE c.oid = i.indrelid AND i.indexrelid = c2.oid AND c.relnamespace = n.oid AND
n.nspname = '%s' AND c.relname = '%s' AND i.indisprimary = False
ORDER BY c2.relnames SELECT a.attname
FROM unnest(ARRAY%r) attrid
JOIN pg_catalog.pg_attribute a ON attrid=a.attnum
JOIN pg_catalog.pg_class c ON c.oid = a.attrelid
JOIN pg_catalog.pg_namespace n ON c.relnamespace = n.oid
WHERE n.nspname = '%s' AND c.relname = '%s't UNIQUEt INDEXs Reverse engineer of index %s.%s was attempted but the referenced columns count differs from the number of its referenced columns. Skipping index!R sz Reverse engineer of index %s.%s was attempted but the referenced column %s could not be found on table %s. Skipping index!( R0 t lent columnsR t
send_errorR
R R R. R t db_Indext isPrimaryt uniquet indexTypeR R t send_warningR t db_IndexColumnt referencedColumnR9 t addIndex( R R
t tableR: t all_indices_queryt index_columns_queryt
index_rowst
index_namet is_uniquet is_clusteredt column_countt column_refst indext colt colst column_namet columnt index_column( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyt reverseEngineerTableIndices[ sB %/ c C s| | d k r] d | j j | j | j f } | j | | j } | r] | d d } q] n t t | j | | | | S( Ns USER-DEFINEDs SELECT a.attname,
pg_catalog.format_type(a.atttypid, a.atttypmod)
FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_class c ON a.attrelid = c.oid
LEFT JOIN pg_catalog.pg_namespace n ON c.relnamespace = n.oid
WHERE n.nspname = '%s' AND c.relname = '%s' AND a.attname = '%s' AND NOT a.attisdropped;
i i ( R0 R R R. R R t getColumnDatatype( R R
RU Rb t type_namet queryt udtype( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyRe s c
C sT | j | } | j j d } | j | | } x | D] \ } } t j j } | | _ | | _ d | k r | | j d } n | } | j
}
x^ | j j D]P } | j j
|
k s |
g | j
D] } | j
^ q k r | | _ Pq q W| | _ | j j | q; Wd }
d } | j | | j d k rS| j d k rS|
n | } d } g } g } xO | D]G \ } } | | k r| } g } | j | | f n | j | quWd } x | D] \ } } t j j } | | _ d d j g | D] } d | j d
d ^ q | _ | | _ | | _ | j j | qWd S(
s
There are several kinds of user datatypes in Postgres, including:
- domains
- tuples/composite (table like structure)
- ranges (numeric ranges with fancy definition, only in 9.2+)
- base types
- enums
- others
As of now, we're only supporting domains and enums.
Ranges can be migrated to their underlying type.
Composite types should be migrated to StructuredTypes at some point.
s SELECT t.typname, pg_catalog.format_type(t.typbasetype, t.typtypmod)
FROM pg_catalog.pg_type t
LEFT JOIN pg_catalog.pg_namespace n ON n.oid = t.typnamespace
WHERE n.nspname NOT IN ('information_schema', 'pg_catalog') AND t.typtype = 'd' t (s SELECT t.typname, e.enumlabel
FROM pg_catalog.pg_type t LEFT JOIN pg_catalog.pg_namespace n
ON n.oid = t.typnamespace
LEFT JOIN pg_catalog.pg_enum e ON e.enumtypid = t.oid
WHERE t.typrelid = 0 AND t.typtype = 'e'
AND n.nspname NOT IN ('information_schema', 'pg_catalog')
AND NOT EXISTS(SELECT 1 FROM pg_catalog.pg_type el WHERE el.oid = t.typelem AND el.typarray = t.oid)
ORDER BY e.enumsortorders SELECT t.typname, e.enumlabel
FROM pg_catalog.pg_type t LEFT JOIN pg_catalog.pg_namespace n
ON n.oid = t.typnamespace
LEFT JOIN pg_catalog.pg_enum e ON e.enumtypid = t.oid
WHERE t.typrelid = 0 AND t.typtype = 'e'
AND n.nspname NOT IN ('information_schema', 'pg_catalog')
AND NOT EXISTS(SELECT 1 FROM pg_catalog.pg_type el WHERE el.oid = t.typelem AND el.typarray = t.oid)
i i s enum(%s)s , s '%s't 's ''N( R t
userDatatypesR- R R R t db_UserDatatypeR t
sqlDefinitiont findR) t _rdbmst simpleDatatypest synonymst
actualTypeR0 R9 R R t Nonet joint replace( R R
t catalogR t
query_domainst domain_typesRf t type_deft datatypet base_typet up_type_namet stypet st query_enumst query_enums_80t
enum_typest ltypet typest valuest
enum_labelt enumTypet enum_labelst l( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyt reverseEngineerUserDatatypes sL
=
6 9 ( t __name__t
__module__t classmethodR
R R R( RG Rd Re R ( ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR s
9c C s
t j d S( Ns postgresql_rdbms_info.xml( R t initializeDBMSInfo( ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR s c C s
t j S( N( R t getDataSourceNames( ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR s c C s
t j | S( N( R t quoteIdentifier( R ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR
s c C s
t j | S( N( R t fullyQualifiedObjectName( t obj( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR s c C s t j | | S( N( R R ( R
R! ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR s c C s
t j | S( N( R t
disconnect( R
( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR s c C s
t j | S( N( R t isConnected( R
( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR s c C s
t j S( N( R R
( ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR
$ s c C s
t j S( N( R t getSupportedObjectTypes( ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR ( s c C s
t j | S( N( R t getServerVersion( R
( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR , s c C s
t j | S( N( R t getCatalogNames( R
( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR 0 s c C s t j | | S( N( R R( ( R
R* ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR( 4 s c C s t j | | | S( N( R t
getTableNames( R
R* R+ ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR 8 s c C s t j | | | S( N( R t getViewNames( R
R* R+ ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR < s c C s t j | | | S( N( R t getTriggerNames( R
R* R+ ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR @ s c C s t j | | | S( N( R t getProcedureNames( R
R* R+ ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR D s c C s t j | | | S( N( R t getFunctionNames( R
R* R+ ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR H s c C s t j | | | | S( N( R t reverseEngineer( R
R* t
schemata_listt context( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR L s c C s t j | | S( N( R R ( R
Rv ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR P s c C s t j | | S( N( R t reverseEngineerCatalog( R
R* ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR T s c C s t j | | S( N( R t reverseEngineerTables( R
R: ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR X s c C s t j | | S( N( R t reverseEngineerViews( R
R: ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR \ s c C s t j | | S( N( R t reverseEngineerProcedures( R
R: ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR ` s c C s t j | | S( N( R t reverseEngineerFunctions( R
R: ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR d s c C s t j | | S( N( R t reverseEngineerTriggers( R
R: ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyR h s (. t db_sql92_re_grtR t wbR t workbench.utilsR R t
ModuleInfoR t exportR t
db_mgmt_RdbmsR t LISTt STRINGR R t GrtNamedObjectR t INTt db_mgmt_ConnectionR R R R
R R R R R( R R R R R t
db_Catalogt DICTR R R t db_SchemaR R R R R ( ( ( sS C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\db_postgresql_re_grt.pyt <module> s< $!$*$$'$*00000B------