sqlite

package
v1.4.2-prerelease09 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 14, 2026 License: Apache-2.0 Imports: 26 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	PluginName = "sqlite"
)

Variables

This section is empty.

Functions

func GetTestClusterOption added in v1.3.0 

func GetTestClusterOption() *pt.TestBaseOptions

GetTestClusterOption returns a test cluster option for sqlite plugin It uses a temporary directory for the database name

Types

type DB 

type DB struct {
	*mysql.DB
	// contains filtered or unexported fields
}

DB contains methods for managing objects in a sqlite database It inherits methods from the mysql.DB to reuse the implementation of the methods sqlplugin.ErrorChecker is customized for sqlite

func NewDB 

func NewDB(driver sqldriver.Driver, numDBShards int, dataConverter mysql.DataConverter, dsn string) (*DB, error)

NewDB returns an instance of DB, which contains a new created mysql.DB with sqlite specific methods

func (*DB) BeginTx added in v1.3.0 

func (mdb *DB) BeginTx(ctx context.Context, dbShardID int) (sqlplugin.Tx, error)

BeginTx starts a new transaction and returns a new Tx

func (*DB) Close added in v1.3.1 

func (mdb *DB) Close() error

func (*DB) CreateDatabase added in v1.2.18 

func (mdb *DB) CreateDatabase(_ string) error

CreateDatabase is not supported by sqlite each sqlite file is a database

func (*DB) DatabaseExists 

func (mdb *DB) DatabaseExists(_ string) (bool, error)

DatabaseExists is not supported by sqlite each sqlite file is a database

func (*DB) DeleteFromActiveClusterSelectionPolicy added in v1.4.1 

func (mdb *DB) DeleteFromActiveClusterSelectionPolicy(ctx context.Context, filter *sqlplugin.ActiveClusterSelectionPolicyFilter) (sql.Result, error)

func (*DB) DeleteFromHistoryNode added in v1.3.0 

func (mdb *DB) DeleteFromHistoryNode(ctx context.Context, filter *sqlplugin.HistoryNodeFilter) (sql.Result, error)

DeleteFromHistoryNode deletes one or more rows from history_node table

func (*DB) DeleteFromTasks added in v1.3.0 

func (mdb *DB) DeleteFromTasks(ctx context.Context, filter *sqlplugin.TasksFilter) (sql.Result, error)

DeleteFromTasks deletes one or more rows from tasks table

func (*DB) DropDatabase added in v1.2.18 

func (mdb *DB) DropDatabase(_ string) error

DropDatabase is not supported by sqlite each sqlite file is a database

func (*DB) GetAckLevels added in v1.3.0 

func (mdb *DB) GetAckLevels(
	ctx context.Context,
	queueType persistence.QueueType,
	forUpdate bool,
) (map[string]int64, error)

GetAckLevels returns ack levels for pulling clusters

func (*DB) GetLastEnqueuedMessageIDForUpdate added in v1.3.0 

func (mdb *DB) GetLastEnqueuedMessageIDForUpdate(
	ctx context.Context,
	queueType persistence.QueueType,
) (int64, error)

GetLastEnqueuedMessageIDForUpdate returns the last enqueued message ID

func (*DB) HasSchemaVersionTables 

func (mdb *DB) HasSchemaVersionTables() (bool, error)

HasSchemaVersionTables checks if schema metadata tables exist.

func (*DB) InsertIntoActiveClusterSelectionPolicy added in v1.4.1 

func (mdb *DB) InsertIntoActiveClusterSelectionPolicy(ctx context.Context, row *sqlplugin.ActiveClusterSelectionPolicyRow) (sql.Result, error)

func (*DB) InsertIntoSignalsRequestedSets added in v1.3.0 

func (mdb *DB) InsertIntoSignalsRequestedSets(ctx context.Context, rows []sqlplugin.SignalsRequestedSetsRow) (sql.Result, error)

InsertIntoSignalsRequestedSets inserts one or more rows into signals_requested_sets table

func (*DB) InsertIntoVisibility added in v1.3.0 

func (mdb *DB) InsertIntoVisibility(ctx context.Context, row *sqlplugin.VisibilityRow) (sql.Result, error)

InsertIntoVisibility inserts a row into visibility table. If an row already exist, its left as such and no update will be made

func (*DB) IsDupEntryError 

func (mdb *DB) IsDupEntryError(err error) bool

IsDupEntryError verify if the error is a duplicate entry error

func (*DB) IsNotFoundError 

func (mdb *DB) IsNotFoundError(err error) bool

IsNotFoundError verify if the error is a not found error

func (*DB) IsThrottlingError 

func (mdb *DB) IsThrottlingError(_ error) bool

IsThrottlingError verify if the error is a throttling error

func (*DB) IsTimeoutError 

func (mdb *DB) IsTimeoutError(err error) bool

IsTimeoutError verify if the error is a timeout error

func (*DB) ListTables added in v1.3.1 

func (mdb *DB) ListTables(_ string) ([]string, error)

ListTables returns a list of tables in this database

func (*DB) LockCurrentExecutions added in v1.3.0 

func (mdb *DB) LockCurrentExecutions(ctx context.Context, filter *sqlplugin.CurrentExecutionsFilter) (*sqlplugin.CurrentExecutionsRow, error)

LockCurrentExecutions acquires a write lock on a single row in current_executions table

func (*DB) LockCurrentExecutionsJoinExecutions added in v1.3.0 

func (mdb *DB) LockCurrentExecutionsJoinExecutions(ctx context.Context, filter *sqlplugin.CurrentExecutionsFilter) ([]sqlplugin.CurrentExecutionsRow, error)

LockCurrentExecutionsJoinExecutions joins a row in current_executions with executions table and acquires a write lock on the result

func (*DB) LockDomainMetadata added in v1.3.0 

func (mdb *DB) LockDomainMetadata(ctx context.Context) error

LockDomainMetadata acquires a write lock on a single row in domain_metadata table

func (*DB) LockTaskLists added in v1.3.0 

func (mdb *DB) LockTaskLists(ctx context.Context, filter *sqlplugin.TaskListsFilter) (int64, error)

LockTaskLists locks a row in task_lists table

func (*DB) PluginName 

func (mdb *DB) PluginName() string

PluginName returns the name of the plugin

func (*DB) RangeDeleteFromReplicationTasks added in v1.3.0 

func (mdb *DB) RangeDeleteFromReplicationTasks(ctx context.Context, filter *sqlplugin.ReplicationTasksFilter) (sql.Result, error)

RangeDeleteFromReplicationTasks deletes multi rows from replication_tasks table

func (*DB) RangeDeleteFromTimerTasks added in v1.3.0 

func (mdb *DB) RangeDeleteFromTimerTasks(ctx context.Context, filter *sqlplugin.TimerTasksFilter) (sql.Result, error)

RangeDeleteFromTimerTasks deletes multi rows from timer_tasks table

func (*DB) RangeDeleteFromTransferTasks added in v1.3.0 

func (mdb *DB) RangeDeleteFromTransferTasks(ctx context.Context, filter *sqlplugin.TransferTasksFilter) (sql.Result, error)

RangeDeleteFromTransferTasks deletes multi rows from transfer_tasks table

func (*DB) ReadLockExecutions added in v1.3.0 

func (mdb *DB) ReadLockExecutions(ctx context.Context, filter *sqlplugin.ExecutionsFilter) (int, error)

ReadLockExecutions acquires a write lock on a single row in executions table

func (*DB) ReadLockShards added in v1.3.0 

func (mdb *DB) ReadLockShards(ctx context.Context, filter *sqlplugin.ShardsFilter) (int, error)

ReadLockShards acquires a read lock on a single row in shards table

func (*DB) SelectFromActiveClusterSelectionPolicy added in v1.4.1 

func (mdb *DB) SelectFromActiveClusterSelectionPolicy(ctx context.Context, filter *sqlplugin.ActiveClusterSelectionPolicyFilter) (*sqlplugin.ActiveClusterSelectionPolicyRow, error)

func (*DB) WriteLockExecutions added in v1.3.0 

func (mdb *DB) WriteLockExecutions(ctx context.Context, filter *sqlplugin.ExecutionsFilter) (int, error)

WriteLockExecutions acquires a write lock on a single row in executions table

func (*DB) WriteLockShards added in v1.3.0 

func (mdb *DB) WriteLockShards(ctx context.Context, filter *sqlplugin.ShardsFilter) (int, error)

WriteLockShards acquires a write lock on a single row in shards table

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.