mysql

Documentation

Index

• Variables
• func ExtractLength(mysqlType string) uint
• func ExtractPrecisionAndScale(mysqlType string) (uint, uint)
• func MysqlToGenericType(mysqlType string) *Type
• type MysqlReader
  • func OpenReader(conf *Config) (*MysqlReader, error)
  • func (r *MysqlReader) CreateProjection(name string, body string, engine string, pk []string, uks [][]string) error
  • func (r *MysqlReader) CreateView(name string, body string) error
  • func (r *MysqlReader) DropProjection(name string) error
  • func (r *MysqlReader) DropView(name string) error
  • func (r *MysqlReader) FilteredTables(incl, excl map[string]bool) []*Table
  • func (r *MysqlReader) Read(table *Table) (*sql.Rows, error)
  • func (r *MysqlReader) TableNames() []string
  • func (r *MysqlReader) Tables() []*Table

Variables

var (
	READER_VERBOSE = false
)

Functions

func ExtractLength

func ExtractLength(mysqlType string) uint

returns 0 if no length could be determined

func ExtractPrecisionAndScale

func ExtractPrecisionAndScale(mysqlType string) (uint, uint)

returns a precision, scale tuple

func MysqlToGenericType

func MysqlToGenericType(mysqlType string) *Type

Types

type MysqlReader

type MysqlReader struct {
	*sql.DB
}

func OpenReader

func OpenReader(conf *Config) (*MysqlReader, error)

func (*MysqlReader) CreateProjection

func (r *MysqlReader) CreateProjection(name string, body string, engine string, pk []string, uks [][]string) error

can't use temporary tables, as they don't appear in SHOW TABLES output

func (*MysqlReader) CreateView

func (r *MysqlReader) CreateView(name string, body string) error

func (*MysqlReader) DropProjection

func (r *MysqlReader) DropProjection(name string) error

func (*MysqlReader) DropView

func (r *MysqlReader) DropView(name string) error

func (*MysqlReader) FilteredTables

func (r *MysqlReader) FilteredTables(incl, excl map[string]bool) []*Table

func (*MysqlReader) Read

func (r *MysqlReader) Read(table *Table) (*sql.Rows, error)

caller is responsible for cleaning up the sql.Rows object

func (*MysqlReader) TableNames

func (r *MysqlReader) TableNames() []string

func (*MysqlReader) Tables

func (r *MysqlReader) Tables() []*Table