public void updateOneExecutor(boolean reconnect, String tableIdentifier) {
        try {
            SimpleJdbcConnectionProvider tableConnectionProvider = connectionExecProviderMap.get(tableIdentifier);
            if (reconnect || null == tableConnectionProvider
                    || !tableConnectionProvider.isConnectionValid()) {
                JdbcExec tableJdbcExec = jdbcExecMap.get(tableIdentifier);
                if (null != tableJdbcExec) {
                    tableJdbcExec.closeStatements();
                    jdbcExecMap.remove(tableIdentifier);
                    getOrCreateStatementExecutor(tableIdentifier);
                }
            }
        } catch (SQLException | IOException e) {
            LOG.error("jdbcExec updateOneExecutor get err", e);
        }
    }
Executes prepared statement and closes all resources of this instance.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java