test/cetus
1
0
Fork 0
mirror of https://gitee.com/wangbin579/cetus.git synced 2024-11-30 10:57:37 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Forbid complex aggregate function on sharded SQL, Closes #12

Browse Source
This commit is contained in:
jingxiaobing 2018-03-26 17:10:42 +08:00
parent 8d33ae2151
commit 59cead53a1
3 changed files with 19 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/myparser.y
View File

@ -951,6 +951,9 @@ func_expr(A) ::= ID(X) LP distinct(D) exprlist(Y) RP(R). {
}
if (sql_func_type(X.z) != FT_UNKNOWN) {
A->flags |= EP_AGGREGATE;
if (context->parsing_place == SELECT_COLUMN) {
context->clause_flags |= CF_AGGREGATE;
}
}
if (D) {
A->flags |= EP_DISTINCT;
@ -961,6 +964,9 @@ func_expr(A) ::= ID(X) LP STAR RP(R). {
A = function_expr_new(&X, 0, &R);
if (sql_func_type(X.z) != FT_UNKNOWN) {
A->flags |= EP_AGGREGATE;
if (context->parsing_place == SELECT_COLUMN) {
context->clause_flags |= CF_AGGREGATE;
}
}
}
func_expr(A) ::= JOIN_KW(N) LP expr(X) COMMA expr(Y) RP(R). {

1
lib/sql-expression.h
View File

@ -120,6 +120,7 @@ enum sql_clause_flag_t {
CF_LOCAL_QUERY = 0x20,
CF_DISTINCT_AGGR = 0x40,
CF_SUBQUERY = 0x80,
CF_AGGREGATE = 0x0100,
};
enum sql_sort_order_t {

16
plugins/shard/sharding-parser.c
View File

@ -1724,10 +1724,18 @@ sharding_filter_sql(sql_context_t *context)
}
}
}
if (select_has_AVG(select)) {
sql_context_set_error(context, PARSE_NOT_SUPPORT,
"(cetus)this AVG would be routed to multiple shards, not allowed");
return;
if (context->clause_flags & CF_AGGREGATE) {
if (select_has_AVG(select)) {
sql_context_set_error(context, PARSE_NOT_SUPPORT,
"(cetus)this AVG would be routed to multiple shards, not allowed");
return;
}
/* if we can't find simple aggregates, it's inside complex expressions */
if (sql_expr_list_find_aggregate(select->columns) == 0) {
sql_context_set_error(context, PARSE_NOT_SUPPORT,
"(cetus) Complex aggregate function not allowed on sharded sql");
return;
}
}
if (select->groupby_clause && select->orderby_clause && !select_groupby_orderby_have_same_column(select)) {
sql_context_set_error(context, PARSE_NOT_SUPPORT,