dialects

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

type Dialect interface {
	Init(*core.DB, *URI) error
	URI() *URI
	DB() *core.DB
	SQLType(*schemas.Column) string
	FormatBytes(b []byte) string
	DefaultSchema() string

	IsReserved(string) bool
	Quoter() schemas.Quoter
	SetQuotePolicy(quotePolicy QuotePolicy)

	AutoIncrStr() string

	GetIndexes(ctx context.Context, tableName string) (map[string]*schemas.Index, error)
	IndexCheckSQL(tableName, idxName string) (string, []interface{})
	CreateIndexSQL(tableName string, index *schemas.Index) string
	DropIndexSQL(tableName string, index *schemas.Index) string

	GetTables(ctx context.Context) ([]*schemas.Table, error)
	IsTableExist(ctx context.Context, tableName string) (bool, error)
	CreateTableSQL(table *schemas.Table, tableName string) ([]string, bool)
	DropTableSQL(tableName string) (string, bool)

	GetColumns(ctx context.Context, tableName string) ([]string, map[string]*schemas.Column, error)
	IsColumnExist(ctx context.Context, tableName string, colName string) (bool, error)
	AddColumnSQL(tableName string, col *schemas.Column) string
	ModifyColumnSQL(tableName string, col *schemas.Column) string

	ForUpdateSQL(query string) string

	Filters() []Filter
	SetParams(params map[string]string)
}

type Driver interface {
	Parse(string, string) (*URI, error)
}

type Filter interface {
	Do(sql string) string
}

type QuotePolicy int

type SeqFilter struct {
	Prefix string
	Start  int
}

type URI struct {
	DBType  schemas.DBType
	Proto   string
	Host    string
	Port    string
	DBName  string
	User    string
	Passwd  string
	Charset string
	Laddr   string
	Raddr   string
	Timeout time.Duration
	Schema  string
}