今天就跟大家聊聊有关怎么将Mysql数据导入到MongoDB,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
(1)从Mysql导出数据位csv文件,如:
Java代码
SELECT * FROM APP_CALL_LOG_1362959187037 CREATE_TIME & lt;& # 39;2013-03-07 14:45:04& # 39;到输出文件& # 39;/tmp/all_call_log_012.csv& # 39;& # 39;字段终止,& # 39;行终止由& # 39;\ n # 39;;
(2)导入csv文件到mongodb,如:
Java代码
/bin/mongoimport——主机114.112.94.104端口27017 - d lb_v1_log - c APP_CALL_LOG——类型csv ignoreBlanks - f ID、IP、URI、URL、D_CODE, D_TYPE, UID, APP_FROM,创建
_TIME USER_AGENT, REMARK - file/usr/local/all_call_log_012。csv
(3)对导入数据矫正处理,如:
Java代码
pmy_log_rs: PRIMARY>db.APP_CALL_LOG.update ({UID:“\ \ N"},{$设置:{& # 39;UID # 39;:零}},假的,真的),
pmy_log_rs: PRIMARY>db.APP_CALL_LOG.update ({IP:“\ \ N"},{$设置:{& # 39;IP # 39;:零}},假的,真的),
pmy_log_rs: PRIMARY>db.APP_CALL_LOG.update ({D_TYPE:“\ \ N"},{$设置:{& # 39;D_TYPE # 39;:零}},假的,真的),
pmy_log_rs: PRIMARY>db.APP_CALL_LOG.update ({D_CODE:“\ \ N"},{$设置:{& # 39;D_CODE& # 39;:零}},假的,真的),
pmy_log_rs: PRIMARY>db.APP_CALL_LOG.update ({CREATE_TIME:“\ \ N"},{$设置:{& # 39;CREATE_TIME& # 39;:零}},假的,真的),
pmy_log_rs: PRIMARY>db.APP_CALL_LOG.update ({APP_FROM:“\ \ N"},{$设置:{& # 39;APP_FROM& # 39;:零}},假的,真的),
pmy_log_rs: PRIMARY>db.APP_CALL_LOG.update ({URI:“\ \ N"},{$设置:{& # 39;URI # 39;:零}},假的,真的),
pmy_log_rs: PRIMARY>db.APP_CALL_LOG.update ({URL:“\ \ N"},{$设置:{& # 39;URL # 39;:零}},假的,真的),
pmy_log_rs: PRIMARY>db.APP_CALL_LOG.update ({USER_AGENT:“\ \ N"},{$设置:{& # 39;USER_AGENT # 39;:零}},假的,真的),
pmy_log_rs: PRIMARY>db.APP_CALL_LOG.update({注:“\ \ N"},{$设置:{& # 39;评论# 39;:零}},假的,真的),
(4)字段类型矫正,如:
Java代码
db.APP_CALL_LOG.find ({})。x (x) {forEach(函数。D_CODE=?“+ x.D_CODE db.APP_CALL_LOG.save (x);});
看完上述内容,你们对怎么将Mysql数据导入到MongoDB有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注行业资讯频道,感谢大家的支持。
