eta_bridge/init_serve/dm_database_orm.go

package init_serve

import (
	"eta/eta_bridge/global"
	"eta/eta_bridge/models/ht/oa"
	"fmt"
	_ "github.com/alexbrainman/odbc"
	"github.com/astaxie/beego/orm"
)

const (
	DR_ODBC orm.DriverType = 6
)

func DMDataBaseORM() {

	//开启日志
	err := orm.RegisterDriver("odbc", orm.DRTiDB)
	if err != nil {
		fmt.Println("注册数据库驱动失败，数据库：", ";Err：", err)
		return
	}
	dsn := "Driver={DM8 ODBC DRIVER};Server=localhost:5236;Database=ETA;UID=ETA;PWD=Han6258199118`;"
	err = orm.RegisterDataBase("default", "odbc", dsn)
	orm.SetMaxIdleConns("default", 50)
	orm.SetMaxOpenConns("default", 100)
	orm.RegisterModel(new(oa.HrmResource))
	orm.RegisterModel(new(oa.HrmDepartment))
	orm.RegisterModel(new(oa.HrmSubCompany))
	if err != nil {
		fmt.Println("注册数据库失败，数据库：", ";Err：", err)
		return
	}
	//ormdb, err := orm.GetDB("defalut")
	//if err != nil {
	//	fmt.Println("获取数据库连接失败，数据库：", ";Err：", err)
	//	return
	//}

	//ormdb.SetConnMaxLifetime(10 * time.Minute)
	if err != nil {
		global.LOG.Errorf("海通OA数据库 启动异常，数据库:", ";Err：", err)
		panic(fmt.Errorf("海通OA数据库 启动异常，数据库:", "Err:%s", err))
	}
	//global.OaDbHTORM = ormdb
	fmt.Println("ht oa database init end")
}