我们以php为例，多表事务处理。
<?php
$connection = new MongoDB\Driver\Manager("mongodb://127.0.0.1:27017");
$session = $connection->startSession();
try {
$session->startTransaction();
$bulk = new MongoDB\Driver\BulkWrite(['ordered' => true]);
$bulk->insert(['x' => 1]);
$bulk->insert(['x' => 2]);
$bulk->insert(['x' => 3]);
$result = $connection->executeBulkWrite('db.users', $bulk, ['session' => $session]);
$bulk2 = new MongoDB\Driver\BulkWrite(['ordered' => true]);
$bulk2->insert(['name' => 1]);
$bulk2->insert(['name' => 2]);
$bulk2->insert(['name' => 3]);
$result2 = $connection->executeBulkWrite('db.product', $bulk2, ['session' => $session]);
$session->commitTransaction();
}catch(Exception $e) {
$session->abortTransaction();
var_dump($e->getMessage());
}
网友回复
我知道答案，我要回答
私活外包
