sql

Documentation

Index

• Variables
• type Config
• type MySQL
  • func NewMySQL(db *sql.DB, bizTag string, step int) (mysql *MySQL, cf func(), err error)
  • func (m *MySQL) GetEndID(ctx context.Context) (startID uint64, endID uint64, step int, err error)
  • func (m *MySQL) InitBizTag(ctx context.Context, bizTag string, maxID uint64, step int, description string) error

Variables

var RowsNotAffectedErr = fmt.Errorf("rows not affected")

Types

type Config

type Config struct {
	DSN    string // write data source name.
	BizTag string
}

Config sql config.

type MySQL

type MySQL struct {
	// contains filtered or unexported fields
}

func NewMySQL

func NewMySQL(db *sql.DB, bizTag string, step int) (mysql *MySQL, cf func(), err error)

NewMySQL new db and retry connection when has error.

func (*MySQL) GetEndID

func (m *MySQL) GetEndID(ctx context.Context) (startID uint64, endID uint64, step int, err error)

func (*MySQL) InitBizTag

func (m *MySQL) InitBizTag(ctx context.Context, bizTag string, maxID uint64, step int, description string) error