Function comdb2CreateTrigger

sqlite/src/comdb2lua.c:134–244

}

void comdb2CreateTrigger(Parse *parse, int consumer, int seq, Token *proc, Cdb2TrigTables *tbl)
{
    if (comdb2IsPrepareOnly(parse))
        return;

    if (comdb2IsDryrun(parse)) {
        sqlite3ErrorMsg(parse, "DRYRUN not supported for this operation");
        parse->rc = SQLITE_MISUSE;
        return;
    }
#ifndef SQLITE_OMIT_AUTHORIZATION
    {
        if( sqlite3AuthCheck(parse, consumer ? SQLITE_CREATE_LUA_CONSUMER :
                             SQLITE_CREATE_LUA_TRIGGER, 0, 0, 0) ){
            sqlite3ErrorMsg(parse, COMDB2_NOT_AUTHORIZED_ERRMSG);
            parse->rc = SQLITE_AUTH;
            return;
        }
    }
#endif

    if (!tbl) {
        sqlite3ErrorMsg(parse, "invalid table name");
        return;
    }

    if (comdb2AuthenticateUserOp(parse))
        return;

    char spname[MAX_SPNAME];

    if (comdb2TokenToStr(proc, spname, sizeof(spname))) {
        sqlite3ErrorMsg(parse, "procedure name is too long");
        return;
    }

    Q4SP(qname, spname);
    if (getqueuebyname(qname)) {
        sqlite3ErrorMsg(parse, "%s:%s already exists", consumer ? "consumer" : "trigger", spname);
        return;
    }

    if (consumer == COMDB2_DEFAULT_CONSUMER) {
        if (tbl->next) {
            sqlite3ErrorMsg(parse, "cannot create default consumer for multiple tables");
            return;
        }
    } else if (!comdb2LocateSP(parse, spname)) {
        sqlite3ErrorMsg(parse, "no such procedure: %s", spname);
        return;
    }

    strbuf *s = strbuf_new();
    while (tbl) {
        Table *table = tbl->table;
        Cdb2TrigEvents *events = tbl->events;
        tbl = tbl->next;
        ColumnEventList celist;