Function Test_DB_Replace

contrib/drivers/gaussdb/gaussdb_z_unit_db_test.go:97–132

(t *testing.T)

}

func Test_DB_Replace(t *testing.T) {
	gtest.C(t, func(t *gtest.T) {
		createTable("t_user")
		defer dropTable("t_user")

		// Insert initial record
		i := 10
		data := g.Map{
			"id":          i,
			"passport":    fmt.Sprintf(`t%d`, i),
			"password":    fmt.Sprintf(`p%d`, i),
			"nickname":    fmt.Sprintf(`T%d`, i),
			"create_time": gtime.Now().String(),
		}
		_, err := db.Insert(ctx, "t_user", data)
		gtest.AssertNil(err)

		// Replace with new data
		data2 := g.Map{
			"id":          i,
			"passport":    fmt.Sprintf(`t%d_new`, i),
			"password":    fmt.Sprintf(`p%d_new`, i),
			"nickname":    fmt.Sprintf(`T%d_new`, i),
			"create_time": gtime.Now().String(),
		}
		_, err = db.Replace(ctx, "t_user", data2)
		gtest.AssertNil(err)

		// Verify the data was replaced
		one, err := db.GetOne(ctx, fmt.Sprintf("SELECT * FROM t_user WHERE id=?"), i)
		gtest.AssertNil(err)
		gtest.Assert(one["passport"].String(), fmt.Sprintf(`t%d_new`, i))
		gtest.Assert(one["password"].String(), fmt.Sprintf(`p%d_new`, i))
		gtest.Assert(one["nickname"].String(), fmt.Sprintf(`T%d_new`, i))
	})
}

func Test_DB_GetAll(t *testing.T) {
	table := createInitTable()