diff -r f82cb65a78ec -r 237844f263b4 libidav/davqlparser.c --- a/libidav/davqlparser.c Fri Apr 17 16:26:53 2015 +0200 +++ b/libidav/davqlparser.c Tue Apr 21 12:13:41 2015 +0200 @@ -49,6 +49,7 @@ static const char* _map_exprtype(davqlexprtype_t type) { switch(type) { + case DAVQL_UNDEFINED_TYP: return "undefined"; case DAVQL_NUMBER: return "NUMBER"; case DAVQL_STRING: return "STRING"; case DAVQL_TIMESTAMP: return "TIMESTAMP"; @@ -92,13 +93,12 @@ // Basic information size_t fieldcount = ucx_list_size(stmt->fields); int specialfield = 0; - UCX_FOREACH(elm, stmt->fields) { - DavQLExpression* expr = (DavQLExpression*)elm->data; - if (expr->type == DAVQL_IDENTIFIER && expr->srctext.length == 1) { - if (expr->srctext.ptr[0] == '*') { - specialfield = 1; - } else if (expr->srctext.ptr[0] == '-') { - specialfield = 2; + if (stmt->fields) { + DavQLField* firstfield = (DavQLField*)stmt->fields->data; + if (firstfield->expr->type == DAVQL_IDENTIFIER) { + switch (firstfield->expr->srctext.ptr[0]) { + case '*': specialfield = 1; break; + case '-': specialfield = 2; break; } } } @@ -113,11 +113,6 @@ _map_specialfield(specialfield), sfmtarg(stmt->path), stmt->where ? "yes" : "no"); - if (stmt->type == DAVQL_SET) { - printf("Value list size matches: %s", - ucx_list_size(stmt->fields) == ucx_list_size(stmt->setvalues) - ? "yes" : "no"); - } // WITH attributes if (stmt->depth == DAV_DEPTH_INFINITY) { @@ -161,29 +156,41 @@ if (dav_debug_ql_expr_selected(expr)) { sstr_t empty = ST("(empty)"); printf( - "Text: %.*s\nType: %s\nOperator: %s\n" - "Left hand: %.*s\nRight hand: %.*s\n", + "Text: %.*s\nType: %s\nOperator: %s\n", sfmtarg(expr->srctext), _map_exprtype(expr->type), - _map_operator(expr->op), - sfmtarg(expr->left?expr->left->srctext:empty), - sfmtarg(expr->right?expr->right->srctext:empty)); + _map_operator(expr->op)); + if (expr->left || expr->right) { + printf("Left hand: %.*s\nRight hand: %.*s\n", + sfmtarg(expr->left?expr->left->srctext:empty), + sfmtarg(expr->right?expr->right->srctext:empty)); + } } } #define DQLD_CMD_Q 0 #define DQLD_CMD_PS 1 #define DQLD_CMD_PE 2 -#define DQLD_CMD_P 10 +#define DQLD_CMD_F 10 +#define DQLD_CMD_W 11 +#define DQLD_CMD_O 12 #define DQLD_CMD_L 21 #define DQLD_CMD_R 22 +#define DQLD_CMD_N 23 +#define DQLD_CMD_P 24 #define DQLD_CMD_H 100 static int dav_debug_ql_command() { printf("> "); - char buffer[16]; - fgets(buffer, 16, stdin); + char buffer[8]; + fgets(buffer, 8, stdin); + // discard remaining chars + if (!strchr(buffer, '\n')) { + int chr; + while ((chr = fgetc(stdin) != '\n') && chr != EOF); + } + if (!strcmp(buffer, "q\n")) { return DQLD_CMD_Q; } else if (!strcmp(buffer, "ps\n")) { @@ -196,6 +203,16 @@ return DQLD_CMD_R; } else if (!strcmp(buffer, "h\n")) { return DQLD_CMD_H; + } else if (!strcmp(buffer, "f\n")) { + return DQLD_CMD_F; + } else if (!strcmp(buffer, "w\n")) { + return DQLD_CMD_W; + } else if (!strcmp(buffer, "o\n")) { + return DQLD_CMD_O; + } else if (!strcmp(buffer, "n\n")) { + return DQLD_CMD_N; + } else if (!strcmp(buffer, "p\n")) { + return DQLD_CMD_P; } else { return -1; } @@ -215,6 +232,8 @@ } DavQLExpression *examineexpr = NULL; + UcxList *examineelem = NULL; + int examineclause = 0; while(1) { int cmd = dav_debug_ql_command(); @@ -222,6 +241,52 @@ case DQLD_CMD_Q: return; case DQLD_CMD_PS: dav_debug_ql_stmt_print(stmt); break; case DQLD_CMD_PE: dav_debug_ql_expr_print(examineexpr); break; + case DQLD_CMD_F: + if (examineclause != DQLD_CMD_F) { + examineclause = DQLD_CMD_F; + examineelem = stmt->fields; + examineexpr = stmt->fields ? + ((DavQLField*)stmt->fields->data)->expr : NULL; + dav_debug_ql_expr_print(examineexpr); + } + break; + case DQLD_CMD_W: + examineclause = 0; examineelem = NULL; + examineexpr = stmt->where; + dav_debug_ql_expr_print(examineexpr); + break; + case DQLD_CMD_O: + if (examineclause != DQLD_CMD_O) { + examineclause = DQLD_CMD_O; + examineelem = stmt->orderby; + examineexpr = stmt->orderby ? + ((DavQLOrderCriterion*)stmt->orderby->data)->column : NULL; + dav_debug_ql_expr_print(examineexpr); + } + break; + case DQLD_CMD_N: + case DQLD_CMD_P: + if (examineelem) { + UcxList *newelem = (cmd == DQLD_CMD_N ? + examineelem->next : examineelem->prev); + if (newelem) { + examineelem = newelem; + if (examineclause == DQLD_CMD_O) { + examineexpr = ((DavQLOrderCriterion*) + examineelem->data)->column; + } else if (examineclause == DQLD_CMD_F) { + examineexpr = ((DavQLField*)examineelem->data)->expr; + } else { + printf("Examining unknown clause type."); + } + dav_debug_ql_expr_print(examineexpr); + } else { + printf("Reached end of list.\n"); + } + } else { + printf("Currently not examining an expression list.\n"); + } + break; case DQLD_CMD_L: if (dav_debug_ql_expr_selected(examineexpr)) { if (examineexpr->left) { @@ -246,6 +311,13 @@ printf( "\nCommands:\n" "ps: print statement information\n" + "o: examine order by clause\n" + "f: examine field list\n" + "w: examine where clause\n" + "n: examine next expression " + "(in order by clause or field list)\n" + "p: examine previous expression " + "(in order by clause or field list)\n" "q: quit\n\n" "\nExpression examination:\n" "pe: print expression information\n" @@ -433,8 +505,10 @@ // process tokens for (size_t i = 0 ; i < n ; i++) { + sstr_t tokendata = *token_sstr(token); // TODO: make it so + printf("Processing %.*s...\n", sfmtarg(tokendata)); // go to next token (if this is not the last token) if (i < n-1) { @@ -468,6 +542,66 @@ #define _step_ORDER_BY_ 50 // ORDER BY clause #define _step_end_ 500 // expect end +struct fieldlist_parser_state { + UcxList *expr_firsttoken; + size_t expr_len; + /* + * 0: begin of field list - may encounter "*" or "-" special fields + * 1: collect expression token + * switch to step 2 on keyword "as" + * expect "," only if expr_len is 1 (add expr to list and continue) + * 2: expect one token (identifier) and a "," - continue with step 1 + */ + int step; +}; + +static int dav_parse_fieldlist(DavQLStatement *stmt, UcxList *token, + struct fieldlist_parser_state *state) { + sstr_t tokendata = *token_sstr(token); + + switch (state->step) { + case 0: + // did not encounter special field, fall through to step 1 + case 1: + break; + } + + _Bool fromkeyword = !sstrcasecmp(tokendata, S("from")); + if (fromkeyword || !sstrcmp(tokendata, S(","))) { + if (state->expr_firsttoken) { + DavQLField *field = malloc(sizeof(DavQLField)); + field->expr = dav_parse_expression( + stmt, state->expr_firsttoken, state->expr_len); + field->name = field->expr->srctext; + stmt->fields = ucx_list_append(stmt->fields, field); + state->expr_firsttoken = NULL; + state->expr_len = 0; + + if (fromkeyword) { + return _step_FROM_; + } + } else { + dav_error_in_context(DAVQL_ERROR_UNEXPECTED_TOKEN, + _unexpected_token, stmt, token); + } + } else { + // collect tokens for field expression + if (state->expr_firsttoken) { + state->expr_len++; + } else { + state->expr_firsttoken = token; + state->expr_len = 1; + } + } + + return _step_fieldlist_; +} + +static void dav_free_field(DavQLField *field) { + dav_free_expression(field->expr); + free(field); +} + static int dav_parse_from(DavQLStatement *stmt, UcxList *token) { sstr_t tokendata = *token_sstr(token); @@ -693,16 +827,11 @@ memset(&state_with, 0, sizeof(struct with_parser_state)); struct orderby_parser_state state_orderby; memset(&state_orderby, 0, sizeof(struct orderby_parser_state)); - - // Variables for token sublists for expressions - // TODO: this is deprecated and won't work with function calls - UcxList *exprstart = NULL; - size_t exprlen = 0; + struct fieldlist_parser_state state_fieldlist; + memset(&state_fieldlist, 0, sizeof(struct fieldlist_parser_state)); // Process tokens UCX_FOREACH(token, tokens) { - sstr_t tokendata = *token_sstr(token); - switch (step) { // too much input data case _step_end_: @@ -711,30 +840,7 @@ break; // field list case _step_fieldlist_: { - _Bool fromkeyword = !sstrcasecmp(tokendata, S("from")); - if (fromkeyword || !sstrcmp(tokendata, S(","))) { - if (exprstart) { - stmt->fields = ucx_list_append(stmt->fields, - dav_parse_expression(stmt, exprstart, exprlen)); - exprstart = NULL; - exprlen = 0; - - if (fromkeyword) { - step = _step_FROM_; - } - } else { - dav_error_in_context(DAVQL_ERROR_UNEXPECTED_TOKEN, - _unexpected_token, stmt, token); - } - } else { - // collect tokens for field expression - if (exprstart) { - exprlen++; - } else { - exprstart = token; - exprlen = 1; - } - } + step = dav_parse_fieldlist(stmt, token, &state_fieldlist); break; } // from clause @@ -828,13 +934,9 @@ void dav_free_statement(DavQLStatement *stmt) { UCX_FOREACH(expr, stmt->fields) { - dav_free_expression(expr->data); + dav_free_field(expr->data); } ucx_list_free(stmt->fields); - UCX_FOREACH(expr, stmt->setvalues) { - dav_free_expression(expr->data); - } - ucx_list_free(stmt->setvalues); if (stmt->where) { dav_free_expression(stmt->where);