db_view/service/internal/modules/data_query/route.go

package data_query

import (
	"github.com/gin-gonic/gin"

	h "dbview/service/internal/modules/data_query/handler"
	svc "dbview/service/internal/modules/data_query/service"
)

// RegisterRoutes 将 data_query 模块的路由注册到 gin 引擎
// 调用方应负责构造实际的 DataService（以具体 DataReader 实现为参数）
func RegisterRoutes(r *gin.Engine, svcObj *svc.DataService) {

	handler := h.NewHandler(svcObj)
	grp := r.Group("/database/data")
	{
		// All endpoints use POST and expect JSON bodies
		grp.POST("/query", handler.QueryDataHandler)
		grp.POST("/task/result", handler.GetTaskResultHandler)
		// WebSocket 订阅端点（用于订阅任务实时推送）
		grp.GET("/tasks/ws", handler.TaskWSHandler)

		// SQL 执行相关路由
		grp.POST("/execute", handler.ExecuteSQLHandler)
		grp.POST("/execute/task/result", handler.GetExecuteTaskResultHandler)
	}
}