ArangoDB 的事務處理是通過 AQL(ArangoDB Query Language)來實現的
要在 ArangoDB 中執行事務,請遵循以下步驟:
transaction
選項設置為 true
。例如,使用 JavaScript 的 arangojs 驅動程序:const { Database } = require('@arangodb');
const db = new Database({
url: 'http://localhost:8529',
databaseName: 'myDatabase',
auth: { username: 'root', password: 'mypassword' },
transaction: true
});
function (params) {
const { collections, db } = params;
// 獲取集合
const usersCollection = db._collection(collections.users);
const ordersCollection = db._collection(collections.orders);
// 插入用戶
const user = { name: 'John Doe', email: 'john.doe@example.com' };
const userResult = usersCollection.save(user);
// 插入訂單
const order = {
product: 'ArangoDB',
price: 199.99,
userId: userResult._key
};
const orderResult = ordersCollection.save(order);
return { userResult, orderResult };
}
db._executeTransaction()
方法,并傳入事務函數以及事務所需的參數。例如:async function executeTransaction() {
try {
const collections = {
users: 'users',
orders: 'orders'
};
const result = await db._executeTransaction(
{
write: [collections.users, collections.orders]
},
transactionFunction,
{ collections }
);
console.log('Transaction executed successfully:', result);
} catch (error) {
console.error('Error executing transaction:', error);
}
}
executeTransaction();
在這個示例中,我們首先創建了一個事務函數,該函數在 users
和 orders
集合上執行插入操作。然后,我們調用 db._executeTransaction()
方法來執行事務。如果事務成功執行,我們將輸出結果;否則,我們將輸出錯誤信息。
請注意,事務函數應該具有原子性,即要么全部成功執行,要么全部失敗。這意味著如果在事務過程中發生錯誤,所有已執行的操作都將被回滾。