feat: 日志查询支持doris --story=121933504

pkg/unify-query/Makefile

@@ -50,3 +50,7 @@ addlicense:
 .PHONY: imports
 imports: addlicense
 	goimports-reviser -rm-unused -set-alias -format -project-name "github.com/TencentBlueKing/bkmonitor-datalink/pkg" ./...
+
+.PHONY: race
+race:
+	go test -race -timeout 1m -parallel 8  ./...

pkg/unify-query/influxdb/router_mock.go

@@ -34,6 +34,7 @@ const (
 	ResultTableEs       = "result_table.es"
 	ResultTableBkBaseEs = "result_table.bk_base_es"
 	ResultTableBkSQL    = "result_table.bk_sql"
+	ResultTableDoris    = "result_table.doris"
 )
 
 var (
@@ -123,7 +124,7 @@ func MockSpaceRouter(ctx context.Context) {
 		)
 		tsdb.SetStorage("2", &tsdb.Storage{Type: consul.InfluxDBStorageType})
 		tsdb.SetStorage("3", &tsdb.Storage{Type: consul.ElasticsearchStorageType, Address: mock.EsUrl})
-		tsdb.SetStorage("4", &tsdb.Storage{Type: consul.BkSqlStorageType, Address: mock.BkSQLUrl})
+		tsdb.SetStorage("4", &tsdb.Storage{Type: consul.BkSqlStorageType, Address: mock.BkBaseUrl})
 
 		r := GetInfluxDBRouter()
 		r.clusterInfo = ir.ClusterInfo{
@@ -183,6 +184,9 @@ func MockSpaceRouter(ctx context.Context) {
 					ResultTableBkBaseEs: &ir.SpaceResultTable{
 						TableId: ResultTableBkBaseEs,
 					},
+					ResultTableDoris: &ir.SpaceResultTable{
+						TableId: ResultTableDoris,
+					},
 				},
 			},
 			ir.ResultTableDetailInfo{
@@ -195,6 +199,7 @@ func MockSpaceRouter(ctx context.Context) {
 					Measurement:     "kubelet_info",
 					BcsClusterID:    "BCS-K8S-00000",
 					MeasurementType: redis.BkSplitMeasurement,
+					StorageType:     consul.VictoriaMetricsStorageType,
 					DataLabel:       "kubelet_info",
 				},
 				"system.cpu_summary": &ir.ResultTableDetail{
@@ -206,6 +211,7 @@ func MockSpaceRouter(ctx context.Context) {
 					VmRt:            "",
 					Fields:          []string{"usage", "free"},
 					MeasurementType: redis.BKTraditionalMeasurement,
+					StorageType:     consul.InfluxDBStorageType,
 					DataLabel:       "cpu_summary",
 				},
 				"system.cpu_detail": &ir.ResultTableDetail{
@@ -214,6 +220,7 @@ func MockSpaceRouter(ctx context.Context) {
 					VmRt:            "100147_ieod_system_cpu_detail_raw",
 					Fields:          []string{"usage", "free"},
 					MeasurementType: redis.BKTraditionalMeasurement,
+					StorageType:     consul.InfluxDBStorageType,
 					DataLabel:       "cpu_detail",
 				},
 				"system.disk": &ir.ResultTableDetail{
@@ -222,6 +229,7 @@ func MockSpaceRouter(ctx context.Context) {
 					VmRt:            "100147_ieod_system_disk_raw",
 					Fields:          []string{"usage", "free"},
 					MeasurementType: redis.BKTraditionalMeasurement,
+					StorageType:     consul.InfluxDBStorageType,
 					DataLabel:       "disk",
 				},
 				ResultTableVM: &ir.ResultTableDetail{
@@ -231,6 +239,7 @@ func MockSpaceRouter(ctx context.Context) {
 					Fields:          vmFiedls,
 					BcsClusterID:    "BCS-K8S-00000",
 					MeasurementType: redis.BkSplitMeasurement,
+					StorageType:     consul.VictoriaMetricsStorageType,
 					DataLabel:       "vm",
 				},
 				ResultTableInfluxDB: &ir.ResultTableDetail{
@@ -243,12 +252,14 @@ func MockSpaceRouter(ctx context.Context) {
 					MeasurementType: redis.BkSplitMeasurement,
 					ClusterName:     "default",
 					DataLabel:       "influxdb",
+					StorageType:     consul.InfluxDBStorageType,
 				},
 				ResultTableEs: &ir.ResultTableDetail{
-					StorageId:  3,
-					TableId:    ResultTableEs,
-					DB:         "es_index",
-					SourceType: "bkdata",
+					StorageId:   3,
+					TableId:     ResultTableEs,
+					DB:          "es_index",
+					SourceType:  "",
+					StorageType: consul.ElasticsearchStorageType,
 					StorageClusterRecords: []ir.Record{
 						{
 							StorageID: 3,
@@ -264,14 +275,25 @@ func MockSpaceRouter(ctx context.Context) {
 					DataLabel: "es",
 				},
 				ResultTableBkSQL: &ir.ResultTableDetail{
-					StorageId: 4,
-					TableId:   ResultTableBkSQL,
-					DataLabel: "bksql",
+					StorageId:   4,
+					TableId:     ResultTableBkSQL,
+					DataLabel:   "bksql",
+					DB:          "2_bklog_bkunify_query_doris",
+					StorageType: consul.BkSqlStorageType,
+				},
+				ResultTableDoris: &ir.ResultTableDetail{
+					StorageId:   4,
+					TableId:     ResultTableDoris,
+					DB:          "2_bklog_bkunify_query_doris",
+					Measurement: "doris",
+					DataLabel:   "bksql",
+					StorageType: consul.BkSqlStorageType,
 				},
 				ResultTableBkBaseEs: &ir.ResultTableDetail{
-					SourceType: "bkdata",
-					DB:         "es_index",
-					DataLabel:  "bkbase_es",
+					SourceType:  "bkdata",
+					DB:          "es_index",
+					DataLabel:   "bkbase_es",
+					StorageType: consul.ElasticsearchStorageType,
 				},
 			}, nil,
 			ir.DataLabelToResultTable{