Articles of 插入

Mongojs:忽略重复的对象插入

我有这个Node.js应用程序,它获得了一个具有唯一ID的JSON数据的大量数据,然后使用Mongojs将它们插入到MongoDB中。 问题是,在这大量的数据中,可能会有一些重复的文件! 所以当使用Mongojs插入这些数据时,它会返回错误E11000 duplicate key error ,并且不会继续插入。 所以我在寻找的东西就像本地Mongo的continueOnError/keepGoing选项。 它会忽略重复并继续insert 。 http://mongodb.github.io/node-mongodb-native/api-generated/collection.html#insert 这是我的代码,如果有帮助: var mongojs = require('mongojs'), dburl = process.env.MONGOHQ_URL || 'mongodb://localhost/test', db = mongojs(dburl, ['concerts']); function insertData(data) { db.concerts.insert(data, {keepGoing: true, safe: true}, function(err, docs){ console.log('err: ' + err + ' docs:' + docs); if(!err) console.log('data inserted successfully!\n'); }); } exports.insertData = insertData; 在这里代码中我已经设置了选项为true,但它仍然不起作用(相同的错误)。 无论如何,我可以用Mongojs做这个,或者我必须使用native-mongo吗? […]

使用node.js将json导入到mysql中

我试图插入在node.js中创build的JSON到MySQL中,但有一个语法错误,我不能纠正错误,任何帮助将不胜感激 我的代码 flowController.on('2', function (_selfid,_participantId,_groupid,_allMemberContent) { var allMemberDetailSQL= "SELECT spFunAllMemberNotificationDetails("+ _selfid + "," + _participantId +") as groupparticipants"; console.log("allMemberDetailSQL"+allMemberDetailSQL); client.query(allMemberDetailSQL,function(detailERROR,detailResult) { if (detailERROR) console.log("detailERROR "+ detailERROR); else { var detailstr=''; detailstr = JSON.stringify(detailResult); console.log('detailResult :'+ detailstr); console.log("detailResult "+detailResult[0].groupparticipants); var otherArray = [detailResult[0].groupparticipants]; var _allMemberDetail = JSON.stringify({ selfid: _selfid, groupid: _groupid, anArray: otherArray }); console.log("_allMemberDetail " […]

Mongodb插入没有成功完成(使用node.js)

我有一个加载XML文件的node.js脚本。 它循环遍历Mongo数组中的每个元素,并说他们都正确地插入,但是当脚本完成了对db.collection.count();的检查时db.collection.count(); 告诉我已经插入数据库的logging比预期数less得多。 我怎样才能使mongo和node.js与插入很好地玩? GrabRss = function() { var http = require('http'); var sys = require('sys'); var xml2js = require('xml2js'); var fs = require('fs'); var Db = require('../lib/mongodb').Db, Conn = require('../lib/mongodb').Connection, Server = require('../lib/mongodb').Server, // BSON = require('../lib/mongodb').BSONPure; BSON = require('../lib/mongodb').BSONNative; var data; var checked = 0; var len = 0; GotResponse = function(res) { […]

如何使用node-jdbc获取生成的ID?

我正在使用node-jdbc和oracle驱动程序“ojdbc6_g.jar”连接到Oracle数据库。 我想执行一些插入查询。 问题: 如何使用node-jdbc将行插入到oracle时获取生成的Id? 我试图调用statement.getGeneratedKeys()但它在callback中返回以下错误: > { [Error: Error running instance method java.sql.SQLException: > operation not allowed > at oracle.jdbc.driver.OracleStatement.getGeneratedKeys(OracleStatement.java:8425) > at oracle.jdbc.driver.OracleStatementWrapper.getGeneratedKeys(OracleStatementWrapper.java:1106) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:483) ] cause: {} }

Mongoose:Model.create和Collection.insert有什么区别

我想在MongoDB中做一个批量插入工作,我在mongoose中发现了两种方法: 一种方法是使用insert : dataArr = [ { id: "", name: "" } { id: "", name: "" } ] Collection.insert(dataArr) 另一种方式是Model.create : Model.create(dataArr) 两者都可以完成批量插入作业,但它们之间有什么区别? 哪一个更有效率?