ITKeyword,专注技术干货聚合推荐

注册 | 登录

mysql数据迁移到mongodb之自写方法实现

yibing548 分享于 2016-01-20

推荐:mysql数据迁移到mongodb之工具迁移

最近写mongodb的数据库操作,写得差不多了,不了解的可以看回spring MongoDB 集成crud操作(简单封装),现在准备把mysql数据迁移到mongodb,上网搜索了一些资料,上了m

2019阿里云全部产品优惠券(新购或升级都可以使用,强烈推荐)
领取地址https://promotion.aliyun.com/ntms/yunparter/invite.html

(1)从mysql导出数据位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)导入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)对导入数据矫正处理,如:
  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);});

推荐:java连接数据方法jdbc:oracle,mysql,mongodb

一、常规的连接方法 MySql 连接方法: Class.forName("com.mysql.jdbc.Driver");Connection ct=DriverManager.getConnection("jdbc:mysql://localhost:3306/dbn

(1)从mysql导出数据位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

相关阅读排行


用户评论

游客

相关内容推荐

最新文章

×

×

请激活账号

为了能正常使用评论、编辑功能及以后陆续为用户提供的其他产品,请激活账号。

您的注册邮箱: 修改

重新发送激活邮件 进入我的邮箱

如果您没有收到激活邮件,请注意检查垃圾箱。