public synchronized void closeActiveConnection() {
    for (PreparedStatement statement : statementCache.values()) {
      closeQuietly(statement);
    }
    statementCache.clear();
    closeQuietly(activeConnection);
    activeConnection = null;
    connectedEndpoint = null;
  }
Close the active connection and clear the statement cache.
ambry-mysql/src/main/java/com/github/ambry/mysql/MySqlDataAccessor.java