java 数据库连接池配置租户连接池审计的核心做法是：在连接池初始化时注入自定义的 connectioninterceptor 或 datasourcedecorator，并在其中通过 threadlocal<string></string> 绑定当前租户 id。当应用发起 sql 请求时，拦截器自动将租户标识附加到 statement 的 clientinfo 中，或者在日志框架（如 logback）中配置 mdc（mapped diagnostic context）捕获该上下文。这样既实现了多租户数据隔离，又确保了所有数据库操作都带有可追溯的审计标签。
如何基于 ThreadLocal 实现租户上下文传递
要实现这一机制，必须在每次 HTTP 请求进入时设置租户 ID，并在请求结束时清理，防止内存泄漏。通常使用 Spring AOP 或 Filter 来完成这一步骤。核心在于确保 ThreadLocal 中的值能正确传递给底层的 JDBC 驱动或连接池代理对象。
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
public class TenantAwareDataSource implements DataSource {
private final DataSource targetDataSource;
public TenantAwareDataSource(DataSource targetDataSource) {
this.targetDataSource = targetDataSource;
}
@Override
public Connection getConnection() throws SQLException {
String tenantId = TenantContext.getTenantId();
Connection conn = targetDataSource.getConnection();
// 假设自定义连接包装器支持设置租户信息
return new TenantConnectionWrapper(conn, tenantId);
}
// 其他 DataSource 方法省略...
}
上述代码展示了最基础的包装模式。实际生产中，推荐使用 HikariCP 或 Druid 提供的扩展点。例如，Druid 支持 WallFilter 和自定义 Filter，可以在 connection_prepareStatement 阶段注入租户参数。关键是要保证 TenantContext 的生命周期与线程生命周期一致，且在 finally 块中调用 TenantContext.clear()。
立即学习“Java免费学习笔记（深入）”；
如何将租户信息写入数据库审计日志
仅仅在应用层持有租户 ID 是不够的，必须将其持久化到数据库侧或通过日志系统记录。对于 MySQL 等关系型数据库，可以通过设置 Connection.setClientInfo("ApplicationName", tenantId) 来实现。数据库管理员可以在 information_schema.processlist 或慢查询日志中看到该标识。另一种更通用的方式是结合 SLF4J 的 MDC，将 tenantId 放入 MDC，这样所有经过 Logback/Log4j2 输出的日志都会自动包含租户字段，便于后续 ELK 或 Splunk 聚合分析。
// 在 Filter 或 Interceptor 中
MDC.put("tenantId", tenantId);
try {
chain.doFilter(request, response);
} finally {
MDC.remove("tenantId");
}
这种方案的优势在于无需修改业务代码，只需配置日志 Pattern。如果数据库本身支持审计插件（如 MySQL Enterprise Audit 或 PostgreSQL pgAudit），可以配置触发器或规则，强制要求所有 DML 操作携带租户上下文。此时，应用层设置的 clientInfo 会被数据库审计模块捕获并记录到独立表中，形成不可篡改的审计轨迹。
当 ThreadLocal 未清理时会发生什么
如果在高并发场景下，ThreadLocal 的值未被及时清除，会导致严重的内存泄漏和租户数据串扰。因为连接池中的线程是复用的，如果上一个请求的租户 ID 残留在 ThreadLocal 中，下一个请求可能会错误地使用该 ID，导致数据泄露。因此，必须在请求生命周期的终点（如 Servlet Filter 的 finally 块、Spring HandlerInterceptor 的 afterCompletion 方法）强制调用 clear()。此外，单元测试中也应模拟这一清理过程，否则测试用例之间会相互污染。
