修改Doris提交格式

factory/doris_factory.go

@@ -72,12 +72,13 @@ func (f *DorisFactory) InsertCSV(database, table, csvData string, skipHeader boo
 
 	url := fmt.Sprintf("http://%s:%d/api/%s/%s/_stream_load", f.FEHost, f.FEPort, database, table)
 
+	fmt.Print(url)
+
 	// 使用 resty 的 API
 	resp, err := f.client.R().
 		SetBasicAuth(f.Username, f.Password).
-		SetHeader("Content-Type", "text/plain").
-		SetHeader("format", "csv").
-		SetHeader("column_separator", ",").
+		SetHeader("column_separator", ","). // 必需
+		SetHeader("enclose", "\"").
 		SetBody(csvData).
 		Put(url)