mysql

package

v1.0.0 Latest Latest Go to latest Published: Dec 17, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pingcap/tipocket

Links

Open Source Insights

Documentation ¶

Index ¶

func IsErrDupEntry(err error) bool
func RunWithRetry(ctx context.Context, retryCnt int, interval time.Duration, f func() error) error
type DBAccessor
type DBConnect
- func OpenDB(dsn string, maxIdleConns int) (*DBConnect, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func IsErrDupEntry ¶

func IsErrDupEntry(err error) bool

IsErrDupEntry returns true if error code = 1062

func RunWithRetry ¶

func RunWithRetry(ctx context.Context, retryCnt int, interval time.Duration, f func() error) error

RunWithRetry tries to run func in specified count

Types ¶

type DBAccessor ¶

type DBAccessor interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
}

DBAccessor can be txn snapshot or db it self

type DBConnect ¶

type DBConnect struct {
	sync.Mutex
	// contains filtered or unexported fields
}

DBConnect wraps db

func OpenDB ¶

func OpenDB(dsn string, maxIdleConns int) (*DBConnect, error)

OpenDB opens db

func (*DBConnect) Begin ¶

func (conn *DBConnect) Begin() error

Begin a transaction

func (*DBConnect) CloseDB ¶

func (conn *DBConnect) CloseDB() error

CloseDB turn off db connection

func (*DBConnect) Commit ¶

func (conn *DBConnect) Commit() error

Commit a transaction

func (*DBConnect) Exec ¶

func (conn *DBConnect) Exec(query string, args ...interface{}) (sql.Result, error)

Exec execute sql

func (*DBConnect) GetBeginTime ¶

func (conn *DBConnect) GetBeginTime() time.Time

GetBeginTime get the begin time of a transaction if not in transaction, return 0

func (*DBConnect) GetDB ¶

func (conn *DBConnect) GetDB() *sql.DB

GetDB get real db object

func (*DBConnect) GetDBAccessor ¶

func (conn *DBConnect) GetDBAccessor() DBAccessor

GetDBAccessor get DBAccessor interface

func (*DBConnect) GetTiDBTS ¶

func (conn *DBConnect) GetTiDBTS() (uint64, error)

GetTiDBTS get the txn begin timestamp from TiDB

func (*DBConnect) IfTxn ¶

func (conn *DBConnect) IfTxn() bool

IfTxn show if in a transaction

func (*DBConnect) MustExec ¶

func (conn *DBConnect) MustExec(query string, args ...interface{}) sql.Result

MustExec must execute sql or fatal

func (*DBConnect) Query ¶

func (conn *DBConnect) Query(query string, args ...interface{}) (*sql.Rows, error)

Query execute select statement

func (*DBConnect) ReConnect ¶

func (conn *DBConnect) ReConnect() error

ReConnect rebuild connection

func (*DBConnect) Rollback ¶

func (conn *DBConnect) Rollback() error

Rollback a transaction

Source Files ¶

View all Source files

mysql.go

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