Node.Js同步mongdb数据
生活随笔
收集整理的這篇文章主要介紹了
Node.Js同步mongdb数据
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
var objectId = require('mongodb').ObjectId;
const mongoose = require("mongoose");
var SchemaObj = mongoose.Schema;
DB_URL = "mongodb://localhost:27017/admin";mongoose.connect(DB_URL); //創建鏈接/** 連接成功*/
mongoose.connection.on("connected", () => {console.log("數據庫連接成功！");
});/*** 連接異常*/
mongoose.connection.on("error", err => {console.log("數據庫連接失敗！" + err);
});/*** 連接斷開*/
mongoose.connection.on("disconnected", () => {console.log("數據庫連接中斷！");
});const UserSchema = new SchemaObj({name: {type: String,required: true},password: {type: String,required: true},avatar: {type: String},type:{type: String,required: true},date: {type: Date,default: Date.now}
});
const User = mongoose.model("users", UserSchema);const UserDataSchema = new SchemaObj({name: {type: String,required: true},password: {type: String,required: true},avatar: {type: String},type:{type: String,required: true},date: {type: Date,default: Date.now}
});
const UserData = mongoose.model("userData", UserDataSchema);let query = User.find({});
let pageSize = 2; //查詢數量
let pageCount = 1; //查詢頁碼
let insertFlag = true; //是否添加數據let setTime = setInterval(() => {let startPage = (pageCount - 1) * pageSize; //開始條數query.limit(pageSize); //設置查詢條數query.skip(startPage); //開始條數console.log("pageSize", pageSize, "startPage", startPage, "pageCount", pageCount)pageCount += 1;query.exec((err, data) => {if (err) throw err;if (data.length < pageSize) {console.log('close');clearInterval(setTime);}for (var i = 0; i < data.length; i++) {const userData = new UserData({_id: data[i]._id,name: data[i].name,password: data[i].password,type: data[i].type,avatar: data[i].avatar,date: data[i].date});//去除重復數據UserData.findOne({_id: objectId(data[i]._id)},function (err, doc) {if (err) throw err;if (doc != null) {insertFlag = false;}});if (insertFlag) {userData.save().then('同步數據: ' + JSON.stringify(userData)).catch(err => console.log(err));}}});
}, 1000);
轉載于:https://www.cnblogs.com/mxh-java/p/11535688.html
與50位技術專家面對面20年技術見證，附贈技術全景圖總結
以上是生活随笔為你收集整理的Node.Js同步mongdb数据的全部內容，希望文章能夠幫你解決所遇到的問題。
