Function run_statement

tools/cdb2sql/cdb2sql.cpp:1467–1696

}

static int run_statement(const char *sql, int ntypes, int *types,
                         int *start_time, int *run_time)
{
    int rc;
    int ncols;
    int col;
    FILE *out = stdout;
    int startms = now_ms();

    if (printmode & DISP_STDERR)
        out = stderr;

    *start_time = 0;
    *run_time = 0;

    if (cdb2h == NULL) {
        if (maxretries) {
            cdb2_set_max_retries(maxretries);
        }
        if (minretries) {
            cdb2_set_min_retries(minretries);
        }

        verbose_print("calling cdb2_open\n");

        int flags = 0;
        char *type = dbtype;

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

        if (isadmin)
            flags |= CDB2_ADMIN;

        rc = cdb2_open(&cdb2h, dbname, type, flags);

        cdb2_push_context(cdb2h, "cdb2sql");
        if (rc) {
            fprintf(stderr, "cdb2_open rc %d %s\n", rc, cdb2_errstr(cdb2h));
            cdb2_close(cdb2h);
            cdb2h = NULL;
            return 1;
        }

        if (connect_to_master) {
            rc = cdb2_run_statement(cdb2h, "SELECT host FROM comdb2_cluster WHERE is_master = 'Y'");
            if (rc != 0) {
                fprintf(stderr, "error retrieving master node rc %d %s\n", rc, cdb2_errstr(cdb2h));
                cdb2_close(cdb2h);
                cdb2h = NULL;
                return 1;
            }

            rc = cdb2_next_record(cdb2h);
            if (rc != CDB2_OK) {
                fprintf(stderr, "error retrieving master node rc %d %s\n", rc, cdb2_errstr(cdb2h));