jdbc-protolib/src/main/java/com/streamsets/pipeline/lib/jdbc/multithread/ConnectionManager.java
public void closeConnection() {
    LOGGER.debug("Closing connection");
    Connection connectionToRemove = threadLocalConnection.get();
    jdbcUtil.closeQuietly(connectionToRemove);
    if (connectionToRemove != null) {
      synchronized (this) {
        connectionsToCloseDuringDestroy.remove(connectionToRemove);
      }
    }
    threadLocalConnection.set(null);
  }
public void closeConnection() {
    LOGGER.debug("Closing connection");
    Connection connectionToRemove = threadLocalConnection.get();
    jdbcUtil.closeQuietly(connectionToRemove);
    if (connectionToRemove != null) {
      synchronized (this) {
        connectionsToCloseDuringDestroy.remove(connectionToRemove);
      }
    }
    threadLocalConnection.set(null);
  }
Close the current thread's connection