首页 文章

如何使用节点js创建和读取相同的临时SQL表

提问于
浏览
1

我正在尝试创建一个临时表,并使用节点js和mssql在同一连接中读取它 .

  • Query1:从一堆不同的地方选择并创建'#mrpSalesHistory'

  • Query2:截断实际表

  • Query3:将'#mrpSalesHistory'中的数据插入到实际表中

  • Query4:从真实表中选择计数

  • Query5:使用'#mrpSalesHistory'作为源合并到实际表中

  • Query6:从真实表中选择全部

代码剪辑:

sql.connect(config).then(function() {
    new sql.Request().batch(query1, (err, result) => {
        if(err){
            console.log('Q1');
            console.log(err);
        }
        console.log('Q1');
        console.log(result)
    })

}).then(function() {

    new sql.Request().batch(query2, (err, result) => {
        if(err){
            console.log('Q2');
            console.log(err);
        }
        console.log('Q2');
        console.log(result)
    })

}).then(function() {

    new sql.Request().batch(query3, (err, result) => {
        if(err){
            console.log('Q3');
            console.log(err);
        }
        console.log('Q3');
        console.log(result)
    })

}).then(function() {

    new sql.Request().batch(query4, (err, result) => {
        if(err){
            console.log('Q4');
            console.log(err);
        }
        console.log('Q4');
        console.log(result)
    })

}).then(function() {

    new sql.Request().batch(query5, (err, result) => {
        if(err){
            console.log('Q5');
            console.log(err);
        }
        console.log('Q5');
        console.log(result)
    })

}).then(function() {

    new sql.Request().batch(query6, (err, result) => {
        if(err){
            console.log('Q6');
            console.log(err);
        }
        console.log('Q6');
        console.log(result)
    })

}).catch(function(err) {

    console.log(err)
});

运行以下代码后,我得到了

RequestError:无效的对象名称'#mrpSalesHistory' . 在第3和第5个查询 .

完整日志输出:

Q3
{ RequestError: Invalid object name '#mrpSalesHistory'.
    at StreamEvents.req.once.err (C:\wamp64\www\mrp\updateNode\node_modules\mssql\lib\msnodesqlv8.js:532:17)
    at Object.onceWrapper (events.js:315:30)
    at emitOne (events.js:116:13)
    at StreamEvents.emit (events.js:211:7)
    at routeStatementError (C:\wamp64\www\mrp\updateNode\node_modules\msnodesqlv8\lib\reader.js:27:18)
    at C:\wamp64\www\mrp\updateNode\node_modules\msnodesqlv8\lib\reader.js:229:15
    at Object.cbFreeStatement [as end] (C:\wamp64\www\mrp\updateNode\node_modules\msnodesqlv8\lib\driver.js:202:9)
    at onInvoke (C:\wamp64\www\mrp\updateNode\node_modules\msnodesqlv8\lib\reader.js:228:26)
    at onQuery (C:\wamp64\www\mrp\updateNode\node_modules\msnodesqlv8\lib\driver.js:114:11)
  code: 'EREQUEST',
  number: 208,
  state: '42S02',
  originalError: { Error: [Microsoft][SQL Server Native Client 11.0][SQL Server]Invalid object name '#mrpSalesHistory'. sqlstate: '42S02', code: 208 },
  name: 'RequestError' }
Q3
undefined
Q2
{ recordsets: [],
  recordset: undefined,
  output: {},
  rowsAffected: [ -1 ] }
Q5
{ RequestError: Invalid object name '#mrpSalesHistory'.
    at StreamEvents.req.once.err (C:\wamp64\www\mrp\updateNode\node_modules\mssql\lib\msnodesqlv8.js:532:17)
    at Object.onceWrapper (events.js:315:30)
    at emitOne (events.js:116:13)
    at StreamEvents.emit (events.js:211:7)
    at routeStatementError (C:\wamp64\www\mrp\updateNode\node_modules\msnodesqlv8\lib\reader.js:27:18)
    at C:\wamp64\www\mrp\updateNode\node_modules\msnodesqlv8\lib\reader.js:229:15
    at Object.cbFreeStatement [as end] (C:\wamp64\www\mrp\updateNode\node_modules\msnodesqlv8\lib\driver.js:202:9)
    at onInvoke (C:\wamp64\www\mrp\updateNode\node_modules\msnodesqlv8\lib\reader.js:228:26)
    at onQuery (C:\wamp64\www\mrp\updateNode\node_modules\msnodesqlv8\lib\driver.js:114:11)
  code: 'EREQUEST',
  number: 208,
  state: '42S02',
  originalError: { Error: [Microsoft][SQL Server Native Client 11.0][SQL Server]Invalid object name '#mrpSalesHistory'. sqlstate: '42S02', code: 208 },
  name: 'RequestError' }
Q5
undefined
Q6
{ recordsets: [ [] ],
  recordset: [],
  output: {},
  rowsAffected: [] }
Q4
{ recordsets: [ [ [Object] ] ],
  recordset: [ { '': 0 } ],
  output: {},
  rowsAffected: [] }
Q1
{ recordsets: [],
  recordset: undefined,
  output: {},
  rowsAffected: [ 77938 ] }

谢谢 .

1 回答

  • 1

    你的 new sql.Request().batch( 电话中的每一个都应该是 return new sql.Request().batch( . 您在代码中真正开始的是,您正在快速连续启动所有这5个sql请求,而无需等待任何完成,然后在没有保证订单的情况下满足它们 . 注意每个查询的输出的随机序列 .

相关问题