Oracle JDBC实际fetchSize与请求次数获取及监控方案问询

云上老周

2026-7-16

Oracle 19c + Spring Boot 3: 监控JDBC查询实际Fetch Size与数据库往返次数

环境

Oracle 19c
ojdbc8-19.3.0.0
JDK 17
Spring Boot 3 Web
Kubernetes

背景

我们有一个仅执行数据库查询并生成JSON响应的Spring Web REST应用，通过Spring JdbcTemplate为查询动态设置fetchSize，取值来自预配置集合。通过Dynatrace发现，数据库实际请求次数与设置fetchSize后的预期次数不符，导致响应性能下降（已通过调整内存解决）。希望将此作为指标监控，当实际请求次数与预期次数的比值超过阈值时触发告警。

问题

已知每个查询设置的fetchSize，如何实现：

获取驱动实际使用的fetchSize？
获取请求次数（往返次数）（Dynatrace是如何实现的？）
其他可行方案？

1. 获取驱动实际使用的fetchSize

Oracle JDBC驱动（ojdbc8）允许通过原生OracleStatement/OraclePreparedStatement的getFetchSize()方法获取实际生效的fetchSize。由于Spring JdbcTemplate封装了JDBC操作，需要拿到底层的原生Statement对象：

方法一：通过`PreparedStatementCreator`直接获取

在执行查询时，自定义PreparedStatementCreator，设置fetchSize后立即获取实际值并记录：

jdbcTemplate.query(
    connection -> {
        OraclePreparedStatement stmt = (OraclePreparedStatement) connection.prepareStatement("SELECT ...");
        int configuredFetchSize = getConfiguredFetchSize(); // 从预配置集合获取
        stmt.setFetchSize(configuredFetchSize);
        // 获取驱动实际生效的fetchSize
        int actualFetchSize = stmt.getFetchSize();
        // 将actualFetchSize上报到监控指标（如Micrometer）
        metricsRegistry.gauge("jdbc.query.actual_fetch_size", actualFetchSize);
        return stmt;
    },
    resultSet -> {
        // 处理结果集逻辑
    }
);

方法二：自定义Statement拦截器

通过Spring的DataSource包装或自定义StatementInterceptor，拦截所有Statement的创建和fetchSize设置操作，统一记录实际值：

public class FetchSizeTrackingInterceptor implements StatementInterceptor {
    @Override
    public Statement intercept(Statement statement, Connection connection) throws SQLException {
        if (statement instanceof OraclePreparedStatement oracleStmt) {
            int actualFetchSize = oracleStmt.getFetchSize();
            // 上报指标
        }
        return statement;
    }
}

然后将该拦截器注册到Spring的DataSource配置中。

注意：Oracle驱动可能会根据查询结果集大小、数据库配置等自动调整fetchSize（比如结果集行数小于设置值时，驱动可能不会使用配置的fetchSize），因此获取的实际值可能与配置值不一致。

2. 获取请求次数（往返次数）

Dynatrace的实现原理

Dynatrace通过**字节码增强（Bytecode Instrumentation）**拦截JDBC核心类的关键方法：

拦截ResultSet.next()方法：当本地缓存的结果行耗尽时，驱动会向数据库发起新的fetch请求，此时next()会触发网络往返，Dynatrace会统计这类触发远程请求的次数。
同时拦截Statement.executeQuery()等方法，关联SQL语句与往返次数。

自行实现的方案

方案一：字节码增强拦截`ResultSet.next()`

使用ByteBuddy或ASM等工具，拦截OracleResultSet.next()方法，统计触发远程fetch的次数：

// 示例：ByteBuddy拦截逻辑
new ByteBuddy()
    .redefine(OracleResultSet.class)
    .method(named("next"))
    .intercept(MethodDelegation.to(FetchCountInterceptor.class))
    .make()
    .load(OracleResultSet.class.getClassLoader(), ClassReloadingStrategy.fromInstalledAgent());

// 拦截器类
public class FetchCountInterceptor {
    public static boolean intercept(@SuperCall Callable<Boolean> superCall) throws Exception {
        boolean hasNext = superCall.call();
        // 判断是否触发了远程fetch（可通过驱动内部状态或统计逻辑推断）
        if (isRemoteFetchTriggered()) {
            metricsRegistry.counter("jdbc.query.fetch_round_trips").increment();
        }
        return hasNext;
    }
}

注：判断是否触发远程fetch需要结合Oracle驱动的内部实现，可通过跟踪OracleResultSet的私有字段（需反射），或统计next()调用次数与fetchSize的倍数关系。

方案二：基于结果集行数计算预期次数，对比实际次数

如果能统计查询返回的总行数，预期往返次数为ceil(totalRows / configuredFetchSize)，再结合实际往返次数对比：

int totalRows = 0;
while (resultSet.next()) {
    totalRows++;
    // 处理结果
}
int expectedRoundTrips = (int) Math.ceil((double) totalRows / configuredFetchSize);
int actualRoundTrips = getActualRoundTrips(); // 通过拦截器获取
// 上报比值指标：actualRoundTrips / expectedRoundTrips
metricsRegistry.gauge("jdbc.query.round_trip_ratio", (double) actualRoundTrips / expectedRoundTrips);

3. 其他可行方案

数据库端监控：查询Oracle的V$SQL视图，通过FETCHES字段获取该SQL执行的实际fetch次数，结合应用端的配置fetchSize和返回行数计算预期次数，在数据库端或Prometheus中配置告警。例如：
```
SELECT sql_id, fetches, rows_processed
FROM v$sql
WHERE sql_text = 'SELECT ...';
```
预期次数为ceil(rows_processed / configuredFetchSize)，对比fetches值。
简化指标监控：直接监控总行数 / 配置fetchSize的比值，若实际fetch次数与该比值偏差超过阈值则告警。这种方式无需拦截JDBC驱动，仅需统计总行数和配置的fetchSize，实现成本低。
优化fetchSize配置逻辑：验证Oracle驱动对fetchSize的限制（比如jdbc.defaultFetchSize系统属性、数据库的OPEN_CURSORS参数等），确保配置的fetchSize能被驱动实际接受，避免驱动自动调整导致的偏差。
Micrometer自定义指标：将实际fetchSize、预期往返次数、实际往返次数、偏差比值作为自定义指标暴露给Prometheus，通过Grafana配置告警规则，当比值超过阈值（如1.2）时触发告警。

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

Oracle JDBC实际fetchSize与请求次数获取及监控方案问询

环境 #

背景 #

问题 #

1. 获取驱动实际使用的fetchSize #

方法一：通过PreparedStatementCreator直接获取