sqlite

Documentation

Index

• Constants
• type DB
  • func NewDB(xdbs []*sqlx.DB, tx *sqlx.Tx, dbShardID int, numDBShards int) (*DB, error)
  • func (mdb *DB) BeginTX(ctx context.Context, dbShardID int) (sqlplugin.Tx, error)
  • func (mdb *DB) IsDupEntryError(err error) bool
  • func (mdb *DB) IsNotFoundError(err error) bool
  • func (mdb *DB) IsThrottlingError(err error) bool
  • func (mdb *DB) IsTimeoutError(err error) bool
  • func (mdb *DB) PluginName() string

Constants

const (
	PluginName = "sqlite"
)

Types

type DB

type DB struct {
	*mysql.DB
}

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(xdbs []*sqlx.DB, tx *sqlx.Tx, dbShardID int, numDBShards int) (*DB, error)

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

func (*DB) BeginTX

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

BeginTX starts a new transaction and returns a new Tx

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(err 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) PluginName

func (mdb *DB) PluginName() string

PluginName returns the name of the plugin