store

Documentation

Index

• Constants
• Variables
• func Compare(srcDSN, dstDSN string, opts CompareOptions) ([]string, error)
• type ColumnInfo
• type CompareOptions
• type DB
  • func NewDB(dsn string) (*DB, error)
  • func (db *DB) Close() error
  • func (db *DB) TableList() (map[string]*TableInfo, error)
  • func (db *DB) Version() (*semver.Version, error)
• type TableInfo

Constants

const (
	DatabaseDriverPostgres = "postgres"
	DatabaseDriverMysql    = "mysql"
)

const MySQLChecksumTmpl = `` /* 402-byte string literal not displayed */

const PostgresChecksumTmpl = `` /* 377-byte string literal not displayed */

The ‘x’ prepended to the hash strings, which tells Postgres to interpret them as hex strings when casting to a number.

Variables

var (
	ErrEmptyTable = errors.New("the table has no rows to calculate md5")
)

Functions

func Compare

func Compare(srcDSN, dstDSN string, opts CompareOptions) ([]string, error)

Types

type ColumnInfo

type ColumnInfo struct {
	ColumnName string `db:"column_name"`
	DataType   string `db:"data_type"`
}

ColumnInfo is the column info

type CompareOptions

type CompareOptions struct {
	ExcludePatterns []string
	Verbose         bool
	PageSize        int
}

type DB

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

DB is the sql.DB wrapper with some utilities

func NewDB

func NewDB(dsn string) (*DB, error)

NewDB creates a DB instance from the given data source

func (*DB) Close

func (db *DB) Close() error

func (*DB) TableList

func (db *DB) TableList() (map[string]*TableInfo, error)

func (*DB) Version

func (db *DB) Version() (*semver.Version, error)

type TableInfo

type TableInfo struct {
	TableName   string
	PrimaryKeys []string
	Columns     []*ColumnInfo
}