Database JUNKY

MySQL,MariaDBを中心としたブログです

MySQL から mongodb にデータを移行するphp

MySQLのデータを、mongoDBデータを移行するphpスクリプトサンプルです。プログラムが残念なのは、 僕がど素人なので、本当に許してください。

以下がphpスクリプトサンプルになります。(正直なところ、csvをインポートするツールとかあってもおかしくないのに。。とか思っておりますが、あるんですかね?)

以下サンプルソースです [php] <? // //* MySQL上の郵便番号データを、mongodbに移行するphpサンプル // $hostname="192.168.101.82:5029"; $uname="myuser"; $upass="mypassword"; $dbname="MYDWH";

if( !$cn = mysql_connect( $hostname, $uname, $upass) ){ print "MYSQL への接続に失敗しました。"; exit; } mysql_select_db( $dbname, $cn );

$mongo = new Mongo("192.168.101.80:27017"); $db = $mongo->selectDB( "MYMONGO" ); $col = $db->selectCollection( "ZIP" );

//SELECT文を実行

$strSQL = "SELECT * FROM MYZIP";

$res = mysql_query($strSQL);

while ($row = mysql_fetch_array($res)) {

$doc = array( "PSJSX401" => $row["PSJSX401"], "PSYUBOLD" => $row["PSYUBOLD"], "PSYUBNEW" => $row["PSYUBNEW"], "PSTDHKKN" => $row["PSTDHKKN"], "PSADR1KN" => $row["PSADR1KN"], "PSADR2KN" => $row["PSADR2KN"], "PSTDHKKJ" => $row["PSTDHKKJ"], "PSADR1KJ" => $row["PSADR1KJ"], "PSADR2KJ" => $row["PSADR2KJ"], "PSKBN001" => $row["PSKBN001"], "PSKBN002" => $row["PSKBN002"], "PSKBN003" => $row["PSKBN003"], "PSKBN004" => $row["PSKBN004"], "PSKBN005" => $row["PSKBN005"], "PSKBN006" => $row["PSKBN006"] );

$col->insert( $doc );

} //結果セットの開放 mysql_free_result ($res) ;

echo "終了"; ?> [/php]