private void reconnect() throws SQLException {
        if (connection != null) {
            try {
                connection.close();
            } catch (Exception e) {
                LOG.error("Reconnect has exception!", e);
            }
            connection = null;
        }
        connection = DriverManager.getConnection(jdbcConfig.getUrl(), jdbcConfig.getUserName(),
                jdbcConfig.getPassword());
        connection.setAutoCommit(false);
    }
reconnect

@throws SQLException Exception when creating connection.
inlong-audit/audit-store/src/main/java/org/apache/inlong/audit/store/service/JdbcService.java