网友回复
我们以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()); }