C:\ProgramData\PLUMSIX\mtu_4.2\x86 （32-bit版） C:\ProgramData\PLUMSIX\mtu_4.2\x64 （64-bit版）
cd /d "MTU adaptor for MySQLの解凍先ディレクトリ名"
| マクロ | 変更前 | 摘要 |
|---|---|---|
| HOST | “localhost” | sshポート転送を利用した暗号化対策が不要な場合は、接続先のMySQL データベースが稼働するホスト名か、またはIPアドレスを記述して下さい。暗号化対策が必要な場合は、localhost を指定してください。 |
| PORT | 13306 | ssh ポート転送を利用した暗号化対策が不要な場合は MySQL のデフォルトポート番号の 3306 を記述して下さい。暗号化対策が必要である場合 Tera Term の準備（後述）で説明する、「ローカルのポート」の番号を記述して下さい。 |
| USER | “scott” | 接続先 MySQL のユーザ名を記述して下さい。 |
| PASSWD | “tiger” | 接続先 MySQL のパスワードを記述して下さい。 |
| DB | “scott” | 接続先 MySQL のデータベース名を記述して下さい。 |
nmake EXE="AdpMysql.exe" OBJS="AdpMysql.obj" CPPFLAGS="/EHsc /nologo /O2 /MD /DNDEBUG /I path_to_mysql_home_dir\include"
実際にビルドした時の様子を示します。
C:\path\to\AdpMysql>nmake EXE="AdpMysql.exe" OBJS="AdpMysql.obj" CPPFLAGS="/EHsc /nologo /O2 /MD /DNDEBUG /I C:\oracle\mysql-5.6.16-win32\include"
Microsoft(R) Program Maintenance Utility Version 11.00.61030.0
Copyright (C) Microsoft Corporation. All rights reserved.
cl /EHsc /nologo /O2 /MD /DNDEBUG /I C:\oracle\mysql-5.6.16-win32\include /c AdpMysql.cpp
AdpMysql.cpp
cl /EHsc /nologo /O2 /MD /DNDEBUG /I C:\oracle\mysql-5.6.16-win32\include /FeAdpMysql.exe AdpMysql.obj
C:\path\to\AdpMysql>
| Oracle Database (移行元) | MySQL (移行先) |
|---|---|
CREATE TABLE DB_MIG_TEST ( NUM_10_0 NUMBER(13) , CLOB_DATA CLOB , VC2_10 VARCHAR2(13) , NCLOB_DATA NCLOB , NUM_10_5 NUMBER(13,5) , DATE_VAL DATE , BLOB_DATA BLOB , LONG_STR LONG , CHAR_10 CHAR(13) ); |
create table DB_MIG_TEST ( NUM_10_0 decimal(13) , CLOB_DATA longtext , VC2_10 varchar(13) , NCLOB_DATA longtext , NUM_10_5 decimal(13,5) , DATE_VAL datetime , BLOB_DATA longblob , LONG_STR longtext , CHAR_10 char(13) ); |
declare i binary_integer; clob_loc CLOB; nclob_loc NCLOB; blob_loc BLOB; clob_tmp CLOB; begin for i in 1 .. 100000 loop insert into DB_MIG_TEST values (i , EMPTY_CLOB() , '＃_' || i , EMPTY_CLOB() , i - i * 0.00001, sysdate , EMPTY_BLOB() , '@ABCDEFGHI' , '＄_' || i) returning clob_data, nclob_data, blob_data into clob_loc, nclob_loc, blob_loc; clob_tmp := EMPTY_CLOB(); for j in 1 .. 5 loop clob_tmp := clob_tmp || to_clob(to_char(i,'fm00000') || to_char(j, 'fm00000') || 'あいうえおかきくけこさしすせそたちつてとなにぬねの' || 'はひふへほまみむめもやゐゆゑよらりるれろわをん' || chr(10)); end loop; dbms_lob.copy(clob_loc, clob_tmp, dbms_lob.getlength(clob_tmp)); dbms_lob.copy(nclob_loc, clob_tmp, dbms_lob.getlength(clob_tmp)); declare max_lob_size integer := dbms_lob.lobmaxsize; dest_offset integer := 1; src_offset integer := 1; blob_csid number := dbms_lob.default_csid; lang_context number := dbms_lob.default_lang_ctx; warning integer; length number; begin dbms_lob.converttoblob(blob_loc, clob_tmp, max_lob_size , dest_offset, src_offset, blob_csid, lang_context, warning); end; if mod(i, 50000) = 0 then commit; end if; end loop; update DB_MIG_TEST set CLOB_DATA = NULL where NUM_10_0 = 892; update DB_MIG_TEST set VC2_10 = NULL where NUM_10_0 = 12543; update DB_MIG_TEST set NCLOB_DATA = NULL where NUM_10_0 = 24543; update DB_MIG_TEST set NUM_10_5 = NULL where NUM_10_0 = 33975; update DB_MIG_TEST set DATE_VAL = NULL where NUM_10_0 = 45432; update DB_MIG_TEST set BLOB_DATA = NULL where NUM_10_0 = 54910; update DB_MIG_TEST set LONG_STR = NULL where NUM_10_0 = 67543; update DB_MIG_TEST set CHAR_10 = NULL where NUM_10_0 = 78853; end; /
PL/SQL の終わりの方で８行分の update 文がありますが、これは MySQL へデータをコピーした後で、NULL が正しく伝達されているかどうかを確認する為の物です。
MTU adaptor for MySQL から MySQL データベースまでの経路上 WAN が存在して、データの暗号化対策を行わなければならない時に、このセクションで説明する準備をして下さい。正確には Tera Term の TTSSH (Tera Term Secure Shell extension) を使用します。
C:\ProgramData\PLUMSIX\mtu_4.2\x86>query
Multi-threaded Unloader (SAMPLE) version 4.2.1
(c) 2003 Plumsix Co.,Ltd. All rights reserved.
Windows 8 Professional (build 9200), 64-bit WOW64
Number of NUMA nodes 1
Number of physical processor packages 1
Number of processor cores 4
Number of logical processors 8
Number of processor L1/L2/L3 caches 8/4/1
任意問合せファイル出力を実行します...
クライアント・キャラクタセットID は 838 (JA16SJISTILDE) です。
ネット・サービス名:local_xe へユーザ名:SYSTEM として接続します。
しばらくお待ちください...
Oracle Database 11g Express Edition Release 11.2.0.2.0 - Production
接続先は SYSTEM@XE (ネット・サービス名:local_xe) です。
サーバー・タイプは DEDICATED です。
監査接続ＩＤは 990485 です。
サーバーの日付時刻は 2014-04-18 14:05:50 です。
対象スキーマは SCOTT です。
任意問い合わせを読取りました。(QUERYVAR) select * from DB_MIG_TEST
キー・バリュー対定義ファイルを読込みます。C:\ProgramData\PLUMSIX\mtu_4.2\x86\input\bind.dat
:b_job :SALESMAN
:b_sal : 1,300
:b_hiredate :1980-01-01
複数の接続を確立します。要求された並列度は 4 です。
空領域サイズチェックの閾値は 1024Mバイトです。
データファイルと制御ファイルを出力中です。[71G] C:\ProgramData\PLUMSIX\mtu_4.2\x86\output
ストリームの位置：named_pipe://\\.\pipe\{C}.{X}
TableName : NumRows: Elapse:Rows/s:Bytes: B/s: Len
DB_MIG_TEST : Executing （← ここで一時停止）
C:\path\to\AdpMysql>PATH=C:\oracle\mysql-5.6.16-win32\lib;%PATH% C:\path\to\AdpMysql>AdpMysql DB_MIG_TEST 20 libmysql.dll
各引数には次の意味があります。
| 引数 | 摘要 |
|---|---|
| 第一引数 | 環境変数 QUERYVAR へ記述したSQL上のキーワード into に続く識別子を指定してください。 |
| 第二引数 | multiple lists of column values: INSERT 文の VALUES に続く構文要素を繰り返す回数。LOBを含むクエリーの場合は、環境変数 BULK_SIZE の値と一致させてください。 |
| 第三引数 | libmysql.dll 自身を含むパス。フォルダ名がPHTHに含まれていれば libmysql.dll のみでOKです。 |
表３．MTU adaptor for MySQL の引数
MTU adaptor for MySQL version 1.0, Copyright (c) 2014 Plumsix Co.,Ltd. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. Loading library libmysql.dll Client version 5.6.16 Attempting to connect to scott@localhost:13306 Server version 5.6.17 Thread safety is true. Current charset is latin1, but changed to charset cp932. Waiting for \\.\pipe\DB_MIG_TEST.ctl... Waiting for \\.\pipe\DB_MIG_TEST.dat... Reading records... 10000 rows processed. 20000 rows processed. 30000 rows processed. 40000 rows processed. 50000 rows processed. 60000 rows processed. 70000 rows processed. 80000 rows processed. 90000 rows processed. 100000 rows processed. Elapsed time = 38.47 sec. Completed successfully. C:\path\to\AdpMysql>
＊＊＊＊＊ 前方省略 ＊＊＊＊＊
複数の接続を確立します。要求された並列度は 4 です。
空領域サイズチェックの閾値は 1024Mバイトです。
データファイルと制御ファイルを出力中です。[58G] C:\ProgramData\PLUMSIX\mtu_4.2\x86\output
ストリームの位置：named_pipe://\\.\pipe\{C}.{X}
TableName : NumRows: Elapse:Rows/s:Bytes: B/s: Len
DB_MIG_TEST : 100,000: 43.18: 2315.: 199M:4739k: 2095. CAN
処理対象となった表の総数 : 1
ラウンドトリップ（回） : 50,075
出力バイト総数（kbytes） : 204645.72
所要時間（秒） : 43.59
処理速度（kbytes/秒） : 4694.57
正常終了しました。
C:\ProgramData\PLUMSIX\mtu_4.2\x86>
select count(*) from DB_MIG_TEST;
select NUM_10_0 from DB_MIG_TEST
where ( CLOB_DATA IS NULL
or VC2_10 IS NULL
or NCLOB_DATA IS NULL
or NUM_10_5 IS NULL
or DATE_VAL IS NULL
or BLOB_DATA IS NULL
or LONG_STR IS NULL
or CHAR_10 IS NULL
)
order by NUM_10_0 ;
C:\path\to\AdpMysql>mysql -u scott -p scott --compress --port 13306
Enter password: *****
Welcome to the MySQL monitor. Commands end with ; or \g.
Your MySQL connection id is 18
Server version: 5.6.17-log MySQL Community Server (GPL)
Copyright (c) 2000, 2014, Oracle and/or its affiliates. All rights reserved.
Oracle is a registered trademark of Oracle Corporation and/or its
affiliates. Other names may be trademarks of their respective
owners.
Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.
mysql> select count(*) from DB_MIG_TEST;
+----------+
| count(*) |
+----------+
| 100000 |
+----------+
1 row in set (0.89 sec)
mysql> select NUM_10_0 from DB_MIG_TEST
-> where ( CLOB_DATA IS NULL
-> or VC2_10 IS NULL
-> or NCLOB_DATA IS NULL
-> or NUM_10_5 IS NULL
-> or DATE_VAL IS NULL
-> or BLOB_DATA IS NULL
-> or LONG_STR IS NULL
-> or CHAR_10 IS NULL
-> )
-> order by NUM_10_0 ;
+----------+
| NUM_10_0 |
+----------+
| 892 |
| 12543 |
| 24543 |
| 33975 |
| 45432 |
| 54910 |
| 67543 |
| 78853 |
+----------+
8 rows in set (1.19 sec)
mysql>
問題なくデータは移行されました。
by 開発１号