nl.topicus.jdbc

Class CloudSpannerConnection

java.lang.Object

nl.topicus.jdbc.metadata.AbstractCloudSpannerWrapper

nl.topicus.jdbc.AbstractCloudSpannerConnection

nl.topicus.jdbc.CloudSpannerConnection

All Implemented Interfaces:

AutoCloseable, Connection, Wrapper

public class CloudSpannerConnection
extends AbstractCloudSpannerConnection

JDBC Driver for Google Cloud Spanner.

Author:

loite

Field Summary

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Method Summary

Modifier and Type	Method and Description
void	close()
void	commit()
Array	createArrayOf(String typeName, Object[] elements)
CloudSpannerStatement	createStatement()
Statement	createStatement(int resultSetType, int resultSetConcurrency)
Statement	createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
Void	executeDDL(String sql)
boolean	getAutoCommit()
String	getClientId()
static com.google.auth.oauth2.GoogleCredentials	getCredentialsFromFile(String credentialsPath)
static com.google.auth.oauth2.GoogleCredentials	getCredentialsFromOAuthToken(String oauthToken)
com.google.cloud.Timestamp	getLastCommitTimestamp()
DatabaseMetaData	getMetaData()
static String	getServiceAccountProjectId(String credentialsPath)
Properties	getSuppliedProperties()
MetaDataStore.TableKeyMetaData	getTable(String name)
CloudSpannerTransaction	getTransaction()
int	getTransactionIsolation()
String	getUrl()
boolean	isAllowExtendedMode()
boolean	isClosed()
boolean	isReadOnly()
boolean	isValid(int timeout)
String	nativeSQL(String sql)
CallableStatement	prepareCall(String sql)
CloudSpannerPreparedStatement	prepareStatement(String sql)
PreparedStatement	prepareStatement(String sql, int autoGeneratedKeys)
PreparedStatement	prepareStatement(String sql, int[] columnIndexes)
PreparedStatement	prepareStatement(String sql, int resultSetType, int resultSetConcurrency)
PreparedStatement	prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
PreparedStatement	prepareStatement(String sql, String[] columnNames)
void	rollback()
void	setAutoCommit(boolean autoCommit)
void	setReadOnly(boolean readOnly)
void	setSimulateProductName(String productName)
void	setTransactionIsolation(int level)

Methods inherited from class nl.topicus.jdbc.AbstractCloudSpannerConnection

abort, clearWarnings, createBlob, createClob, createNClob, createSQLXML, createStruct, getCatalog, getClientInfo, getClientInfo, getHoldability, getNetworkTimeout, getSchema, getTypeMap, getWarnings, prepareCall, prepareCall, releaseSavepoint, rollback, setCatalog, setClientInfo, setClientInfo, setHoldability, setNetworkTimeout, setSavepoint, setSavepoint, setSchema, setTypeMap

Methods inherited from class nl.topicus.jdbc.metadata.AbstractCloudSpannerWrapper

extractColumnType, getClassName, getGoogleTypeName, isWrapperFor, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Wrapper

isWrapperFor, unwrap

Method Detail

getCredentialsFromOAuthToken

public static com.google.auth.oauth2.GoogleCredentials getCredentialsFromOAuthToken(String oauthToken)

getCredentialsFromFile

public static com.google.auth.oauth2.GoogleCredentials getCredentialsFromFile(String credentialsPath)
                                                                       throws IOException

Throws:

IOException

getServiceAccountProjectId

public static String getServiceAccountProjectId(String credentialsPath)

setSimulateProductName

public void setSimulateProductName(String productName)

executeDDL

public Void executeDDL(String sql)
                throws SQLException

Throws:

SQLException

createStatement

public CloudSpannerStatement createStatement()
                                      throws SQLException

Throws:

SQLException

prepareStatement

public CloudSpannerPreparedStatement prepareStatement(String sql)
                                               throws SQLException

Throws:

SQLException

prepareCall

public CallableStatement prepareCall(String sql)
                              throws SQLException

Throws:

SQLException

nativeSQL

public String nativeSQL(String sql)
                 throws SQLException

Throws:

SQLException

setAutoCommit

public void setAutoCommit(boolean autoCommit)
                   throws SQLException

Throws:

SQLException

getAutoCommit

public boolean getAutoCommit()
                      throws SQLException

Throws:

SQLException

commit

public void commit()
            throws SQLException

Throws:

SQLException

rollback

public void rollback()
              throws SQLException

Throws:

SQLException

getTransaction

public CloudSpannerTransaction getTransaction()

close

public void close()
           throws SQLException

Throws:

SQLException

isClosed

public boolean isClosed()
                 throws SQLException

Throws:

SQLException

getMetaData

public DatabaseMetaData getMetaData()
                             throws SQLException

Throws:

SQLException

setReadOnly

public void setReadOnly(boolean readOnly)
                 throws SQLException

Throws:

SQLException

isReadOnly

public boolean isReadOnly()
                   throws SQLException

Throws:

SQLException

setTransactionIsolation

public void setTransactionIsolation(int level)
                             throws SQLException

Throws:

SQLException

getTransactionIsolation

public int getTransactionIsolation()
                            throws SQLException

Throws:

SQLException

createStatement

public Statement createStatement(int resultSetType,
                                 int resultSetConcurrency)
                          throws SQLException

Throws:

SQLException

prepareStatement

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

Throws:

SQLException

createStatement

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

Throws:

SQLException

prepareStatement

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

Throws:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql,
                                          int autoGeneratedKeys)
                                   throws SQLException

Throws:

SQLException

prepareStatement

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

Throws:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql,
                                          String[] columnNames)
                                   throws SQLException

Throws:

SQLException

getUrl

public String getUrl()

getClientId

public String getClientId()

isValid

public boolean isValid(int timeout)
                throws SQLException

Throws:

SQLException

createArrayOf

public Array createArrayOf(String typeName,
                           Object[] elements)
                    throws SQLException

Throws:

SQLException

getTable

public MetaDataStore.TableKeyMetaData getTable(String name)
                                        throws SQLException

Throws:

SQLException

getSuppliedProperties

public Properties getSuppliedProperties()

isAllowExtendedMode

public boolean isAllowExtendedMode()

getLastCommitTimestamp

public com.google.cloud.Timestamp getLastCommitTimestamp()

Returns:

The commit timestamp of the last transaction that committed succesfully