Method ExecuteQuery

server/querier/engine/clickhouse/clickhouse.go:184–332

(args *common.QuerierParams)

}

func (e *CHEngine) ExecuteQuery(args *common.QuerierParams) (*common.Result, map[string]interface{}, error) {
	// 解析show开头的sql
	// show metrics/tags from <table_name> 例：show metrics/tags from l4_flow_log
	var err error
	sql := args.Sql
	e.Context = args.Context
	e.NoPreWhere = args.NoPreWhere
	e.Language = args.Language
	e.ORGID = common.DEFAULT_ORG_ID
	if args.ORGID != "" {
		e.ORGID = args.ORGID
	}
	query_uuid := args.QueryUUID // FIXME: should be queryUUID
	debug_info := &client.DebugInfo{}
	// replace custom_biz_filter
	fromMatch := fromRegexp.FindStringSubmatch(sql)
	if len(fromMatch) > 1 {
		table := fromMatch[1]
		if table != chCommon.TABLE_NAME_ALERT_EVENT && table != chCommon.TABLE_NAME_ALERT_RECORD {
			sql, err = ReplaceCustomBizServiceFilter(sql, e.ORGID)
			if err != nil {
				return nil, nil, err
			}
		}
	}
	// Parse withSql
	withResult, withDebug, err := e.QueryWithSql(sql, args)
	if err != nil {
		if withDebug != nil {
			debug_info.Debug = append(debug_info.Debug, *withDebug)
		}
		return nil, debug_info.Get(), err
	}
	if withResult != nil {
		debug_info.Debug = append(debug_info.Debug, *withDebug)
		return withResult, debug_info.Get(), err
	}
	// Parse slimitSql
	slimitResult, slimitDebug, err := e.QuerySlimitSql(sql, args)
	if err != nil {
		if slimitDebug != nil {
			debug_info.Debug = append(debug_info.Debug, *slimitDebug)
		}
		return nil, debug_info.Get(), err
	}
	if slimitResult != nil {
		debug_info.Debug = append(debug_info.Debug, *slimitDebug)
		return slimitResult, debug_info.Get(), err
	}
	// Parse showSql
	debug := &client.Debug{
		IP:        config.Cfg.Clickhouse.Host,
		QueryUUID: query_uuid,
	}
	// For testing purposes, ParseShowSql requires the addition of the debug parameter
	result, sqlList, isShow, err := e.ParseShowSql(sql, args, debug_info)
	if isShow {
		if err != nil {