Gravity 同步MongoDB数据到TiDB

准备工作：在TiDB中创建的表、列字段要和MongoDB中的大小写一模一样,否则就会报错。
1.

2.

3.生成测试数据：

for (i = 1; i < 21; i++) {
       db.users.insert({
	   "userid": i, "username": "user" + i, "age": Math.floor(Math.random()*120), "sex": Math.floor(Math.random()*2), "createtime": new Date()	   
	   })
	  }

TiDB中预先定义对应的表名和表结构：

 CREATE TABLE `users` (
  `_id` varchar(32) DEFAULT NULL,
  `userid` int(11) DEFAULT NULL,
  `username` varchar(16) DEFAULT NULL,
  `age` int(11) DEFAULT NULL,
  `sex` int(11) DEFAULT NULL,
  `createtime` varchar(36) DEFAULT NULL
);

4.更新数据：

 db.users.update({"username" : "user20"},{$set:{"username":"MongoDB"}},{multi:true})


5.删除数据：
db.users.remove({"userid":null})
db.users.remove({"userid":2})


在MongoBD中重试删除：
yjp:PRIMARY> use _gravity
switched to db _gravity
yjp:PRIMARY> db.gravity_positions.drop()
true
yjp:PRIMARY> db.heartbeat.drop()
true