Method QueryWithSql

server/querier/engine/clickhouse/clickhouse.go:1004–1044

(sql string, args *common.QuerierParams)

}

func (e *CHEngine) QueryWithSql(sql string, args *common.QuerierParams) (*common.Result, *client.Debug, error) {
	sql, callbacks, columnSchemaMap, err := e.ParseWithSql(sql)
	if err != nil {
		log.Error(err)
		return nil, nil, err
	}
	if sql == "" {
		return nil, nil, nil
	}

	query_uuid := args.QueryUUID
	debug := &client.Debug{
		IP:        config.Cfg.Clickhouse.Host,
		QueryUUID: query_uuid,
	}
	debug.Sql = sql
	chClient := client.Client{
		Host:     config.Cfg.Clickhouse.Host,
		Port:     config.Cfg.Clickhouse.Port,
		UserName: config.Cfg.Clickhouse.User,
		Password: config.Cfg.Clickhouse.Password,
		DB:       e.DB,
		Debug:    debug,
		Context:  e.Context,
	}
	params := &client.QueryParams{
		Sql:             sql,
		UseQueryCache:   args.UseQueryCache,
		QueryCacheTTL:   args.QueryCacheTTL,
		Callbacks:       callbacks,
		QueryUUID:       query_uuid,
		ColumnSchemaMap: columnSchemaMap,
		ORGID:           args.ORGID,
	}
	rst, err := chClient.DoQuery(params)
	if err != nil {
		log.Error(err)
		return nil, debug, err
	}
	return rst, debug, err
}

func (e *CHEngine) ParseWithSql(sql string) (string, map[string]func(*common.Result) error, map[string]*common.ColumnSchema, error) {
	checks := checkWithSqlRegexp.FindAllStringSubmatch(sql, -1)