Tag: sql server

使用Node.js将数据从MSSQL传输到DynamoDB

我正在尝试使用Node.js将数据从SQL服务器传输到DynamoDb sql.connect(config, function (err) { if (err) console.log(err); // create Request object var request = new sql.Request(); // query to the database and get the records request.query('SELECT Client, Brand FROM Client WHERE Brand = 6', function (err, recordset) { if (err) console.log(err); console.log('request exectued'); var itemProcessed = 0; // send records as a response recordset.forEach(function […]

如何使用nodejs将本地sql文件转换为json

我想将一个本地的sql文件(backup.mysql,大约50MB)转换成节点中的json格式,我在一些插件上search了一下,但没有运气,大多数需要一个sql server来转换数据。 任何读者或插件可以将一个SQL文件转换为JSON吗? 谢谢! 这是我的SQL文件的样子: INSERT INTO `field_data_body` VALUES ('node','post','0','7112','1942','und','0','<p style="text-align: ce… <– 14269 lines like this. 我想在nodejs中将sql转换为json: _fs.readFile( _path.in[_i], _encode, ( _err, _result ) => { if( _err ) c.log( '$fs.readFile(), ' + _err ); else { _result = _schema + '=' + JSON.stringify( _result, null, 4 ); //<– what should i do with […]

(Javascript的Node.js)如何从一个IIFE获得varibles

请参阅我的代码如下:我想分配logging集到一个variables,可以使用index.js来调用这个variables。 我能够console.loglogging集。 但是当我叫这个IIFE时,总是说未定义的。 var mssql = require('mssql'); var dbcon = require('./dbcon'); var storage = (function () { var connection = new mssql.Connection(dbcon); var request = new mssql.Request(connection); connection.connect(function (recordset) { request.query('select getdate()', function (err, recordset) { console.dir(recordset); }); connection.close(); }); })(); module.exports = storage; index.js var storage = require('./storage'); "AMAZON.HelpIntent": function (intent, session, response) { […]

NodeJS – SQL Server连接已closures

我试图从SQL Server调用注册存储过程。 我正在使用mssql包的mssql 。 我从mssql Npm文档中获得了大部分代码。 但它仍然不起作用。 代码基本上试图启动一个ConnectionPool作为读取的最后一个更新,重命名ConnectionPool ,创build一个新的请求,引入参数并执行存储过程。 我这样做是因为我需要偶尔将连接variables更改为另一个数据库。 我得到的错误是: ConnectionError:连接已closures。 我的代码: const sql = require('mssql'); const config = require('../config/dbPoly'); module.exports.registerUser = function(pUserName, pPassword, pNombre, pApellidos, pFK_TipoUsuario, callback) { var connection = new sql.ConnectionPool(config); var request = new sql.Request(connection); request.input('input_parameter', sql.VARCHAR(25), pUserName); request.input('input_parameter', sql.VARCHAR(16), pPassword); request.input('input_parameter', sql.VARCHAR(25), pNombre); request.input('input_parameter', sql.VARCHAR(50), pApellidos); request.input('input_parameter', sql.Int, pFK_TipoUsuario); […]

格式化date时,NodeJS小时内的SQL查询处于closures状态

我想在我的查询中SELECT FORMAT(MAX(dTime),'yyyy-MM-dd hh:mm:ss') FROM triangulations dtime2字段: SELECT FORMAT(MAX(dTime),'yyyy-MM-dd hh:mm:ss') FROM triangulations 这给出了输出{result:[{'':'03:34:30'}],rowcount:1} 小时数应该是15.当查询格式不存在时,这也会显示出来。 查询: SELECT MAX(dTime) FROM triangulations给出输出: {result:[{'':Mon Jul 17 2017 15:34:30 GMT + 0000(Coordinated Universal Time)}],rowcount:1} 我使用库node-mssql-connector在NodeJs中执行查询。 为什么SQL给我错误的时间?

nodejs mssql返回logging集

我试图从mssql request.query像返回值的logging集。 在https://www.npmjs.com/package/mssql上的代码很容易做出一个控制台输出,但是当我尝试将logging集作为另一个variables不起作用。 我在做什么错? var sql = require('mssql'); var config = { user: 'sa', password: 'XXXXXX', server: '192.168.8.25', database: '3TWIMDB', } var resultado=''; sql.connect(config, function(err){ var request = new sql.Request(); request.query('select 1 as VehiCLASS',function(err,recordset){ console.log(recordset[0].VehiCLASS); resultado = recordset[0].VehiCLASS; }); sql.close(); }); console.log("rsul: "+resultado); 谢谢。

node-mssql插入返回未定义的logging集

select语句工作正常,但每当我尝试插入或更新logging集和受影响的值是未定义的。 插入/更新在数据库中工作,我只是不能读取返回的值。 var sql = require('mssql'); var config = {…}; sql.connect(config).then(function() { new sql.Request().query("INSERT INTO MyTable (Name, Age) VALUES ('John', 30)").then(function(recordset, affected) { console.log('Recordset: ' + recordset); console.log('Affected: ' + affected); }).catch(function(err) { console.log('Request error: ' + err); }); }).catch(function(err) { if (err) { console.log('SQL Connection Error: ' + err); } }); 输出到控制台是: Recordset: undefined […]

将XML传递给节点中的存储过程

我想弄清楚如何使用MSSQL节点驱动程序将XML值传递给存储过程,从文档中我可以看到驱动程序确实支持存储过程,还可以像这样定义自定义数据types: sql.map.register(MyClass, sql.Text); 但我还没有find一个例子到目前为止如何做到这一点。 我find了一个类似的问题,但对于一个.NET SQL驱动程序,试图找出是否有人为Node做了这个。 UPDATE 我能够发送一个XML到一个存储过程,并parsing它在数据库中,这里的例子: var request = new sql.Request(connection); var xml = '<root><stock><id>3</id><name>Test3</name><ask>91011</ask></stock></root>' request.input('XStock', sql.Xml, xml); request.execute('StockUpdateTest', function (err, recordsets, returnValue, affected) { });

Amazon SQS是将分析日志logging数据处理到数据库的好工具吗?

我们有几个nodejs服务器,每个请求的详细信息和有效负载需要logging到SQL Server进行报告和其他业务分析。 请求的数量和服务器之间的需求相似性,我想用一个集中的日志服务来处理这个问题。 我的第一个直觉就是使用像Amazon SQS这样的东西,并让它直接作为SQL Server的缓冲区,或者构build一个小型日志logging服务器,这个服务器可以使SQS引导数据库调用。 这听起来像SQS的一个很好的使用,或者我错过了这个任务广泛使用的工具?

使用可选参数运行SQL查询的最佳方式是什么?

我目前正在运行以下查询将数据添加到我的数据库中的表: INSERT INTO IDEIAS_INTERACOES (CODIGO, ARQUIVO, REMETENTE, MENSAGEM, UNIT, DATA) VALUES (@codigo, @file, @remetente, @mensagem, @unit, @data) 这工作正常,但@file参数并不总是存在的,我希望列在这种情况下是'Undefined' 。 我可以使用三元运算符轻松完成这个任务,但是由此产生的代码很混乱,可能不是最理想的。 什么是更完美的方式来完成这个? Ps .:我正在使用mssql模块。