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);
  }
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
Close the current thread s connection