如何按顺序执行 SQL 个命令列表?
How to execute a list of SQL commands sequentially?
我正在使用 MySQL for NodeJS 并尝试做这样的事情:
dbQueries = ['multiple', 'sql', 'statements', 'that', 'need', 'to', 'be', 'executed', 'in', 'order'];
executedQueries = 0;
dbConn = mysql.connect();
maxQueries = dbQueries.length;
dbQueries.forEach(async (dbQuery) => {
console.log("Start");
return dbConn.query(dbQuery, function(err, results, fields) {
console.log("Finish");
if (err) {
errorList.push({ err, results, fields, dbQuery });
}
executedQueries++;
if (executedQueries >= maxQueries) {
if (errorList.length > 0) {
console.log("Error: ", databaseTable.name, " Errors reported: ", errorList);
}
if (typeof(callbackFunc) === 'function') { callbackFunc(errorList, executedQueries); }
}
});
});
但最终发生的情况是,有时查询会乱序完成。我知道这一点是因为我设置了列,然后通过添加主键等修改 table,有时 Table 'blah.blah' doesn't exist
会出错。错误每次都会改变。我能看到这个是因为在看到多个 Finish
之前有多个 Start
。不确定我是否正确使用异步。
如果可能,我不想打开 multipleStatements
。
您看到意外结果的主要原因是 nodejs 异步执行这些查询。 运行 多个查询的正确方法:
dbQueries = ['multiple', 'sql', 'statements', 'that', 'need', 'to', 'be', 'executed', 'in', 'order'];
dbConn = mysql.connect();
function runQueries(dbQueriesArr) {
if(dbQueriesArr.length === 0)
return;
var dbQuery = dbQueriesArr[0];
dbConn.query(dbQuery, function(err, results, fields) {
if (err) {
errorList.push({ err, results, fields, dbQuery });
}
var dbQueriesArr_rest = dbQueriesArr.splice(1);
runQueries(dbQueriesArr_rest);
});
}
runQueries(dbQueries);
我正在使用 MySQL for NodeJS 并尝试做这样的事情:
dbQueries = ['multiple', 'sql', 'statements', 'that', 'need', 'to', 'be', 'executed', 'in', 'order'];
executedQueries = 0;
dbConn = mysql.connect();
maxQueries = dbQueries.length;
dbQueries.forEach(async (dbQuery) => {
console.log("Start");
return dbConn.query(dbQuery, function(err, results, fields) {
console.log("Finish");
if (err) {
errorList.push({ err, results, fields, dbQuery });
}
executedQueries++;
if (executedQueries >= maxQueries) {
if (errorList.length > 0) {
console.log("Error: ", databaseTable.name, " Errors reported: ", errorList);
}
if (typeof(callbackFunc) === 'function') { callbackFunc(errorList, executedQueries); }
}
});
});
但最终发生的情况是,有时查询会乱序完成。我知道这一点是因为我设置了列,然后通过添加主键等修改 table,有时 Table 'blah.blah' doesn't exist
会出错。错误每次都会改变。我能看到这个是因为在看到多个 Finish
之前有多个 Start
。不确定我是否正确使用异步。
如果可能,我不想打开 multipleStatements
。
您看到意外结果的主要原因是 nodejs 异步执行这些查询。 运行 多个查询的正确方法:
dbQueries = ['multiple', 'sql', 'statements', 'that', 'need', 'to', 'be', 'executed', 'in', 'order'];
dbConn = mysql.connect();
function runQueries(dbQueriesArr) {
if(dbQueriesArr.length === 0)
return;
var dbQuery = dbQueriesArr[0];
dbConn.query(dbQuery, function(err, results, fields) {
if (err) {
errorList.push({ err, results, fields, dbQuery });
}
var dbQueriesArr_rest = dbQueriesArr.splice(1);
runQueries(dbQueriesArr_rest);
});
}
runQueries(dbQueries);