dbEngine

Documentation

Index

• type Column
  • func SimpleColumns(names ...string) []Column
• type Connection
• type DB
  • func NewDB(ctx context.Context, conn Connection) (*DB, error)
  • func (db *DB) ReadTableSQL(path string, info os.FileInfo, err error) error
• type ErrNotFoundField
  • func (err ErrNotFoundField) Error() string
• type ErrNotFoundTable
  • func (err ErrNotFoundTable) Error() string
• type Index
• type NumberColumn
  • func NewNumberColumn(name, comment string, req bool) *NumberColumn
  • func (s *NumberColumn) BasicType() types.BasicKind
  • func (s *NumberColumn) BasicTypeInfo() types.BasicInfo
  • func (s *NumberColumn) CharacterMaximumLength() int
  • func (s *NumberColumn) CheckAttr(fieldDefine string) string
  • func (s *NumberColumn) Comment() string
  • func (s *NumberColumn) Name() string
  • func (s *NumberColumn) Required() bool
  • func (c *NumberColumn) SetNullable(f bool)
  • func (s *NumberColumn) Type() string
• type ParserTableDDL
  • func NewtableParser(table Table, db *DB) ParserTableDDL
  • func (p ParserTableDDL) Parse(ddl string) error
• type Routine
• type RowScanner
• type StringColumn
  • func NewStringColumn(name, comment string, req bool) *StringColumn
  • func (s *StringColumn) BasicType() types.BasicKind
  • func (s *StringColumn) BasicTypeInfo() types.BasicInfo
  • func (s *StringColumn) CharacterMaximumLength() int
  • func (s *StringColumn) CheckAttr(fieldDefine string) string
  • func (s *StringColumn) Comment() string
  • func (s *StringColumn) Name() string
  • func (s *StringColumn) Required() bool
  • func (c *StringColumn) SetNullable(f bool)
  • func (s *StringColumn) Type() string
• type Table

Types

type Column

type Column interface {
	BasicType() types.BasicKind
	BasicTypeInfo() types.BasicInfo
	CheckAttr(fieldDefine string) string
	CharacterMaximumLength() int
	Comment() string
	Name() string
	Type() string
	Required() bool
	SetNullable(bool)
}

func SimpleColumns

func SimpleColumns(names ...string) []Column

type Connection

type Connection interface {
	InitConn(ctx context.Context, dbURL string) error
	GetSchema(ctx context.Context) (map[string]Table, map[string]Routine, error)
	GetStat() string
	ExecDDL(ctx context.Context, sql string, args ...interface{}) error
	NewTable(name, typ string) Table
}

type DB

type DB struct {
	Cfg      map[string]interface{}
	Conn     Connection
	Tables   map[string]Table
	Routines map[string]Routine
}

func NewDB

func NewDB(ctx context.Context, conn Connection) (*DB, error)

func (*DB) ReadTableSQL

func (db *DB) ReadTableSQL(path string, info os.FileInfo, err error) error

type ErrNotFoundField

type ErrNotFoundField struct {
	Table     string
	FieldName string
}

ErrNotFoundField if not found in table {Table} field by name {FieldName}

func (ErrNotFoundField) Error

func (err ErrNotFoundField) Error() string

type ErrNotFoundTable

type ErrNotFoundTable struct {
	Table string
}

ErrNotFoundTable if not found table by name {Table}

func (ErrNotFoundTable) Error

func (err ErrNotFoundTable) Error() string

type Index

type Index interface {
	Name() string
}

type NumberColumn

type NumberColumn struct {
	IsNullable bool
	// contains filtered or unexported fields
}

func NewNumberColumn

func NewNumberColumn(name, comment string, req bool) *NumberColumn

func (*NumberColumn) BasicType

func (s *NumberColumn) BasicType() types.BasicKind

func (*NumberColumn) BasicTypeInfo

func (s *NumberColumn) BasicTypeInfo() types.BasicInfo

func (*NumberColumn) CharacterMaximumLength

func (s *NumberColumn) CharacterMaximumLength() int

func (*NumberColumn) CheckAttr

func (s *NumberColumn) CheckAttr(fieldDefine string) string

func (*NumberColumn) Comment

func (s *NumberColumn) Comment() string

func (*NumberColumn) Name

func (s *NumberColumn) Name() string

func (*NumberColumn) Required

func (s *NumberColumn) Required() bool

func (*NumberColumn) SetNullable

func (c *NumberColumn) SetNullable(f bool)

func (*NumberColumn) Type

func (s *NumberColumn) Type() string

type ParserTableDDL

type ParserTableDDL struct {
	Table
	*DB
	// contains filtered or unexported fields
}

func NewtableParser

func NewtableParser(table Table, db *DB) ParserTableDDL

func (ParserTableDDL) Parse

func (p ParserTableDDL) Parse(ddl string) error

type Routine

type Routine interface {
	Name() string
	Select() error
	Call()
	Params()
}

type RowScanner

type RowScanner interface {
	GetFields([]Column) []interface{}
}

type StringColumn

type StringColumn struct {
	IsNullable bool
	// contains filtered or unexported fields
}

func NewStringColumn

func NewStringColumn(name, comment string, req bool) *StringColumn

func (*StringColumn) BasicType

func (s *StringColumn) BasicType() types.BasicKind

func (*StringColumn) BasicTypeInfo

func (s *StringColumn) BasicTypeInfo() types.BasicInfo

func (*StringColumn) CharacterMaximumLength

func (s *StringColumn) CharacterMaximumLength() int

func (*StringColumn) CheckAttr

func (s *StringColumn) CheckAttr(fieldDefine string) string

func (*StringColumn) Comment

func (s *StringColumn) Comment() string

func (*StringColumn) Name

func (s *StringColumn) Name() string

func (*StringColumn) Required

func (s *StringColumn) Required() bool

func (*StringColumn) SetNullable

func (c *StringColumn) SetNullable(f bool)

func (*StringColumn) Type

func (s *StringColumn) Type() string

type Table

type Table interface {
	Columns() []Column
	FindField(name string) Column
	FindIndex(name string) Index
	GetColumns(ctx context.Context) error
	Insert(ctx context.Context)
	Name() string
	RecacheField(nameColumn string) Column
	Select(ctx context.Context)
	SelectAndScanEach(ctx context.Context, each func() error, rowValue RowScanner) error
	SelectAndRunEach(ctx context.Context, each func(values []interface{}, columns []Column) error) error
}