go-svc-agent/functions/query_json.go

package functions

import (
	"git.x2erp.com/qdy/go-base/ctx"
	"git.x2erp.com/qdy/go-base/model/request/dorisreq"
	"git.x2erp.com/qdy/go-base/model/response"

	"git.x2erp.com/qdy/go-db/factory/database"
)

// 执行查询，返回CSV数据格式。无参数查询
func QueryToJSON(dbname string, dbsFactory *database.DBSFactory, req dorisreq.QueryRequest, reqCtx *ctx.RequestContext) (*response.QueryResult[[]map[string]interface{}], error) {

	if dbFactory, err := dbsFactory.CreateDBFactory(dbname); err != nil {
		return nil, err
	} else {
		return dbFactory.QueryToJSON(req.SQL, reqCtx), nil
	}

}

// 执行查询，返回CSV数据格式。带参数名称进行查询
func QueryParamNameToJSON(dbname string, dbsFactory *database.DBSFactory, req dorisreq.QueryRequest, reqCtx *ctx.RequestContext) (*response.QueryResult[[]map[string]interface{}], error) {

	if dbFactory, err := dbsFactory.CreateDBFactory(dbname); err != nil {
		return nil, err
	} else {
		return dbFactory.QueryParamsNameToJSON(req.SQL, req.Params, reqCtx), nil
	}

}

// 执行查询，返回JSON数据格式。带占位参数进行查询
func QueryPositionalToJSON(dbname string, dbsFactory *database.DBSFactory, req dorisreq.QueryRequest, reqCtx *ctx.RequestContext) (*response.QueryResult[[]map[string]interface{}], error) {

	if dbFactory, err := dbsFactory.CreateDBFactory(dbname); err != nil {
		return nil, err
	} else {
		return dbFactory.QueryPositionalToJSON(req.SQL, req.PositionalParams, reqCtx), nil
	}

}