java 多线程写入mysql

// 示例代码：使用HikariCP配置数据库连接池
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://localhost:3306/mydatabase");
config.setUsername("username");
config.setPassword("password");
config.setMaximumPoolSize(50);
HikariDataSource dataSource = new HikariDataSource(config);

// 示例代码：使用事务保证数据一致性
try (Connection conn = dataSource.getConnection()) {
    conn.setAutoCommit(false);
    try (PreparedStatement ps = conn.prepareStatement("INSERT INTO mytable (column1, column2) VALUES (?, ?)")) {
        ps.setString(1, "value1");
        ps.setString(2, "value2");
        ps.executeUpdate();
    }
    conn.commit();
} catch (SQLException e) {
    conn.rollback();
    e.printStackTrace();
}

// 示例代码：设置事务超时时间
try (Connection conn = dataSource.getConnection()) {
    conn.setAutoCommit(false);
    conn.setNetworkTimeout(Executors.newSingleThreadExecutor(), 5000); // 设置5秒超时
    try (PreparedStatement ps = conn.prepareStatement("INSERT INTO mytable (column1, column2) VALUES (?, ?)")) {
        ps.setString(1, "value1");
        ps.setString(2, "value2");
        ps.executeUpdate();
    }
    conn.commit();
} catch (SQLException e) {
    conn.rollback();
    e.printStackTrace();
}