Class BigQueryConnection (1.2.0)

1.2.0 (latest) 1.1.0 1.0.0

public class BigQueryConnection extends BigQueryNoOpsConnection

An implementation of java.sql.Connection for establishing a connection with BigQuery and executing SQL statements See Also: BigQueryStatement

Inheritance

java.lang.Object > com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection > BigQueryConnection

Inherited Members

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.createArrayOf(java.lang.String,java.lang.Object[])

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.createBlob()

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.createClob()

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.createNClob()

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.createSQLXML()

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.createStruct(java.lang.String,java.lang.Object[])

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.getClientInfo()

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.getClientInfo(java.lang.String)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.getNetworkTimeout()

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.getSchema()

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.getTypeMap()

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.isReadOnly()

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.isValid(int)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.nativeSQL(java.lang.String)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.prepareCall(java.lang.String)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.prepareCall(java.lang.String,int,int)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.prepareCall(java.lang.String,int,int,int)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.prepareStatement(java.lang.String,int)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.prepareStatement(java.lang.String,int[])

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.prepareStatement(java.lang.String,java.lang.String[])

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.releaseSavepoint(java.sql.Savepoint)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.rollback(java.sql.Savepoint)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.setCatalog(java.lang.String)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.setClientInfo(java.lang.String,java.lang.String)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.setClientInfo(java.util.Properties)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.setNetworkTimeout(java.util.concurrent.Executor,int)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.setReadOnly(boolean)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.setSavepoint()

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.setSavepoint(java.lang.String)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.setSchema(java.lang.String)

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.setTypeMap(java.util.Map<java.lang.String,java.lang.Class<?>>)

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

<T>unwrap(Class<T> iface)

public T <T>unwrap(Class<T> iface)

Parameter
Name	Description
iface	Class<T>

Returns
Type	Description
T

Exceptions
Type	Description
SQLException

abort(Executor executor)

public void abort(Executor executor)

Parameter
Name	Description
executor	Executor

Exceptions
Type	Description
SQLException

addOpenStatements(Statement statement)

protected void addOpenStatements(Statement statement)

Parameter
Name	Description
statement	Statement

clearWarnings()

public void clearWarnings()

close()

public void close()

Releases this BigQueryConnection object's BigQuery resources immediately instead of waiting for them to be automatically released. See Also: Connection#close()

Exceptions
Type	Description
SQLException	if a BigQuery access error occurs

commit()

public void commit()

createStatement()

public Statement createStatement()

Creates and returns a new Statement object for executing BigQuery SQL queries See Also: Connection#createStatement()

Returns
Type	Description
Statement	a new Statement object

Exceptions
Type	Description
SQLException

createStatement(int resultSetType, int resultSetConcurrency)

public Statement createStatement(int resultSetType, int resultSetConcurrency)

Creates and returns a new Statement object for executing BigQuery SQL queries. This method is similar to BigQueryConnection#createStatement(), but it overrides the type and concurrency of the generated ResultSet. See Also: Connection#createStatement(int, int), ResultSet

Parameters
Name	Description
resultSetType	int
resultSetConcurrency	int

Returns
Type	Description
Statement

Exceptions
Type	Description
SQLException	if a BigQuery connection error occurs, if this method is called on a closed connection, or the given parameters are not ResultSet constants indicating type and concurrency.

createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)

public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)

Creates and returns a new Statement object for executing BigQuery SQL queries. This method is similar to BigQueryConnection#createStatement(), but it overrides the type, concurrency, and holdability of the generated ResultSet. See Also: ResultSet, Connection#createStatement(int, int, int)

Parameters
Name	Description
resultSetType	int
resultSetConcurrency	int
resultSetHoldability	int

Returns
Type	Description
Statement

Exceptions
Type	Description
SQLException	if a BigQuery connection error occurs, if this method is called on a closed connection, or the given parameters are not ResultSet constants indicating type, concurrency, and holdability.

getAuthProperties()

public Map<String,String> getAuthProperties()

Returns
Type	Description
Map<String,String>

getAutoCommit()

public boolean getAutoCommit()

Returns
Type	Description
boolean

getCatalog()

public String getCatalog()

Returns
Type	Description
String

getClientInfo()

public Properties getClientInfo()

Returns
Type	Description
Properties

Overrides

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.getClientInfo()

getClientInfo(String name)

public String getClientInfo(String name)

Parameter
Name	Description
name	String

Returns
Type	Description
String

Overrides

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.getClientInfo(java.lang.String)

getConnectionId()

public String getConnectionId()

Returns
Type	Description
String

getDefaultDataset()

public DatasetId getDefaultDataset()

Returns
Type	Description
com.google.cloud.bigquery.DatasetId

getDiscoveredProjects()

public synchronized List<String> getDiscoveredProjects()

Returns
Type	Description
List<String>

Exceptions
Type	Description
SQLException

getHoldability()

public int getHoldability()

Returns
Type	Description
int

getLocation()

public String getLocation()

Returns
Type	Description
String

getMetaData()

public DatabaseMetaData getMetaData()

Returns
Type	Description
DatabaseMetaData

Exceptions
Type	Description
SQLException

getOtelContext()

public Context getOtelContext()

Returns
Type	Description
io.opentelemetry.context.Context

getPartnerToken()

public String getPartnerToken()

Returns
Type	Description
String

getTracer()

public Tracer getTracer()

Returns
Type	Description
io.opentelemetry.api.trace.Tracer

getTransactionIsolation()

public int getTransactionIsolation()

Returns
Type	Description
int

getWarnings()

public SQLWarning getWarnings()

Returns
Type	Description
SQLWarning

isClosed()

public boolean isClosed()

Returns
Type	Description
boolean

isEnableProjectDiscovery()

public boolean isEnableProjectDiscovery()

Returns
Type	Description
boolean

isReadOnlyTokenUsed()

public boolean isReadOnlyTokenUsed()

Returns
Type	Description
boolean

isTransactionStarted()

public boolean isTransactionStarted()

Returns
Type	Description
boolean

isValid(int timeout)

public boolean isValid(int timeout)

Parameter
Name	Description
timeout	int

Returns
Type	Description
boolean

Overrides

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.isValid(int)

Exceptions
Type	Description
SQLException

isWrapperFor(Class<?> iface)

public boolean isWrapperFor(Class<?> iface)

Parameter
Name	Description
iface	Class<?>

Returns
Type	Description
boolean

Exceptions
Type	Description
SQLException

nativeSQL(String sql)

public String nativeSQL(String sql)

Parameter
Name	Description
sql	String

Returns
Type	Description
String

Overrides

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.nativeSQL(java.lang.String)

Exceptions
Type	Description
SQLException

prepareCall(String sql)

public CallableStatement prepareCall(String sql)

Parameter
Name	Description
sql	String

Returns
Type	Description
CallableStatement

Overrides

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.prepareCall(java.lang.String)

Exceptions
Type	Description
SQLException

prepareCall(String sql, int resultSetType, int resultSetConcurrency)

public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency)

Parameters
Name	Description
sql	String
resultSetType	int
resultSetConcurrency	int

Returns
Type	Description
CallableStatement

Overrides

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.prepareCall(java.lang.String,int,int)

Exceptions
Type	Description
SQLException

prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)

public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)

Parameters
Name	Description
sql	String
resultSetType	int
resultSetConcurrency	int
resultSetHoldability	int

Returns
Type	Description
CallableStatement

Overrides

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.prepareCall(java.lang.String,int,int,int)

Exceptions
Type	Description
SQLException

prepareStatement(String sql)

public PreparedStatement prepareStatement(String sql)

Parameter
Name	Description
sql	String

Returns
Type	Description
PreparedStatement

Exceptions
Type	Description
SQLException

prepareStatement(String sql, int autoGeneratedKeys)

public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys)

Parameters
Name	Description
sql	String
autoGeneratedKeys	int

Returns
Type	Description
PreparedStatement

Overrides

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.prepareStatement(java.lang.String,int)

Exceptions
Type	Description
SQLException

prepareStatement(String sql, int resultSetType, int resultSetConcurrency)

public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency)

Parameters
Name	Description
sql	String
resultSetType	int
resultSetConcurrency	int

Returns
Type	Description
PreparedStatement

Exceptions
Type	Description
SQLException

prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)

public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)

Parameters
Name	Description
sql	String
resultSetType	int
resultSetConcurrency	int
resultSetHoldability	int

Returns
Type	Description
PreparedStatement

Exceptions
Type	Description
SQLException

prepareStatement(String sql, int[] columnIndexes)

public PreparedStatement prepareStatement(String sql, int[] columnIndexes)

Parameters
Name	Description
sql	String
columnIndexes	int[]

Returns
Type	Description
PreparedStatement

Overrides

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.prepareStatement(java.lang.String,int[])

Exceptions
Type	Description
SQLException

rollback()

public void rollback()

Exceptions
Type	Description
SQLException

setAutoCommit(boolean autoCommit)

public void setAutoCommit(boolean autoCommit)

Parameter
Name	Description
autoCommit	boolean

Exceptions
Type	Description
SQLException

setClientInfo(String name, String value)

public void setClientInfo(String name, String value)

Parameters
Name	Description
name	String
value	String

Overrides

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.setClientInfo(java.lang.String,java.lang.String)

setClientInfo(Properties properties)

public void setClientInfo(Properties properties)

Parameter
Name	Description
properties	Properties

Overrides

com.google.cloud.bigquery.jdbc.BigQueryNoOpsConnection.setClientInfo(java.util.Properties)

setHoldability(int holdability)

public void setHoldability(int holdability)

Parameter
Name	Description
holdability	int

Exceptions
Type	Description
SQLException

setTransactionIsolation(int level)

public void setTransactionIsolation(int level)

Parameter
Name	Description
level	int

Exceptions
Type	Description
SQLException