我正在尝试创建一个临时表,并使用节点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 回答
你的
new sql.Request().batch(
电话中的每一个都应该是return new sql.Request().batch(
. 您在代码中真正开始的是,您正在快速连续启动所有这5个sql请求,而无需等待任何完成,然后在没有保证订单的情况下满足它们 . 注意每个查询的输出的随机序列 .