如何组合这三个函数。compdb() 和 pardb() 与动态数组一起使用。
函数 marketdb(sellwalletamount, custId, receiveamount) {
return new Promise(function(resolve, reject) {
let sql1 = "SELECT * FROM pair_master WHERE id ='" + req.body.pair_id + "'";
connection.query(sql1, function(error, pairdata) {
if (error) {
reject(error)
} else {
if (pairdata[0] == null || pairdata[0] == undefined) {
reject(error);
} else {
let sql2 = "SELECT * FROM customer_wallet WHERE customer_id ='" + custId + "'AND currency_code='" + pairdata[0].to + "'";
connection.query(sql2, function(error, receivewalletdata) {
if (error) {
reject(error);
} else {
if (receivewalletdata[0] == null || receivewalletdata == undefined) {
console.log({ success: false, message: "received wallet not found" });
reject(error);
} else {
var addmoney = receivewalletdata[0].total_amount + receivedamount;
let sql3 = "UPDATE customer_wallet SET total_amount ='" + addmoney + "' WHERE customer_id='" + custId + "'AND currency_code='" + pairdata[0].to + "'";
connection.query(sql3, function(error, response) {
if (error) {
console.log({ success: false, message: "Error", error: error });
reject(error);
} else {
var presentBalance = sellwalletamount - req.body.quantity;
let sql4 = "UPDATE customer_wallet SET total_amount ='" + presentBalance + "' WHERE customer_id='" + custId + "'AND currency_code='" + pairdata[0].from + "'";
connection.query(sql4, function(error, final) {
if (error) {
console.log({ success: false, message: "Error", error: error });
reject(error);
} else {
let sql5 = "INSERT INTO transaction_master (status,trade_type,type,customer_id,avg_price,created_at) values ('Fully Executed','Sell','Market','" + custId + "','" + receivedamount + "','" + created_at + "');"
connection.query(sql5, function(err, transmasterid) {
if (err) {
reject(error);
} else {
resolve(transmasterid.insertId)
}
})
}
})
}
})
}
}
})
}
}
})
})
}
function compdb(dedd, mcustId, custtranmastId) {
return new Promise(function(resolve, reject) {
var i = dedd.length
console.log("i in complte save", i)
async.forEachOf(dedd, function(error, i, inner_callback) {
let sql1 = "UPDATE buy SET status = 'Fully Executed' WHERE id ='" + dedd[i].trade_id + "'";
console.log(sql1)
connection.query(sql1, function(err, rows, fields) {
if (!err) {
console.log("done")
console.log(dedd.trade_id)
let sql = "Select*from transaction_master where trade_type ='Buy' and trade_id='" + dedd[i].trade_id + "'";
console.log(sql)
connection.query(sql, function(err, transactionmasterdata) {
if (err) {
inner_callback(err);
} else if (transactionmasterdata[0] == null || transactionmasterdata[0] == undefined) {
console.log(transactionmasterdata)
let sql2 = "INSERT INTO transaction_master (status,trade_type,type,trade_id,customer_id,avg_price,created_at) values ('Fully Executed','Buy','Limit','" + dedd[i].trade_id + "','" + dedd[i].customer_id + "','" + dedd[i].money + "','" + created_at + "');"
connection.query(sql2, function(err, results) {
if (!err) {
let sql4 = "INSERT INTO transaction (customer_id,trade_type,type,trade_id,to_from_customer_id,price,quantity,status,pair_id,created_at,transanction_master_id) values ('" + dedd[i].customer_id + "','Buy','Limit','" + dedd[i].trade_id + "','" + mcustId + "','" + dedd[i].money + "','" + dedd[i].quantity + "','Fully Executed','" + dedd[i].pair_id + "','" + created_at + "','" + results.insertId + "'),('" + mcustId + "','Sell','Market','" + dedd[i].trade_id + "','" + dedd[i].customer_id + "','" + dedd[i].money + "','" + dedd[i].quantity + "','Fully Executed','" + dedd[i].pair_id + "','" + created_at + "','" + custtranmastId + "');"
connection.query(sql4, function(err, rows, fields) {
if (!err) {
inner_callback(null);
} else {
inner_callback(err);
};
});
} else {
inner_callback(err);
}
})
} else {
var newavg_price = (transactionmasterdata[0].avg_price + dedd[i].money) / 2;
let sql2 = "UPDATE transaction_master SET status='Fully Executed',avg_price='" + newavg_price + "' where id= '" + transactionmasterdata[0].id + "'";
connection.query(sql2, function(err, results) {
if (!err) {
let sql4 = "INSERT INTO transaction (customer_id,trade_type,type,trade_id,to_from_customer_id,price,quantity,status,pair_id,created_at,transanction_master_id) values ('" + dedd[i].customer_id + "','Buy','Limit','" + dedd[i].trade_id + "','" + mcustId + "','" + dedd[i].money + "','" + dedd[i].quantity + "','Fully Executed','" + dedd[i].pair_id + "','" + created_at + "','" + transactionmasterdata[0].id + "'),('" + mcustId + "','Sell','Market','" + dedd[i].trade_id + "','" + dedd[i].customer_id + "','" + dedd[i].money + "','" + dedd[i].quantity + "','Fully Executed','" + dedd[i].pair_id + "','" + created_at + "','" + transactionmasterdata[0].id + "');"
connection.query(sql4, function(err, rows, fields) {
if (!err) {
inner_callback(null);
} else {
inner_callback(err);
};
});
} else {
inner_callback(err);
}
})
}
})
} else {
inner_callback(err);
}
})
},
function(err) {
if (err) {
reject(err)
console.log(err)
} else {
resolve("ok")
}
});
})
}
function pardb(dedd, mcustId) {
return new Promise(function(resolve, reject) {
var i = dedd.length
async.forEachOf(dedd, function(error, i, inner_callback) {
let sql1 = "UPDATE buy SET status = 'Partially Executed',quantity='" + dedd[i].newquantity + "' WHERE id ='" + dedd[i].trade_id + "'";
connection.query(sql1, function(err, rows, fields) {
if (!err) {
console.log("done")
//inner_callback(null);
let sql2 = "INSERT INTO transaction (customer_id,trade_type,type,trade_id,to_from_customer_id,price,quantity,status,pair_id,created_at) values ('" + dedd[i].customer_id + "','Buy','Limit'," + dedd[i].trade_id + "','" + mcustId + "','" + dedd[i].money + "','" + dedd[i].quantity + "','Partially Executed','" + dedd[i].pair_id + "','" + created_at + "'),('" + mcustId + "','Sell','Market'," + dedd[i].trade_id + "','" + dedd.customer_id + "','" + dedd[i].money + "','" + dedd[i].quantity + "','Partially Executed','" + dedd[i].pair_id + "','" + created_at + "');"
connection.query(sql2, function(err, rows, fields) {
if (!err) {
inner_callback(null);
} else {
inner_callback(err);
};
});
} else {
inner_callback(err);
}
})
},
function(err) {
if (err) {
reject(err)
} else {
resolve("ok")
}
});
})
}
如何将这三个函数合并为一个，如果发生错误，则回滚 Node js中的所有函数。所有函数都一个接一个地正常工作，但我必须包括回滚所有函数，以防出现错误。 第一个功能仅针对单个用户更改状态。 第二个函数适用于数组并更改数组中当前所有用户的状态。 第三个函数也与第二个函数执行相同的操作，但状态不同
最佳答案
我强烈建议您使用sequelize.js 。这是更容易和更容易理解的。有一个名为 transactions 的部分其中包含实现事务(包括提交和回滚)所需的所有信息。但在深入研究这个中间件之前，我建议您阅读 Promise chains 。通常，您在最后的 then 处提交事务，并在 catch error 部分回滚。
换句话说，当一切正常时，交易将被提交，如果发生错误，整个链将回滚到原来的状态。这是一个简单的例子:
sequelize.transaction().then(async transaction => {
// firstPromise (you should pass transaction inside the query function)
.then(()=>{
// second promise
// you can return a value from this promise to the next one
})
.then(()=>{
// third promise
})
.then(()=>{
// final state
transaction.commit();
})
.catch(err => {
transaction.rollback();
});
});
关于javascript - 如果在 Node js 中使用 mysql 发生错误，如何在 Node js 中回滚函数，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/47151341/