dump

Documentation

Index

• Variables
• func Parse(r io.Reader, h ParseHandler) error
• type Dumper
  • func NewDumper(executionPath string, addr string, user string, password string) (*Dumper, error)
  • func (d *Dumper) AddDatabases(dbs ...string)
  • func (d *Dumper) AddIgnoreTables(db string, tables ...string)
  • func (d *Dumper) AddTables(db string, tables ...string)
  • func (d *Dumper) Dump(w io.Writer) error
  • func (d *Dumper) DumpAndParse(h ParseHandler) error
  • func (d *Dumper) Reset()
  • func (d *Dumper) SetErrOut(o io.Writer)
• type ParseHandler

Variables

var (
	ErrSkip = errors.New("Handler error, but skipped")
)

Functions

func Parse

func Parse(r io.Reader, h ParseHandler) error

Parse the dump data with Dumper generate. It can not parse all the data formats with mysqldump outputs

Types

type Dumper

type Dumper struct {
	// mysqldump execution path, like mysqldump or /usr/bin/mysqldump, etc...
	ExecutionPath string

	Addr     string
	User     string
	Password string

	// Will override Databases
	Tables  []string
	TableDB string

	Databases []string

	IgnoreTables map[string][]string

	ErrOut io.Writer
}

Unlick mysqldump, Dumper is designed for parsing and syning data easily.

func NewDumper

func NewDumper(executionPath string, addr string, user string, password string) (*Dumper, error)

func (*Dumper) AddDatabases

func (d *Dumper) AddDatabases(dbs ...string)

func (*Dumper) AddIgnoreTables

func (d *Dumper) AddIgnoreTables(db string, tables ...string)

func (*Dumper) AddTables

func (d *Dumper) AddTables(db string, tables ...string)

func (*Dumper) Dump

func (d *Dumper) Dump(w io.Writer) error

func (*Dumper) DumpAndParse

func (d *Dumper) DumpAndParse(h ParseHandler) error

Dump MySQL and parse immediately

func (*Dumper) Reset

func (d *Dumper) Reset()

func (*Dumper) SetErrOut

func (d *Dumper) SetErrOut(o io.Writer)

type ParseHandler

type ParseHandler interface {
	// Parse CHANGE MASTER TO MASTER_LOG_FILE=name, MASTER_LOG_POS=pos;
	BinLog(name string, pos uint64) error

	Data(schema string, table string, values []string) error
}