Function comdb2AddIndexInt

sqlite/src/comdb2build.c:5328–5663

}

static void comdb2AddIndexInt(
    Parse *pParse,      /* All information about this parse */
    char *keyname,      /* Index name (Optional) */
    ExprList *pList,    /* A list of columns to be indexed */
    int onError,        /* OE_Abort, OE_Ignore, OE_Replace, or OE_None */
    Expr *pPIWhere,     /* WHERE clause for partial indices */
    const char *zStart, /* Start of WHERE clause token text */
    const char *zEnd,   /* End of WHERE clause token text */
    int sortOrder,      /* Sort order of primary key when pList==NULL */
    u8 idxType,         /* The index type */
    int withOpts,       /* WITH options (DATACOPY) */
    ExprList *pdList    /* A list of columns in the partial datacopy */
)
{
    struct comdb2_ddl_context *ctx = pParse->comdb2_ddl_ctx;
    struct comdb2_key *key;

    if (use_sqlite_impl(pParse)) {
        assert(ctx == 0);
        assert(idxType != SQLITE_IDXTYPE_DUPKEY);
        sqlite3CreateIndex(pParse, 0, 0, 0, pList, onError, 0, 0, 0, 0,
                           idxType);
        return;
    }

    if (ctx == 0) {
        /* An error must have been set. */
        assert(pParse->rc != 0);
        return;
    }

    if ((ctx->flags & DDL_NOOP) != 0) {
        return;
    }

    key = comdb2_calloc(ctx->mem, 1, sizeof(struct comdb2_key));
    if (key == 0)
        goto oom;

    if (keyname) {
        if (idxType != SQLITE_IDXTYPE_PRIMARYKEY && is_pk(keyname)) {
            pParse->rc = SQLITE_ERROR;
            sqlite3ErrorMsg(pParse, "Invalid key name '%s'.", keyname);
            goto cleanup;
        }
        key->name = keyname;
    } else {
        /* Key name not specified, will be generated later. */
    }

    switch (idxType) {
    case SQLITE_IDXTYPE_APPDEF:
        /* For CREATE INDEX, we need to check onError */
        if (onError != OE_Abort) {
            key->flags |= KEY_DUP;
        } else {
            key->flags |= KEY_UNIQNULLS;
        }