注意事项

Session，Engine避坑指南

Session

正确方法

  1. //GetDbInstance里面缓存了所有mysql实例的连接对象,Engine是对于连接实例全局已经实现了单例,GetSession方法能正确的获取Engine创建的Session
  2. session := torm.GetDbInstance("encourage", "writer").GetSession()
  3. session.Begin()
  4. ...
  5. session.Commit()

错误方法

  1. //禁止将torm.DbBaseDao类型对象变成全局对象
  2. var db torm.DbBaseDao
  4. func dbdemo(){
  5.     //禁止私自创建DbBaseDao对象
  6.     db = new(torm.DbBaseDao)
  7.     //强制使用GetInstance方法获取mysql实例对象
  8.     reader := torm.GetDbInstance("default", "writer")
  9.     //此处将reader.Engine复制给全局db实例会让session全局化,session全局范围内共享
  10.     db.UpdateEngine(reader.Engine)
  11.     //这块获取的session已经是全局共享了
  12.     session := db.GetSession()
  13.     session.Begin()
  14.     //这里的数据库操作执行会出问题
  15.     ...
  16.     session.Commit()    
  17. }

Engine

正确方法

  1. //GetDbInstance里面缓存了所有mysql实例的连接对象,Engine是对于连接实例全局已经实现了单例
  2. engine := torm.GetDbInstance("encourage", "writer").Engine

错误方法

  1. //禁止将torm.DbBaseDao类型对象变成全局对象
  2. var db torm.DbBaseDao
  4. func dbdemo(){
  5.     //禁止私自创建DbBaseDao对象
  6.     db = new(torm.DbBaseDao)
  7.     //强制使用GetInstance方法获取mysql实例对象
  8.     reader := torm.GetDbInstance("default", "reader")
  9.     //此处将reader.Engine复制给全局db实例会让session全局化,session全局范围内共享
  10.     db.UpdateEngine(reader.Engine)
  11. }

表结构体私有化

用自动代码生成工具（xorm）生成的表映射结构体，在使用的时候是并发不安全的，请不要当做共享变量来使用，
正确的方式是作为私有变量，即谁使用谁实例化

自动生产的表模型如下

  1. package sqlFollowClass
  3. import (
  4.     "github.com/tal-tech/torm"
  5. )
  7. type XesOfflineWarn struct {
  8.     Id          int   `xorm:"not null pk autoincr INT(10)"`
  9.     OfflineType int   `xorm:"not null default 2 comment('离线类型 2不在线 3挂机') TINYINT(4)"`
  10.     TimeSec     int   `xorm:"not null default 2 comment('时间分钟') INT(11)"`
  11.     BizId       int   `xorm:"not null default 0 comment('业务ID') INT(11)"`
  12.     PlanId      int   `xorm:"not null default 0 comment('场次ID') index(plan_id_stu_id) INT(11)"`
  13.     ClassId     int   `xorm:"not null default 0 comment('班级ID') INT(11)"`
  14.     StuId       int   `xorm:"not null default 0 comment('学生ID') index(plan_id_stu_id) INT(11)"`
  15.     TeacherId   int   `xorm:"not null default 0 comment('辅导老师ID') INT(11)"`
  16.     CreateTime  int64 `xorm:"not null default 0 comment('创建时间戳') BIGINT(20)"`
  17. }
  19. type XesOfflineWarnDao struct {
  20.     torm.DbBaseDao
  21. }
  23. func NewXesOfflineWarnDao(v ...interface{}) *XesOfflineWarnDao {
  24.     this := new(XesOfflineWarnDao)
  25.     if ins := torm.GetDbInstance("default", "writer"); ins != nil {
  26.         this.UpdateEngine(ins.Engine)
  27.     } else {
  28.         return nil
  29.     }
  30.     if len(v) != 0 {
  31.         this.UpdateEngine(v...)
  32.     }
  33.     return this
  34. }
  36. func (this *XesOfflineWarnDao) Get(mId torm.Param) (ret []XesOfflineWarn, err error) {
  37.     ret = make([]XesOfflineWarn, 0)
  38.     this.InitSession()
  40.     this.BuildQuery(mId, "id")
  42.     err = this.Session.Find(&ret)
  43.     return
  44. }

服务层调用示例

  1. //正确方式
  2. for {
  3.     //每次循环，代表一个执行分支
  4.     dbins := sqlFollowClass.NewXesOfflineWarnDao()
  5.     dbins.Get(torm.Param(1))
  6. }
  8. //错误方式
  9. dbins2 := sqlFollowClass.NewXesOfflineWarnDao()
  10. for {
  11.     go func() {
  12.         dbins2.Get(torm.Param(1))
  13.     }()
  15.     go func() {
  16.         dbins2.Get(torm.Param(1))
  17.     }()
  19.     go func() {
  20.         dbins2.Get(torm.Param(1))
  21.     }()
  22. }