default void dealExecuteError(Connection connection,
								  Exception e,
								  AbstractDtRichOutputFormat metricOutputFormat,
								  Row row,
								  long errorLimit,
								  Logger LOG) {
		JdbcConnectionUtil.rollBack(connection);
		JdbcConnectionUtil.commit(connection);

		if (metricOutputFormat.outDirtyRecords.getCount() % DIRTYDATA_PRINT_FREQUENTY == 0 ||
			LOG.isDebugEnabled()) {
			LOG.error(
				String.format(
					"record insert failed. \nRow: [%s]. \nCause: [%s]",
					row.toString(),
					ExceptionTrace.traceOriginalCause(e)));
		}
		metricOutputFormat.outDirtyRecords.inc();

		if (errorLimit > -1) {
			if (metricOutputFormat.outDirtyRecords.getCount() > errorLimit) {
				throw new SuppressRestartsException(e);
			}
		}
	}
Close JDBC related statements and other classes.
rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/writer/JDBCWriter.java