Versions in this module Expand all Collapse all v0 v0.0.3 Nov 18, 2020 v0.0.2 Nov 13, 2020 Changes in this version + var DefaultKingbaseSchema = "public" + var DefaultPostgresSchema = "public" + func ColumnString(dialect Dialect, col *schemas.Column, includePrimaryKey bool) (string, error) + func FormatColumnTime(dialect Dialect, defaultTimeZone *time.Location, col *schemas.Column, ...) (v interface{}) + func FormatTime(dialect Dialect, sqlTypeName string, t time.Time) (v interface{}) + func FullTableName(dialect Dialect, mapper names.Mapper, bean interface{}, includeSchema ...bool) string + func QueryDefaultKingbaseSchema(ctx context.Context, queryer core.Queryer) (string, error) + func QueryDefaultPostgresSchema(ctx context.Context, queryer core.Queryer) (string, error) + func RegisterDialect(dbName schemas.DBType, dialectFunc func() Dialect) + func RegisterDriver(driverName string, driver Driver) + func RegisteredDriverSize() int + func TableNameNoSchema(dialect Dialect, mapper names.Mapper, tableName interface{}) string + func TableNameWithSchema(dialect Dialect, tableName string) string + type Base struct + func (b *Base) DBType() schemas.DBType + func (b *Base) ForUpdateSQL(query string) string + func (b *Base) FormatBytes(bs []byte) string + func (b *Base) Init(dialect Dialect, uri *URI) error + func (b *Base) Quoter() schemas.Quoter + func (b *Base) SetParams(params map[string]string) + func (b *Base) URI() *URI + func (db *Base) AddColumnSQL(tableName string, col *schemas.Column) string + func (db *Base) CreateIndexSQL(tableName string, index *schemas.Index) string + func (db *Base) DropIndexSQL(tableName string, index *schemas.Index) string + func (db *Base) DropTableSQL(tableName string) (string, bool) + func (db *Base) HasRecords(queryer core.Queryer, ctx context.Context, query string, args ...interface{}) (bool, error) + func (db *Base) IsColumnExist(queryer core.Queryer, ctx context.Context, tableName, colName string) (bool, error) + func (db *Base) ModifyColumnSQL(tableName string, col *schemas.Column) string + type Dialect interface + AddColumnSQL func(tableName string, col *schemas.Column) string + AutoIncrStr func() string + CreateIndexSQL func(tableName string, index *schemas.Index) string + CreateTableSQL func(table *schemas.Table, tableName string) ([]string, bool) + DropIndexSQL func(tableName string, index *schemas.Index) string + DropTableSQL func(tableName string) (string, bool) + Filters func() []Filter + ForUpdateSQL func(query string) string + FormatBytes func(b []byte) string + GetColumns func(queryer core.Queryer, ctx context.Context, tableName string) ([]string, map[string]*schemas.Column, error) + GetIndexes func(queryer core.Queryer, ctx context.Context, tableName string) (map[string]*schemas.Index, error) + GetTables func(queryer core.Queryer, ctx context.Context) ([]*schemas.Table, error) + IndexCheckSQL func(tableName, idxName string) (string, []interface{}) + Init func(*URI) error + IsColumnExist func(queryer core.Queryer, ctx context.Context, tableName string, colName string) (bool, error) + IsReserved func(string) bool + IsTableExist func(queryer core.Queryer, ctx context.Context, tableName string) (bool, error) + ModifyColumnSQL func(tableName string, col *schemas.Column) string + Quoter func() schemas.Quoter + SQLType func(*schemas.Column) string + SetParams func(params map[string]string) + SetQuotePolicy func(quotePolicy QuotePolicy) + URI func() *URI + func OpenDialect(driverName, connstr string) (Dialect, error) + func QueryDialect(dbName schemas.DBType) Dialect + type Driver interface + Parse func(string, string) (*URI, error) + func QueryDriver(driverName string) Driver + type Filter interface + Do func(sql string) string + type QuotePolicy int + const QuotePolicyAlways + const QuotePolicyNone + const QuotePolicyReserved + type SeqFilter struct + Prefix string + Start int + func (s *SeqFilter) Do(sql string) string + type URI struct + Charset string + DBName string + DBType schemas.DBType + Host string + Laddr string + Passwd string + Port string + Proto string + Raddr string + Schema string + Timeout time.Duration + User string + func (uri *URI) SetSchema(schema string)