fulldump

Documentation

Overview

Package fulldump provides helper functions for full dump.

Index

• func FullDump(ctx context.Context, cfg *FullDumpConfig, handler Handler) (gtidSet string, err error)
• type Handler
• type RowIter
  • func FullTableQuery(ctx context.Context, q sqlh.Queryer, dbName, table string) (RowIter, error)
  • func Query(ctx context.Context, q sqlh.Queryer, query string, args ...interface{}) (iter RowIter, err error)

Functions

func FullDump

func FullDump(
	ctx context.Context,
	cfg *FullDumpConfig,
	handler Handler,
) (gtidSet string, err error)

FullDump is similar to mysqldump --single-transaction, see mycanal's doc for prerequisites.

NOTE: Since `BeginTx` can not run 'START TRANSACTION WITH CONSISTENT SNAPSHOT', use `*sql.Conn` instead of `*sql.Tx`. More discussions:

• https://github.com/golang/go/issues/19981

Other refs:

• https://issues.redhat.com/browse/DBZ-210

Types

type Handler

type Handler func(ctx context.Context, q sqlh.Queryer) error

Handler is used to dump content.

type RowIter

type RowIter func(next bool) (map[string]interface{}, error)

RowIter is used for result set iteration. It returns nil if no more row. Caller should invoke RowIter(false) to close the iterator and release resource.

func FullTableQuery

func FullTableQuery(ctx context.Context, q sqlh.Queryer, dbName, table string) (RowIter, error)

FullTableQuery full dump a table.

func Query

func Query(ctx context.Context, q sqlh.Queryer, query string, args ...interface{}) (iter RowIter, err error)

Query and returns RowIter