private void closeConnection()

in flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [770:789]

• 20 lines of code
• 5 McCabe index (conditional complexity)

	private void closeConnection() {
		try {
			if (statement != null) {
				statement.close();
				statement = null;
			}
			if (connection != null) {
				if (!connection.isClosed()) {
					connection.close();
					dataSource.discardConnection(connection);
				}
				connection = null;
			}
		} catch (SQLException e) {
			throw new RuntimeException(e);
		} finally {
			statement = null;
			connection = null;
		}
	}