Transaction

Transaction

If you want to begin a transaction, you have to create a session with engine.NewSession() at first, and then start session.Begin() and don’t forget invoke session.Commit() after all operations finished.

Don’t forget invoke session.Close().

1. session := engine.NewSession()
2. defer session.Close()

4. // add Begin() before any action
5. err := session.Begin()
6. user1 := Userinfo{Username: "xiaoxiao", Departname: "dev", Alias: "lunny", Created: time.Now()}
7. _, err = session.Insert(&user1)
8. if err != nil {
9. session.Rollback()
10. return
11. }
12. user2 := Userinfo{Username: "yyy"}
13. _, err = session.Where("id = ?", 2).Update(&user2)
14. if err != nil {
15. session.Rollback()
16. return
17. }

19. _, err = session.Exec("delete from userinfo where username = ?", user2.Username)
20. if err != nil {
21. session.Rollback()
22. return
23. }

25. // add Commit() after all actions
26. err = session.Commit()
27. if err != nil {
28. return
29. }