Java 中的 TokuMX MVCC 事务

Question

在同一文档上运行并发事务时如何保存高度竞争的记录？

似乎正在发生这种情况：

1. MVCC 事务 A 开始。
2. MVCC 事务 B 开始。
3. 事务 A 更新 docA 和 docB。
4. 事务 A 提交。
5. 事务 B 更新 docA 和 docC - 在事务 A 已提交且未持有任何锁时获得锁。
6. 事务 B 提交覆盖了转换 A 在 docA 上所做的工作。

示例代码如下：

        mongoClient = new MongoClient( "localhost" , 27017 );
        db = mongoClient.getDB("test");
        collection = db.getCollection("testData");

        //Create usable Mongo key from key String (i.e {_id:ObjectId("53b4477d44aef43e83c18922")})
        String key = "53b4477d44aef43e83c18922";
        String key2 = "53bfff9e44aedb6d98a5c578";
        ObjectId keyObj = new ObjectId(key);
        ObjectId keyObj2 = new ObjectId(key2);

        //Set up the transaction
        BasicDBObject transaction = new BasicDBObject();
        transaction.append("beginTransaction", 1);
        transaction.append("isolation", "mvcc");
        db.command(transaction);

        //Create search query
        BasicDBObject query = new BasicDBObject().append("_id",keyObj);
        BasicDBObject query2 = new BasicDBObject().append("_id",keyObj2);

        //Create set  
        BasicDBObject set = new BasicDBObject();
        set.append("$inc", new BasicDBObject().append("balance",50));

        //Run command
        collection.update(query, set);
        collection.update(query2, set);

        //Commit the transactions
        BasicDBObject commitTransaction = new BasicDBObject();
        commitTransaction.append("commitTransaction", 1);
        db.command(commitTransaction);

是否可以通过检查来决定是否提交交易？或者这是 TokuMX 的预期行为（或者我做错了什么）？

Answer 1

TokuMX 多语句事务与 MySQL 多语句事务非常相似。在您的示例中，将在更新发生时持有文档级锁定，因此对该记录的更新将被序列化。

如果因为两个事务同时更新同一个文档而发生冲突，update 方法将返回一个错误，指出存在锁冲突。

为了帮助您了解发生了什么，让两个线程运行它，但都没有提交。您将看到一个线程等待并最终超时并出现锁定超时错误。

另外，如果您的事务是单个更新，您可以直接运行它，不需要将其包装在事务中。如果您想使用多语句事务，您可能需要“可序列化”隔离而不是 MVCC，如果您将读取作为事务的一部分：http://docs.tokutek.com/tokumx/tokumx-transactions.html#tokumx-transactions-isolation-serializable 此外，您需要为事务保留连接，否则连接池会使您的事务行为不正常：http://docs.tokutek.com/tokumx/tokumx-transactions.html#tokumx-transactions-multi-statement-drivers