qast.h 3.0 KB
Newer Older
H
hzcheng 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef TDENGINE_TAST_H
#define TDENGINE_TAST_H

19
#include <tbuffer.h>
H
hzcheng 已提交
20 21 22 23
#ifdef __cplusplus
extern "C" {
#endif

24
#include <tskiplist.h>
25
#include "os.h"
H
hzcheng 已提交
26

S
slguan 已提交
27
#include "taosmsg.h"
H
hzcheng 已提交
28
#include "taosdef.h"
29
#include "tvariant.h"
H
hzcheng 已提交
30

H
hjxilinx 已提交
31
struct tExprNode;
H
hzcheng 已提交
32 33 34 35 36
struct SSchema;
struct tSkipList;
struct tSkipListNode;

enum {
H
hjxilinx 已提交
37 38
  TSQL_NODE_EXPR  = 0x1,
  TSQL_NODE_COL   = 0x2,
H
hzcheng 已提交
39 40 41
  TSQL_NODE_VALUE = 0x4,
};

S
slguan 已提交
42 43 44 45 46 47 48 49
typedef bool (*__result_filter_fn_t)(const void *, void *);
typedef void (*__do_filter_suppl_fn_t)(void *, void *);

/**
 * this structure is used to filter data in tags, so the offset of filtered tag column in tagdata string is required
 *
 */
typedef struct tQueryInfo {
50
  int32_t       colIndex; // index of column in schema
S
slguan 已提交
51
  uint8_t       optr;     // expression operator
H
hjxilinx 已提交
52
  SSchema       sch;      // schema of tags
S
slguan 已提交
53 54 55 56 57 58 59 60 61 62
  tVariant      q;        // query condition value on the specific schema, filter expression
  __compar_fn_t compare;  // filter function
} tQueryInfo;

typedef struct SBinaryFilterSupp {
  __result_filter_fn_t   fp;
  __do_filter_suppl_fn_t setupInfoFn;
  void *                 pExtInfo;
} SBinaryFilterSupp;

H
hjxilinx 已提交
63
typedef struct tExprNode {
H
hzcheng 已提交
64 65
  uint8_t nodeType;
  union {
H
[td-32]  
hjxilinx 已提交
66
    struct {
67 68 69
      uint8_t optr;             // filter operator
      uint8_t hasPK;            // 0: do not contain primary filter, 1: contain
      void *  info;             // support filter operation on this expression only available for leaf node
H
[td-32]  
hjxilinx 已提交
70
      
H
hjxilinx 已提交
71 72
      struct tExprNode *pLeft;  // left child pointer
      struct tExprNode *pRight; // right child pointer
H
[td-32]  
hjxilinx 已提交
73 74 75
    } _node;
    struct SSchema *pSchema;
    tVariant *      pVal;
H
hzcheng 已提交
76
  };
H
hjxilinx 已提交
77
} tExprNode;
H
hzcheng 已提交
78

H
hjxilinx 已提交
79
void tSQLBinaryExprFromString(tExprNode **pExpr, SSchema *pSchema, int32_t numOfCols, char *src, int32_t len);
H
hzcheng 已提交
80

H
hjxilinx 已提交
81
void tSQLBinaryExprToString(tExprNode *pExpr, char *dst, int32_t *len);
H
hzcheng 已提交
82

83
void tExprTreeDestroy(tExprNode **pExprs, void (*fp)(void*));
H
hzcheng 已提交
84

85
void tExprTreeTraverse(tExprNode *pExpr, SSkipList *pSkipList, SArray *result, SBinaryFilterSupp *param);
H
hzcheng 已提交
86

H
hjxilinx 已提交
87
void tSQLBinaryExprCalcTraverse(tExprNode *pExprs, int32_t numOfRows, char *pOutput, void *param, int32_t order,
H
hzcheng 已提交
88 89
                                char *(*cb)(void *, char *, int32_t));

H
hjxilinx 已提交
90
void tSQLBinaryExprTrv(tExprNode *pExprs, int32_t *val, int16_t *ids);
H
hzcheng 已提交
91

H
hjxilinx 已提交
92 93
uint8_t getBinaryExprOptr(SSQLToken *pToken);

94 95
SBuffer exprTreeToBinary(tExprNode* pExprTree);

96
int32_t exprTreeFromBinary(const void* pBuf, size_t size, tExprNode** pExprNode);
97

H
hzcheng 已提交
98 99 100 101 102
#ifdef __cplusplus
}
#endif

#endif  // TDENGINE_TAST_H