HiPoweredDev
/
xorm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

make DbType public

This commit is contained in:
Nash Tsai 2014-04-11 21:05:08 +08:00
parent 22c515f1e0
commit dbcb6fe173
1 changed files with 8 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
dialect.go
View File

@ -6,10 +6,10 @@ import (
"time" "time"
) )
type dbType string type DbType string
type Uri struct { type Uri struct {
DbType dbType DbType DbType
Proto string Proto string
Host string Host string
Port string Port string
@ -26,7 +26,7 @@ type Uri struct {
type Dialect interface { type Dialect interface {
Init(*Uri, string, string) error Init(*Uri, string, string) error
URI() *Uri URI() *Uri
DBType() dbType DBType() DbType
SqlType(t *Column) string SqlType(t *Column) string
SupportInsertMany() bool SupportInsertMany() bool
QuoteStr() string QuoteStr() string
@ -70,7 +70,7 @@ func (b *Base) URI() *Uri {
return b.Uri return b.Uri
} }
func (b *Base) DBType() dbType { func (b *Base) DBType() DbType {
return b.Uri.DbType return b.Uri.DbType
} }
@ -137,19 +137,16 @@ func (b *Base) CreateTableSql(table *Table, tableName, storeEngine, charset stri
} }
var ( var (
dialects = map[dbType]Dialect{} dialects = map[DbType]Dialect{}
) )
func RegisterDialect(dbName dbType, dialect Dialect) { func RegisterDialect(dbName DbType, dialect Dialect) {
if dialect == nil { if dialect == nil {
panic("core: Register dialect is nil") panic("core: Register dialect is nil")
} }
if _, dup := dialects[dbName]; dup { dialects[dbName] = dialect // !nashtsai! allow override dialect
panic("core: Register called twice for dialect " + dbName)
}
dialects[dbName] = dialect
} }
func QueryDialect(dbName dbType) Dialect { func QueryDialect(dbName DbType) Dialect {
return dialects[dbName] return dialects[dbName]
} }