nl.topicus.jdbc.transaction

Class CloudSpannerTransaction

java.lang.Object

nl.topicus.jdbc.transaction.CloudSpannerTransaction

All Implemented Interfaces:

com.google.cloud.spanner.BatchReadOnlyTransaction, com.google.cloud.spanner.ReadContext, com.google.cloud.spanner.ReadOnlyTransaction, com.google.cloud.spanner.TransactionContext, AutoCloseable

public class CloudSpannerTransaction
extends Object
implements com.google.cloud.spanner.TransactionContext, com.google.cloud.spanner.BatchReadOnlyTransaction

An abstraction of transactions on Google Cloud Spanner JDBC connections.

Author:

loite

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CloudSpannerTransaction.TransactionException

Nested classes/interfaces inherited from interface com.google.cloud.spanner.ReadContext

com.google.cloud.spanner.ReadContext.QueryAnalyzeMode

Constructor Summary

Constructors

Constructor and Description
CloudSpannerTransaction(com.google.cloud.spanner.DatabaseClient dbClient, com.google.cloud.spanner.BatchClient batchClient, CloudSpannerConnection connection)

Method Summary

Modifier and Type	Method and Description
com.google.cloud.spanner.ResultSet	analyzeQuery(com.google.cloud.spanner.Statement statement, com.google.cloud.spanner.ReadContext.QueryAnalyzeMode queryMode)
void	begin()
void	buffer(Iterable<com.google.cloud.spanner.Mutation> mutations)
void	buffer(com.google.cloud.spanner.Mutation mutation)
void	close() Close method is needed for the interface, but does not do anything
com.google.cloud.Timestamp	commit()
void	commitPreparedTransaction(String xid)
com.google.cloud.spanner.ResultSet	execute(com.google.cloud.spanner.Partition partition)
com.google.cloud.spanner.ResultSet	executeQuery(com.google.cloud.spanner.Statement statement, com.google.cloud.spanner.Options.QueryOption... options)
com.google.cloud.spanner.BatchReadOnlyTransaction	getBatchReadOnlyTransaction()
com.google.cloud.spanner.BatchTransactionId	getBatchTransactionId()
int	getNumberOfBufferedMutations()
com.google.cloud.Timestamp	getReadTimestamp()
boolean	hasBufferedMutations()
boolean	isRunning()
List<com.google.cloud.spanner.Partition>	partitionQuery(com.google.cloud.spanner.PartitionOptions partitionOptions, com.google.cloud.spanner.Statement statement, com.google.cloud.spanner.Options.QueryOption... options)
List<com.google.cloud.spanner.Partition>	partitionRead(com.google.cloud.spanner.PartitionOptions partitionOptions, String table, com.google.cloud.spanner.KeySet keys, Iterable<String> columns, com.google.cloud.spanner.Options.ReadOption... options)
List<com.google.cloud.spanner.Partition>	partitionReadUsingIndex(com.google.cloud.spanner.PartitionOptions partitionOptions, String table, String index, com.google.cloud.spanner.KeySet keys, Iterable<String> columns, com.google.cloud.spanner.Options.ReadOption... options)
void	prepareTransaction(String xid)
com.google.cloud.spanner.ResultSet	read(String table, com.google.cloud.spanner.KeySet keys, Iterable<String> columns, com.google.cloud.spanner.Options.ReadOption... options)
com.google.cloud.spanner.Struct	readRow(String table, com.google.cloud.spanner.Key key, Iterable<String> columns)
com.google.cloud.spanner.Struct	readRowUsingIndex(String table, String index, com.google.cloud.spanner.Key key, Iterable<String> columns)
com.google.cloud.spanner.ResultSet	readUsingIndex(String table, String index, com.google.cloud.spanner.KeySet keys, Iterable<String> columns, com.google.cloud.spanner.Options.ReadOption... options)
void	releaseSavepoint(Savepoint savepoint)
void	rollback()
void	rollbackPreparedTransaction(String xid)
void	rollbackSavepoint(Savepoint savepoint)
void	setSavepoint(Savepoint savepoint)

Methods inherited from class java.lang.Object

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

Constructor Detail

CloudSpannerTransaction

public CloudSpannerTransaction(com.google.cloud.spanner.DatabaseClient dbClient,
                               com.google.cloud.spanner.BatchClient batchClient,
                               CloudSpannerConnection connection)

Method Detail

isRunning

public boolean isRunning()

hasBufferedMutations

public boolean hasBufferedMutations()

getNumberOfBufferedMutations

public int getNumberOfBufferedMutations()

begin

public void begin()
           throws SQLException

Throws:

SQLException

commit

public com.google.cloud.Timestamp commit()
                                  throws SQLException

Throws:

SQLException

rollback

public void rollback()
              throws SQLException

Throws:

SQLException

setSavepoint

public void setSavepoint(Savepoint savepoint)
                  throws SQLException

Throws:

SQLException

rollbackSavepoint

public void rollbackSavepoint(Savepoint savepoint)
                       throws SQLException

Throws:

SQLException

releaseSavepoint

public void releaseSavepoint(Savepoint savepoint)
                      throws SQLException

Throws:

SQLException

prepareTransaction

public void prepareTransaction(String xid)
                        throws SQLException

Throws:

SQLException

commitPreparedTransaction

public void commitPreparedTransaction(String xid)
                               throws SQLException

Throws:

SQLException

rollbackPreparedTransaction

public void rollbackPreparedTransaction(String xid)
                                 throws SQLException

Throws:

SQLException

buffer

public void buffer(com.google.cloud.spanner.Mutation mutation)

Specified by:

buffer in interface com.google.cloud.spanner.TransactionContext

buffer

public void buffer(Iterable<com.google.cloud.spanner.Mutation> mutations)

Specified by:

buffer in interface com.google.cloud.spanner.TransactionContext

executeQuery

public com.google.cloud.spanner.ResultSet executeQuery(com.google.cloud.spanner.Statement statement,
                                                       com.google.cloud.spanner.Options.QueryOption... options)

Specified by:

executeQuery in interface com.google.cloud.spanner.ReadContext

read

public com.google.cloud.spanner.ResultSet read(String table,
                                               com.google.cloud.spanner.KeySet keys,
                                               Iterable<String> columns,
                                               com.google.cloud.spanner.Options.ReadOption... options)

Specified by:

read in interface com.google.cloud.spanner.ReadContext

readUsingIndex

public com.google.cloud.spanner.ResultSet readUsingIndex(String table,
                                                         String index,
                                                         com.google.cloud.spanner.KeySet keys,
                                                         Iterable<String> columns,
                                                         com.google.cloud.spanner.Options.ReadOption... options)

Specified by:

readUsingIndex in interface com.google.cloud.spanner.ReadContext

readRow

public com.google.cloud.spanner.Struct readRow(String table,
                                               com.google.cloud.spanner.Key key,
                                               Iterable<String> columns)

Specified by:

readRow in interface com.google.cloud.spanner.ReadContext

readRowUsingIndex

public com.google.cloud.spanner.Struct readRowUsingIndex(String table,
                                                         String index,
                                                         com.google.cloud.spanner.Key key,
                                                         Iterable<String> columns)

Specified by:

readRowUsingIndex in interface com.google.cloud.spanner.ReadContext

analyzeQuery

public com.google.cloud.spanner.ResultSet analyzeQuery(com.google.cloud.spanner.Statement statement,
                                                       com.google.cloud.spanner.ReadContext.QueryAnalyzeMode queryMode)

Specified by:

analyzeQuery in interface com.google.cloud.spanner.ReadContext

close

public void close()

Close method is needed for the interface, but does not do anything

Specified by:

close in interface com.google.cloud.spanner.ReadContext

Specified by:

close in interface AutoCloseable

getReadTimestamp

public com.google.cloud.Timestamp getReadTimestamp()

Specified by:

getReadTimestamp in interface com.google.cloud.spanner.ReadOnlyTransaction

partitionRead

public List<com.google.cloud.spanner.Partition> partitionRead(com.google.cloud.spanner.PartitionOptions partitionOptions,
                                                              String table,
                                                              com.google.cloud.spanner.KeySet keys,
                                                              Iterable<String> columns,
                                                              com.google.cloud.spanner.Options.ReadOption... options)
                                                       throws com.google.cloud.spanner.SpannerException

Specified by:

partitionRead in interface com.google.cloud.spanner.BatchReadOnlyTransaction

Throws:

com.google.cloud.spanner.SpannerException

partitionReadUsingIndex

public List<com.google.cloud.spanner.Partition> partitionReadUsingIndex(com.google.cloud.spanner.PartitionOptions partitionOptions,
                                                                        String table,
                                                                        String index,
                                                                        com.google.cloud.spanner.KeySet keys,
                                                                        Iterable<String> columns,
                                                                        com.google.cloud.spanner.Options.ReadOption... options)
                                                                 throws com.google.cloud.spanner.SpannerException

Specified by:

partitionReadUsingIndex in interface com.google.cloud.spanner.BatchReadOnlyTransaction

Throws:

com.google.cloud.spanner.SpannerException

partitionQuery

public List<com.google.cloud.spanner.Partition> partitionQuery(com.google.cloud.spanner.PartitionOptions partitionOptions,
                                                               com.google.cloud.spanner.Statement statement,
                                                               com.google.cloud.spanner.Options.QueryOption... options)
                                                        throws com.google.cloud.spanner.SpannerException

Specified by:

partitionQuery in interface com.google.cloud.spanner.BatchReadOnlyTransaction

Throws:

com.google.cloud.spanner.SpannerException

execute

public com.google.cloud.spanner.ResultSet execute(com.google.cloud.spanner.Partition partition)
                                           throws com.google.cloud.spanner.SpannerException

Specified by:

execute in interface com.google.cloud.spanner.BatchReadOnlyTransaction

Throws:

com.google.cloud.spanner.SpannerException

getBatchTransactionId

public com.google.cloud.spanner.BatchTransactionId getBatchTransactionId()

Specified by:

getBatchTransactionId in interface com.google.cloud.spanner.BatchReadOnlyTransaction

getBatchReadOnlyTransaction

public com.google.cloud.spanner.BatchReadOnlyTransaction getBatchReadOnlyTransaction()