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.

Constructor Summary

Constructors

Constructor and Description
DruidConnection(String connectionId, int maxStatements, Map<String,Object> userSecret, QueryContext context)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	closeIfEmpty() Closes this connection if it has no statements.
void	closeStatement(int statementId)
DruidJdbcPreparedStatement	createPreparedStatement(SqlStatementFactory sqlStatementFactory, SqlQueryPlus sqlQueryPlus, long maxRowCount)
DruidJdbcStatement	createStatement(SqlStatementFactory sqlStatementFactory)
String	getConnectionId()
AbstractDruidJdbcStatement	getStatement(int statementId)
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 Detail

DruidConnection

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

Method Detail

getConnectionId

public String getConnectionId()

createStatement

public DruidJdbcStatement createStatement(SqlStatementFactory sqlStatementFactory)

createPreparedStatement

public DruidJdbcPreparedStatement createPreparedStatement(SqlStatementFactory sqlStatementFactory,
                                                          SqlQueryPlus sqlQueryPlus,
                                                          long maxRowCount)

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)

userSecret

public Map<String,Object> userSecret()