mirror of
https://github.com/gogf/gf.git
synced 2025-04-05 03:05:05 +08:00
1752 lines
41 KiB
Go
1752 lines
41 KiB
Go
// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
|
|
//
|
|
// This Source Code Form is subject to the terms of the MIT License.
|
|
// If a copy of the MIT was not distributed with this file,
|
|
// You can obtain one at https://github.com/gogf/gf.
|
|
|
|
package mysql_test
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
"fmt"
|
|
"testing"
|
|
|
|
"github.com/gogf/gf/v2/database/gdb"
|
|
"github.com/gogf/gf/v2/errors/gerror"
|
|
"github.com/gogf/gf/v2/frame/g"
|
|
"github.com/gogf/gf/v2/os/gctx"
|
|
"github.com/gogf/gf/v2/os/gtime"
|
|
"github.com/gogf/gf/v2/test/gtest"
|
|
)
|
|
|
|
func Test_TX_Query(t *testing.T) {
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Query("SELECT ?", 1)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Query("SELECT ?+?", 1, 2)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Query("SELECT ?+?", g.Slice{1, 2})
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Query("ERROR")
|
|
t.AssertNE(err, nil)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_Exec(t *testing.T) {
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Exec("SELECT ?", 1)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Exec("SELECT ?+?", 1, 2)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Exec("SELECT ?+?", g.Slice{1, 2})
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Exec("ERROR")
|
|
t.AssertNE(err, nil)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_Commit(t *testing.T) {
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_Rollback(t *testing.T) {
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
err = tx.Rollback()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_Prepare(t *testing.T) {
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
st, err := tx.Prepare("SELECT 100")
|
|
t.AssertNil(err)
|
|
|
|
rows, err := st.Query()
|
|
t.AssertNil(err)
|
|
|
|
array, err := rows.Columns()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(array[0], "100")
|
|
|
|
err = rows.Close()
|
|
t.AssertNil(err)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_Insert(t *testing.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
user := tx.Model(table)
|
|
|
|
_, err = user.Data(g.Map{
|
|
"id": 1,
|
|
"passport": "t1",
|
|
"password": "25d55ad283aa400af464c76d713c07ad",
|
|
"nickname": "T1",
|
|
"create_time": gtime.Now().String(),
|
|
}).Insert()
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Insert(table, g.Map{
|
|
"id": 2,
|
|
"passport": "t1",
|
|
"password": "25d55ad283aa400af464c76d713c07ad",
|
|
"nickname": "T1",
|
|
"create_time": gtime.Now().String(),
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
n, err := tx.Model(table).Count()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(n, int64(2))
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_BatchInsert(t *testing.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Insert(table, g.List{
|
|
{
|
|
"id": 2,
|
|
"passport": "t",
|
|
"password": "25d55ad283aa400af464c76d713c07ad",
|
|
"nickname": "T2",
|
|
"create_time": gtime.Now().String(),
|
|
},
|
|
{
|
|
"id": 3,
|
|
"passport": "t3",
|
|
"password": "25d55ad283aa400af464c76d713c07ad",
|
|
"nickname": "T3",
|
|
"create_time": gtime.Now().String(),
|
|
},
|
|
}, 10)
|
|
t.AssertNil(err)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
n, err := db.Model(table).Count()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(n, int64(2))
|
|
})
|
|
}
|
|
|
|
func Test_TX_BatchReplace(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Replace(table, g.List{
|
|
{
|
|
"id": 2,
|
|
"passport": "USER_2",
|
|
"password": "PASS_2",
|
|
"nickname": "NAME_2",
|
|
"create_time": gtime.Now().String(),
|
|
},
|
|
{
|
|
"id": 4,
|
|
"passport": "USER_4",
|
|
"password": "PASS_4",
|
|
"nickname": "NAME_4",
|
|
"create_time": gtime.Now().String(),
|
|
},
|
|
}, 10)
|
|
t.AssertNil(err)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
n, err := db.Model(table).Count()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(n, int64(TableSize))
|
|
|
|
value, err := db.Model(table).Fields("password").Where("id", 2).Value()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(value.String(), "PASS_2")
|
|
})
|
|
}
|
|
|
|
func Test_TX_BatchSave(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Save(table, g.List{
|
|
{
|
|
"id": 4,
|
|
"passport": "USER_4",
|
|
"password": "PASS_4",
|
|
"nickname": "NAME_4",
|
|
"create_time": gtime.Now().String(),
|
|
},
|
|
}, 10)
|
|
t.AssertNil(err)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
n, err := db.Model(table).Count()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(n, int64(TableSize))
|
|
|
|
value, err := db.Model(table).Fields("password").Where("id", 4).Value()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(value.String(), "PASS_4")
|
|
})
|
|
}
|
|
|
|
func Test_TX_Replace(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Replace(table, g.Map{
|
|
"id": 1,
|
|
"passport": "USER_1",
|
|
"password": "PASS_1",
|
|
"nickname": "NAME_1",
|
|
"create_time": gtime.Now().String(),
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
err = tx.Rollback()
|
|
t.AssertNil(err)
|
|
|
|
value, err := db.Model(table).Fields("nickname").Where("id", 1).Value()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(value.String(), "name_1")
|
|
})
|
|
}
|
|
|
|
func Test_TX_Save(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Save(table, g.Map{
|
|
"id": 1,
|
|
"passport": "USER_1",
|
|
"password": "PASS_1",
|
|
"nickname": "NAME_1",
|
|
"create_time": gtime.Now().String(),
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
value, err := db.Model(table).Fields("nickname").Where("id", 1).Value()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(value.String(), "NAME_1")
|
|
})
|
|
}
|
|
|
|
func Test_TX_Update(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
result, err := tx.Update(table, "create_time='2019-10-24 10:00:00'", "id=3")
|
|
t.AssertNil(err)
|
|
|
|
n, _ := result.RowsAffected()
|
|
t.Assert(n, 1)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Model(table).Fields("create_time").Where("id", 3).Value()
|
|
t.AssertNE(err, nil)
|
|
|
|
value, err := db.Model(table).Fields("create_time").Where("id", 3).Value()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(value.String(), "2019-10-24 10:00:00")
|
|
})
|
|
}
|
|
|
|
func Test_TX_GetAll(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
result, err := tx.GetAll(fmt.Sprintf("SELECT * FROM %s WHERE id=?", table), 1)
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(result), 1)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_GetOne(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
record, err := tx.GetOne(fmt.Sprintf("SELECT * FROM %s WHERE passport=?", table), "user_2")
|
|
t.AssertNil(err)
|
|
|
|
t.AssertNE(record, nil)
|
|
t.Assert(record["nickname"].String(), "name_2")
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_GetValue(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
value, err := tx.GetValue(fmt.Sprintf("SELECT id FROM %s WHERE passport=?", table), "user_3")
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(value.Int(), 3)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_GetCount(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
count, err := tx.GetCount("SELECT * FROM " + table)
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(count, int64(TableSize))
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_GetStruct(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
type User struct {
|
|
Id int
|
|
Passport string
|
|
Password string
|
|
NickName string
|
|
CreateTime gtime.Time
|
|
}
|
|
user := new(User)
|
|
err = tx.GetStruct(user, fmt.Sprintf("SELECT * FROM %s WHERE id=?", table), 3)
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(user.NickName, "name_3")
|
|
t.Assert(user.CreateTime.String(), "2018-10-24 10:00:00")
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
type User struct {
|
|
Id int
|
|
Passport string
|
|
Password string
|
|
NickName string
|
|
CreateTime *gtime.Time
|
|
}
|
|
user := new(User)
|
|
err = tx.GetStruct(user, fmt.Sprintf("SELECT * FROM %s WHERE id=?", table), 3)
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(user.NickName, "name_3")
|
|
t.Assert(user.CreateTime.String(), "2018-10-24 10:00:00")
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_GetStructs(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
type User struct {
|
|
Id int
|
|
Passport string
|
|
Password string
|
|
NickName string
|
|
CreateTime gtime.Time
|
|
}
|
|
var users []User
|
|
err = tx.GetStructs(&users, fmt.Sprintf("SELECT * FROM %s WHERE id>=?", table), 1)
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(users), TableSize)
|
|
t.Assert(users[0].Id, 1)
|
|
t.Assert(users[1].Id, 2)
|
|
t.Assert(users[2].Id, 3)
|
|
t.Assert(users[0].NickName, "name_1")
|
|
t.Assert(users[1].NickName, "name_2")
|
|
t.Assert(users[2].NickName, "name_3")
|
|
t.Assert(users[2].CreateTime.String(), "2018-10-24 10:00:00")
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
type User struct {
|
|
Id int
|
|
Passport string
|
|
Password string
|
|
NickName string
|
|
CreateTime *gtime.Time
|
|
}
|
|
var users []User
|
|
err = tx.GetStructs(&users, fmt.Sprintf("SELECT * FROM %s WHERE id>=?", table), 1)
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(users), TableSize)
|
|
t.Assert(users[0].Id, 1)
|
|
t.Assert(users[1].Id, 2)
|
|
t.Assert(users[2].Id, 3)
|
|
t.Assert(users[0].NickName, "name_1")
|
|
t.Assert(users[1].NickName, "name_2")
|
|
t.Assert(users[2].NickName, "name_3")
|
|
t.Assert(users[2].CreateTime.String(), "2018-10-24 10:00:00")
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_GetScan(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
type User struct {
|
|
Id int
|
|
Passport string
|
|
Password string
|
|
NickName string
|
|
CreateTime gtime.Time
|
|
}
|
|
user := new(User)
|
|
err = tx.GetScan(user, fmt.Sprintf("SELECT * FROM %s WHERE id=?", table), 3)
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(user.NickName, "name_3")
|
|
t.Assert(user.CreateTime.String(), "2018-10-24 10:00:00")
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
type User struct {
|
|
Id int
|
|
Passport string
|
|
Password string
|
|
NickName string
|
|
CreateTime *gtime.Time
|
|
}
|
|
user := new(User)
|
|
err = tx.GetScan(user, fmt.Sprintf("SELECT * FROM %s WHERE id=?", table), 3)
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(user.NickName, "name_3")
|
|
t.Assert(user.CreateTime.String(), "2018-10-24 10:00:00")
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
type User struct {
|
|
Id int
|
|
Passport string
|
|
Password string
|
|
NickName string
|
|
CreateTime gtime.Time
|
|
}
|
|
var users []User
|
|
err = tx.GetScan(&users, fmt.Sprintf("SELECT * FROM %s WHERE id>=?", table), 1)
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(users), TableSize)
|
|
t.Assert(users[0].Id, 1)
|
|
t.Assert(users[1].Id, 2)
|
|
t.Assert(users[2].Id, 3)
|
|
t.Assert(users[0].NickName, "name_1")
|
|
t.Assert(users[1].NickName, "name_2")
|
|
t.Assert(users[2].NickName, "name_3")
|
|
t.Assert(users[2].CreateTime.String(), "2018-10-24 10:00:00")
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
type User struct {
|
|
Id int
|
|
Passport string
|
|
Password string
|
|
NickName string
|
|
CreateTime *gtime.Time
|
|
}
|
|
var users []User
|
|
err = tx.GetScan(&users, fmt.Sprintf("SELECT * FROM %s WHERE id>=?", table), 1)
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(users), TableSize)
|
|
t.Assert(users[0].Id, 1)
|
|
t.Assert(users[1].Id, 2)
|
|
t.Assert(users[2].Id, 3)
|
|
t.Assert(users[0].NickName, "name_1")
|
|
t.Assert(users[1].NickName, "name_2")
|
|
t.Assert(users[2].NickName, "name_3")
|
|
t.Assert(users[2].CreateTime.String(), "2018-10-24 10:00:00")
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
})
|
|
}
|
|
|
|
func Test_TX_Delete(t *testing.T) {
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Delete(table, 1)
|
|
t.AssertNil(err)
|
|
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
n, err := db.Model(table).Count()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(n, int64(0))
|
|
t.Assert(tx.IsClosed(), true)
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Delete(table, 1)
|
|
t.AssertNil(err)
|
|
|
|
n, err := tx.Model(table).Count()
|
|
t.AssertNil(err)
|
|
t.Assert(n, int64(0))
|
|
|
|
err = tx.Rollback()
|
|
t.AssertNil(err)
|
|
|
|
n, err = db.Model(table).Count()
|
|
t.AssertNil(err)
|
|
t.Assert(n, int64(TableSize))
|
|
t.AssertNE(n, int64(0))
|
|
t.Assert(tx.IsClosed(), true)
|
|
})
|
|
}
|
|
|
|
func Test_Transaction(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
ctx := context.TODO()
|
|
err := db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
_, err := tx.Ctx(ctx).Replace(table, g.Map{
|
|
"id": 1,
|
|
"passport": "USER_1",
|
|
"password": "PASS_1",
|
|
"nickname": "NAME_1",
|
|
"create_time": gtime.Now().String(),
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(tx.IsClosed(), false)
|
|
return gerror.New("error")
|
|
})
|
|
t.AssertNE(err, nil)
|
|
|
|
value, err := db.Model(table).Ctx(ctx).Fields("nickname").Where("id", 1).Value()
|
|
t.AssertNil(err)
|
|
t.Assert(value.String(), "name_1")
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
ctx := context.TODO()
|
|
err := db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
_, err := tx.Replace(table, g.Map{
|
|
"id": 1,
|
|
"passport": "USER_1",
|
|
"password": "PASS_1",
|
|
"nickname": "NAME_1",
|
|
"create_time": gtime.Now().String(),
|
|
})
|
|
t.AssertNil(err)
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
value, err := db.Model(table).Fields("nickname").Where("id", 1).Value()
|
|
t.AssertNil(err)
|
|
t.Assert(value.String(), "NAME_1")
|
|
})
|
|
}
|
|
|
|
func Test_Transaction_Panic(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
ctx := context.TODO()
|
|
err := db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
_, err := tx.Replace(table, g.Map{
|
|
"id": 1,
|
|
"passport": "USER_1",
|
|
"password": "PASS_1",
|
|
"nickname": "NAME_1",
|
|
"create_time": gtime.Now().String(),
|
|
})
|
|
t.AssertNil(err)
|
|
panic("error")
|
|
return nil
|
|
})
|
|
t.AssertNE(err, nil)
|
|
|
|
value, err := db.Model(table).Fields("nickname").Where("id", 1).Value()
|
|
t.AssertNil(err)
|
|
t.Assert(value.String(), "name_1")
|
|
})
|
|
}
|
|
|
|
func Test_Transaction_Nested_Begin_Rollback_Commit(t *testing.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
// tx begin.
|
|
err = tx.Begin()
|
|
t.AssertNil(err)
|
|
|
|
// tx rollback.
|
|
_, err = tx.Model(table).Data(g.Map{
|
|
"id": 1,
|
|
"passport": "user_1",
|
|
"password": "pass_1",
|
|
"nickname": "name_1",
|
|
}).Insert()
|
|
err = tx.Rollback()
|
|
t.AssertNil(err)
|
|
|
|
// tx commit.
|
|
_, err = tx.Model(table).Data(g.Map{
|
|
"id": 2,
|
|
"passport": "user_2",
|
|
"password": "pass_2",
|
|
"nickname": "name_2",
|
|
}).Insert()
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
// check data.
|
|
all, err := db.Model(table).All()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(all), 1)
|
|
t.Assert(all[0]["id"], 2)
|
|
})
|
|
}
|
|
|
|
func Test_Transaction_Nested_TX_Transaction_UseTX(t *testing.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
db.SetDebug(true)
|
|
defer db.SetDebug(false)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
var (
|
|
err error
|
|
ctx = context.TODO()
|
|
)
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
// commit
|
|
err = tx.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = tx2.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = tx2.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = tx2.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = tx2.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err = tx2.Model(table).Data(g.Map{
|
|
"id": 1,
|
|
"passport": "USER_1",
|
|
"password": "PASS_1",
|
|
"nickname": "NAME_1",
|
|
"create_time": gtime.Now().String(),
|
|
}).Insert()
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// rollback
|
|
err = tx.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err = tx2.Model(table).Data(g.Map{
|
|
"id": 2,
|
|
"passport": "USER_2",
|
|
"password": "PASS_2",
|
|
"nickname": "NAME_2",
|
|
"create_time": gtime.Now().String(),
|
|
}).Insert()
|
|
t.AssertNil(err)
|
|
|
|
panic("error")
|
|
return err
|
|
})
|
|
t.AssertNE(err, nil)
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
all, err := db.Ctx(ctx).Model(table).All()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(all), 1)
|
|
t.Assert(all[0]["id"], 1)
|
|
|
|
// another record.
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
// commit
|
|
err = tx.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = tx2.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = tx2.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = tx2.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = tx2.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err = tx2.Model(table).Data(g.Map{
|
|
"id": 3,
|
|
"passport": "USER_1",
|
|
"password": "PASS_1",
|
|
"nickname": "NAME_1",
|
|
"create_time": gtime.Now().String(),
|
|
}).Insert()
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// rollback
|
|
err = tx.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err = tx2.Model(table).Data(g.Map{
|
|
"id": 4,
|
|
"passport": "USER_2",
|
|
"password": "PASS_2",
|
|
"nickname": "NAME_2",
|
|
"create_time": gtime.Now().String(),
|
|
}).Insert()
|
|
t.AssertNil(err)
|
|
|
|
panic("error")
|
|
return err
|
|
})
|
|
t.AssertNE(err, nil)
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
all, err = db.Ctx(ctx).Model(table).All()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(all), 2)
|
|
t.Assert(all[0]["id"], 1)
|
|
t.Assert(all[1]["id"], 3)
|
|
})
|
|
}
|
|
|
|
func Test_Transaction_Nested_TX_Transaction_UseDB(t *testing.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
// db.SetDebug(true)
|
|
// defer db.SetDebug(false)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
var (
|
|
err error
|
|
ctx = context.TODO()
|
|
)
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
// commit
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err = db.Model(table).Ctx(ctx).Data(g.Map{
|
|
"id": 1,
|
|
"passport": "USER_1",
|
|
"password": "PASS_1",
|
|
"nickname": "NAME_1",
|
|
"create_time": gtime.Now().String(),
|
|
}).Insert()
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// rollback
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err = tx2.Model(table).Ctx(ctx).Data(g.Map{
|
|
"id": 2,
|
|
"passport": "USER_2",
|
|
"password": "PASS_2",
|
|
"nickname": "NAME_2",
|
|
"create_time": gtime.Now().String(),
|
|
}).Insert()
|
|
t.AssertNil(err)
|
|
|
|
// panic makes this transaction rollback.
|
|
panic("error")
|
|
return err
|
|
})
|
|
t.AssertNE(err, nil)
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
all, err := db.Model(table).All()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(all), 1)
|
|
t.Assert(all[0]["id"], 1)
|
|
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
// commit
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err = db.Model(table).Ctx(ctx).Data(g.Map{
|
|
"id": 3,
|
|
"passport": "USER_1",
|
|
"password": "PASS_1",
|
|
"nickname": "NAME_1",
|
|
"create_time": gtime.Now().String(),
|
|
}).Insert()
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// rollback
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err = tx2.Model(table).Ctx(ctx).Data(g.Map{
|
|
"id": 4,
|
|
"passport": "USER_2",
|
|
"password": "PASS_2",
|
|
"nickname": "NAME_2",
|
|
"create_time": gtime.Now().String(),
|
|
}).Insert()
|
|
t.AssertNil(err)
|
|
|
|
// panic makes this transaction rollback.
|
|
panic("error")
|
|
return err
|
|
})
|
|
t.AssertNE(err, nil)
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
all, err = db.Model(table).All()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(all), 2)
|
|
t.Assert(all[0]["id"], 1)
|
|
t.Assert(all[1]["id"], 3)
|
|
})
|
|
}
|
|
|
|
func Test_Transaction_Nested_SavePoint_RollbackTo(t *testing.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
|
|
// tx save point.
|
|
_, err = tx.Model(table).Data(g.Map{
|
|
"id": 1,
|
|
"passport": "user_1",
|
|
"password": "pass_1",
|
|
"nickname": "name_1",
|
|
}).Insert()
|
|
err = tx.SavePoint("MyPoint")
|
|
t.AssertNil(err)
|
|
|
|
_, err = tx.Model(table).Data(g.Map{
|
|
"id": 2,
|
|
"passport": "user_2",
|
|
"password": "pass_2",
|
|
"nickname": "name_2",
|
|
}).Insert()
|
|
// tx rollback to.
|
|
err = tx.RollbackTo("MyPoint")
|
|
t.AssertNil(err)
|
|
|
|
// tx commit.
|
|
err = tx.Commit()
|
|
t.AssertNil(err)
|
|
|
|
// check data.
|
|
all, err := db.Model(table).All()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(all), 1)
|
|
t.Assert(all[0]["id"], 1)
|
|
})
|
|
}
|
|
|
|
func Test_Transaction_Method(t *testing.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
var err error
|
|
err = db.Transaction(gctx.New(), func(ctx context.Context, tx gdb.TX) error {
|
|
_, err = db.Model(table).Ctx(ctx).Data(g.Map{
|
|
"id": 1,
|
|
"passport": "t1",
|
|
"password": "25d55ad283aa400af464c76d713c07ad",
|
|
"nickname": "T1",
|
|
"create_time": gtime.Now().String(),
|
|
}).Insert()
|
|
t.AssertNil(err)
|
|
|
|
_, err = db.Ctx(ctx).Exec(ctx, fmt.Sprintf(
|
|
"insert into %s(`passport`,`password`,`nickname`,`create_time`,`id`) "+
|
|
"VALUES('t2','25d55ad283aa400af464c76d713c07ad','T2','2021-08-25 21:53:00',2) ",
|
|
table))
|
|
t.AssertNil(err)
|
|
|
|
return gerror.New("rollback")
|
|
})
|
|
t.AssertNE(err, nil)
|
|
|
|
count, err := db.Model(table).Count()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(count, int64(0))
|
|
})
|
|
}
|
|
|
|
func Test_Transaction_Propagation(t *testing.T) {
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
// Test PropagationRequired
|
|
err := db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
// Insert initial record
|
|
_, err := tx.Insert(table, g.Map{
|
|
"id": 1,
|
|
"passport": "required",
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Nested transaction with PropagationRequired
|
|
err = tx.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationRequired,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
// Should use the same transaction
|
|
_, err := tx2.Insert(table, g.Map{
|
|
"id": 2,
|
|
"passport": "required_nested",
|
|
})
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Verify both records exist
|
|
count, err := db.Model(table).Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(2))
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
// Test PropagationRequiresNew
|
|
err := db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
// Insert in outer transaction
|
|
_, err := tx.Insert(table, g.Map{
|
|
"id": 3,
|
|
"passport": "outer",
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Inner transaction with PropagationRequiresNew
|
|
err = tx.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationRequiresNew,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
// This is a new transaction
|
|
_, _ = tx2.Insert(table, g.Map{
|
|
"id": 4,
|
|
"passport": "inner_new",
|
|
})
|
|
// Simulate error to test independent rollback
|
|
return gerror.New("rollback inner transaction")
|
|
})
|
|
// Inner transaction error should not affect outer transaction
|
|
t.AssertNE(err, nil)
|
|
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Verify only outer transaction record exists
|
|
count, err := db.Model(table).Where("passport", "outer").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(1))
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
// Test PropagationNested
|
|
err := db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
// Insert in outer transaction
|
|
_, err := tx.Insert(table, g.Map{
|
|
"id": 5,
|
|
"passport": "nested_outer",
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Nested transaction
|
|
err = tx.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationNested,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, _ = tx2.Insert(table, g.Map{
|
|
"id": 6,
|
|
"passport": "nested_inner",
|
|
})
|
|
// Simulate error to test savepoint rollback
|
|
return gerror.New("rollback to savepoint")
|
|
})
|
|
t.AssertNE(err, nil)
|
|
|
|
// Insert another record after nested transaction rollback
|
|
_, err = tx.Insert(table, g.Map{
|
|
"id": 7,
|
|
"passport": "nested_after",
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Verify outer transaction records exist, but nested transaction record doesn't
|
|
count, err := db.Model(table).Where("passport", "nested_inner").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(0))
|
|
|
|
count, err = db.Model(table).Where("passport IN(?,?)",
|
|
"nested_outer", "nested_after").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(2))
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
// Test PropagationNotSupported
|
|
err := db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
// Insert in transaction
|
|
_, err := tx.Insert(table, g.Map{
|
|
"id": 8,
|
|
"passport": "tx_record",
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Non-transactional operation
|
|
err = tx.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationNotSupported,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
// Should execute without transaction
|
|
t.Assert(tx2, nil)
|
|
_, err := db.Insert(ctx, table, g.Map{
|
|
"id": 9,
|
|
"passport": "non_tx_record",
|
|
})
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return gerror.New("rollback outer transaction")
|
|
})
|
|
t.AssertNE(err, nil)
|
|
|
|
// Verify transactional record is rolled back but non-transactional record exists
|
|
count, err := db.Model(table).Where("passport", "tx_record").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(0))
|
|
|
|
count, err = db.Model(table).Where("passport", "non_tx_record").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(1))
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
// Test PropagationMandatory
|
|
err := db.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationMandatory,
|
|
}, func(ctx context.Context, tx gdb.TX) error {
|
|
return nil
|
|
})
|
|
// Should fail because no transaction exists
|
|
t.AssertNE(err, nil)
|
|
|
|
// Test within an existing transaction
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
return tx.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationMandatory,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
// Should succeed because transaction exists
|
|
_, err := tx2.Insert(table, g.Map{
|
|
"id": 10,
|
|
"passport": "mandatory",
|
|
})
|
|
return err
|
|
})
|
|
})
|
|
t.AssertNil(err)
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
// Test PropagationNever
|
|
err := db.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationNever,
|
|
}, func(ctx context.Context, tx gdb.TX) error {
|
|
// Should execute without transaction
|
|
t.Assert(tx, nil)
|
|
_, err := db.Insert(ctx, table, g.Map{
|
|
"id": 11,
|
|
"passport": "never",
|
|
})
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Test within an existing transaction
|
|
err = db.Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
|
|
return tx.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationNever,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
return nil
|
|
})
|
|
})
|
|
// Should fail because transaction exists
|
|
t.AssertNE(err, nil)
|
|
})
|
|
}
|
|
|
|
func Test_Transaction_Propagation_Complex(t *testing.T) {
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table1 := createTable()
|
|
table2 := createTable()
|
|
defer dropTable(table1)
|
|
defer dropTable(table2)
|
|
|
|
// Test nested transactions with different propagation behaviors
|
|
err := db.Transaction(ctx, func(ctx context.Context, tx1 gdb.TX) error {
|
|
// Insert in outer transaction
|
|
_, err := tx1.Insert(table1, g.Map{
|
|
"id": 1,
|
|
"passport": "outer",
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// First nested transaction (NESTED)
|
|
err = tx1.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationNested,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err := tx2.Insert(table1, g.Map{
|
|
"id": 2,
|
|
"passport": "nested1",
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Second nested transaction (REQUIRES_NEW)
|
|
err = tx2.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationRequiresNew,
|
|
}, func(ctx context.Context, tx3 gdb.TX) error {
|
|
_, _ = tx3.Insert(table1, g.Map{
|
|
"id": 3,
|
|
"passport": "new1",
|
|
})
|
|
// This will be rolled back independently
|
|
return gerror.New("rollback new transaction")
|
|
})
|
|
t.AssertNE(err, nil)
|
|
|
|
// Third nested transaction (NESTED)
|
|
return tx2.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationNested,
|
|
}, func(ctx context.Context, tx3 gdb.TX) error {
|
|
_, _ = tx3.Insert(table1, g.Map{
|
|
"id": 4,
|
|
"passport": "nested2",
|
|
})
|
|
// This will rollback to the savepoint
|
|
return gerror.New("rollback nested transaction")
|
|
})
|
|
})
|
|
t.AssertNE(err, nil)
|
|
|
|
// Fourth transaction (NOT_SUPPORTED)
|
|
// Note that, it locks table if it continues using table1.
|
|
err = tx1.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationNotSupported,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
// Should execute without transaction
|
|
t.Assert(tx2, nil)
|
|
|
|
_, err := db.Insert(ctx, table2, g.Map{
|
|
"id": 5,
|
|
"passport": "not_supported",
|
|
})
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Verify final state
|
|
// 1. "outer" should exist (committed)
|
|
count, err := db.Model(table1).Where("passport", "outer").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(1))
|
|
|
|
// 2. "nested1" should not exist (rolled back due to error)
|
|
count, err = db.Model(table1).Where("passport", "nested1").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(0))
|
|
|
|
// 3. "new1" should not exist (rolled back independently)
|
|
count, err = db.Model(table1).Where("passport", "new1").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(0))
|
|
|
|
// 4. "nested2" should not exist (rolled back to savepoint)
|
|
count, err = db.Model(table1).Where("passport", "nested2").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(0))
|
|
|
|
// 5. "not_supported" should exist (non-transactional)
|
|
count, err = db.Model(table2).Where("passport", "not_supported").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(1))
|
|
})
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
// Test transaction suspension and resume
|
|
err := db.Transaction(ctx, func(ctx context.Context, tx1 gdb.TX) error {
|
|
// Insert in outer transaction
|
|
_, err := tx1.Insert(table, g.Map{
|
|
"id": 6,
|
|
"passport": "suspend_outer",
|
|
"password": "pass6",
|
|
"nickname": "suspend_outer",
|
|
"create_time": gtime.Now().String(),
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Suspend current transaction (NOT_SUPPORTED)
|
|
err = tx1.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationNotSupported,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
// Should execute without transaction
|
|
t.Assert(tx2, nil)
|
|
|
|
// Start a new independent transaction
|
|
return db.Transaction(ctx, func(ctx context.Context, tx3 gdb.TX) error {
|
|
_, err := tx3.Insert(table, g.Map{
|
|
"id": 7,
|
|
"passport": "independent",
|
|
"password": "pass7",
|
|
"nickname": "independent",
|
|
"create_time": gtime.Now().String(),
|
|
})
|
|
return err
|
|
})
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Resume original transaction
|
|
_, err = tx1.Insert(table, g.Map{
|
|
"id": 8,
|
|
"passport": "suspend_resume",
|
|
"password": "pass8",
|
|
"nickname": "suspend_resume",
|
|
"create_time": gtime.Now().String(),
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Simulate error to rollback outer transaction
|
|
return gerror.New("rollback outer transaction")
|
|
})
|
|
t.AssertNE(err, nil)
|
|
|
|
// Verify final state
|
|
// 1. "suspend_outer" and "suspend_resume" should not exist (rolled back)
|
|
count, err := db.Model(table).Where("passport IN(?,?)",
|
|
"suspend_outer", "suspend_resume").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(0))
|
|
|
|
// 2. "independent" should exist (committed independently)
|
|
count, err = db.Model(table).Where("passport", "independent").Count()
|
|
t.AssertNil(err)
|
|
t.Assert(count, int64(1))
|
|
})
|
|
}
|
|
|
|
func Test_Transaction_ReadOnly(t *testing.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
// Test read-only transaction
|
|
err := db.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
ReadOnly: true,
|
|
}, func(ctx context.Context, tx gdb.TX) error {
|
|
// Try to modify data in read-only transaction
|
|
_, err := tx.Update(table, g.Map{"passport": "changed"}, "id=1")
|
|
// Should return error
|
|
return err
|
|
})
|
|
t.AssertNE(err, nil)
|
|
|
|
// Verify data was not modified
|
|
v, err := db.Model(table).Where("id=1").Value("passport")
|
|
t.AssertNil(err)
|
|
t.Assert(v.String(), "user_1")
|
|
})
|
|
}
|
|
|
|
func Test_Transaction_Isolation(t *testing.T) {
|
|
// Test READ UNCOMMITTED
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
err := db.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Isolation: sql.LevelReadUncommitted,
|
|
}, func(ctx context.Context, tx1 gdb.TX) error {
|
|
// Update value in first transaction
|
|
_, err := tx1.Update(table, g.Map{"passport": "dirty_read"}, "id=1")
|
|
t.AssertNil(err)
|
|
|
|
// Start another transaction to verify dirty read
|
|
err = db.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Isolation: sql.LevelReadUncommitted,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
// Should see uncommitted change in READ UNCOMMITTED
|
|
v, err := tx2.Model(table).Where("id=1").Value("passport")
|
|
t.AssertNil(err)
|
|
t.Assert(v.String(), "dirty_read")
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Rollback the first transaction
|
|
return gerror.New("rollback first transaction")
|
|
})
|
|
t.AssertNE(err, nil)
|
|
|
|
// Verify the value is rolled back
|
|
v, err := db.Model(table).Where("id=1").Value("passport")
|
|
t.AssertNil(err)
|
|
t.Assert(v.String(), "user_1")
|
|
})
|
|
|
|
// Test REPEATABLE READ (default)
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
// Start a transaction with REPEATABLE READ isolation
|
|
err := db.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationRequiresNew,
|
|
Isolation: sql.LevelRepeatableRead,
|
|
}, func(ctx context.Context, tx1 gdb.TX) error {
|
|
// First read
|
|
v1, err := tx1.Model(table).Where("id=1").Value("passport")
|
|
t.AssertNil(err)
|
|
initialValue := v1.String()
|
|
|
|
// Another transaction updates and commits the value
|
|
err = db.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationRequiresNew,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err := tx2.Update(table, g.Map{
|
|
"passport": "changed_value",
|
|
}, "id=1")
|
|
t.AssertNil(err)
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Verify the change is visible outside transaction
|
|
v, err := db.Model(table).Where("id=1").Value("passport")
|
|
t.AssertNil(err)
|
|
t.Assert(v.String(), "changed_value")
|
|
|
|
// Should still see old value in REPEATABLE READ transaction
|
|
v2, err := tx1.Model(table).Where("id=1").Value("passport")
|
|
t.AssertNil(err)
|
|
t.Assert(v2.String(), initialValue)
|
|
|
|
// Even after multiple reads, should still see the same value
|
|
v3, err := tx1.Model(table).Where("id=1").Value("passport")
|
|
t.AssertNil(err)
|
|
t.Assert(v3.String(), initialValue)
|
|
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// After transaction ends, should see the committed change
|
|
v, err := db.Model(table).Where("id=1").Value("passport")
|
|
t.AssertNil(err)
|
|
t.Assert(v.String(), "changed_value")
|
|
})
|
|
|
|
// Test SERIALIZABLE
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
|
|
err := db.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationRequiresNew,
|
|
Isolation: sql.LevelSerializable,
|
|
}, func(ctx context.Context, tx1 gdb.TX) error {
|
|
// Read all records
|
|
_, err := tx1.Model(table).All()
|
|
t.AssertNil(err)
|
|
|
|
// Try concurrent insert in another transaction
|
|
err = db.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationRequiresNew,
|
|
Isolation: sql.LevelSerializable,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err := tx2.Insert(table, g.Map{
|
|
"id": 1000,
|
|
"passport": "new_user",
|
|
})
|
|
return err
|
|
})
|
|
t.AssertNE(err, nil)
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
})
|
|
|
|
// Test READ COMMITTED
|
|
gtest.C(t, func(t *gtest.T) {
|
|
table := createInitTable()
|
|
defer dropTable(table)
|
|
err := db.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationRequiresNew,
|
|
Isolation: sql.LevelReadCommitted,
|
|
}, func(ctx context.Context, tx1 gdb.TX) error {
|
|
// First read
|
|
v1, err := tx1.Model(table).Where("id=1").Value("passport")
|
|
t.AssertNil(err)
|
|
initialValue := v1.String()
|
|
|
|
// Another transaction updates and commits
|
|
err = db.TransactionWithOptions(ctx, gdb.TxOptions{
|
|
Propagation: gdb.PropagationRequiresNew,
|
|
Isolation: sql.LevelReadCommitted,
|
|
}, func(ctx context.Context, tx2 gdb.TX) error {
|
|
_, err := tx2.Update(table, g.Map{"passport": "committed_value"}, "id=1")
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
// Should see new value in READ COMMITTED
|
|
v2, err := tx1.Model(table).Where("id=1").Value("passport")
|
|
t.AssertNil(err)
|
|
t.Assert(v2.String(), "committed_value")
|
|
t.AssertNE(v2.String(), initialValue)
|
|
return nil
|
|
})
|
|
t.AssertNil(err)
|
|
})
|
|
}
|
|
|
|
func Test_Transaction_Spread(t *testing.T) {
|
|
table := createTable()
|
|
defer dropTable(table)
|
|
|
|
db.SetDebug(true)
|
|
defer db.SetDebug(false)
|
|
|
|
gtest.C(t, func(t *gtest.T) {
|
|
var (
|
|
err error
|
|
ctx = context.TODO()
|
|
)
|
|
tx, err := db.Begin(ctx)
|
|
t.AssertNil(err)
|
|
err = db.Transaction(tx.GetCtx(), func(ctx context.Context, tx gdb.TX) error {
|
|
_, err = db.Model(table).Ctx(ctx).Data(g.Map{
|
|
"id": 1,
|
|
"passport": "USER_1",
|
|
"password": "PASS_1",
|
|
"nickname": "NAME_1",
|
|
"create_time": gtime.Now().String(),
|
|
}).Insert()
|
|
return err
|
|
})
|
|
t.AssertNil(err)
|
|
|
|
all, err := tx.Model(table).All()
|
|
t.AssertNil(err)
|
|
|
|
t.Assert(len(all), 1)
|
|
t.Assert(all[0]["id"], 1)
|
|
|
|
err = tx.Rollback()
|
|
t.AssertNil(err)
|
|
|
|
all, err = db.Ctx(ctx).Model(table).All()
|
|
t.AssertNil(err)
|
|
t.Assert(len(all), 0)
|
|
})
|
|
}
|