import org.jdbi.v3.core.mapper.RowMapper; //导入依赖的package包/类
@Override
public Optional<RowMapper<?>> build(Type type, ConfigRegistry configRegistry) {
    if (acceptsPredicate.test(type, configRegistry)) {
        RowMapper<?> rowMapper = cache.get(type);
        if (rowMapper == null) {
            Mapper<ResultSet, ?> resultSetMapper = mapperFactory.newInstance(type);
            rowMapper = toRowMapper(resultSetMapper);
            RowMapper<?> cachedMapper = cache.putIfAbsent(type, rowMapper);
            if (cachedMapper != null) {
                rowMapper = cachedMapper;
            }
        }
        return Optional.of(rowMapper);
    }

    return Optional.empty();
}
 

import org.jdbi.v3.core.mapper.RowMapper; //导入依赖的package包/类
private RowMapper<BitemporalRow<ProductEntity>> getProductRowMapper() {
    return (rs, ctx) -> {
        long vid = rs.getLong("vid");
        long eid = rs.getLong("eid");
        long exchangeId = rs.getLong("exchange_id");
        long baseAssetId = rs.getLong("base_asset_id");
        long quoteAssetId = rs.getLong("quote_asset_id");
        String name = rs.getString("name");
        long minOrderSize = rs.getLong("min_order_size");
        long maxOrderSize = rs.getLong("max_order_size");
        long minOrderIncr = rs.getLong("min_order_increment");
        long minQuoteIncr = rs.getLong("min_quote_increment");
        String updateUser = rs.getString("update_user");
        int version = rs.getInt("version");
        Date startTime = rs.getDate("start_time");
        Date endTime = rs.getDate("end_time");

        ProductEntity value = new ProductEntity(
                dbCtx.getEnumCache(Exchange.class).getById(exchangeId),
                dbCtx.getEnumCache(Asset.class).getById(baseAssetId),
                dbCtx.getEnumCache(Asset.class).getById(quoteAssetId),
                name,
                minOrderSize,
                maxOrderSize,
                minOrderIncr,
                minQuoteIncr
        );

        ValidRange validRange = new ValidRange(Instant.ofEpochMilli(startTime.getTime()),
                Instant.ofEpochMilli(endTime.getTime()));
        return new BitemporalRow<>(vid, eid, value, updateUser, validRange, version);
    };
}
 

import org.jdbi.v3.core.mapper.RowMapper; //导入依赖的package包/类
private <T> RowMapper<T> toRowMapper(Mapper<ResultSet, T> resultSetMapper) {
    RowMapper<T> mapper;
    if (resultSetMapper instanceof DynamicJdbcMapper) {
        mapper = new DynamicRowMapper<T>((DynamicJdbcMapper<T>) resultSetMapper);
    } else {
        mapper = new StaticRowMapper<T>(resultSetMapper);
    }
    return mapper;
}
 

import org.jdbi.v3.core.mapper.RowMapper; //导入依赖的package包/类
@Override
public RowMapper<T> specialize(ResultSet rs, StatementContext ctx) throws SQLException {
    return new StaticRowMapper<T>(dynamicMapper.getMapper(rs.getMetaData()));
}