怎么將Mysql數(shù)據(jù)導(dǎo)入到MongoDB

167次閱讀

共計(jì) 1585 個(gè)字符，預(yù)計(jì)需要花費(fèi) 4 分鐘才能閱讀完成。

自動(dòng)寫(xiě)代碼機(jī)器人，免費(fèi)開(kāi)通

今天就跟大家聊聊有關(guān)怎么將 Mysql 數(shù)據(jù)導(dǎo)入到 MongoDB，可能很多人都不太了解，為了讓大家更加了解，丸趣 TV 小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

(1)從 mysql 導(dǎo)出數(shù)據(jù)位 csv 文件, 如：
Java 代碼
SELECT * FROM APP_CALL_LOG_1362959187037 WHERE CREATE_TIME 2013-03-07 14:45:04 into outfile /tmp/all_call_log_012.csv fields terminated by , lines terminated by \n
(2) 導(dǎo)入 csv 文件到 mongodb, 如：
Java 代碼
bin/mongoimport –host 114.112.94.104 –port 27017 -d lb_v1_log -c APP_CALL_LOG –type csv –ignoreBlanks -f ID,IP,URI,URL,D_CODE,D_TYPE,UID,APP_FROM,CREATE
_TIME,USER_AGENT,REMARK -file /usr/local/all_call_log_012.csv
(3) 對(duì)導(dǎo)入數(shù)據(jù)矯正處理, 如:
Java 代碼
pmy_log_rs:PRIMARY db.APP_CALL_LOG.update({UID: \\N}, {$set: { UID : null} },false,true);
pmy_log_rs:PRIMARY db.APP_CALL_LOG.update({IP: \\N}, {$set: { IP : null} },false,true);
pmy_log_rs:PRIMARY db.APP_CALL_LOG.update({D_TYPE: \\N}, {$set: { D_TYPE : null} },false,true);
pmy_log_rs:PRIMARY db.APP_CALL_LOG.update({D_CODE: \\N}, {$set: { D_CODE : null} },false,true);
pmy_log_rs:PRIMARY db.APP_CALL_LOG.update({CREATE_TIME: \\N}, {$set: { CREATE_TIME : null} },false,true);
pmy_log_rs:PRIMARY db.APP_CALL_LOG.update({APP_FROM: \\N}, {$set: { APP_FROM : null} },false,true);
pmy_log_rs:PRIMARY db.APP_CALL_LOG.update({URI: \\N}, {$set: { URI : null} },false,true);
pmy_log_rs:PRIMARY db.APP_CALL_LOG.update({URL: \\N}, {$set: { URL : null} },false,true);
pmy_log_rs:PRIMARY db.APP_CALL_LOG.update({USER_AGENT: \\N}, {$set: { USER_AGENT : null} },false,true);
pmy_log_rs:PRIMARY db.APP_CALL_LOG.update({REMARK: \\N}, {$set: { REMARK : null} },false,true);
(4) 字段類型矯正, 如：
Java 代碼
db.APP_CALL_LOG.find({}).forEach(function (x) {x.D_CODE = +x.D_CODE;db.APP_CALL_LOG.save(x);});