如何为io.vertx.mysqlclient.MySQLPool设置事务隔离级及最佳实践

场景说明 #

之前使用Python时，会先执行SET TRANSACTION ISOLATION LEVEL READ COMMITTED设置事务隔离级，再执行查询。现在切换到Java/Kotlin，使用io.vertx.mysqlclient.MySQLPool，编写了如下示例代码，但对设置方式的合理性和验证方法存在疑问：

private val pool: MySQLPool

init {
    logger.info(
        "Building MySqlClient with host: [${connectOptions.host}], " +
            "port: [${connectOptions.port}], " +
            "db user: [${connectOptions.user}], poolSize: ${poolOptions.maxSize}"
    )
    pool = MySQLPool.pool(vertx, connectOptions, poolOptions)
}

fun executeQuery(query: String, args: List<Any>): Future<RowSet<Row>> {
    logger.debug("Execute the following query: [$query] with args [$args] on [${connectOptions.host}]")
    // Get a connection from the pool
    return pool.getConnection()
        .compose { connection ->
            // Set the transaction isolation level on the connection
            val isolationLevelQuery = "SET TRANSACTION ISOLATION LEVEL READ COMMITTED"
            connection.query(isolationLevelQuery).execute()
                .compose { _ ->
                    // Execute your actual query
                    connection.preparedQuery(query).execute(Tuple.tuple(args))
                }
                .eventually { _ ->
                    // Close the connection when done
                    connection.close()
                }
        }
}

疑问解答 #

1. 如何确认当前已使用READ COMMITTED事务隔离级？ #

可以通过执行MySQL内置查询语句直接验证当前连接的隔离级：

• 执行SELECT @@transaction_isolation;（MySQL 8.0及以上版本）或SELECT @@tx_isolation;（MySQL 5.7及以前版本），返回结果为READ-COMMITTED即说明当前隔离级生效。
• 可以在代码中加入验证步骤，打印日志确认：

connection.query("SET TRANSACTION ISOLATION LEVEL READ COMMITTED").execute()
    .compose {
        // 验证隔离级
        connection.query("SELECT @@transaction_isolation;").execute()
    }
    .compose { result ->
        val currentLevel = result.first().getString(0)
        logger.debug("Current transaction isolation level: $currentLevel")
        // 执行实际查询
        connection.preparedQuery(query).execute(Tuple.tuple(args))
    }

2. 上述设置方式是否合理，此类定制的最佳实践是什么？ #

当前方式的问题

你现在的代码每次获取连接都执行SET语句，会产生额外的查询开销，尤其是在高频调用场景下；虽然能覆盖连接池中可能存在的隔离级变更，但重复执行属于冗余操作。

最佳实践

（1）全局初始化（推荐）

利用Vert.x MySQLClient的连接初始化机制，在连接创建时一次性设置隔离级，避免重复执行：

• 使用initSql配置：直接在MySQLConnectOptions中指定初始化SQL，Vert.x会在连接创建完成后自动执行：

connectOptions.initSql = listOf("SET TRANSACTION ISOLATION LEVEL READ COMMITTED")
pool = MySQLPool.pool(vertx, connectOptions, poolOptions)

• 自定义连接提供者：如果需要更复杂的初始化逻辑，可通过连接池的自定义提供者实现：

val pool = MySQLPool.pool(vertx, connectOptions, poolOptions) { connection ->
    connection.query("SET TRANSACTION ISOLATION LEVEL READ COMMITTED")
        .execute()
        .map { connection } // 初始化完成后返回可用连接
}

（2）按需设置（特殊场景）

如果只有部分查询需要特定隔离级，而非全局生效，当前的方式是可行的，但需注意恢复原隔离级，避免影响后续复用该连接的查询：

pool.getConnection()
    .compose { connection ->
        // 先保存原隔离级
        connection.query("SELECT @@transaction_isolation;").execute()
            .compose { result ->
                val originalLevel = result.first().getString(0)
                // 设置目标隔离级并执行查询
                connection.query("SET TRANSACTION ISOLATION LEVEL READ COMMITTED").execute()
                    .compose {
                        connection.preparedQuery(query).execute(Tuple.tuple(args))
                    }
                    // 恢复原隔离级
                    .eventually {
                        connection.query("SET TRANSACTION ISOLATION LEVEL $originalLevel").execute()
                    }
                    // 关闭连接
                    .eventually {
                        connection.close()
                    }
            }
    }

（3）检查默认隔离级

MySQL 8.0及以上版本的默认事务隔离级就是READ COMMITTED，可以先查询数据库全局默认值：SELECT @@global.transaction_isolation;，如果已经符合需求，无需额外设置。

内容的提问来源于stack exchange，提问作者Ehud Lev