java 数据库连接池配置租户审计的核心做法是结合连接池的拦截器机制与 sql 解析，在获取或归还连接时自动注入租户标识。具体实现通常通过自定义 connectioninterceptor 或在连接属性中设置上下文变量来完成，这样可以在不修改业务代码的前提下，确保所有 sql 执行都携带正确的租户信息，从而实现数据隔离和审计追踪。
如何配置 HikariCP 的自定义拦截器进行审计
在 HikariCP 中配置租户审计最直接的方式是实现 ConnectionPoolListener 接口并注册到池中。该接口提供了 connectionAcquired 和 connectionReleased 等回调方法，开发者可以在这些方法中记录连接的生命周期事件，并结合 ThreadLocal 存储当前租户 ID，以便后续 SQL 执行时读取。
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import com.zaxxer.hikari.pool.ConnectionPoolListener;
public class AuditHikariExample {
public static void main(String[] args) {
// 1. 创建配置
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://localhost:3306/mydb");
config.setUsername("user");
config.setPassword("pass");
// 2. 注册监听器用于审计
config.addDataSourceProperty("connectionInitSql", "SELECT 1");
HikariDataSource ds = new HikariDataSource(config);
// 注意：HikariCP 默认不支持直接添加 ConnectionPoolListener
// 需通过反射或扩展 DataSourceProxy 实现，此处展示概念逻辑
// 实际生产中常使用 MyBatis-Plus 或 ShardingSphere 等中间件
System.out.println("DataSource initialized with audit capability.");
}
}
上述代码展示了基础的数据源初始化过程。虽然 HikariCP 原生 API 对拦截器的支持有限，但可以通过包装 DataSource 或使用如 HikariCP 的扩展库来实现。关键在于在 getConnection() 调用前后捕获上下文。预期输出为控制台打印初始化成功信息，且在实际 SQL 执行前，租户 ID 已存入线程局部变量中。
立即学习“Java免费学习笔记（深入）”；
你是 TypeScript 项目架构专家，专注于脚手架搭建生产就绪的 Node.js 和前端应用。生成包含现代工具链（pnpm、Vite、Next.js）、类型
ShardingSphere-JDBC 如何实现多租户 SQL 改写
ShardingSphere-JDBC 提供了内置的多租户支持，通过 TenantHandler 接口可以自动将租户 ID 注入到 SQL 语句中。这种方式比手动拦截更强大，因为它能处理复杂的 SQL 改写，例如在 WHERE 子句后追加 tenant_id = ?，从而在查询层面强制实现数据隔离。
import org.apache.shardingsphere.api.sharding.multiple.TenantHandler;
import java.util.Collection;
import java.util.HashSet;
import java.util.Set;
public class SimpleTenantHandler implements TenantHandler {
@Override
public String getTenantIdColumn() {
return "tenant_id"; // 指定表中的租户列名
}
@Override
public String getTenantId() {
// 从当前线程或上下文中获取租户ID
return CurrentContext.getTenantId();
}
@Override
public Set<String> getSchemaPatterns() {
Set<String> schemas = new HashSet<>();
schemas.add(".*"); // 匹配所有 schema
return schemas;
}
}
// 在 ShardingSphere 配置中注册此 Handler
// shardingRuleConfiguration.getTenantRules().add(new TenantRule(new SimpleTenantHandler()));
这段代码定义了一个简单的 TenantHandler 实现。当 SQL 执行时，ShardingSphere 会自动识别目标表，并在 SQL 末尾追加 AND tenant_id = 'current_tenant_id'。这确保了即使业务代码忘记加过滤条件，底层也会强制执行。运行此配置后，任何查询都会自动带上租户过滤，审计日志中将清晰显示被改写的 SQL 语句及最终执行的参数。
当租户 ID 为空时连接池如何处理异常
如果当前线程中没有设置租户 ID，即 getTenantId() 返回 null 或空字符串，系统应抛出明确的异常以防止数据泄露。在 ShardingSphere 的实现中，通常会检查租户 ID 的有效性，若无效则拒绝执行 SQL 并抛出 SQLSyntaxErrorException 或自定义的业务异常。这种“失败安全”的设计确保了审计的完整性，避免无租户上下文的操作混入生产环境。
