| Server IP : 209.209.40.120 / Your IP : 216.73.217.112 Web Server : Microsoft-IIS/10.0 System : Windows NT NEWWWW 10.0 build 17763 (Windows Server 2019) i586 User : NEWWWW$ ( 0) PHP Version : 8.3.30 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : C:/Program Files/MySQL/MySQL Workbench 6.3 CE/modules/ |
Upload File : |
�
�"�Xc @ s� 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 e d d d d
d d � Z
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$ � � Z0 e
j e j e j j e j j/ � d% � � Z1 e
j e j e j j e j j/ � d& � � Z2 e
j e j e j j e j j/ � d' � � Z3 e
j e j e j j e j j/ � d( � � Z4 e
j e j e j j � d) � � Z5 d S(* i����( t GenericReverseEngineering( t DefineModule( t find_object_with_namet server_version_str2tuplet replace_string_parameters( t db_driver( t NotConnectedErrorNt namet DbSQLAnywhereREt authors Oracle Corp.t versions 1.0c s � f d � } | S( s� Deletes the available cursors in the connection once the wrapped method finishes.
This is needed because in sqlanydb the cursors are not deleted once they go out of scope,
because the connection keeps a set with each instantiated cursor. To make things worse,
the number of available cursors is limited so the rev eng process may fail at some point
when this limit is reached.
Any method of the Rev Eng class that executes a query should be decorated with this function.
c sp � | | | � } | j | � } | j j d k rl x$ | j j D] } | j d t � q@ Wt � | j _ n | S( Nt sqlanydbt remove( t get_connectiont drivert driverLibraryNamet connt cursorst closet Falset set( t clst
connectiont argst rest ct cursor( t method( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt wrapped_method' s ( ( R R ( ( R sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt release_cursors s
t SQLAnywhereReverseEngineeringc B s1 e Z e d � � Z e d � � Z e e d � � � Z e e d � � � Z e e d � � � Z e e d � � � Z e e d � � � Z
e e d � � � Z e d � � Z e e d � � � Z
e e d
� � � Z e e d � � � Z e e d � � � Z e e d
� � � Z e e d � � � Z RS( c C s d S( Nt SQLAnywhere( ( R ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt getTargetDBMSName3 s c C s | j | j d S( NR
( t _connectionst __id__( R R ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt
serverVersion7 s c C sz d } yq | j | � } y( | j � j d � s? t d � � n Wn3 t k
ru } t j d | j � t d � � n XWnet k
r�} t j d | j � | j j
d k r�d d l } t | j j
t | j � � } d d l } y | j | � } Wn' t k
r!} t j d | � � n Xt d
� | j � D� � } | | d <t | � }
d |
d <t |
� | j d
<| j | � } n t j | | � } | s�t j d t | � � � n t j d � i | d 6| j | j <n X| rv| j | d � j � d } t j d d | j | f � t | � d } t j j � }
| d \ |
_! |
_" |
_# |
_$ |
| j | j d <n d S( s� Establishes a connection to the server and stores the connection object in the connections pool.
It first looks for a connection with the given connection parameters in the connections pool to
reuse existent connections. If such connection is found it queries the server to ensure that the
connection is alive and reestablishes it if is dead. If no suitable connection is found in the
connections pool, a new one is created and stored in the pool.
Parameters:
===========
connection: an object of the class db_mgmt_Connection storing the parameters
for the connection.
password: a string with the password to use for the connection (ignored for SQLite).
s SELECT 1s connection errors1 Connection to %s apparently lost, reconnecting...s Connection errors Connecting to %s...R i����Ns: The given connection string is not a valid python dict: %sc s s? | ]5 \ } } | j d � o* | j d � s | | f Vq d S( t %N( t
startswitht endswith( t .0t keyt value( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pys <genexpr>a s t passwords
%password%t wbcopytables_connection_strings Connection failedt ConnectedR s SELECT @@versioni s SQLAnywhere REs Connected to %s, %s
i R
i ( i i i i (% t NoneR
R t executet Exceptiont grtt send_infot hostIdentifierR R R t sqlanydbwrapperR t connectionStringTemplatet dictt parameterValuest astt literal_evalt
send_errort iteritemst reprt connectR t strR! R" t
execute_queryt fetchonet log_infoR R t classest
GrtVersiont majorNumbert minorNumbert
releaseNumbert buildNumber( R R R* t cont excR t connstrR7 t all_params_dictt paramst conn_paramst vert ver_partsR
( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR< ; sR
"c C s | j | d � j � d g S( s� Returns a list of the available catalogs.
[NOTE] This will in fact return the name of the database we are connected to.
s SELECT DB_PROPERTY('Name')i ( R> R? ( R R ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt getCatalogNames{ s c C s& t t d � | j | d � D� � � S( s; Returns a list of schemata for the given connection object.c s s | ] } | d Vq d S( i N( ( R' t row( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pys <genexpr>� s t sp_tables( t sortedR R> ( R R t catalog_name( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt getSchemaNames� s c C s1 d | } g | j | | � D] } | d ^ q S( Ns� SELECT st.table_name
FROM SYSTAB st LEFT JOIN SYSUSER su ON st.creator=su.user_id
WHERE su.user_name = '%s' AND st.table_type = 1i ( R> ( R R RS t schema_namet queryRP ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt
getTableNames� s
c C s1 d | } g | j | | � D] } | d ^ q S( Ns� SELECT st.table_name
FROM SYSTAB st LEFT JOIN SYSUSER su ON st.creator=su.user_id
WHERE su.user_name = '%s' AND st.table_type IN (2, 21)i ( R> ( R R RS RU RV RP ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt getViewNames� s
c C s1 d | } g | j | | � D] } | d ^ q S( Nsp SELECT sp.proc_name
FROM SYSPROCEDURE sp LEFT JOIN SYSUSER su ON sp.creator=su.user_id
WHERE su.user_name = '%s'i ( R> ( R R RS RU RV RP ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt getProcedureNames� s
c C s. t t | � j | d | | � } | | _ | S( Nt ( t superR t reverseEngineerR ( R R RS t
schemata_listt contextt catalog( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR\ � s ! c C sI d | j | j j f } d j g | j | | � D] } | d ^ q2 � S( Ns� SELECT sr.remarks
FROM SYSTAB st JOIN SYSUSER su ON st.creator=su.user_id
JOIN SYSREMARK sr ON st.object_id=sr.object_id
WHERE st.table_name='%s' AND su.user_name='%s'RZ i ( R t ownert joinR> ( R R t tableRV RP ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt getCommentForTable� s c
C s, | j j � d } | j | � j d k r4 d } n t � } x4 | j j D]& } | j | j g t | j
� � qJ Wx� | j | | � D]� \ } } } | | k r� q� n t j
j � } | | _ | | _ x? | j j D]1 } | j | k s� | | j
k r� | | _ Pq� q� W| | _ | j j | � q� Wd S( Ns� SELECT UPPER(st.type_name), UPPER(base_type_str), UPPER(sd.domain_name )
FROM SYSUSERTYPE st LEFT JOIN SYSDOMAIN sd ON st.domain_id=sd.domain_idi s� SELECT
UPPER(st.type_name),
CASE
WHEN st.type_name = 'money' THEN UPPER(sd.domain_name+'(19,4)')
WHEN st.type_name = 'smallmoney' THEN UPPER(sd.domain_name+'(10,4)')
WHEN st.type_name = 'sysname' THEN UPPER(sd.domain_name+'(30)')
WHEN st.type_name = 'uniqueidentifierstr' THEN 'CHAR(36)'
WHEN st.type_name = 'uniqueidentifier' THEN 'BINARY(16)'
ELSE
UPPER(sd.domain_name)
END AS base_type_str,
UPPER(sd.domain_name )
FROM
SYSUSERTYPE st
LEFT JOIN
SYSDOMAIN sd ON st.domain_id=sd.domain_id( t
userDatatypest
remove_allR# RC R t _rdbmst simpleDatatypest updateR t listt synonymsR> R0 RA t db_UserDatatypet
sqlDefinitiont
actualTypeR` t append(
R R R_ RV t simple_datatypest datatypet type_namet sql_definitiont parent_typet stype( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt reverseEngineerUserDatatypes� s&
$" c C s� d | j | j j f } x�| j | | � D]�\ } } } } } } t j j � }
| p\ d |
_ | d k |
_ d |
_ | j d � r� | d } |
j j
d � n | j | j j | � \ } } | s#| j | j j d � \ } } d } d
| |
j | j j | j f }
t j d |
� n | r5| |
_
n | |
_ | d k rVt | � n d |
_ | rq| j j n | j j j } | d k r�t | � n d } | j � d
k r�d |
_ | |
_ | |
_ n | |
_ d |
_ |
_ | j |
� q, Wd S( Ns1 SELECT UPPER(sd.domain_name), sc.column_name, sc.nulls, sc.width, sc.scale, sc."default"
FROM SYSTABCOL sc JOIN SYSDOMAIN sd ON sc.domain_id=sd.domain_id
JOIN SYSTAB st ON sc.table_id=st.table_id
JOIN SYSUSER su ON st.creator=su.user_id
WHERE st.table_name='%s' AND su.user_name='%s'
ORDER BY sc.column_idRZ t Nt ns UNSIGNED i t UNSIGNEDt VARCHARi� sX Column datatype "%s" for column "%s" in table "%s.%s" reverse engineered as VARCHAR(255)s( SQL Anywhere reverseEngineerTableColumnsi����t NUMERIC( Rv Rw ( R R` R> R0 RA t db_Columnt isNotNullt
collationNameR% t flagsRn t find_datatype_objectt send_warningt
simpleTypet userTypeR- R= t defaultValuet groupRm t intt uppert lengtht precisiont scalet addColumn( R R Rb RV Rp t col_namet nullablet widthR� t
default_valuet columnt is_simple_datatypet datatype_objectt msgR� ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt reverseEngineerTableColumns� s8 +
" !! c C s! | j } t | j � d k r6 t j d | j � d Sd | j | j f } | j | � j � } x�| j | � D]�\ } } } } }
t j j
� } | | _ | d k r� d n d | _ |
d k r� d n d | _ | d k r� d | _
nK | d k r� qq n9 | d k r.|
d k r"d | _
q7d | _
n d
| _
d | | f } | j | � j � }
x� |
j | � D]� \ } } t | j | � } | rlt j j � } | d | | _ | | _ | r�| j � d
k r�d n d | _ | j j | � qlqlW| j | � | j rq | | _ qq qq Wd S( s9 Reverse engineers the primary key(s) for the given table.i sw Migration: reverseEngineerTablePK: Reverse engineering of table %s was attempted but the table has no columns attributei s� SELECT st.table_id, si.index_id, si.index_name, si.index_category, si."unique"
FROM SYSIDX si
JOIN SYSTAB st ON si.table_id=st.table_id
JOIN SYSUSER su ON st.creator=su.user_id
WHERE st.table_name='%s' AND su.user_name='%s'
ORDER BY si.index_idi t PRIMARYi t UNIQUEt INDEXt FULLTEXTs� SELECT sc.column_name, sic."order"
FROM SYSIDXCOL sic
JOIN SYSTAB st ON sic.table_id=st.table_id
JOIN SYSTABCOL sc ON (sc.column_id = sic.column_id AND sc.table_id = sic.table_id)
WHERE st.table_id=%s AND sic.index_id=%s
ORDER BY sic.sequencet .t D( i i ( R` t lent columnsR0 R9 R R
R R. RA t db_Indext isPrimaryt uniquet indexTypeR t db_IndexColumnt referencedColumnR� t descendRn t addIndext
primaryKey( R R Rb t schemaRV t
idx_cursort table_idt index_idt
index_namet index_categoryt index_uniquet indext idx_cols_queryt idx_cols_cursort column_namet orderR� t index_column( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt reverseEngineerTablePK sD %
'
c C s9 | j } | j } t | j � d k r? t j d | j � d Sd | j | j f } | j | � j � } x�| j | � D]�\ } } } }
} d | | f } d |
| f }
| j | | � j
� } | j | |
� j
� } t j j � } | | _ | | _ | d d r(t
| j | d d � n | } | d d rVt
| j | d d � n | | _ x� t | | � D]� \ \ } \ } } } t
| j | � } | s�t j d | | j f � qon t
| j j | � } | s�t j d | | j j f � qon | j j | � | j j | � qoW| j j | � qz Wd S( s7 Reverse engineers the foreign keys for the given table.i sx Migration: reverseEngineerTableFKs: Reverse engineering of table %s was attempted but the table has no columns attributei s� SELECT si.index_name, sfk.foreign_table_id, sfk.foreign_index_id, sfk.primary_table_id, sfk.primary_index_id
FROM SYSFKEY sfk
JOIN SYSIDX si ON (sfk.foreign_index_id=si.index_id AND sfk.foreign_table_id=si.table_id)
JOIN SYSTAB st ON sfk.foreign_table_id=st.table_id
JOIN SYSUSER su ON st.creator=su.user_id
WHERE st.table_name='%s' AND su.user_name='%s'
ORDER BY sfk.primary_index_ids� SELECT stc.column_name
FROM SYSIDXCOL sic
JOIN SYSTABCOL stc ON (sic.table_id=stc.table_id AND sic.column_id=stc.column_id)
WHERE sic.table_id=%d AND sic.index_id=%d
ORDER BY sic.sequences, SELECT su.user_name, st.table_name, stc.column_name
FROM SYSIDXCOL sic
JOIN SYSTABCOL stc ON (sic.table_id=stc.table_id AND sic.column_id=stc.column_id)
JOIN SYSTAB st ON stc.table_id=st.table_id
JOIN SYSUSER su ON st.creator=su.user_id
WHERE sic.table_id=%d AND sic.index_id=%d
ORDER BY sic.sequencesG Migration: reverseEngineerTableFKs: Column "%s" not found in table "%s"( R` R� R� R0 R9 R R
R R. R> t fetchallRA t
db_ForeignKeyR t schematat tablest referencedTablet zipRn t referencedColumnst foreignKeys( R R Rb R� R_ RV t fk_cursort fk_namet
this_table_idt
this_index_idt other_table_idt other_index_idt this_column_queryt other_column_queryt
these_columnst
other_columnst foreign_keyt referenced_schemat this_column_namet _t other_column_nameR� t
ref_column( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt reverseEngineerTableFKsR s< % .1( c C sJ | j | d � j � d j � } d | k r2 d Sd | k rB d Sd Sd S( Ns SELECT PROPERTY ('Platform')i t unixt linuxt windowst darwin( R> R? t lowerR- ( R R t _os( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt getOS� s " ( t __name__t
__module__t classmethodR R# R R< RO RT RW RX RY R\ Rc Ru R� R� R� R� ( ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR 2 s6 ? +/=>c C s
t j d � S( Ns sqlanywhere_rdbms_info.xml( R t initializeDBMSInfo( ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s
t j � S( N( R t getDataSourceNames( ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s
t j | � S( N( R t quoteIdentifier( R ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s
t j | � S( N( R t fullyQualifiedObjectName( t obj( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s t j | | � S( N( R R< ( R R* ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR< � s c C s
t j | � S( N( R t
disconnect( R ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s
t j | � S( N( R t isConnected( R ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s
t j � S( N( R R ( ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR � s c C s
t j � S( N( R t getSupportedObjectTypes( ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s
t j | � S( N( R t getServerVersion( R ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s
t j | � S( N( R RO ( R ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyRO � s c C s t j | | � S( N( R RT ( R RS ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyRT � s c C s t j | | | � S( N( R RW ( R RS RU ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyRW � s c C s t j | | | � S( N( R RX ( R RS RU ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyRX � s c C s t j | | | � S( N( R t getTriggerNames( R RS RU ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s t j | | | � S( N( R RY ( R RS RU ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyRY � s c C s t j | | | � S( N( R t getFunctionNames( R RS RU ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s t j | | | | � S( N( R R\ ( R RS R] R^ ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR\ � s c C s t j | | � S( N( R Ru ( R R_ ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyRu � s c C s t j | | � S( N( R t reverseEngineerCatalog( R RS ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s t j | | � S( N( R t reverseEngineerTables( R R� ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s t j | | � S( N( R t reverseEngineerViews( R R� ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s t j | | � S( N( R t reverseEngineerProcedures( R R� ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s t j | | � S( N( R t reverseEngineerFunctions( R R� ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� � s c C s t j | | � S( N( R t reverseEngineerTriggers( R R� ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� s c C s
t j | � S( N( R R� ( R ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyR� s (6 t db_generic_re_grtR t wbR t workbench.utilsR R R t workbenchR t workbench.exceptionsR R0 t
ModuleInfoR R t exportRA t
db_mgmt_RdbmsR� t LISTt STRINGR� R� t GrtNamedObjectR� t INTt db_mgmt_ConnectionR< R� R� R R� RB R� RO RT RW RX R� RY R� t
db_Catalogt DICTR\ Ru R� t db_SchemaR� R� R� R� R� R� ( ( ( sN C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\db_sqlanywhere_re_grt.pyt <module> sF � n $!$*$$'$*00000B-------