Mongodb事务demo

    public boolean mongoInsertManyTransaction(final MongoClient client, List<Document> document) {

        TransactionOptions txnOptions = TransactionOptions.builder()
                .readPreference(ReadPreference.primary())
                .readConcern(ReadConcern.MAJORITY)
                .writeConcern(WriteConcern.MAJORITY)
                .build();

        // 事务逻辑
        try (ClientSession clientSession = client.startSession()) {
            clientSession.withTransaction(
                    () -> {
                        // 获取数据库
                        MongoDatabase db = client.getDatabase(dbName);
                        MongoCollection<Document> collection = db.getCollection(collectionName);
                        //插入多条文档数据
                        collection.insertMany(clientSession, document);
                        return true;
                    },
                    txnOptions
            );
        }
        return false;
    }