修复bom第一启动时的全量上报

zhangzengfei

2023-09-11 1873461012c99801f364bd07fae2c218d245048e

 kingdee/db.go

@@ -2,8 +2,13 @@

import (
   "fmt"
   "github.com/jinzhu/gorm"

   "kingdee-dbapi/logger"

   //"gorm.io/driver/sqlserver"
   //"gorm.io/gorm"

   "github.com/jinzhu/gorm"
   _ "github.com/jinzhu/gorm/dialects/mssql"
)

@@ -14,12 +19,14 @@
func Init(username, password, addr, dbName string) error {
   var err error

   sqlServer := fmt.Sprintf("sqlserver://%s:%s@%s:1433?database=%s",
   sqlServer := fmt.Sprintf("sqlserver://%s:%s@%s:1433?database=%s;encrypt=disable;",
      username, password, addr, dbName)
   fmt.Println(sqlServer)

   logger.Debug("sqlServer地址:%s", sqlServer)
   // 打开数据库连接
   //db, err = gorm.Open("mssql", "sqlserver://sa:LZdba@)@)@10.6.201.7:1433?database=LZGS")
   db, err = gorm.Open("mssql", sqlServer)
   // gorm 2.0
   //db, err = gorm.Open(sqlserver.Open(sqlServer), &gorm.Config{})
   if err != nil {
      return err
   }
@@ -31,9 +38,16 @@
   return db
}

// CloseDB .
// 2.0 CloseDB .
//func CloseDB() {
//   sqlDB, err := db.DB()
//   if err != nil {
//      return
//   }
//
//   sqlDB.Close()
//}

func CloseDB() {
   if db != nil {
      db.Close()
   }
   db.Close()
}