MultiTenancyGetConnectionByTenant.java

@Override
public Connection getConnection(String tenantIdentifier) throws SQLException {
    log.debugf("Requesting connection for tenant %s", tenantIdentifier);
    final Connection connection = getAnyConnection();
    connection.createStatement().execute("USE " + tenantIdentifier);
    return connection;
}

@Override
public void releaseConnection(String tenantIdentifier, Connection connection) throws SQLException {
    final String schema = configurationService.getSetting(
                AvailableSettings.DEFAULT_SCHEMA, String.class, "public");
    selectConnectionProvider(tenantIdentifier).closeConnection(connection);
}