ds-sdk/test/sdk_test.go

package main

import (
	"fmt"
	"git.sxidc.com/go-tools/utils/strutils"
	"git.sxidc.com/service-supports/ds-sdk/sdk"
	"git.sxidc.com/service-supports/ds-sdk/sdk/raw_sql_tpl"
	"git.sxidc.com/service-supports/ds-sdk/sdk/tag"
	"github.com/iancoleman/strcase"
	"math/rand"
	"sync"
	"testing"
	"time"
)

type Class struct {
	ID              string     `sqlmapping:"key;" mapstructure:"id"`
	Name            string     `sqlmapping:"updateClear;" mapstructure:"name"`
	StudentNum      int        `sqlmapping:"column:student_num;notUpdate;" mapstructure:"student_num_alias"`
	GraduatedTime   time.Time  `sqlresult:"callback" mapstructure:"graduated_time"`
	CreatedTime     *time.Time `mapstructure:"created_time"`
	LastUpdatedTime time.Time  `mapstructure:"last_updated_time"`
	Ignored         string     `sqlmapping:"-" mapstructure:"-"`
}

const (
	token               = "IpTTwAQweh/BP51fz5CzWKQFaXHvZe6ewvk6yOcAOkU="
	address             = "localhost"
	httpPort            = "10000"
	grpcPort            = "10001"
	namespace           = "ns-sdk-demo"
	dataSource          = "ds-sdk-demo"
	deleteSql           = "delete-sdk-demo"
	goRoutineCount      = 100
	tableName           = "test.classes"
	sqlResultTimeFormat = "2006-01-02T15:04:05.000000+08:00"
)

var (
	sqlSpec = sdk.SqlSpec{
		Clauses: "- DELETE FROM {{ .table_name }} WHERE id = '{{ .id }}'",
	}
)

func TestBasic(t *testing.T) {
	classID := strutils.SimpleUUID()
	className := strutils.SimpleUUID()
	studentNum := rand.Int31n(100)
	now := time.Now()

	insertExecuteParams, err := 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),
	}.Map()
	if err != nil {
		t.Fatal(err)
	}

	deleteExecuteParams := map[string]any{
		"table_name": tableName,
		"id":         classID,
	}

	err = sdk.InitInstance(token, address, httpPort, grpcPort, namespace, dataSource)
	if err != nil {
		t.Fatal(err)
	}

	defer func() {
		err := sdk.DestroyInstance()
		if err != nil {
			t.Fatal(err)
		}
	}()

	err = sdk.GetInstance().CreateSQL(deleteSql, sqlSpec.ToMap())
	if err != nil {
		t.Fatal(err)
	}

	defer func() {
		err = sdk.GetInstance().DeleteSQL(deleteSql)
		if err != nil {
			t.Fatal(err)
		}
	}()

	_, err = sdk.GetInstance().ExecuteRawSql(raw_sql_tpl.InsertTpl, insertExecuteParams)
	if err != nil {
		t.Fatal(err)
	}

	_, err = sdk.GetInstance().ExecuteSql(deleteSql, deleteExecuteParams)
	if err != nil {
		t.Fatal(err)
	}

	wg := sync.WaitGroup{}
	wg.Add(goRoutineCount)

	start := time.Now()

	for i := 0; i < goRoutineCount; i++ {
		go func() {
			defer wg.Done()

			err = sdk.GetInstance().Transaction(func(tx *sdk.Transaction) error {
				_, err := tx.ExecuteRawSql(raw_sql_tpl.InsertTpl, insertExecuteParams)
				if err != nil {
					return err
				}

				_, err = tx.ExecuteSql(deleteSql, deleteExecuteParams)
				if err != nil {
					return err
				}

				return nil
			})
			if err != nil {
				panic(err)
			}
		}()
	}

	wg.Wait()

	end := time.Now()

	fmt.Println(end.Sub(start).Milliseconds())
}

func TestRawSqlTemplate(t *testing.T) {
	classID := strutils.SimpleUUID()
	className := strutils.SimpleUUID()
	studentNum := rand.Int31n(100)
	newClassName := strutils.SimpleUUID()
	newStudentNum := rand.Int31n(100)

	now := time.Now()
	exceptedNowStr := now.Format(sqlResultTimeFormat)

	insertExecuteParams, err := 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),
	}.Map()
	if err != nil {
		t.Fatal(err)
	}

	deleteExecuteParams, err := raw_sql_tpl.DeleteExecuteParams{
		TableName:  tableName,
		Conditions: raw_sql_tpl.NewConditions().Equal("id", classID),
	}.Map()
	if err != nil {
		t.Fatal(err)
	}

	updateExecuteParams, err := raw_sql_tpl.UpdateExecuteParams{
		TableName: tableName,
		TableRows: raw_sql_tpl.NewTableRows().Add("name", newClassName).
			Add("student_num", newStudentNum),
		Conditions: raw_sql_tpl.NewConditions().Equal("id", classID),
	}.Map()
	if err != nil {
		t.Fatal(err)
	}

	queryExecuteParams, err := raw_sql_tpl.QueryExecuteParams{
		TableName:     tableName,
		SelectColumns: []string{"id", "name", "student_num as student_num_alias", "graduated_time", "created_time", "last_updated_time"},
		Conditions: raw_sql_tpl.NewConditions().
			Equal("id", classID).
			Equal("name", className).
			Equal("student_num", studentNum),
		PageNo:   1,
		PageSize: 1,
	}.Map()
	if err != nil {
		t.Fatal(err)
	}

	newQueryExecuteParams, err := raw_sql_tpl.QueryExecuteParams{
		TableName:     tableName,
		SelectColumns: []string{"id", "name", "student_num as student_num_alias", "graduated_time", "created_time", "last_updated_time"},
		Conditions: raw_sql_tpl.NewConditions().
			Equal("id", classID).
			Equal("name", newClassName).
			Equal("student_num", newStudentNum),
		PageNo:   0,
		PageSize: 0,
	}.Map()
	if err != nil {
		t.Fatal(err)
	}

	countExecuteParams, err := raw_sql_tpl.ConditionsExecuteParams{
		TableName: tableName,
		Conditions: raw_sql_tpl.NewConditions().
			Equal("id", classID).
			Equal("name", className).
			Equal("student_num", studentNum),
	}.Map()
	if err != nil {
		t.Fatal(err)
	}

	newCountExecuteParams, err := raw_sql_tpl.ConditionsExecuteParams{
		TableName: tableName,
		Conditions: raw_sql_tpl.NewConditions().
			Equal("id", classID).
			Equal("name", newClassName).
			Equal("student_num", newStudentNum),
	}.Map()
	if err != nil {
		t.Fatal(err)
	}

	err = sdk.InitInstance(token, address, httpPort, grpcPort, namespace, dataSource)
	if err != nil {
		t.Fatal(err)
	}

	defer func() {
		err := sdk.DestroyInstance()
		if err != nil {
			t.Fatal(err)
		}
	}()

	_, err = sdk.GetInstance().ExecuteRawSql(raw_sql_tpl.InsertTpl, insertExecuteParams)
	if err != nil {
		t.Fatal(err)
	}

	queryResults, err := sdk.GetInstance().ExecuteRawSql(raw_sql_tpl.QueryTpl, queryExecuteParams)
	if err != nil {
		t.Fatal(err)
	}

	countResults, err := sdk.GetInstance().ExecuteRawSql(raw_sql_tpl.CountTpl, countExecuteParams)
	if err != nil {
		t.Fatal(err)
	}

	classes := make([]Class, 0)
	err = sdk.ParseSqlResults(queryResults, &classes)
	if err != nil {
		t.Fatal(err)
	}

	if float64(len(classes)) != countResults[0]["count"].(float64) {
		t.Fatal("总数不正确")
	}

	if classes[0].ID != classID ||
		classes[0].Name != className ||
		classes[0].StudentNum != int(studentNum) ||
		classes[0].GraduatedTime.Format(sqlResultTimeFormat) != exceptedNowStr ||
		classes[0].CreatedTime.Format(sqlResultTimeFormat) != exceptedNowStr ||
		classes[0].LastUpdatedTime.Format(sqlResultTimeFormat) != exceptedNowStr {
		t.Fatal("查询数据不正确")
	}

	_, err = sdk.GetInstance().ExecuteRawSql(raw_sql_tpl.UpdateTpl, updateExecuteParams)
	if err != nil {
		t.Fatal(err)
	}

	queryResults, err = sdk.GetInstance().ExecuteRawSql(raw_sql_tpl.QueryTpl, newQueryExecuteParams)
	if err != nil {
		t.Fatal(err)
	}

	countResults, err = sdk.GetInstance().ExecuteRawSql(raw_sql_tpl.CountTpl, newCountExecuteParams)
	if err != nil {
		t.Fatal(err)
	}

	classes = make([]Class, 0)
	err = sdk.ParseSqlResults(queryResults, &classes)
	if err != nil {
		t.Fatal(err)
	}

	if float64(len(classes)) != countResults[0]["count"].(float64) {
		t.Fatal("总数不正确")
	}

	if classes[0].ID != classID ||
		classes[0].Name != newClassName ||
		classes[0].StudentNum != int(newStudentNum) ||
		classes[0].GraduatedTime.Format(sqlResultTimeFormat) != exceptedNowStr ||
		classes[0].CreatedTime.Format(sqlResultTimeFormat) != exceptedNowStr ||
		classes[0].LastUpdatedTime.Format(sqlResultTimeFormat) != exceptedNowStr {
		t.Fatal("查询数据不正确")
	}

	_, err = sdk.GetInstance().ExecuteRawSql(raw_sql_tpl.DeleteTpl, deleteExecuteParams)
	if err != nil {
		t.Fatal(err)
	}
}

func TestSqlMapping(t *testing.T) {
	sqlMapping, err := tag.ParseSqlMapping(&Class{})
	if err != nil {
		t.Fatal(err)
	}

	for fieldName, sqlColumn := range sqlMapping.ColumnMap {
		if fieldName != "ID" && fieldName != "Name" &&
			fieldName != "StudentNum" && fieldName != "GraduatedTime" &&
			fieldName != "CreatedTime" && fieldName != "LastUpdatedTime" {
			t.Fatal("字段名不正确")
		}

		if sqlColumn.Name != "id" && sqlColumn.Name != "name" &&
			sqlColumn.Name != "student_num" && sqlColumn.Name != "graduated_time" &&
			sqlColumn.Name != "created_time" && sqlColumn.Name != "last_updated_time" {
			t.Fatal("列名不正确")
		}

		if sqlColumn.Name != strcase.ToSnake(fieldName) {
			t.Fatal("列名不正确")
		}

		if sqlColumn.IsKey && sqlColumn.Name != "id" {
			t.Fatal("键字段不正确")
		}

		if !sqlColumn.CanUpdate && (sqlColumn.Name != "id" && sqlColumn.Name != "student_num") {
			t.Fatal("不可更新字段不正确")
		}

		if sqlColumn.CanUpdateClear && sqlColumn.Name != "name" {
			t.Fatal("可清除字段不正确")
		}
	}
}

func TestSql(t *testing.T) {
	classID := strutils.SimpleUUID()
	className := strutils.SimpleUUID()
	studentNum := rand.Int31n(100)
	newClassName := strutils.SimpleUUID()
	newStudentNum := rand.Int31n(100)
	now := time.Now()

	insertExecuteParams, err := 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),
	}.Map()
	if err != nil {
		t.Fatal(err)
	}

	deleteExecuteParams := map[string]any{
		"table_name": tableName,
		"id":         classID,
	}

	class := &Class{
		ID:            classID,
		Name:          className,
		StudentNum:    int(studentNum),
		GraduatedTime: time.Now(),
		Ignored:       "",
	}

	newClass := &Class{
		ID:            classID,
		Name:          newClassName,
		StudentNum:    int(newStudentNum),
		GraduatedTime: time.Now(),
		Ignored:       "",
	}

	err = sdk.InitInstance(token, address, httpPort, grpcPort, namespace, dataSource)
	if err != nil {
		t.Fatal(err)
	}

	defer func() {
		err := sdk.DestroyInstance()
		if err != nil {
			t.Fatal(err)
		}
	}()

	err = sdk.GetInstance().CreateSQL(deleteSql, sqlSpec.ToMap())
	if err != nil {
		t.Fatal(err)
	}

	defer func() {
		err = sdk.GetInstance().DeleteSQL(deleteSql)
		if err != nil {
			t.Fatal(err)
		}
	}()

	err = sdk.InsertEntity(sdk.GetInstance(), tableName, class)
	if err != nil {
		t.Fatal(err)
	}

	err = sdk.UpdateEntity(sdk.GetInstance(), tableName, newClass)
	if err != nil {
		t.Fatal(err)
	}

	err = sdk.DeleteEntity(sdk.GetInstance(), tableName, class)
	if err != nil {
		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)
	}

	_, err = sdk.ExecuteSql(sdk.GetInstance(), deleteSql, deleteExecuteParams)
	if err != nil {
		t.Fatal(err)
	}

	err = sdk.GetInstance().Transaction(func(tx *sdk.Transaction) error {
		err = sdk.InsertEntity(tx, tableName, class)
		if err != nil {
			t.Fatal(err)
		}

		err = sdk.UpdateEntity(tx, tableName, newClass)
		if err != nil {
			t.Fatal(err)
		}

		err = sdk.DeleteEntity(tx, tableName, class)
		if err != nil {
			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)
		}

		_, err = sdk.ExecuteSql(tx, deleteSql, deleteExecuteParams)
		if err != nil {
			t.Fatal(err)
		}

		return nil
	})
	if err != nil {
		t.Fatal(err)
	}
}