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数据的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。