| 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 : C:/Program Files (x86)/MySQL/MySQL Workbench 6.1 CE/modules/ |
Upload File : |
,2Sc @ s4 d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l 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 m Z d e f d
YZ d Z e d Z d
Z d e
f d YZ d e f d YZ d S( i( t with_statementN( t Thread( t get_connection_parameters( t replace_string_parameterst parameters_from_dsnt' dsn_parameters_to_connection_parameters( t NotConnectedError( t db_utils( t request_passwordt HelperExitedc B s e Z d Z RS( c C s t j | | | | _ d S( N( t Exceptiont __init__t
returncode( t selft whatR ( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyR " s ( t __name__t
__module__R ( ( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyR ! s c C s | j } | j j d k r# d | S| j j d k r| j d t s y) t j | d t | } | j Wn& t t j
f k
r t d n X| j d } | r | j
r | j d } i | d d 6| d 6} | j q t d
n d | St d | j j d S(
Nt MysqlNatives" %(userName)s@%(hostName)s:%(port)st MysqlNativeSockett sockett passwords There is no connection to the target MySQL server and the socket parameter in your target connection settings is blank. Please check that your target server is running or go back to the Target Selection page and set the socket parameter there.s SHOW VARIABLES LIKE 'socket';t Valuet userNames Failed while querying the socket server variable and the socket parameter in your target connection settings is blank. Please go back to the Target Selection page and make sure that you have the socket parameter set.s %(userName)s@::%(socket)ss8 Connection method type %s is not supported for migration( t parameterValuest drivert namet gett FalseR t MySQLConnectionR t connectR t
MySQLErrorR
t executeQueryt nextRowt stringByNamet
disconnect( t connt paramt
connectiont resultR ( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyt mysql_conn_string' s$
c C sn t | j } | j t | | j j p1 d } t | | } | rj t j d d | j d } n | S( Nsa DRIVER={%driver%};SERVER=%host%;PORT=%port%;DATABASE={%database%};UID=%username%;PWD={%password%}s (PWD={[^;]}*|PWD=[^;]*)t t ;(
t dictR t updateR R t connectionStringTemplateR t ret subt rstrip( R# t strip_passwordt conn_paramst connection_string_templatet
connstring( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyt odbc_conn_stringC s !c C s | j j d | j d S( Ns ://t wbcopytables_connection_string( R t driverLibraryNameR ( R# ( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyt python_conn_stringM s t TableCopyWorkerc B s, e Z d Z d Z d Z d Z RS( c C s t j | | | _ | | _ | | _ t j d d | | j j d j | t j
d k r t j | d t j
d t j
d t j d t d t | _ n9 t j | d t j
d t j
d t j d t d
t | _ d S( Nt Migrations Spawning copy worker task: %st t win32t stdint stdoutt stderrt universal_newlinest shellt close_fds( R R t _ownert result_queuet
_process_argst grtt
log_debug3t send_infot joint syst platformt
subprocesst Popent PIPEt STDOUTt Truet process( R
t ownert argsRC ( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyR R s
''c C sx | j j d k r_ t | t k r9 | j d } n | j j j | | j j j n t d | j j
d S( Ns utf-8s% Table copy task finished unexpectedly( RP t pollt Nonet typet unicodet encodeR< t writet flushR R ( R
t text( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyt
feed_inputb s c C s, yx | j j d k r | j j r< t j d n | j j j } | d k r | j j
d \ } } } | d k r | j j | | f q | j j d | f q q W| j j j
} | j d } xv | D]n } | d k r | j j
d \ } } } | d k r7| j j | | f qP| j j d | f q q W| j j d k r| j j d
d | j j f n | j j d Wn t j k
r} | j j d | j | j | j j d nE t k
r'} d d l } | j | j j d
t | f n Xd S( Ns Canceled by usert :t PROGRESSt ERRORt BEGINt ENDt LOGs
i t DONEs Worker exited with status %ss0 Copy task interrupted by user, terminating %s...t INTERRUPTEDi( s PROGRESSs ERRORR_ s END( s PROGRESSs ERRORR_ s END( Rb N( Rc N( RP RS RT RB t query_cancel_statusRE t
UserInterruptR= t readlinet stript partitionRC t putt readt splitR RG R t terminateR
t tracebackt print_exct str( R
t lineRU t _t msgt outputt linest eRm ( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyt runl s:
#
c C sT | j j d k rC| j j \ } } | r d } x? | j d D]. } | j d rd | } qF | j j | qF W| r | j j | q n | r | j j | n yK t
| j d r | j j n% d d l } t
j | j j | j WqCt k
r?} | j d k r q@| j j d | j j | f qCXn | j j d S( Ns
s PROGRESS:Rl ii s! Unable to kill worker task %s: %s( RP RS RT t communicateRk t
startswithRB RG RC Ri t hasattrRl t signalt ost killt pidt SIGTERMt OSErrort errnot
send_errort idt wait( R
t oRu t
last_progresst lRz ( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyRl s, '( R R R R[ Rv Rl ( ( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyR8 Q s
%t DataMigratorc B s; e Z d Z d Z d Z d Z d Z d Z RS( t wbcopytablesc C s t | d r- t | d r- t | d s3 t | | _ | | _ | | _ | pW d | _ | | _ | po d | _ g | _ g | _ d | _ d S( NRG R t
send_progressR( ( Ry t AssertionErrorRB t _optionst _src_conn_objectt
_src_passwordt _tgt_conn_objectt
_tgt_passwordt _taskst
_processesRT t _error( R
t message_targett optionst
srcconnobjt srcpasswordt
tgtconnobjt tgtpassword( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyR s 3 c C s g } t j d k r y t j d d t z } x\ | j D]N } g } | j | d | j | d d j | } | j | d q= W| j d | j Wd QXWqt
k
r } t d | j qXn2 x/ | j D]! } | d
| d | d g 7} q Wd } | j
s&t d n | j j j j d
k rWd t | j g } nb t | j j t j j r| j j j d k rd t | j g } n d t | j t g } | j
d d g | | }
| j j d j |
t j d k r.t j |
d t j d t j d t j d t } n* t j |
d t j d t j d t j } | j d j! d } x} | j" d k r| j$ | \ }
} d } |
r| |
7} n | rx* | j% d D] } | j j | qWn d } qqW| j& d k rx g | j% d D]( } | j' d r| j% d d ^ qD]A \ } } } t( | j) } | | 7} | | | d | d <q<W| St d d S(! NR; t wt deletet
source_schemat source_tables s
s --table-file=%ss Error creating table file: %ss --tableR( s Path to wbcopytables not foundt Mysqls --mysql-source="%s"t pyodbcs --pythondbapi-source="%s"s --odbc-source="%s"s --count-onlys --passwords-from-stdinR: R< R= R> R@ t utf8i t ROW_COUNTR\ i t .t row_counts* Error getting row count from source tables(* RI RJ t tempfilet NamedTemporaryFileR t valuest appendRH RX R t IOErrorR
t strerrort copytable_patht RuntimeErrorR R RQ R' t
isinstanceRE t classest db_mgmt_PythonDBAPIDriverR6 R7 R4 RO RB RG RK RL RM R RW RS RT Rw Rk R Rx t intRg ( R
t working_sett table_paramt
table_filet taskt fieldsRp Ru R= RR t argvt outt passwordsR R t totalt schemat tablet count( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyt count_table_rows s\ 3*
N
c C s g } t j d k r+y t j d d t } x | j D] } g } | j | d | j | d | j | d | j | d | j d d r | j | d n
| j d d
j | } | j
| d q= W| j d | j Wd QXWqt k
r'} t
d
| j qXns xp | j D]b } | d | d | d | d | d g 7} | j d d r| j | d q8| j d q8Wd } t | | k rt | } n | j }
|
d d g 7}
| j j d t r|
j d n | j j d t r+|
j d n |
j d t | | j g |
| } | | _ t j t | | _ t | j | | j } | j | j d
| j d | j | j }
| j |
S( NR; R R R R t
target_schemat target_tablet select_expressiont *s s
s --table-file=%ss Error creating table file: %ss --tableR( s
--progresss --passwords-from-stdint TruncateTargetTabless --truncate-targett DebugTableCopys --log-level=debug3s --thread-count=( RI RJ R R R R R R RT RH RX R R R
R t lent helper_basic_arglistR Ro R t _working_sett Queuet
_result_queueR8 RB R[ R R t startt process_until_doneRl ( R
t
num_processesR R R R R Rp Ru R= RR R t workert results( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyt migrate_data sT
)
c C s | j j j j d k r1 d t | j g } nb t | j j t j j rz | j j j d k rz d t
| j g } n d t | j t g } | d t | j
g 7} | j j j d t r | j d n | S( NR s --mysql-source="%s"R s --pythondbapi-source="%s"s --odbc-source="%s"s
--target="%s"t ODBCDriverUsesUTF8s --force-utf8-for-source( R R RQ R R' R RE R R R6 R7 R4 RO R R R R R ( R
RR ( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyR 9 s c C s d } x% | j j D] } | | d 7} q Wi } t | _ t } t } xt r| r y | j j \ } } Wq t j k
r Pq Xn | j j
\ } } | d k r | j d d } | j | | j
j | qO | d k rW| j d d } | | k r | j | n | j
j | t | j
| t d f d f | | <qO | d k r| j d d } | | k r| j | n | j
j | | j
j d | | qO | d k rE| j d \ } } }
t t | f | | <| j
j t t g | j D] } | d ^ q | d
d j | qO | d k rd| j
j | qO | d
k rt } | r| j
j d | q| j
j d qO | d k rt } t | _ | j
j d qO | j
j | d | qO W| S( Ni R R_ R\ R` i R^ i R] s
Copying %ss , Ra Rb s$ Copy helper exited with an error: %ss Copy helper has finishedRc s Copy helper was aborted by users : ( R R R t interruptedt setRO R t
get_nowaitR t EmptyR Rk t addRB RG t removeR t
add_log_entryR R t floatt sumRH ( R
t total_row_countR t progress_row_countt active_job_namest donet msgtypet messageR t currentR t x( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyR J s^
) P ( R R R R R R R R ( ( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyR s = : ( t
__future__R R{ RI RK R RE R- R t threadingR t workbench.db_driverR t workbench.utilsR R R t workbench.exceptionsR t workbenchR t migration_source_selectionR R
R R' R R4 R7 R8 t objectR ( ( ( sK C:\Program Files (x86)\MySQL\MySQL Workbench 6.1 CE\modules\DataMigrator.pyt <module> s&
`