Function indexes_expressions_data

db/sqlglue.c:12648–12722

}

int indexes_expressions_data(const struct dbtable *tbl, struct schema *sc,
                             const char *inbuf, char *outbuf, blob_buffer_t *blobs,
                             size_t maxblobs, struct field *f,
                             struct convert_failure *fail_reason,
                             const char *tzname)
{
    Mem *m = NULL;
    Mem mout = {{0}};
    int nblobs = 0;
    struct field_conv_opts_tz convopts = {.flags = 0};
    struct mem_info info;
    strbuf *sql;
    int i, rc;
    int exist = 0;

    if (!inbuf || !outbuf) {
        logmsg(LOGMSG_ERROR, "%s: invalid input\n", __func__);
        return -1;
    }

    if (!tzname || !tzname[0])
        tzname = "America/New_York";

    sql = strbuf_new();

    m = (Mem *)alloca(sizeof(Mem) * sc->nmembers);

    for (i = 0; i < sc->nmembers; i++) {
        memset(&m[i], 0, sizeof(Mem));
        rc = get_data_from_ondisk(tbl, sc, (uint8_t *)inbuf, blobs, maxblobs, i,
                                  &m[i], 0, tzname);
        if (rc) {
            logmsg(LOGMSG_ERROR, "%s: failed to convert to ondisk\n", __func__);
            goto done;
        }
    }

    build_indexes_expressions_query(sql, sc, "expridx_temp", f->name);

    rc =
        run_verify_indexes_query((char *)strbuf_buf(sql), sc, m, &mout, &exist);
    if (rc || !exist) {
        logmsg(LOGMSG_ERROR, "%s: failed to run internal query, rc %d\n",
               __func__, rc);
        rc = -1;
        goto done;
    }

    info.s = sc;
    info.null = 0;
    info.fail_reason = fail_reason;
    info.tzname = tzname;
    info.m = &mout;
    info.nblobs = &nblobs;
    info.convopts = &convopts;
    info.outblob = NULL;
    info.maxblobs = maxblobs;
    info.fldidx = -1;