Function db_generator

tools/cdb2sql/cdb2sql.cpp:304–383

}

static char *db_generator(const int state, const char *sql)
{
    static char **db_words;
    static int list_index, len;
    const char *name;
    if (!state) { //if state is 0 get the completions from the db
        cdb2_hndl_tp *cdb2h_2 = NULL; // use a new db handle
        if (db_words) {
            char *wrd;
            list_index = 0;
            while ((wrd = db_words[list_index])) {
                free(wrd);
                db_words[list_index] = NULL;
                list_index++;
            }
            free(db_words);
            db_words = NULL;
        }

        list_index = 0;
        int rc;
        int flags = 0;
        char *type = dbtype;

        if (dbhostname) {
            type = dbhostname;
            flags |= CDB2_DIRECT_CPU;
        }

        if (isadmin)
            flags |= CDB2_ADMIN;

        rc = cdb2_open(&cdb2h_2, dbname, type, flags);
        if (rc) {
            if (debug_trace)
                fprintf(stderr, "cdb2_open rc %d %s\n", rc, cdb2_errstr(cdb2h));
            cdb2_close(cdb2h_2);
            return ((char *) NULL);
        }
        rc = cdb2_run_statement(cdb2h_2, sql);
        if (rc) {
            if (debug_trace)
                fprintf(stderr, "failed to run sql '%s'\n", sql);
            return ((char *) NULL);
        }

        int ncols = cdb2_numcolumns(cdb2h_2);
        assert(ncols == 1);
        int count = 0;
        int sz = 0;
        while ((rc = cdb2_next_record(cdb2h_2)) == CDB2_OK) {
            if ( sz < count + 1 ) {
                sz = (sz == 0) ? 32 : sz * 2;
                char **m = (char**) realloc(db_words, sz * sizeof(char *));
                if (!m) {
                    fprintf(stderr, "error with malloc/realloc\n");
                    abort();
                    break;