pgsql

Documentation

Index

• Constants
• func FromParameters(parameters map[string]interface{}) (storage.Driver, error)
• func New(params DriverParameters) (storage.Driver, error)
• type DriverParameters

Constants

const (
	InsertGlobalTransaction = `` /* 208-byte string literal not displayed */

	QueryGlobalTransactionByXid = `` /* 144-byte string literal not displayed */

	UpdateGlobalTransaction = "update %s set status = $1, gmt_modified = CURRENT_TIMESTAMP where xid = $2"

	InactiveGlobalTransaction = "update %s set active = 0, gmt_modified = CURRENT_TIMESTAMP where xid = $1"

	DeleteGlobalTransaction = "delete from %s where xid = $1"

	InsertBranchTransaction = `` /* 236-byte string literal not displayed */

	QueryBranchTransaction = `` /* 183-byte string literal not displayed */

	QueryBranchTransactionByXid = `` /* 189-byte string literal not displayed */

	UpdateBranchTransaction = "update %s set status = $1, gmt_modified = CURRENT_TIMESTAMP where xid = $2 and branch_id = $3"

	DeleteBranchTransaction = "delete from %s where xid = $1 and branch_id = $2"

	InsertRowLock = `insert into %s (xid, transaction_id, branch_id, resource_id, table_name, pk, row_key, gmt_create,
		gmt_modified) values %s`

	QueryRowKey = `` /* 144-byte string literal not displayed */

)

Functions

func FromParameters

func FromParameters(parameters map[string]interface{}) (storage.Driver, error)

func New

func New(params DriverParameters) (storage.Driver, error)

New constructs a new Driver

Types

type DriverParameters

type DriverParameters struct {
	DSN                string
	GlobalTable        string
	BranchTable        string
	LockTable          string
	QueryLimit         int
	MaxOpenConnections int
	MaxIdleConnections int
	MaxLifeTime        time.Duration
}