事务处理

当使用事务处理时，需要创建 Session 对象。在进行事务处理时，可以混用 ORM 方法和 RAW 方法，如下代码所示：

  1. func MyTransactionOps() error {
  2.     session := engine.NewSession()
  3.     defer session.Close()
  5.     // add Begin() before any action
  6.     if err := session.Begin(); err != nil {
  7.         return err
  8.     }
  10.     user1 := Userinfo{Username: "xiaoxiao", Departname: "dev", Alias: "lunny", Created: time.Now()}
  11.     if _, err := session.Insert(&user1); err != nil {
  12.         return err
  13.     }
  14.     user2 := Userinfo{Username: "yyy"}
  15.     if _, err = session.Where("id = ?", 2).Update(&user2); err != nil {
  16.         return err
  17.     }
  19.     if _, err = session.Exec("delete from userinfo where username = ?", user2.Username); err != nil {
  20.         return err
  21.     }
  23.     // add Commit() after all actions
  24.     return session.Commit()
  25. }
  • 注意如果您使用的是 mysql，数据库引擎为 innodb 事务才有效，myisam 引擎是不支持事务的。