Node.js 事务处理是指在 Node.js 应用程序中处理数据库事务的过程。事务是一组原子性的操作序列,要么全部成功执行,要么全部失败回滚。事务处理确保了数据的一致性和完整性。
BEGIN
COMMIT
ROLLBACK
const mysql = require('mysql');
const connection = mysql.createConnection({
host: 'localhost',
user: 'your_username',
password: 'your_password',
database: 'your_database'
});
connection.connect();
connection.beginTransaction(err => {
if (err) throw err;
connection.query('INSERT INTO users (name, email) VALUES (?, ?)', ['John Doe', 'john@example.com'], (err, result) => {
if (err) {
return connection.rollback(() => {
throw err;
});
}
const userId = result.insertId;
connection.query('INSERT INTO orders (user_id, product) VALUES (?, ?)', [userId, 'Laptop'], (err, result) => {
if (err) {
return connection.rollback(() => {
throw err;
});
}
connection.commit(err => {
if (err) {
return connection.rollback(() => {
throw err;
});
}
console.log('Transaction completed successfully!');
});
});
});
});
connection.end();
通过合理的事务管理和错误处理,可以有效提升 Node.js 应用程序的数据可靠性和稳定性。
没有搜到相关的文章