package unit_test

import (
	"testing"

	"git.wecise.com/wecise/odbserver/odb/test"
	"git.wecise.com/wecise/odbserver/test/unit/mql/alter"
	"git.wecise.com/wecise/odbserver/test/unit/mql/basic"
	"git.wecise.com/wecise/odbserver/test/unit/mql/batch"
	"git.wecise.com/wecise/odbserver/test/unit/mql/bucket"
	"git.wecise.com/wecise/odbserver/test/unit/mql/ckeys"
	"git.wecise.com/wecise/odbserver/test/unit/mql/conflict"
	"git.wecise.com/wecise/odbserver/test/unit/mql/cypher"
	"git.wecise.com/wecise/odbserver/test/unit/mql/id"
	"git.wecise.com/wecise/odbserver/test/unit/mql/network"
	"git.wecise.com/wecise/odbserver/test/unit/mql/partition"
	"git.wecise.com/wecise/odbserver/test/unit/mql/prepare"
	"git.wecise.com/wecise/odbserver/test/unit/mql/prepare_batch"
	"git.wecise.com/wecise/odbserver/test/unit/search"
)

func TestClear(t *testing.T) {

	// 顺序读取当前目录下文件，执行其中的mql
	t.Run("TestClear", func(t *testing.T) { test.MQLTest(t, "clear") })
}

func TestMqlBasic(t *testing.T) {
	t.Run("TestMqlBasic", basic.BasicTest)
}

func TestMqlCollect(t *testing.T) {
	t.Run("TestMqlCollect", basic.CollectTest)
}

func TestMqlDateTime(t *testing.T) {
	t.Run("TestMqlDateTime", basic.DateTimeTest)
}

func TestMqlDelete(t *testing.T) {
	t.Run("TestMqlDelete", basic.DeleteTest)
}

func TestMqlEnum(t *testing.T) {
	t.Run("TestMqlEnum", basic.EnumTest)
}

func TestMqlOO(t *testing.T) {
	t.Run("TestMqlOO", basic.OOTest)
}

func TestMqlAlter(t *testing.T) {
	t.Run("TestMqlAlter", alter.AlterTest)
}

func TestMqlCypher(t *testing.T) {
	t.Run("TestMqlCypher", cypher.CypherTest)
}

func TestMqlBatchInsert(t *testing.T) {
	t.Run("TestMqlBatchInsert", batch.BatchInsertTest)
}

func TestMqlBatchUpdate(t *testing.T) {
	t.Run("TestMqlBatchUpdate", batch.BatchUpdateTest)
}

func TestMqlBatchDelete(t *testing.T) {
	t.Run("TestMqlBatchDelete", batch.BatchDeleteTest)
}

func TestMqlBucketLogs(t *testing.T) {
	t.Run("TestMqlBucketLogs", bucket.BucketLogsTest)
}

func TestMqlBucketStruLogs(t *testing.T) {
	t.Run("TestMqlBucketStruLogs", bucket.BucketStruLogsTest)
}

func TestMqlBucketTSDB(t *testing.T) {
	t.Run("TestMqlBucketTSDB", bucket.BucketTSDBTest)
}

func TestMqlBucketPromdb(t *testing.T) {
	t.Run("TestMqlBucketPromdb", bucket.BucketPromdbTest)
}

func TestMqlCKInt(t *testing.T) {
	t.Run("TestMqlCKInt", ckeys.CKIntTest)
}

func TestMqlConcatKey(t *testing.T) {
	t.Run("TestMqlConcatKey", ckeys.ConcatKeyTest)
}

func TestMqlConcat2(t *testing.T) {
	t.Run("TestMqlConcat2", ckeys.Concat2Test)
}

func TestMqlConflict(t *testing.T) {
	t.Run("TestMqlConflict", conflict.ConflictTest)
}

func TestMqlSeqKey(t *testing.T) {
	t.Run("TestMqlSeqKey", id.SeqKeyTest)
}

func TestMqlUUIDKey(t *testing.T) {
	t.Run("TestMqlUUIDKey", id.UUIDKeyTest)
}

func TestMqlNetwork(t *testing.T) {
	t.Run("TestMqlNetwork", network.NetworkTest)
}

func TestMqlPartition(t *testing.T) {
	t.Run("TestMqlPartition", partition.PartitionTest)
}

func TestMqlMPartition(t *testing.T) {
	t.Run("TestMqlMPartition", partition.MPartitionTest)
}

func TestMqlPrepare(t *testing.T) {
	t.Run("TestMqlPrepare", prepare.PrepareTest)
}

func TestMqlPrepareInsertBatch(t *testing.T) {
	t.Run("TestMqlPrepareInsertBatch", prepare_batch.PrepareInsertBatchTest)
}

func TestMqlPrepareUpdateBatch(t *testing.T) {
	t.Run("TestMqlPrepareUpdateBatch", prepare_batch.PrepareUpdateBatchTest)
}

func TestMqlPrepareDeleteBatch(t *testing.T) {
	t.Run("TestMqlPrepareDeleteBatch", prepare_batch.PrepareDeleteBatchTest)
}

func TestSearchBasic(t *testing.T) {
	t.Run("TestSearchBasic", search.BasicTest)
}

func TestSearchCollect(t *testing.T) {
	t.Run("TestSearchCollect", search.CollectTest)
}

func TestSearchHuge(t *testing.T) {
	t.Run("TestSearchHuge", search.HugeTest)
}

func TestScenarioBasic(t *testing.T) {
	t.Run("TestScenarioBasic", func(t *testing.T) { test.MQLTest(t, "scenario/basic") })
}

func TestScenarioDemo1(t *testing.T) {
	t.Run("TestScenarioDemo1", func(t *testing.T) { test.MQLTest(t, "scenario/demo1") })
}

func TestScenarioDemo2(t *testing.T) {
	t.Run("TestScenarioDemo2", func(t *testing.T) { test.MQLTest(t, "scenario/demo2") })
}

func TestScenarioStep(t *testing.T) {
	t.Run("TestScenarioStep", func(t *testing.T) { test.MQLTest(t, "scenario/step") })
}

func TestScenarioStep2(t *testing.T) {
	t.Run("TestScenarioStep2", func(t *testing.T) { test.MQLTest(t, "scenario/step2") })
}

// test all //
func TestAll(t *testing.T) {
	TestClear(t)
	TestMqlBasic(t)
	TestMqlCollect(t)
	TestMqlDateTime(t)
	TestMqlDelete(t)
	TestMqlEnum(t)
	TestMqlOO(t)
	TestMqlAlter(t)
	TestMqlCypher(t)
	TestMqlBatchInsert(t)
	TestMqlBatchUpdate(t)
	TestMqlBatchDelete(t)
	TestMqlBucketLogs(t)
	TestMqlBucketStruLogs(t)
	TestMqlBucketTSDB(t)
	TestMqlBucketPromdb(t)
	TestMqlCKInt(t)
	TestMqlConcatKey(t)
	TestMqlConcat2(t)
	TestMqlConflict(t)
	TestMqlSeqKey(t)
	TestMqlUUIDKey(t)
	TestMqlNetwork(t)
	TestMqlPartition(t)
	TestMqlMPartition(t)
	TestMqlPrepare(t)
	TestMqlPrepareInsertBatch(t)
	TestMqlPrepareUpdateBatch(t)
	TestMqlPrepareDeleteBatch(t)
	TestSearchBasic(t)
	TestSearchCollect(t)
	//TestSearchHuge(t)
	//TestScenarioBasic(t)
	//TestScenarioDemo1(t)
	//TestScenarioDemo2(t)
	//TestScenarioStep(t)

	TestScenarioStep2(t)
}