autoincrement

Documentation

Index

• func GetAutoIncrement(node *sqlparser.DDL) (*config.AutoIncrement, error)
• type AutoIncrement
  • func (autoinc *AutoIncrement) Close() error
  • func (autoinc *AutoIncrement) Init() error
  • func (autoinc *AutoIncrement) Process(database string, ins *sqlparser.Insert) error
• type AutoIncrementHandler
  • func NewAutoIncrement(log *xlog.Log, router *router.Router) AutoIncrementHandler

Functions

func GetAutoIncrement

func GetAutoIncrement(node *sqlparser.DDL) (*config.AutoIncrement, error)

GetAutoIncrement -- used to get config AutoIncrement from 'create table' DDL sqlnode.

Types

type AutoIncrement

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

AutoIncrement struct. Using Now().UnixNano as start seed seq.

func (*AutoIncrement) Close

func (autoinc *AutoIncrement) Close() error

Close -- close the plugin.

func (*AutoIncrement) Init

func (autoinc *AutoIncrement) Init() error

Init -- used to init the plug module.

func (*AutoIncrement) Process

func (autoinc *AutoIncrement) Process(database string, ins *sqlparser.Insert) error

Process -- process auto-increment. Append the auto-increment column&value to the end of the row if not exists.

type AutoIncrementHandler

type AutoIncrementHandler interface {
	Init() error
	Process(database string, ins *sqlparser.Insert) error
	Close() error
}

func NewAutoIncrement

func NewAutoIncrement(log *xlog.Log, router *router.Router) AutoIncrementHandler

NewAutoIncrement -- creates new AutoIncrement.