spannerdriver

Mar 28, 2025

Changes in this version

type ConnectorConfig

+ IsolationLevel sql.IsolationLevel

type SpannerConn

+ IsolationLevel func() sql.IsolationLevel

+ SetIsolationLevel func(level sql.IsolationLevel) error

Mar 18, 2025

Changes in this version

type AutocommitDMLMode

+ const Unspecified

type ConnectorConfig

+ AutoConfigEmulator bool

type ExecOptions

+ AutocommitDMLMode AutocommitDMLMode

Feb 10, 2025

Changes in this version

+ func BeginBatchReadOnlyTransaction(ctx context.Context, db *sql.DB, options BatchReadOnlyTransactionOptions) (*sql.Tx, error)

+ func WithBatchReadOnly(level sql.IsolationLevel) sql.IsolationLevel

+ type BatchReadOnlyTransactionOptions struct

+ TimestampBound spanner.TimestampBound

type ConnectorConfig

+ AutoBatchDml bool

+ AutoBatchDmlUpdateCount int64

+ DecodeToNativeArrays bool

+ DisableAutoBatchDmlUpdateCountVerification bool

type ExecOptions

+ DecodeToNativeArrays bool

+ PartitionedQueryOptions PartitionedQueryOptions

+ type ExecutePartition struct

+ Index int

+ PartitionedQuery *PartitionedQuery

+ type PartitionedQuery struct

+ Partitions []*spanner.Partition

+ func (pq *PartitionedQuery) Close()

+ func (pq *PartitionedQuery) Execute(ctx context.Context, index int, db *sql.DB) (*sql.Rows, error)

+ func (pq *PartitionedQuery) Scan(value any) error

+ type PartitionedQueryOptions struct

+ AutoPartitionQuery bool

+ ExecutePartition ExecutePartition

+ MaxParallelism int

+ PartitionOptions spanner.PartitionOptions

+ PartitionQuery bool

type SpannerConn

+ AutoBatchDml func() bool

+ AutoBatchDmlUpdateCount func() int64

+ AutoBatchDmlUpdateCountVerification func() bool

+ DecodeToNativeArrays func() bool

+ SetAutoBatchDml func(autoBatch bool) error

+ SetAutoBatchDmlUpdateCount func(updateCount int64) error

+ SetAutoBatchDmlUpdateCountVerification func(verify bool) error

+ SetDecodeToNativeArrays func(decodeToNativeArrays bool) error

Jan 27, 2025

Changes in this version

+ const LevelNotice

+ func BeginReadOnlyTransaction(ctx context.Context, db *sql.DB, options ReadOnlyTransactionOptions) (*sql.Tx, error)

+ func BeginReadWriteTransaction(ctx context.Context, db *sql.DB, options ReadWriteTransactionOptions) (*sql.Tx, error)

+ func CreateConnector(config ConnectorConfig) (driver.Connector, error)

+ func RunTransactionWithOptions(ctx context.Context, db *sql.DB, opts *sql.TxOptions, ...) error

+ type ConnectorConfig struct

+ Configurator func(config *spanner.ClientConfig, opts *[]option.ClientOption)

+ Database string

+ Host string

+ Instance string

+ Params map[string]string

+ Project string

+ func ExtractConnectorConfig(dsn string) (ConnectorConfig, error)

+ func (cc *ConnectorConfig) String() string

+ type DecodeOption int

+ const DecodeOptionNormal

+ const DecodeOptionProto

+ type ExecOptions struct

+ DecodeOption DecodeOption

+ QueryOptions spanner.QueryOptions

+ TransactionOptions spanner.TransactionOptions

+ type ReadOnlyTransactionOptions struct

+ TimestampBound spanner.TimestampBound

+ type ReadWriteTransactionOptions struct

+ DisableInternalRetries bool

+ TransactionOptions spanner.TransactionOptions

type SpannerConn

+ MaxCommitDelay func() time.Duration

+ SetMaxCommitDelay func(delay time.Duration) error

+ SetTransactionTag func(transactionTag string) error

+ TransactionTag func() string

Nov 22, 2024

Changes in this version

+ func WithDisableRetryAborts(level sql.IsolationLevel) sql.IsolationLevel

Nov 14, 2024

Changes in this version

+ func RunTransaction(ctx context.Context, db *sql.DB, opts *sql.TxOptions, ...) error

type SpannerConn

+ GetBatchedStatements func() []spanner.Statement

+ UnderlyingClient func() (client *spanner.Client, err error)

May 30, 2024

Changes in this version

type SpannerConn

+ ExcludeTxnFromChangeStreams func() bool

+ SetExcludeTxnFromChangeStreams func(excludeTxnFromChangeStreams bool) error

Sep 15, 2022

Changes in this version

+ var ErrAbortedDueToConcurrentModification = status.Error(codes.Aborted, "Transaction was aborted due to a concurrent modification")

+ type AutocommitDMLMode int

+ const PartitionedNonAtomic

+ const Transactional

+ func (mode AutocommitDMLMode) String() string

+ type Driver struct

+ func (d *Driver) Open(name string) (driver.Conn, error)

+ func (d *Driver) OpenConnector(name string) (driver.Connector, error)

+ type SpannerConn interface

+ AbortBatch func() error

+ Apply func(ctx context.Context, ms []*spanner.Mutation, opts ...spanner.ApplyOption) (commitTimestamp time.Time, err error)

+ AutocommitDMLMode func() AutocommitDMLMode

+ BufferWrite func(ms []*spanner.Mutation) error

+ CommitTimestamp func() (commitTimestamp time.Time, err error)

+ InDDLBatch func() bool

+ InDMLBatch func() bool

+ ReadOnlyStaleness func() spanner.TimestampBound

+ RetryAbortsInternally func() bool

+ RunBatch func(ctx context.Context) error

+ SetAutocommitDMLMode func(mode AutocommitDMLMode) error

+ SetReadOnlyStaleness func(staleness spanner.TimestampBound) error

+ SetRetryAbortsInternally func(retry bool) error

+ StartBatchDDL func() error

+ StartBatchDML func() error