本文整理汇总了Golang中github.com/go-xorm/xorm.NewEngine函数的典型用法代码示例。如果您正苦于以下问题:Golang NewEngine函数的具体用法?Golang NewEngine怎么用?Golang NewEngine使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了NewEngine函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: NewTestEngine
func NewTestEngine(x *xorm.Engine) (err error) {
switch DbCfg.Type {
case "mysql":
x, err = xorm.NewEngine("mysql", fmt.Sprintf("%s:%[email protected](%s)/%s?charset=utf8",
DbCfg.User, DbCfg.Pwd, DbCfg.Host, DbCfg.Name))
case "postgres":
var host, port = "127.0.0.1", "5432"
fields := strings.Split(DbCfg.Host, ":")
if len(fields) > 0 && len(strings.TrimSpace(fields[0])) > 0 {
host = fields[0]
}
if len(fields) > 1 && len(strings.TrimSpace(fields[1])) > 0 {
port = fields[1]
}
cnnstr := fmt.Sprintf("user=%s password=%s host=%s port=%s dbname=%s sslmode=%s",
DbCfg.User, DbCfg.Pwd, host, port, DbCfg.Name, DbCfg.SslMode)
//fmt.Println(cnnstr)
x, err = xorm.NewEngine("postgres", cnnstr)
case "sqlite3":
if !EnableSQLite3 {
return fmt.Errorf("Unknown database type: %s", DbCfg.Type)
}
os.MkdirAll(path.Dir(DbCfg.Path), os.ModePerm)
x, err = xorm.NewEngine("sqlite3", DbCfg.Path)
default:
return fmt.Errorf("Unknown database type: %s", DbCfg.Type)
}
if err != nil {
return fmt.Errorf("models.init(fail to conntect database): %v", err)
}
return x.Sync(tables...)
}
开发者ID:jcfrank,项目名称:gogs,代码行数:32,代码来源:models.go
示例2: ConDb
func ConDb() (*xorm.Engine, error) {
switch {
case DataType == "memory":
return xorm.NewEngine("tidb", "memory://tidb/tidb")
case DataType == "goleveldb":
return xorm.NewEngine("tidb", "goleveldb://./data/goleveldb")
case DataType == "boltdb":
return xorm.NewEngine("tidb", "boltdb://./data/boltdb")
case DataType == "mysql":
return xorm.NewEngine("mysql", "root:[email protected]/db?charset=utf8")
//return xorm.NewEngine("mysql", "root:[email protected]/db?charset=utf8")
case DataType == "postgres":
return xorm.NewEngine("postgres", "user=postgres [email protected]#$%^&* dbname=pgsql sslmode=disable")
//return xorm.NewEngine("postgres", "user=postgres [email protected]#$%^&* dbname=pgsql sslmode=disable")
// "user=postgres [email protected]#$%^&* dbname=yougam sslmode=disable maxcons=10 persist=true"
//return xorm.NewEngine("postgres", "host=110.76.39.205 user=postgres [email protected]#$%^&* dbname=yougam sslmode=disable")
//return xorm.NewEngine("postgres", "host=127.0.0.1 port=6432 user=postgres [email protected]#$%^&* dbname=yougam sslmode=disable")
}
return nil, errors.New("尚未设定数据库连接")
}
开发者ID:xqbumu,项目名称:zenpress,代码行数:26,代码来源:models.go
示例3: newTidbEngine
func newTidbEngine(storeType string) (*xorm.Engine, error) {
if storeType == "memory" {
return xorm.NewEngine("tidb", storeType+"://tidb/tidb?parseTime=true")
}
os.Remove("./tidb_" + storeType)
return xorm.NewEngine("tidb", storeType+"://./tidb_"+storeType+"/tidb?parseTime=true")
}
开发者ID:go-xorm,项目名称:tidb,代码行数:8,代码来源:tidb_test.go
示例4: InitDB
func InitDB() (err error) {
// utils.LoadConfig("conf/app.conf")
utils.LoadConfig("conf/app-local.conf")
// utils.LoadConfig("conf/app-skytap.conf")
// appname = goTestLinkReport
// httpport = 8080
// runmode = dev
// appname = utils.Cfg.MustValue("server", key, ...)
// dbtype = mysql
// host = 127.0.0.1
// port = 3306
// name = report
// user = root
// pwd = 123123
// # SSLMODE = false
dbtype := utils.Cfg.MustValue("db", "dbtype")
host := utils.Cfg.MustValue("db", "host")
port := utils.Cfg.MustValue("db", "port")
name := utils.Cfg.MustValue("db", "name")
user := utils.Cfg.MustValue("db", "user")
pwd := utils.Cfg.MustValue("db", "pwd")
ssl := utils.Cfg.MustValue("db", "ssl")
switch dbtype {
case "mysql":
// connstr := fmt.Sprintf("%s:%[email protected](%s:%s)/%s?charset=utf8",
// user, pwd, host, port, name)
connstr := fmt.Sprintf("%s:%[email protected](%s:%s)/%s?charset=utf8",
user, pwd, host, port, name)
fmt.Errorf(connstr)
orm, err = xorm.NewEngine("mysql", connstr)
if err != nil {
beego.Debug(fmt.Sprintf("Failed to create new engine : %v\n", err))
}
case "postgres":
cnnstr := fmt.Sprintf("user=%s password=%s host=%s port=%s dbname=%s sslmode=%s",
user, pwd, host, port, name, ssl)
orm, err = xorm.NewEngine("postgres", cnnstr)
default:
beego.Debug(fmt.Sprintf("Unknown db type: %s\n", dbtype))
return fmt.Errorf("Unknown db type: %s\n", dbtype)
}
if err != nil {
beego.Debug(fmt.Sprintf("models.init(failed to connect database): %v\n", err))
return fmt.Errorf("models.init(failed to connect database): %v\n", err)
}
// orm.ShowSQL = true
// orm.ShowInfo = true
// orm.ShowDebug = true
// orm.ShowWarn = true
orm.ShowErr = true
fmt.Println("success!")
return orm.Sync(tables...)
}
开发者ID:DevilEVG,项目名称:goTestLinkReport,代码行数:58,代码来源:models.go
示例5: xConnDb
func xConnDb() (*xorm.Engine, error) {
switch DbType {
case "sqlite":
return xorm.NewEngine("sqlite3", filepath.Join(os.Getenv("GOPATH"), "src", "goAcq", "data", fmt.Sprintf("%s.db", DbName)))
case "mysql":
return xorm.NewEngine("mysql", fmt.Sprintf("%s:%[email protected](%v)/%s?charset=%v", DbUser, DbPwd, DbHost, DbName, DbCharSet))
case "pgsql":
return xorm.NewEngine("postgres", fmt.Sprintf("user=%s password=%s dbname=%s sslmode=disable", DbUser, DbPwd, DbName))
}
return nil, fmt.Errorf("UnSopported database type: %v", DbType)
}
开发者ID:aiwuTech,项目名称:goAcq,代码行数:13,代码来源:lasting.go
示例6: InitDB
func InitDB() (err error) {
utils.LoadConfig("../conf/app.conf")
dbtype := utils.Cfg.MustValue("db", "dbtype")
host := utils.Cfg.MustValue("db", "host")
port := utils.Cfg.MustValue("db", "port")
name := utils.Cfg.MustValue("db", "name")
user := utils.Cfg.MustValue("db", "user")
pwd := utils.Cfg.MustValue("db", "pwd")
ssl := utils.Cfg.MustValue("db", "ssl")
switch dbtype {
case "mysql":
// connstr := fmt.Sprintf("%s:%[email protected](%s:%s)/%s?charset=utf8",
// user, pwd, host, port, name)
connstr := fmt.Sprintf("%s:%[email protected](%s:%s)/%s?charset=utf8",
user, pwd, host, port, name)
fmt.Errorf(connstr)
orm, err = xorm.NewEngine("mysql", connstr)
if err != nil {
beego.Debug(fmt.Sprintf("Failed to create new engine : %v\n", err))
}
case "postgres":
cnnstr := fmt.Sprintf("user=%s password=%s host=%s port=%s dbname=%s sslmode=%s",
user, pwd, host, port, name, ssl)
orm, err = xorm.NewEngine("postgres", cnnstr)
default:
beego.Debug(fmt.Sprintf("Unknown db type: %s\n", dbtype))
return fmt.Errorf("Unknown db type: %s\n", dbtype)
}
if err != nil {
beego.Debug(fmt.Sprintf("models.init(failed to connect database): %v\n", err))
return fmt.Errorf("models.init(failed to connect database): %v\n", err)
}
// orm.ShowSQL = true
// orm.ShowInfo = true
// orm.ShowDebug = true
// orm.ShowWarn = true
orm.ShowErr = true
orm.SetMapper(core.SameMapper{})
fmt.Println("success!")
// return orm.Sync(tables...)
err = orm.Sync(new(Test), new(PkgFunc))
if err != nil {
fmt.Println("Failed to Sync()!")
}
return
}
开发者ID:DevilEVG,项目名称:goStockAnalyst,代码行数:51,代码来源:test_xorm.go
示例7: ExampleRegisterStandardDatabases
func ExampleRegisterStandardDatabases() {
engine1, _ = xorm.NewEngine("mysql", "root:@/example_user?charset=utf8")
engine2, _ = xorm.NewEngine("mysql", "root:@/example_user?charset=utf8")
engine3, _ = xorm.NewEngine("mysql", "root:@/example_foobar?charset=utf8")
engine4, _ = xorm.NewEngine("mysql", "root:@/example_other?charset=utf8")
w = wizard.NewWizard()
stndardCluster := w.CreateCluster(User{}, engine1) // engine is master database used for table of User{}
stndardCluster.RegisterSlave(engine2) // add slave
_ = w.CreateCluster("foobar", engine3) // engine3 is master database used for table of foobar
stndardCluster = wizard.NewCluster(engine4)
w.SetDefault(stndardCluster) // engine4 is master database used for all the other tables
}
开发者ID:kaneshin,项目名称:wizard,代码行数:15,代码来源:examples_test.go
示例8: init
func init() {
// 创建 ORM 引擎与数据库
var err error
x, err = xorm.NewEngine("sqlite3", "./bank.db")
if err != nil {
log.Fatalf("Fail to create engine: %v\n", err)
}
// 同步结构体与数据表
if err = x.Sync(new(Account)); err != nil {
log.Fatalf("Fail to sync database: %v\n", err)
}
// 记录日志
f, err := os.Create("sql.log")
if err != nil {
log.Fatalf("Fail to create log file: %v\n", err)
return
}
x.Logger = xorm.NewSimpleLogger(f)
x.ShowSQL = true
// 设置默认 LRU 缓存
cacher := xorm.NewLRUCacher(xorm.NewMemoryStore(), 1000)
x.SetDefaultCacher(cacher)
}
开发者ID:Zcgong,项目名称:go-rock-libraries-showcases,代码行数:26,代码来源:models.go
示例9: InitDB
//初始化数据库
func (api *Api) InitDB(database string) {
var err error
conf, err := ConfigFromFile(configPath)
if err != nil {
panic(err.Error())
}
dbConf := conf.DataBase
sqlUrl := fmt.Sprintf(dbConf.URL, dbConf.User, dbConf.Password, dbConf.Host, dbConf.Port, database)
api.DB, err = xorm.NewEngine("mysql", sqlUrl)
if err != nil {
log.Fatalf("Got error when connect database, the error is '%v'", err)
}
api.DB.ShowSQL = true
api.DB.ShowDebug = true
api.DB.ShowErr = true
api.DB.SetMaxIdleConns(dbConf.MaxIdleConnections)
api.DB.SetMaxOpenConns(dbConf.MaxOpenConnections)
//记录到日志文件中.
// f, err := os.Create("sql.log")
// if err != nil {
// println(err.Error())
// return
// }
// defer f.Close()
// api.DB.Logger = xorm.NewSimpleLogger(f)
}
开发者ID:ohlinux,项目名称:golang-snippet-cn,代码行数:30,代码来源:mysql.go
示例10: getEngine
func getEngine() (*xorm.Engine, error) {
cnnstr := ""
switch DbCfg.Type {
case "mysql":
if DbCfg.Host[0] == '/' { // looks like a unix socket
cnnstr = fmt.Sprintf("%s:%[email protected](%s)/%s?charset=utf8&parseTime=true",
DbCfg.User, DbCfg.Passwd, DbCfg.Host, DbCfg.Name)
} else {
cnnstr = fmt.Sprintf("%s:%[email protected](%s)/%s?charset=utf8&parseTime=true",
DbCfg.User, DbCfg.Passwd, DbCfg.Host, DbCfg.Name)
}
case "postgres":
var host, port = "127.0.0.1", "5432"
fields := strings.Split(DbCfg.Host, ":")
if len(fields) > 0 && len(strings.TrimSpace(fields[0])) > 0 {
host = fields[0]
}
if len(fields) > 1 && len(strings.TrimSpace(fields[1])) > 0 {
port = fields[1]
}
cnnstr = fmt.Sprintf("postgres://%s:%[email protected]%s:%s/%s?sslmode=%s",
url.QueryEscape(DbCfg.User), url.QueryEscape(DbCfg.Passwd), host, port, DbCfg.Name, DbCfg.SSLMode)
case "sqlite3":
if !EnableSQLite3 {
return nil, fmt.Errorf("Unknown database type: %s", DbCfg.Type)
}
if err := os.MkdirAll(path.Dir(DbCfg.Path), os.ModePerm); err != nil {
return nil, fmt.Errorf("Fail to create directories: %v", err)
}
cnnstr = "file:" + DbCfg.Path + "?cache=shared&mode=rwc"
default:
return nil, fmt.Errorf("Unknown database type: %s", DbCfg.Type)
}
return xorm.NewEngine(DbCfg.Type, cnnstr)
}
开发者ID:BitSchupser,项目名称:gogs,代码行数:35,代码来源:models.go
示例11: NewXormDBAppender
// NewXormDBAppender create new db appender
func NewXormDBAppender(driver, spec, table string) (*XormDBAppender, error) {
if table == "" {
table = "common_wlog"
}
wlog.DB_LOG_TABLE = table
m := &XormDBAppender{}
e, err := xorm.NewEngine(driver, spec)
if err != nil {
return nil, err
}
// config Engine
e.SetTableMapper(core.SnakeMapper{})
e.SetColumnMapper(core.SameMapper{})
// Sync Table
e.Sync(wlog.LogTable{})
m.Xorm = e
m.BaseAppender = wlog.NewBaseAppender("db")
return m, nil
}
开发者ID:mabetle,项目名称:mlog,代码行数:28,代码来源:appender_db_xorm.go
示例12: main
func main() {
f := "singleMapping.db"
os.Remove(f)
Orm, err := xorm.NewEngine("sqlite3", f)
if err != nil {
fmt.Println(err)
return
}
Orm.ShowSQL = true
err = Orm.CreateTables(&User{}, &LoginInfo{})
if err != nil {
fmt.Println(err)
return
}
_, err = Orm.Insert(&User{1, "xlw"}, &LoginInfo{1, "127.0.0.1", 1, "", 23})
if err != nil {
fmt.Println(err)
return
}
info := LoginInfo{}
_, err = Orm.Id(1).Get(&info)
if err != nil {
fmt.Println(err)
return
}
fmt.Println(info)
}
开发者ID:NicolasSamDuval,项目名称:xorm,代码行数:30,代码来源:singlemapping.go
示例13: Run
func (s *Sprint) Run() error {
var err error
dsn, _ := pq.ParseURL(os.Getenv("DATABASE_URL"))
db, err := xorm.NewEngine("postgres", dsn)
if err != nil {
return err
}
err = db.Sync(Project{})
if err != nil {
return err
}
s.Db = db
s.Validator = validator.New(&validator.Config{TagName: "validate"})
port := os.Getenv("PORT")
r := gin.Default()
r.GET("/api/projects", s.GetProjects)
r.GET("/api/projects/:id", s.GetProjectsOne)
r.POST("/api/projects", s.CreateProjects)
r.DELETE("/api/projects/:id", s.DeleteProjects)
r.Run(":" + port)
return nil
}
开发者ID:mikoim,项目名称:codecheck-1015,代码行数:31,代码来源:main.go
示例14: Update0508
//var engine *xorm.Engine
func Update0508() {
var err error
engine, err = xorm.NewEngine("sqlite3", "./test.db")
engine.SetMapper(core.SameMapper{})
if err != nil {
fmt.Println(err)
}
cs := make([]Coordinate, 0)
err = engine.Where("FormName='Frm05_8'").Find(&cs)
if err != nil {
fmt.Println(err)
}
ps := make([]PageProfile, 0)
err = engine.Where("FormName='Frm05_8'").Find(&ps)
if err != nil {
fmt.Println(err)
}
for _, coor := range cs {
cname := coor.CoordinateName
for _, pro := range ps {
pname := pro.ItemName_CN + pro.Display_CN
if cname == pname {
coor.CustomID = pro.CustomID
_, err := engine.Id(coor.ID).Cols("CustomID").Update(&coor)
if err != nil {
fmt.Println(err)
}
}
}
}
}
开发者ID:hefju,项目名称:DbSync,代码行数:35,代码来源:cao.go
示例15: runSource
func runSource(cmd *Command, args []string) {
if len(args) != 2 {
fmt.Println("params error, please see xorm help source")
return
}
var err error
engine, err = xorm.NewEngine(args[0], args[1])
if err != nil {
fmt.Println(err)
return
}
engine.ShowSQL, engine.ShowDebug = false, false
engine.ShowErr, engine.ShowWarn = false, false
err = engine.Ping()
if err != nil {
fmt.Println(err)
return
}
_, err = engine.Import(os.Stdin)
if err.Error() == "not an error" {
err = nil
}
if err != nil {
fmt.Println(err)
return
}
}
开发者ID:sillydong,项目名称:cmd,代码行数:31,代码来源:source.go
示例16: initDb
func initDb() {
var err error
Engine, err = xorm.NewEngine("mysql", mysql_dsn)
if err != nil {
panic(err.Error()) // proper error handling instead of panic in your app
}
tbMapper := core.NewPrefixMapper(core.SnakeMapper{}, "pk_")
Engine.SetTableMapper(tbMapper)
Engine.ShowSQL = true //则会在控制台打印出生成的SQL语句;
Engine.ShowDebug = true //则会在控制台打印调试信息;
Engine.ShowErr = true //则会在控制台打印错误信息;
Engine.ShowWarn = true //则会在控制台打印警告信息;
f, err := os.Create("sql.log")
if err != nil {
println("error:")
println(err.Error())
return
}
defer f.Close()
Engine.Logger = xorm.NewSimpleLogger(f)
// fmt.Println(Engine)
}
开发者ID:ryancsq,项目名称:test,代码行数:26,代码来源:myinit.go
示例17: init
func init() {
c, err := goconfig.LoadConfigFile("conf/conf.ini")
if err != nil {
panic(err)
}
driver, err := c.GetValue("Database", "driver")
if err != nil {
panic(err)
}
dsn, err := c.GetValue("Database", "dsn")
if err != nil {
panic(err)
}
DataBase, err = xorm.NewEngine(driver, dsn)
if err != nil {
panic(err)
}
err = DataBase.Ping()
if err != nil {
panic(err)
}
}
开发者ID:kyugao,项目名称:gametcp_ex,代码行数:27,代码来源:sql.go
示例18: TestMysqlGonicMapper
func TestMysqlGonicMapper(t *testing.T) {
err := mysqlDdlImport()
if err != nil {
t.Error(err)
return
}
engine, err := xorm.NewEngine("mysql", "root:@/xorm_test1?charset=utf8")
if err != nil {
t.Error(err)
return
}
defer engine.Close()
engine.ShowSQL = ShowTestSql
engine.ShowErr = ShowTestSql
engine.ShowWarn = ShowTestSql
engine.ShowDebug = ShowTestSql
engine.SetMapper(core.GonicMapper{})
BaseTestAll(engine, t)
//BaseTestAllSameMapper(engine, t)
BaseTestAll2(engine, t)
BaseTestAll3(engine, t)
}
开发者ID:gotokatsuya,项目名称:tests,代码行数:25,代码来源:mysql_test.go
示例19: TestMysqlWithCacheSameMapper
func TestMysqlWithCacheSameMapper(t *testing.T) {
err := mysqlDdlImport()
if err != nil {
t.Error(err)
return
}
engine, err := xorm.NewEngine("mysql", "root:@/xorm_test3?charset=utf8")
if err != nil {
t.Error(err)
return
}
defer engine.Close()
engine.SetMapper(core.SameMapper{})
engine.SetDefaultCacher(NewCacher())
engine.ShowSQL = ShowTestSql
engine.ShowErr = ShowTestSql
engine.ShowWarn = ShowTestSql
engine.ShowDebug = ShowTestSql
BaseTestAll(engine, t)
BaseTestAllSameMapper(engine, t)
BaseTestAll2(engine, t)
}
开发者ID:gotokatsuya,项目名称:tests,代码行数:25,代码来源:mysql_test.go
示例20: init
func init() {
var err error
X, err = xorm.NewEngine("mssql", "server=.;database=goodsmanage;user id=sa;password=yiche2014")
fmt.Println("-------11111")
if err != nil {
log.Fatalf("failt to carete engine")
}
fmt.Println("-------11111")
X.SetMapper(core.SameMapper{})
//用户表
if err = X.Sync2(new(Tuser)); err != nil {
log.Fatalf("failt Tuser to sync", err.Error())
}
//菜单表
if err = X.Sync2(new(TMenus)); err != nil {
log.Fatalf("failt TMenus to sync", err.Error())
}
//角色表
if err = X.Sync2(new(TRoles)); err != nil {
log.Fatalf("failt TRoles to sync", err.Error())
}
//初始管理员
// var tuser = new(Tuser).Init()
// var d = tuser.GetUser("admin")
// if d == false {
// _, _ = X.Exec("insert into [Tuser]([uname],password)values('admin','admin')")
// }
var tuser = new(Tuser).Init()
if !tuser.Get(1) {
_, _ = X.Exec("insert into [Tuser]([uname],password)values('admin','admin')")
}
}
开发者ID:kebikeyi,项目名称:GoodsManage,代码行数:33,代码来源:Init.go
注:本文中的github.com/go-xorm/xorm.NewEngine函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论