踢出gin

factory/database/db_factory.go

@@ -112,6 +112,13 @@ func (f *DBFactory) Close() error {
 	return nil
 }
 
+// GetDBType 得到当前使用数据库类型
+func (f *DBFactory) GetDBType() string {
+	cfg := config.GetConfig()
+	dbConfig := cfg.GetDatabase()
+	return dbConfig.Type
+}
+
 // QueryToJSON 快捷查询，直接返回 JSON 字节流
 func (f *DBFactory) QueryToJSON(sql string) *types.QueryResult {
 	return functions.QueryToJSON(f.db, sql)

gct.sh

@@ -52,18 +52,18 @@ else
 fi
 
 # 检查标签是否已存在
-if git rev-parse "$VERSION_TAG" >/dev/null 2>&1; then
-    echo "错误: 标签 '$VERSION_TAG' 已经存在。"
-    exit 1
-fi
+#if git rev-parse "$VERSION_TAG" >/dev/null 2>&1; then
+ #   echo "错误: 标签 '$VERSION_TAG' 已经存在。"
+  #  exit 1
+#fi
 
 # 创建标签
-git tag "$VERSION_TAG"
-if [ $? -ne 0 ]; then
-    echo "错误: 创建标签失败。"
-    exit 1
-fi
-echo "✅ 标签 '$VERSION_TAG' 已创建"
+#git tag "$VERSION_TAG"
+#if [ $? -ne 0 ]; then
+#    echo "错误: 创建标签失败。"
+#    exit 1
+#fi
+#echo "✅ 标签 '$VERSION_TAG' 已创建"
 
 # 推送到远程仓库并推送标签
 echo "正在推送到远程仓库..."
@@ -73,10 +73,10 @@ if [ $? -ne 0 ]; then
     exit 1
 fi
 
-git push origin "$VERSION_TAG"
-if [ $? -ne 0 ]; then
-    echo "错误: 推送标签失败。"
-    exit 1
-fi
+#git push origin "$VERSION_TAG"
+#if [ $? -ne 0 ]; then
+#    echo "错误: 推送标签失败。"
+#    exit 1
+#fi
 
-echo "✅ 完成！提交已推送，版本标签 $VERSION_TAG 已创建并推送。"
+#echo "✅ 完成！提交已推送，版本标签 $VERSION_TAG 已创建并推送。"

myhandle/queryHandlerBytes.go

@@ -0,0 +1,36 @@
+package myhandle
+
+import (
+	"encoding/json"
+	"net/http"
+
+	"git.x2erp.com/qdy/go-base/types"
+	"git.x2erp.com/qdy/go-db/factory/database"
+)
+
+// 最简单的 queryHandler，只处理 []byte 返回
+func QueryHandlerBytes(
+	w http.ResponseWriter,
+	r *http.Request,
+	dbFactory *database.DBFactory,
+	handlerFunc func(*database.DBFactory, types.QueryRequest) []byte,
+) {
+	// 解析请求参数
+	var req types.QueryRequest
+	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
+		// 返回 CSV 格式的错误信息
+		errorCSV := "error,Invalid request body\n"
+		w.Header().Set("Content-Type", "text/csv")
+		w.WriteHeader(http.StatusBadRequest)
+		w.Write([]byte(errorCSV))
+		return
+	}
+
+	// 调用业务逻辑函数
+	csvData := handlerFunc(dbFactory, req)
+
+	// 直接返回 CSV 数据（包含错误信息时也会被正确处理）
+	w.Header().Set("Content-Type", "text/csv")
+	w.Header().Set("Content-Disposition", "attachment; filename=query_result.csv")
+	w.Write(csvData)
+}

myhandle/queryHandlerJson.go

@@ -0,0 +1,38 @@
+package myhandle
+
+import (
+	"encoding/json"
+	"net/http"
+	"time"
+
+	"git.x2erp.com/qdy/go-base/types"
+	"git.x2erp.com/qdy/go-db/factory/database"
+)
+
+// queryHandler - 最简单的版本
+func QueryHandlerJson(
+	w http.ResponseWriter,
+	r *http.Request,
+	dbFactory *database.DBFactory,
+	handlerFunc func(*database.DBFactory, types.QueryRequest) *types.QueryResult,
+) {
+	// 解析请求参数
+	var req types.QueryRequest
+	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
+		// 如果解析失败，也返回 QueryResult 格式
+		w.Header().Set("Content-Type", "application/json")
+		json.NewEncoder(w).Encode(&types.QueryResult{
+			Success: false,
+			Error:   "Invalid request body: " + err.Error(),
+			Time:    time.Now().Format(time.RFC3339),
+		})
+		return
+	}
+
+	// 执行业务逻辑
+	result := handlerFunc(dbFactory, req)
+
+	// 设置头，写入结果
+	w.Header().Set("Content-Type", "application/json")
+	json.NewEncoder(w).Encode(result)
+}