sql

package

Go to main page

Versions in this module

v1

v1.2.0

May 29, 2023

Changes in this version

type DBResource

+ func (db *DBResource) ConnectionForXA(ctx context.Context, xaXid XAXid) (*XAConn, error)

+ func (db *DBResource) GetDB() *sql.DB

+ func (db *DBResource) GetDBName() string

+ func (db *DBResource) GetDbType() types.DBType

+ func (db *DBResource) GetDbVersion() string

+ func (db *DBResource) GetKeeper() *sync.Map

+ func (db *DBResource) Hold(xaBranchID string, v interface{}) error

+ func (db *DBResource) IsShouldBeHeld() bool

+ func (db *DBResource) Lookup(xaBranchID string) (interface{}, bool)

+ func (db *DBResource) Release(xaBranchID string)

+ func (db *DBResource) SetDbType(dbType types.DBType)

+ func (db *DBResource) SetDbVersion(v string)

+ type Option func(*XABranchXid)

+ func WithBranchId(branchId uint64) Option

+ func WithBranchQualifier(branchQualifier []byte) Option

+ func WithGlobalTransactionId(globalTransactionId []byte) Option

+ func WithXid(xid string) Option

+ type XABranchXid struct

+ func NewXABranchXid(opt ...Option) *XABranchXid

+ func XaIdBuild(xid string, branchId uint64) *XABranchXid

+ func XaIdBuildWithByte(globalTransactionId []byte, branchQualifier []byte) *XABranchXid

+ func (x *XABranchXid) GetBranchId() uint64

+ func (x *XABranchXid) GetBranchQualifier() []byte

+ func (x *XABranchXid) GetGlobalTransactionId() []byte

+ func (x *XABranchXid) GetGlobalXid() string

+ func (x *XABranchXid) String() string

+ type XAConfig struct

+ TwoPhaseHoldTime time.Duration

+ func (cfg *XAConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

type XAConn

+ func (c *XAConn) Close() error

+ func (c *XAConn) CloseForce() error

+ func (c *XAConn) Commit(ctx context.Context) error

+ func (c *XAConn) Rollback(ctx context.Context) error

+ func (c *XAConn) ShouldBeHeld() bool

+ func (c *XAConn) XaCommit(ctx context.Context, xaXid XAXid) error

+ func (c *XAConn) XaRollback(ctx context.Context, xaXid XAXid) error

+ func (c *XAConn) XaRollbackByBranchId(ctx context.Context, xaXid XAXid) error

+ type XAConnConf struct

+ XaBranchExecutionTimeout time.Duration

+ func (cfg *XAConnConf) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

+ type XAResourceManager struct

+ func InitXA(config XAConfig) *XAResourceManager

+ func (xaManager *XAResourceManager) BranchCommit(ctx context.Context, branchResource rm.BranchResource) (branch.BranchStatus, error)

+ func (xaManager *XAResourceManager) BranchRegister(ctx context.Context, req rm.BranchRegisterParam) (int64, error)

+ func (xaManager *XAResourceManager) BranchReport(ctx context.Context, param rm.BranchReportParam) error

+ func (xaManager *XAResourceManager) BranchRollback(ctx context.Context, branchResource rm.BranchResource) (branch.BranchStatus, error)

+ func (xaManager *XAResourceManager) CreateTableMetaCache(ctx context.Context, resID string, dbType types.DBType, db *sql.DB) (datasource.TableMetaCache, error)

+ func (xaManager *XAResourceManager) GetBranchType() branch.BranchType

+ func (xaManager *XAResourceManager) GetCachedResources() *sync.Map

+ func (xaManager *XAResourceManager) LockQuery(ctx context.Context, param rm.LockQueryParam) (bool, error)

+ func (xaManager *XAResourceManager) RegisterResource(res rm.Resource) error

+ func (xaManager *XAResourceManager) UnregisterResource(resource rm.Resource) error

+ type XAXid interface

+ GetBranchId func() uint64

+ GetGlobalXid func() string

+ String func() string

v1.1.0

Mar 7, 2023

Changes in this version

+ var BranchStatusCache = gcache.New(1024).LRU().Expiration(time.Minute * 10).Build()

+ func Init()

+ type BaseDataSourceResource struct

+ Cache map[string]branch.BranchStatus

+ func (b *BaseDataSourceResource) GetBranchStatus(xaBranchXid string) (interface{}, error)

+ func (b *BaseDataSourceResource) GetCache() map[string]branch.BranchStatus

+ func (b *BaseDataSourceResource) GetDB() *DBResource

+ func (b *BaseDataSourceResource) GetDbType() string

+ func (b *BaseDataSourceResource) GetKeeper() map[string]interface{}

+ func (b *BaseDataSourceResource) GetResourceId() string

+ func (b *BaseDataSourceResource) Hold(key string, value Holdable) (interface{}, error)

+ func (b *BaseDataSourceResource) IsShouldBeHeld() bool

+ func (b *BaseDataSourceResource) Release(key string, value Holdable) (interface{}, error)

+ func (b *BaseDataSourceResource) SetCache(cache map[string]branch.BranchStatus)

+ func (b *BaseDataSourceResource) SetDB(db *DBResource)

+ func (b *BaseDataSourceResource) SetDbType(dbType types.DBType)

+ func (b *BaseDataSourceResource) SetKeeper(keeper map[string]interface{})

+ func (b *BaseDataSourceResource) SetShouldBeHeld(shouldBeHeld bool)

type Conn

+ func (c *Conn) GetAutoCommit() bool

+ type Holdable interface

+ IsHeld func() bool

+ SetHeld func(held bool)

+ ShouldBeHeld func() bool

+ type RootContext interface

+ Bind func(xid string)

+ GetTimeout func() (int, bool)

+ GetXID func() string

+ RootContext func()

+ SetDefaultBranchType func(branchType branch.BranchType)

+ SetTimeout func(timeout int)

v1.0.3

Jan 5, 2023

Changes in this version

+ const REPORT_RETRY_COUNT

+ const SeataATMySQLDriver

+ const SeataXAMySQLDriver

+ func CleanTxHooks()

+ func InitAT(cfg undo.Config, asyncCfg AsyncWorkerConfig)

+ func RegisterTxHook(h txHook)

+ type ATConn struct

+ func (c *ATConn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (c *ATConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ func (c *ATConn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (c *ATConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

+ type ATSourceManager struct

+ func (a *ATSourceManager) BranchCommit(ctx context.Context, resource rm.BranchResource) (branch.BranchStatus, error)

+ func (a *ATSourceManager) BranchRegister(ctx context.Context, req rm.BranchRegisterParam) (int64, error)

+ func (a *ATSourceManager) BranchReport(ctx context.Context, param rm.BranchReportParam) error

+ func (a *ATSourceManager) BranchRollback(ctx context.Context, branchResource rm.BranchResource) (branch.BranchStatus, error)

+ func (a *ATSourceManager) CreateTableMetaCache(ctx context.Context, resID string, dbType types.DBType, db *sql.DB) (datasource.TableMetaCache, error)

+ func (a *ATSourceManager) GetBranchType() branch.BranchType

+ func (a *ATSourceManager) GetCachedResources() *sync.Map

+ func (a *ATSourceManager) LockQuery(ctx context.Context, param rm.LockQueryParam) (bool, error)

+ func (a *ATSourceManager) RegisterResource(res rm.Resource) error

+ func (a *ATSourceManager) UnregisterResource(res rm.Resource) error

+ type ATTx struct

+ func (tx *ATTx) Commit() error

+ func (tx *ATTx) Rollback() error

+ type AsyncWorker struct

+ func NewAsyncWorker(prom prometheus.Registerer, conf AsyncWorkerConfig, ...) *AsyncWorker

+ func (aw *AsyncWorker) BranchCommit(ctx context.Context, req rm.BranchResource) (branch.BranchStatus, error)

+ type AsyncWorkerConfig struct

+ BufferCleanInterval time.Duration

+ BufferLimit int

+ CommitWorkerBufferSize int

+ CommitWorkerCount int

+ ReceiveChanSize int

+ func (cfg *AsyncWorkerConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

+ type Conn struct

+ func (c *Conn) Begin() (driver.Tx, error)

+ func (c *Conn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (c *Conn) Close() error

+ func (c *Conn) Exec(query string, args []driver.Value) (driver.Result, error)

+ func (c *Conn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ func (c *Conn) Prepare(query string) (driver.Stmt, error)

+ func (c *Conn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (c *Conn) Query(query string, args []driver.Value) (driver.Rows, error)

+ func (c *Conn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

+ func (c *Conn) ResetSession(ctx context.Context) error

+ type DBResource struct

+ func (db *DBResource) GetBranchType() branch.BranchType

+ func (db *DBResource) GetResourceGroupId() string

+ func (db *DBResource) GetResourceId() string

+ type SqlDBProxy struct

+ func (s *SqlDBProxy) GetDB() *sql.DB

+ func (s *SqlDBProxy) GetDBName() string

+ type Stmt struct

+ func (s *Stmt) Close() error

+ func (s *Stmt) Exec(args []driver.Value) (driver.Result, error)

+ func (s *Stmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *Stmt) NumInput() int

+ func (s *Stmt) Query(args []driver.Value) (driver.Rows, error)

+ func (s *Stmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)

+ type Tx struct

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Rollback() error

+ type XAConn struct

+ func (c *XAConn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (c *XAConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ func (c *XAConn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (c *XAConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

+ type XATx struct

+ func (tx *XATx) Commit() error

+ func (tx *XATx) Rollback() error

v1.0.2-rc3

Jan 3, 2023

v1.0.2-rc2

Dec 3, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL