如何在Spring Boot服务中获取当前数据库操作的MySQL thread_id

嘿，这个场景我之前刚好处理过，给你几个靠谱的方案，结合你要用Blackhole引擎关联request_id的需求，咱们一步步来：

方法1：直接执行SQL查询（最通用无依赖） #

MySQL本身提供了SELECT CONNECTION_ID();语句来获取当前连接的thread_id，这是最稳妥的方式，不管用什么持久化框架都能生效。

在Spring Boot里，用JdbcTemplate直接执行的示例：

@Autowired
private JdbcTemplate jdbcTemplate;

public Long getCurrentThreadId() {
    return jdbcTemplate.queryForObject("SELECT CONNECTION_ID();", Long.class);
}

如果用JPA的EntityManager，可以这么写：

@PersistenceContext
private EntityManager entityManager;

public Long getCurrentThreadId() {
    Query query = entityManager.createNativeQuery("SELECT CONNECTION_ID();");
    return ((Number) query.getSingleResult()).longValue();
}

要是用MyBatis，直接在Mapper里加方法就行：

<select id="getConnectionId" resultType="java.lang.Long">
    SELECT CONNECTION_ID();
</select>

方法2：通过MySQL驱动API直接获取（更高效） #

如果你用的是MySQL官方驱动，可以直接从Connection对象里拿到thread_id，不用走SQL查询。不过要注意驱动版本差异：

• MySQL Connector/J 5.x：对应实现类是com.mysql.jdbc.ConnectionImpl
• MySQL Connector/J 8.x：对应实现类是com.mysql.cj.jdbc.ConnectionImpl

示例代码（以8.x为例）：

@Autowired
private DataSource dataSource;
@Autowired
private JdbcTemplate jdbcTemplate;

public Long getCurrentThreadId() throws SQLException {
    try (Connection conn = dataSource.getConnection()) {
        if (conn instanceof com.mysql.cj.jdbc.ConnectionImpl) {
            return ((com.mysql.cj.jdbc.ConnectionImpl) conn).getThreadId();
        }
        // 兼容其他情况，降级到SQL查询
        return jdbcTemplate.queryForObject("SELECT CONNECTION_ID();", Long.class);
    }
}

⚠️ 注意：这种方式依赖驱动的具体实现类，虽然高效，但如果后续换驱动或升级版本，可能需要调整代码，所以建议加上降级逻辑。

结合Blackhole引擎关联request_id的实践 #

你的核心需求是把当前请求的request_id和MySQL thread_id映射，让Maxwell捕获这条关联记录。这里关键要保证业务操作和插入Blackhole表用的是同一个数据库连接（也就是同一个thread_id），所以最好把两个操作放在同一个事务里：

@Transactional
public void doBusinessOperation(String requestId, YourBusinessData data) {
    // 1. 执行业务增改操作
    businessRepository.save(data);
    
    // 2. 获取当前thread_id
    Long threadId = getCurrentThreadId();
    
    // 3. 插入Blackhole表（假设表名为thread_request_mapping）
    String insertSql = "INSERT INTO thread_request_mapping (thread_id, request_id) VALUES (?, ?)";
    jdbcTemplate.update(insertSql, threadId, requestId);
}

Blackhole引擎的表不会实际存储数据，但Maxwell依然会捕获到这条INSERT的变更日志，这样你就能在Kafka消息里拿到thread_id和request_id的对应关系，再和业务变更日志关联起来了。

一些注意事项 #

• 事务一致性：一定要确保业务操作和插入Blackhole的操作在同一个事务中，否则可能因为连接池分配不同连接导致thread_id不匹配。
• 连接池配置：如果你的连接池有复用连接的机制，只要在同一个事务里，连接不会被释放，thread_id会保持一致。
• 驱动版本兼容性：如果用方法2，记得测试不同驱动版本的兼容性，保留降级到SQL查询的逻辑更稳妥。

内容的提问来源于stack exchange，提问作者Abhishek Verma