contentionapp/sqlstmts.h at master · homework/contentionapp · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
/* sqlstmts.h
 *
 * SQL statement definitions (used by parser)
 *
 * Created by Oliver Sharma on 2009-05-03.
 * Copyright (c) 2009. All rights reserved.
 */
#ifndef HWDB_SQLSTMTS_H
#define HWDB_SQLSTMTS_H

#include "typetable.h"

#define SQL_TYPE_SELECT 1
#define SQL_TYPE_CREATE 2
#define SQL_TYPE_INSERT 3
#define SQL_SHOW_TABLES 4
#define SQL_TYPE_SAVE_SELECT 5
#define SQL_TYPE_EXEC_SAVED_SELECT 6
#define SQL_TYPE_SUBSCRIBE 7
#define SQL_TYPE_PUBLISH 8
#define SQL_TYPE_UNSUBSCRIBE 9
#define SQL_TYPE_DELETE_QUERY 10

#define SQL_WINTYPE_NONE 0
#define SQL_WINTYPE_TIME 1
#define SQL_WINTYPE_TPL 2

#define SQL_WINTYPE_TIME_SECONDS 1
#define SQL_WINTYPE_TIME_MINUTES 2
#define SQL_WINTYPE_TIME_HOURS 3
#define SQL_WINTYPE_TIME_NOW 4
#define SQL_WINTYPE_TIME_MILLIS 5

#define SQL_FILTER_EQUAL 1
#define SQL_FILTER_GREATER 2
#define SQL_FILTER_LESS 3
#define SQL_FILTER_LESSEQ 4
#define SQL_FILTER_GREATEREQ 5

#define SQL_FILTER_TYPE_AND 0
#define SQL_FILTER_TYPE_OR 1

extern const int sql_colattrib_types[];

#define SQL_COLATTRIB_NONE 	&sql_colattrib_types[0]
#define SQL_COLATTRIB_COUNT &sql_colattrib_types[1]
#define SQL_COLATTRIB_MIN 	&sql_colattrib_types[2]
#define SQL_COLATTRIB_MAX 	&sql_colattrib_types[3]
#define SQL_COLATTRIB_AVG 	&sql_colattrib_types[4]
#define SQL_COLATTRIB_SUM 	&sql_colattrib_types[5]

extern const char *colattrib_name[];

union filterval {
	int intv;
	double realv;
	char charv;
	char tinyv;
	short int smallv;
	unsigned long long tstampv;
};

typedef struct sqlwindow {
	int type;
	int num;
	int unit;
} sqlwindow;

typedef struct sqlfilter {
	char *varname;
	int sign; /* =, >, <, <=, >= */
	//int value;
	union filterval value;
} sqlfilter;

typedef struct sqlselect {
	int ncols;
	char **cols;
	int **colattrib;
	int ntables;
	char **tables;
	sqlwindow **windows;  /* Array of windows (one per table) */
	int nfilters;
	sqlfilter **filters; /* Array of where filters */
	int filtertype; 	/* Temp only. Remove when brackets implemented */
	char *orderby;
	int isCountStar;
	int containsMinMaxAvgSum;
} sqlselect;

typedef struct sqlcreate {
	char *tablename;
	int ncols;
	char **colname;
	int **coltype;
} sqlcreate;

typedef struct sqlinsert {
	char *tablename;
	int ncols;
	char **colval;
	int **coltype;
} sqlinsert;

typedef struct sqlsubscribe {
	char *queryname;
	char *ipaddr;
	char *port;
	char *service;
} sqlsubscribe;

typedef struct sqlstmt {
	int type;
	char *name;
	union {
		sqlselect select;
		sqlcreate create;
		sqlinsert insert;
		sqlsubscribe subscribe;
	} sql;
} sqlstmt;

/* Helper functions */

sqlwindow *sqlstmt_new_stubwindow();
sqlwindow *sqlstmt_new_timewindow(int num, int unit);
sqlwindow *sqlstmt_new_timewindow_now();
sqlwindow *sqlstmt_new_tuplewindow(int num);

sqlfilter *sqlstmt_new_filter(int ctype, char *name, int dtype, char *value);
sqlfilter *sqlstmt_new_filter_equal(char *name, int value);
sqlfilter *sqlstmt_new_filter_greater(char *name, int value);
sqlfilter *sqlstmt_new_filter_less(char *name, int value);
sqlfilter *sqlstmt_new_filter_greatereq(char *name, int value);
sqlfilter *sqlstmt_new_filter_lesseq(char *name, int value);

int sqlstmt_calc_len(sqlinsert *insert);

#endif