xorm/xorm.go

47 lines
1.2 KiB
Go
Raw Normal View History

2013-05-03 07:26:51 +00:00
package xorm
import (
2013-06-16 03:05:16 +00:00
"errors"
"fmt"
"os"
2013-05-08 14:50:19 +00:00
"reflect"
2013-06-16 03:05:16 +00:00
"sync"
2013-05-03 07:26:51 +00:00
)
const (
version string = "0.1.9"
)
// new a db manager according to the parameter. Currently support three
// driver
2013-06-16 03:05:16 +00:00
func NewEngine(driverName string, dataSourceName string) (*Engine, error) {
engine := &Engine{ShowSQL: false, DriverName: driverName, Mapper: SnakeMapper{},
2013-05-09 01:56:58 +00:00
DataSourceName: dataSourceName}
2013-06-16 03:05:16 +00:00
engine.Tables = make(map[reflect.Type]*Table)
engine.mutex = &sync.Mutex{}
2013-05-19 05:25:52 +00:00
engine.TagIdentifier = "xorm"
engine.Filters = make([]Filter, 0)
2013-05-09 01:56:58 +00:00
if driverName == SQLITE {
engine.Dialect = &sqlite3{}
2013-06-16 03:05:16 +00:00
} else if driverName == MYSQL {
engine.Dialect = &mysql{}
} else if driverName == POSTGRES {
engine.Dialect = &postgres{}
engine.Filters = append(engine.Filters, &PgSeqFilter{})
engine.Filters = append(engine.Filters, &PgQuoteFilter{})
} else if driverName == MYMYSQL {
engine.Dialect = &mysql{}
2013-06-16 03:05:16 +00:00
} else {
return nil, errors.New(fmt.Sprintf("Unsupported driver name: %v", driverName))
2013-05-03 07:26:51 +00:00
}
engine.Filters = append(engine.Filters, &IdFilter{})
engine.Logger = os.Stdout
2013-05-03 07:26:51 +00:00
//engine.Pool = NewSimpleConnectPool()
//engine.Pool = NewNoneConnectPool()
2013-08-29 09:26:33 +00:00
err := engine.SetPool(NewSysConnectPool())
return engine, err
2013-05-03 07:26:51 +00:00
}