|
|
@@ -417,6 +417,40 @@ func TestSql(t *testing.T) {
|
|
|
t.Fatal(err)
|
|
|
}
|
|
|
|
|
|
+ err = sdk.Insert(sdk.GetInstance(), &raw_sql_tpl.InsertExecuteParams{
|
|
|
+ TableName: tableName,
|
|
|
+ TableRows: raw_sql_tpl.NewTableRows().Add("id", classID).
|
|
|
+ Add("name", className).
|
|
|
+ Add("student_num", studentNum).
|
|
|
+ Add("graduated_time", now).
|
|
|
+ Add("created_time", now).
|
|
|
+ Add("last_updated_time", now),
|
|
|
+ })
|
|
|
+ if err != nil {
|
|
|
+ t.Fatal(err)
|
|
|
+ }
|
|
|
+
|
|
|
+ err = sdk.Update(sdk.GetInstance(), &raw_sql_tpl.UpdateExecuteParams{
|
|
|
+ TableName: tableName,
|
|
|
+ TableRows: raw_sql_tpl.NewTableRows().Add("id", classID).
|
|
|
+ Add("name", newClassName).
|
|
|
+ Add("student_num", newStudentNum),
|
|
|
+ Conditions: raw_sql_tpl.NewConditions().
|
|
|
+ Equal("id", classID),
|
|
|
+ })
|
|
|
+ if err != nil {
|
|
|
+ t.Fatal(err)
|
|
|
+ }
|
|
|
+
|
|
|
+ err = sdk.Delete(sdk.GetInstance(), &raw_sql_tpl.DeleteExecuteParams{
|
|
|
+ TableName: tableName,
|
|
|
+ Conditions: raw_sql_tpl.NewConditions().
|
|
|
+ Equal("id", classID),
|
|
|
+ })
|
|
|
+ if err != nil {
|
|
|
+ t.Fatal(err)
|
|
|
+ }
|
|
|
+
|
|
|
_, err = sdk.ExecuteRawSql(sdk.GetInstance(), raw_sql_tpl.InsertTpl, insertExecuteParams)
|
|
|
if err != nil {
|
|
|
t.Fatal(err)
|
|
|
@@ -443,6 +477,40 @@ func TestSql(t *testing.T) {
|
|
|
t.Fatal(err)
|
|
|
}
|
|
|
|
|
|
+ err = sdk.Insert(tx, &raw_sql_tpl.InsertExecuteParams{
|
|
|
+ TableName: tableName,
|
|
|
+ TableRows: raw_sql_tpl.NewTableRows().Add("id", classID).
|
|
|
+ Add("name", className).
|
|
|
+ Add("student_num", studentNum).
|
|
|
+ Add("graduated_time", now).
|
|
|
+ Add("created_time", now).
|
|
|
+ Add("last_updated_time", now),
|
|
|
+ })
|
|
|
+ if err != nil {
|
|
|
+ t.Fatal(err)
|
|
|
+ }
|
|
|
+
|
|
|
+ err = sdk.Update(tx, &raw_sql_tpl.UpdateExecuteParams{
|
|
|
+ TableName: tableName,
|
|
|
+ TableRows: raw_sql_tpl.NewTableRows().Add("id", classID).
|
|
|
+ Add("name", newClassName).
|
|
|
+ Add("student_num", newStudentNum),
|
|
|
+ Conditions: raw_sql_tpl.NewConditions().
|
|
|
+ Equal("id", classID),
|
|
|
+ })
|
|
|
+ if err != nil {
|
|
|
+ t.Fatal(err)
|
|
|
+ }
|
|
|
+
|
|
|
+ err = sdk.Delete(tx, &raw_sql_tpl.DeleteExecuteParams{
|
|
|
+ TableName: tableName,
|
|
|
+ Conditions: raw_sql_tpl.NewConditions().
|
|
|
+ Equal("id", classID),
|
|
|
+ })
|
|
|
+ if err != nil {
|
|
|
+ t.Fatal(err)
|
|
|
+ }
|
|
|
+
|
|
|
_, err = sdk.ExecuteRawSql(tx, raw_sql_tpl.InsertTpl, insertExecuteParams)
|
|
|
if err != nil {
|
|
|
t.Fatal(err)
|