| 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 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 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_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
( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyR " s ( t __name__t
__module__R ( ( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 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 ( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 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( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 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! ( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 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 argsRA ( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 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( RN t pollt Nonet typet unicodet encodeR: t writet flushR R
( R t text( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyt
feed_inputb s c C� s, y�x� | 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( R` N( Ra N( RN RQ RR R@ t query_cancel_statusRC t
UserInterruptR; t readlinet stript partitionRA t putt readt splitR
RE R t terminateR t tracebackt print_exct str( R t lineRS t _t msgt outputt linest eRk ( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyt runl s:
#
c C� sr | j j � d k ra| j j � \ } } | r� d } xW | j d � D]F } | j d � r| | j � j d � \ } } } qF | j j | � qF W| r� | j
j | | f � q� n | r� | j j | � n yK t | j d � r� | j j
� n% d d l } t j | j j | j � Wqat k
r]} | j d k r:q^| j j d | j j | f � qaXn | j j � d S( Ns
s PROGRESS:RZ Rj i����i s! Unable to kill worker task %s: %s( RN RQ RR t communicateRi t
startswithRe Rf R@ RE RA Rg t hasattrRj t signalt ost killt pidt SIGTERMt OSErrort errnot
send_errort idt wait( R t oRs t
last_progressRn RS Ro Rx ( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyRj � s, ! '( R
R R RY Rt Rj ( ( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyR6 Q s
%t DataMigratorc B� sD e Z d Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s wbcopytables-binc C� s� t | d � r- t | d � r- t | d � s3 t � | | _ | | _ | | _ | pW d | _ | | _ | po d | _ t | _ g | _
g | _ d | _
d S( NRE R t
send_progressR& ( Rw t AssertionErrorR@ t _optionst _src_conn_objectt
_src_passwordt _tgt_conn_objectt
_tgt_passwordR t _resumet _taskst
_processesRR t _error( R t message_targett optionst
srcconnobjt srcpasswordt
tgtconnobjt tgtpassword( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyR � s 3 c C� s� g } t j d k rYyt j d d t ��� } x� | j � D]� } g } | j | d � | j | d � | j r� | j | d � | j | d � | j | d � | j | d � | j d
d � r� | j | d
� q� | j d � n d j
| � } | j | d
� q= W| j d | j � Wd QXWqt
k
rU} t d | j � � qXn� x� | j � D]� } | j r�| d | d | d | d | d | d | d g 7} | j d
d � r�| j | d
� q�| j d � qf| d | d | d g 7} qfWd } | j s t d � � n | j | j � } d | k rU| j d | d � n d | k ry| j d | d � n | j r�| j d � n | j d d g | | }
| j j d j
|
� � t j d k rt 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 r^| j d | j d
j d � } n | j d
j d � } x} | j � d k r�| j | � \ }
} d } |
r�| |
7} n | r�x* | j d
� D] } | j j | � q�Wn d } qwW| j d k r�x� g | j d
� D]( } | j d! � r| j d" � d# ^ qD]A \ } } } t! | j" � � } | | 7} | | | d$ | d% <qBW| S| j j | � t d& | j � � d S(' NR9 t wt deletet
source_schemat source_tablet
target_schemat target_tablet source_primary_keyt target_primary_keyt select_expressiont *s s
s --table-file=%ss Error creating table file: %ss --tableR& s Path to wbcopytables not foundt stimeouts --source-timeout=%st ttimeouts --target-timeout=%ss --resumes --count-onlys --passwords-from-stdinR8 R: R; R< R> t utf8i t ROW_COUNTRZ i t .t row_countsL Error getting row count from source tables, wbcopytables exited with code %s(# RG RH t tempfilet NamedTemporaryFileR t valuest appendR� R RR RF RV R t IOErrorR t strerrort copytable_patht RuntimeErrort helper_basic_arglistR@ RE RI RJ RK RM R� R� RU RQ Ru Ri R
Rv t intRe ( R t working_sett table_paramt
table_filet taskt fieldsRn Rs R; RP t argvt outt passwordsR� t lt totalt schemat tablet count( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyt count_table_rows� s~ 7 3* $
N
c
C� s� g } t j d k rMy t j d d t ��� } x� | j � D]� } g } | j | d � | j | d � | 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 QXWq�t k
rI} t
d | j � � q�Xn� x~ | j � D]p } | d | d | d | d | d | d | d g 7} | j d
d � r�| j | d
� qZ| j d � qZWt | � | k r�t | � } n | j t � } | d d g 7} | j j d t � r3| j d � n | j j d t � rX| j d � n | j j d t � r}| j d � n | j d t | � � | j d | j j j j � d | k r�| j d | d � n d | k r�| j d | d � n d | j j j � k rC| j j j d � }
|
rC| j d |
� qCn | j r\| j d! � n | j g | | } | | _ t j t | � � | _ t | j | | j � } | j | j! d | j" d
� | j# � | j$ � }
| j% � |
S(" NR9 R� R� R� R� R� R� R� R� R� R� s s
s --table-file=%ss Error creating table file: %ss --tables
--progresss --passwords-from-stdint TruncateTargetTabless --truncate-targett DebugTableCopys --log-level=debug3t DriverSendsDataAsUTF8s --force-utf8-for-sources --thread-count=s --source-rdbms-type=%sR� s --source-timeout=%sR� s --target-timeout=%st defaultCharSets --source-charset=%ss --resume(& RG RH R� R� R R� R� R RR RF RV R R� R R� t lenR� RM R� Rm R� R RO R t keysR� R� t _working_sett Queuet
_result_queueR6 R@ RY R� R� t startt process_until_doneRj ( R t
num_processesR� R� R� R� R� Rn Rs RP t default_charsetR� t workert results( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyt migrate_data sp
7
c C� s g } | j j j j d k rc | j d t | j � � | j j j d t � r� | j d � q� nj t | j j t
j j � r� | j j j
d k r� | j d t | j � � n | j d t | j t � � | r| j d t | j � � | j j j d t � r| j d � qn | S(
Nt Mysqls --mysql-source="%s"t OPT_ENABLE_CLEARTEXT_PLUGINs --source-use-cleartextt pyodbcs --pythondbapi-source="%s"s --odbc-source="%s"s
--target="%s"s --target-use-cleartext( R� R RO R R� R% R R R t
isinstanceRC t classest db_mgmt_PythonDBAPIDriverR4 R5 R2 RM R� ( R t include_target_connRP ( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyR� _ s c C� s� i | j j j d d � d 6d d 6| j j j d d � d 6| j j j d d � d 6| j j j d d � d
6| j j j j j � d 6} | S( NR t roott source_userR& t source_instancet porti� t source_portt target_portt target_usert source_rdbms( R� R R R� R RO R t lower( R t conn_args( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyt helper_connections_arglists s c
C� s] d } x% | j j � D] } | | d 7} q Wi } t | _ t � } t | _ t } xt rX| r� yJ t | j d d � } t
| � r� | | j � n | j j � \ } } Wq� t
j k
r� Pq� Xn | j j � \ } } | d k r | j d � d } | j | � | j j | � qX | d k r�| j d � d } | | k rX| j | � n | j j | � t | j | t d f � d f | | <qX | d k r| j d � d } | | k r�| j | � n | j j | � | j j d | | � t j d
d | � t | _ qX | d k r�| j d � \ } }
} t t |
� f | | <| j j t t g | j � D] } | d ^ qh� � | d
d j | � � qX | d k r�| j j | � qX | d k rt } | r�t | _ | j j d | � qU| j j d � qX | d k r=t } t | _ t | _ | j j d � qX | j j | d | � qX W| S( Ni R� t _update_resume_statusR] RZ R^ i R\ i R7 s %s
R[ s
Copying %ss , R_ R` s$ Copy helper exited with an error: %ss Copy helper has finishedRa s Copy helper was aborted by users : ( R� R� R t interruptedt setR� RM t getattrR@ RR t callableR� t
get_nowaitR� t EmptyR Ri t addRE t removeR t
add_log_entryRC t log_errorR� R� t floatt sumRF (
R t total_row_countR� t progress_row_countt active_job_namest doneR� t msgtypet messageR� t currentR� t x( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyR� ~ sn
) P ( R
R R� R R� R� R� R� R� ( ( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyR� � s S I ( t
__future__R Ry RG RI R� RC R+ R� t threadingR t workbench.db_driverR t workbench.utilsR t workbench.exceptionsR t workbenchR t migration_source_selectionR R R R% R R2 R5 R6 t objectR� ( ( ( sE C:\Program Files\MySQL\MySQL Workbench 6.3 CE\modules\DataMigrator.pyt <module> s&
`