如何在JDBC抽取重插入时保留MariaDB datetime(6)的微秒精度

我之前做数据库同步的时候也踩过这个微秒精度丢失的坑，咱们从根源到解决方案一步步梳理清楚：

核心原因分析 #

这个问题的本质是JDBC驱动默认的日期时间处理逻辑会自动截断微秒，再加上连接参数配置不到位、数据读写方式不正确，最终导致datetime(6)的最后三位小数（微秒级别精度）丢失。

分步解决方案 #

1. 升级并配置MariaDB JDBC驱动（Connector/J） #

首先确保你使用的是2.7.0及以上版本的MariaDB Connector/J，旧版本默认不支持微秒精度。然后在连接URL中必须添加以下关键参数：

// 上游数据库连接URL
String upstreamUrl = "jdbc:mariadb://upstream-host:3306/upstream_db?useLegacyDatetimeCode=false&useMicroseconds=true&serverTimezone=UTC";
// 下游数据库连接URL
String downstreamUrl = "jdbc:mariadb://downstream-host:3306/downstream_db?useLegacyDatetimeCode=false&useMicroseconds=true&serverTimezone=UTC";

• useLegacyDatetimeCode=false：禁用旧的日期时间处理逻辑，启用符合JDBC 4.2标准的新处理方式
• useMicroseconds=true：明确告知驱动要保留完整的微秒精度
• serverTimezone=UTC：避免时区转换带来的精度偏差（可根据业务实际时区调整）

2. 正确读取上游数据 #

不要用ResultSet.getTimestamp()，直接用getObject()指定LocalDateTime类型获取数据，这样能完整拿到6位小数的微秒信息：

String querySql = "SELECT id, create_time FROM upstream_table";
try (PreparedStatement stmt = upstreamConn.prepareStatement(querySql);
     ResultSet rs = stmt.executeQuery()) {
    while (rs.next()) {
        Long id = rs.getLong("id");
        // 直接获取LocalDateTime，保留完整微秒精度
        LocalDateTime createTime = rs.getObject("create_time", LocalDateTime.class);
        // 组装模型类实例
        DataModel model = new DataModel(id, createTime);
        // 写入下游数据库
        writeToDownstream(model);
    }
}

3. 模型类用LocalDateTime存储 #

模型类的日期字段一定要用java.time.LocalDateTime（Java 8+），不要使用旧的java.sql.Timestamp——LocalDateTime原生支持纳秒精度，完全覆盖datetime(6)的微秒需求：

public class DataModel {
    private Long id;
    private LocalDateTime createTime;

    // 构造器、Getter、Setter
    public DataModel(Long id, LocalDateTime createTime) {
        this.id = id;
        this.createTime = createTime;
    }

    // 省略Getter和Setter方法
}

4. 正确写入下游数据库 #

写入下游时，同样用PreparedStatement.setObject()传入LocalDateTime，不要用setTimestamp()，确保驱动把完整的微秒精度传递给下游数据库：

private void writeToDownstream(DataModel model) throws SQLException {
    String insertSql = "INSERT INTO downstream_table (id, create_time) VALUES (?, ?)";
    try (PreparedStatement stmt = downstreamConn.prepareStatement(insertSql)) {
        stmt.setLong(1, model.getId());
        // 直接传入LocalDateTime，保证精度不丢失
        stmt.setObject(2, model.getCreateTime());
        stmt.executeUpdate();
    }
}

5. 验证下游数据库字段类型 #

最后一定要确认下游数据库的对应字段是datetime(6)类型，而不是默认的datetime（默认是datetime(0)，会截断所有小数位）或者datetime(3)（只保留毫秒精度）。

额外排查点 #

• 如果用Spring JDBC、MyBatis这类ORM框架，要确保框架配置支持LocalDateTime：比如MyBatis需要指定类型处理器为org.apache.ibatis.type.LocalDateTimeTypeHandler
• 驱动版本验证：Maven项目可以直接在pom.xml中指定最新稳定版：

<dependency>
    <groupId>org.mariadb.jdbc</groupId>
    <artifactId>mariadb-java-client</artifactId>
    <version>3.3.3</version> <!-- 替换为最新稳定版本 -->
</dependency>

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