Package org.apache.druid.sql.avatica

Class DruidConnection

java.lang.Object

org.apache.druid.sql.avatica.DruidConnection

public class DruidConnection
extends Object

Connection tracking for DruidMeta. Thread-safe.

Lock is the instance itself. Used here to protect two members, and in other code when we must resolve the connection after resolving the statement. The lock prevents closing the connection concurrently with an operation on a statement for that connection.

Constructor Summary

Constructors

Constructor	Description
DruidConnection(String connectionId, int maxStatements, Map<String,Object> userSecret, Map<String,Object> sessionContext)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	closeIfEmpty()	Closes this connection if it has no statements.
void	closeStatement(int statementId)
DruidJdbcPreparedStatement	createPreparedStatement(SqlStatementFactory sqlStatementFactory, SqlQueryPlus sqlQueryPlus, Map<String,Object> systemDefaultContext, long maxRowCount, DruidJdbcResultSet.ResultFetcherFactory fetcherFactory)
DruidJdbcStatement	createStatement(SqlStatementFactory sqlStatementFactory, Map<String,Object> systemDefaultContext, DruidJdbcResultSet.ResultFetcherFactory fetcherFactory)
String	getConnectionId()
AbstractDruidJdbcStatement	getStatement(int statementId)
Map<String,Object>	sessionContext()
DruidConnection	sync(Future<?> newTimeoutFuture)
Map<String,Object>	userSecret()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DruidConnection

public DruidConnection(String connectionId,
 int maxStatements,
 Map<String,Object> userSecret,
 Map<String,Object> sessionContext)

Method Details

getConnectionId

public String getConnectionId()

sessionContext

public Map<String,Object> sessionContext()

userSecret

public Map<String,Object> userSecret()

createStatement

public DruidJdbcStatement createStatement(SqlStatementFactory sqlStatementFactory,
 Map<String,Object> systemDefaultContext,
 DruidJdbcResultSet.ResultFetcherFactory fetcherFactory)

createPreparedStatement

public DruidJdbcPreparedStatement createPreparedStatement(SqlStatementFactory sqlStatementFactory,
 SqlQueryPlus sqlQueryPlus,
 Map<String,Object> systemDefaultContext,
 long maxRowCount,
 DruidJdbcResultSet.ResultFetcherFactory fetcherFactory)

getStatement

public AbstractDruidJdbcStatement getStatement(int statementId)

closeStatement

public void closeStatement(int statementId)

closeIfEmpty

public boolean closeIfEmpty()

Closes this connection if it has no statements.

Returns:

true if closed

close

public void close()

sync

public DruidConnection sync(Future<?> newTimeoutFuture)