Tag: sql

节点SQL Server mssqlstream

我是新来的节点,并与mssql工作,以连接到SQL Server。 任何人都可以帮助给我一个更完整的mssqlstream的例子。 我发现git的例子模糊,不知道从哪里开始。 任何援助将不胜感激。 var sql = require('mssql'); var config = { user: '…', password: '…', server: 'localhost', // You can use 'localhost\\instance' to connect to named instance database: '…', stream: true, options: {// Use this if you're on Windows Azure } } sql.connect(config, function(err) { var request = new sql.Request(); request.stream = true; […]

与Sequelize交易不起作用

我想build立一个简单的networking表单,你可以input一个人的名字,姓氏,并为这个人select多个组(但现在是一个) 我正在使用node.js并将其存储在MariaDB数据库中。 Sequelize根据定义的模型创build了表Persons , Groups和GroupsPersons 。 var Sequelize = require("sequelize"); var sequelize = new Sequelize(config.database, config.username, config.password, config); var Group = sequelize.define("Group", { name: { type: DataTypes.STRING, allowNull: false } } var Person = sequelize.define("Person", { firstName: { type: DataTypes.STRING, allowNull: false }, lastName: { type: DataTypes.STRING, allowNull: false } } Person.belongsToMany(Group, {as: 'Groups'}); Group.belongsToMany(Person, […]

在大表中使用node.js中的mysql模块

我在我的MySQL数据库(大约一千万行)有一个大的表,我需要把所有这些数据转换成JSON格式。 对于较小的表,我会使用基本的connection.query("SELECT * FROM TABLE, function(err, results) {}); syntax。但是,我不想将整个表加载到内存中。 我注意到,mysql模块有能力“stream”行( https://github.com/felixge/node-mysql/#streaming-query-rows ),所以我想知道是否仍然将整个表加载到内存和那么只是给我们一行一行,或者它实际上每次只加载一行,所以整个表不会一次存储在内存中。

续集“哪里”指的是包括模特专栏

我有以下模型使用node.js与Sequelize(@ 3.3.2): module.exports = function (sequelize, DataTypes) { var Topic = sequelize.define("Topic", { name: DataTypes.STRING, }, { classMethods: { associate: function (models) { Topic.hasMany(models.Section, {as: 'sections'}); } } }); return Topic; }; module.exports = function (sequelize, DataTypes) { var Section = sequelize.define("Section", { previewImg: DataTypes.STRING, description: { type: DataTypes.TEXT, allowNull: true } }, { classMethods: […]

数据与带有express的Node中的sql比较

这是我在Stackoverflow上的第一篇文章。 我刚开始编程,现在我正在做我的第一个Node.js应用程序。 login表单不能很好地工作。 我想比较发布请求中的数据和数据库中的数据,看看是否有匹配。 有谁知道这里有什么问题? router.post('/login', function(req, res, next) { req.getConnection(function(err, connection) { var data = { username: req.body.username, password: req.body.password }; var user = data[0], pass = data[1]; connection.query('SELECT username, password FROM users WHERE username = ? AND password = ?', [user], [pass], function(err, results) { if(results) { req.session.regenerate(function() { req.session.login = true; req.session.username […]

使用postgres和node js在单个语句中执行多个查询

我需要像这样在一个语句中执行插入和删除查询 INSERT INTO COMPANY (ID,NAME) VALUES (1, 'Paul');DELETE FROM COMPANY WHERE ID='12'; 这是我执行查询的node.js代码 pg.connect(pgConString, function (err, client, done) { if (err) { callBack("DB connection failed. " + err, null); return; } var query = client.query({ text: "INSERT INTO COMPANY (ID,NAME) VALUES (1, 'Paul');DELETE FROM COMPANY WHERE ID='12';" values: [1, "Poul1"], name: "insertQuery" }); query.on("error", function […]

在节点oracledb中防止SQL注入

node-oracledb是否逃避/清理查询? 它通过绑定参数化查询: connection.execute( "INSERT INTO countries VALUES (:country_id, :country_name)", [90, "Tonga"], function(err, result) { if (err) console.error(err.message); else console.log("Rows inserted " + result.rowsAffected); }); 我查看了文档,并通过源代码快速准备好了,但是没有任何地方也没有表明它逃避了查询。 如果没有,我正在考虑在传递给connection.execute方法之前,使用node-mysql以及用户input和查询的丰富谓词的组合。

Pg-promise:交易问题

我用pg-promise与发生器交易得到了一些奇怪的东西。 这就是我要的 : 获取或注册一个用户(getOrRegisterUser) 做批次的东西(4插入发生器) 最后,使用getOrRegisterCurrentParkingIfProvided生成器的最后一个插入(发生器registerCall) 这是我的代码: db.tx(function (t) { return t.task.call(params, getOrRegisterUser).then(function (user) { params.masterId = user.id; // NOTICE : MY USER ID DATABASE return t.batch([ t.task.call(params, registerNewPhones), t.task.call(params, registerNewPlate), t.task.call(params, registerNewSubscriptions), t.task.call(params, getOrRegisterCurrentParkingIfProvided) ]).then(function (result) { params.ParkingId = (result[3] !== undefined) ? result[3].id : null; return t.task.call(params, registerCall); }) }); }).then(function () { […]

如何从Node中将表值参数插入到Sql Azure中?

我正在研究一个批量插入数据的应用程序,以减less我想要使用Table Valued参数的查询数量。 例: var sql = require('node-sqlserver'); var connectionString = 'Driver={SQL Server Native Client 11.0};server=tcp:serverName.database.windows.net,1433;UID=user@serverName;PWD=password;Database={databaseName};Encrypt=yes;Connection Timeout=30;'; sql.open(connectionString, function(err, conn) { if(err) { return console.error('could not connect to sql', err); } var tableValuedObject = ???; var query = 'usp_InsertSomeTable ?'; conn.query(query, tableValuedObject, function(err, result) { if(err) { return console.error('error running insert', err); } }); }); 其中usp_InsertSomeTable被定义为 […]

nodejs如何用2个语句执行mysql查询

我想在节点js中执行2个mysql语句。 然而,这个失败与错误: ER_PARSE_ERROR:您的SQL语法有错误; 请查看与您的MySQL服务器版本相对应的手册,以获取要使用的正确语法 我的节点命令和mysql查询如下所示。 connection.query( "UPDATE `table1` SET `count` = `count` + 1 WHERE `id` = ? LIMIT 1; INSERT INTO `table2` (`id`, `field1`, `datetime`, `field2`, `field3`, `field4`) VALUES (NULL, ?, NOW(), ?, ?, 'impression');", [var1, var2, var3,var4], function(err, rows) { connection.release(); if (err != null) { // Do error logging console.log(this.sql); console.log(err); } […]