IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Changeset 21402


Ignore:
Timestamp:
Feb 6, 2009, 3:25:03 PM (17 years ago)
Author:
eugene
Message:

converting to the new formatting version of p_psDBRunQueryF where appropriate

Location:
trunk/ippTools/src
Files:
22 edited

Legend:

Unmodified
Added
Removed

  • trunk/ippTools/src/camtool.c

    r20541 r21402  
    886886    char *query = "DELETE FROM camMask WHERE label = '%s'";
    887887
    888     if (!p_psDBRunQuery(config->dbh, query, label)) {
     888    if (!p_psDBRunQueryF(config->dbh, query, label)) {
    889889        psError(PS_ERR_UNKNOWN, false, "database error");
    890890        return false;

  • trunk/ippTools/src/chiptool.c

    r21308 r21402  
    809809    char *query = "DELETE FROM chipMask WHERE label = '%s'";
    810810
    811     if (!p_psDBRunQuery(config->dbh, query, label)) {
     811    if (!p_psDBRunQueryF(config->dbh, query, label)) {
    812812        psError(PS_ERR_UNKNOWN, false, "database error");
    813813        return false;
    … …  
    11731173
    11741174    // note only updates if chipRun.state = run_state
    1175     if (!p_psDBRunQuery(config->dbh, query, data_state, chip_id, class_id, run_state)) {
     1175    if (!p_psDBRunQueryF(config->dbh, query, data_state, chip_id, class_id, run_state)) {
    11761176        psError(PS_ERR_UNKNOWN, false, "database error");
    11771177        // rollback
    … …  
    11891189
    11901190    query = pxDataGet("chiptool_change_exp_state.sql");
    1191     if (!p_psDBRunQuery(config->dbh, query, data_state, chip_id, data_state)) {
     1191    if (!p_psDBRunQueryF(config->dbh, query, data_state, chip_id, data_state)) {
    11921192        // rollback
    11931193        if (!psDBRollback(config->dbh)) {

  • trunk/ippTools/src/dettool.c

    r19988 r21402  
    968968    }
    969969
    970     if (!p_psDBRunQuery(config->dbh, query, (long long) newDet_id, (long long) det_id, iteration)) {
     970    if (!p_psDBRunQueryF(config->dbh, query, (long long) newDet_id, (long long) det_id, iteration)) {
    971971        psError(PS_ERR_UNKNOWN, false, "database error");
    972972        psFree(query);
    … …  
    17331733
    17341734    char *query = "UPDATE detRun SET iteration = iteration + 1 WHERE det_id = %" PRId64;
    1735     if (!p_psDBRunQuery(config->dbh, query, det_id)) {
     1735    if (!p_psDBRunQueryF(config->dbh, query, det_id)) {
    17361736        psError(PS_ERR_UNKNOWN, false,
    17371737                "failed to increment iteration for det_id %" PRId64, det_id);
    … …  
    17731773
    17741774    char *query = "UPDATE detRun SET state = '%s' WHERE det_id = %" PRId64;
    1775     if (!p_psDBRunQuery(config->dbh, query, state, det_id)) {
     1775    if (!p_psDBRunQueryF(config->dbh, query, state, det_id)) {
    17761776        psError(PS_ERR_UNKNOWN, false, "failed to change state for det_id %" PRId64, det_id);
    17771777        return false;
    … …  
    18351835        " AND exp_id = %" PRId64
    18361836        " AND class_id = '%s'";
    1837     if (!p_psDBRunQuery(config->dbh, query, data_state, det_id, exp_id, class_id)) {
     1837    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, exp_id, class_id)) {
    18381838        psError(PS_ERR_UNKNOWN, false,
    18391839                "failed to change state for det_id %" PRId64 ", exp_id %" PRId64 ", class_id %s",
    … …  
    18551855        " WHERE det_id = %" PRId64
    18561856        " AND exp_id = %" PRId64;
    1857     if (!p_psDBRunQuery(config->dbh, query, data_state, det_id, exp_id)) {
     1857    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, exp_id)) {
    18581858        psError(PS_ERR_UNKNOWN, false,
    18591859                "failed to change state for det_id %" PRId64 ", exp_id %" PRId64,
    … …  
    18781878        " AND iteration = %" PRId32
    18791879        " AND class_id = %s";
    1880     if (!p_psDBRunQuery(config->dbh, query, data_state, det_id, iteration, class_id)) {
     1880    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration, class_id)) {
    18811881        psError(PS_ERR_UNKNOWN, false,
    18821882                "failed to change state for det_id %" PRId64 ", iteration %" PRId32 "class_id %s",
    … …  
    19001900        " AND iteration = %" PRId32
    19011901        " AND class_id = %s";
    1902     if (!p_psDBRunQuery(config->dbh, query, data_state, det_id, iteration)) {
     1902    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration)) {
    19031903        psError(PS_ERR_UNKNOWN, false,
    19041904                "failed to change state for det_id %" PRId64 ", iteration %" PRId32,
    … …  
    19221922        " AND iteration = %" PRId32
    19231923        " AND class_id = %s";
    1924     if (!p_psDBRunQuery(config->dbh, query, data_state, det_id, iteration, class_id)) {
     1924    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration, class_id)) {
    19251925        psError(PS_ERR_UNKNOWN, false,
    19261926                "failed to change state for det_id %" PRId64 ", iteration %" PRId32 " class %s",
    … …  
    19421942        " WHERE det_id = %" PRId64
    19431943        " AND iteration = %" PRId32;
    1944     if (!p_psDBRunQuery(config->dbh, query, data_state, det_id, iteration)) {
     1944    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration)) {
    19451945        psError(PS_ERR_UNKNOWN, false,
    19461946                "failed to change state for det_id %" PRId64 ", iteration %" PRId32,
    … …  
    19651965        " AND exp_id = %" PRId64
    19661966        " AND class_id = '%s'";
    1967     if (!p_psDBRunQuery(config->dbh, query, data_state, det_id, iteration, exp_id, class_id)) {
     1967    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration, exp_id, class_id)) {
    19681968        psError(PS_ERR_UNKNOWN, false,
    19691969                "failed to change state for det_id %" PRId64 ", iteration %" PRId32 ", exp_id %" PRId64 ", class_id %s",
    … …  
    19861986        " AND iteration = %" PRId32
    19871987        " AND exp_id = %" PRId64;
    1988     if (!p_psDBRunQuery(config->dbh, query, data_state, det_id, iteration, exp_id)) {
     1988    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration, exp_id)) {
    19891989        psError(PS_ERR_UNKNOWN, false,
    19901990                "failed to change state for det_id %" PRId64 ", iteration %" PRId32 ", exp_id %" PRId64,

  • trunk/ippTools/src/dettool_detrunsummary.c

    r19092 r21402  
    356356
    357357    char *query = "UPDATE detRunSummary SET accept = %d WHERE det_id = %"PRId64;
    358     if (!p_psDBRunQuery(config->dbh, query, accept, det_id)) {
    359         psError(PS_ERR_UNKNOWN, false, "database error");
    360         return false;
    361     }
    362 
    363     return true;
    364 }
    365 
    366 
     358    if (!p_psDBRunQueryF(config->dbh, query, accept, det_id)) {
     359        psError(PS_ERR_UNKNOWN, false, "database error");
     360        return false;
     361    }
     362
     363    return true;
     364}
     365
     366

  • trunk/ippTools/src/dettool_processedexp.c

    r19092 r21402  
    105105    }
    106106
    107     if (!p_psDBRunQuery(config->dbh, query, (long long) det_id, (long long) exp_id)) {
     107    if (!p_psDBRunQueryF(config->dbh, query, (long long) det_id, (long long) exp_id)) {
    108108        psError(PS_ERR_UNKNOWN, false, "database error");
    109109        psFree(query);

  • trunk/ippTools/src/difftool.c

    r21399 r21402  
    207207    psString tess_id = NULL;
    208208    if (warp1) {
    209         if (!p_psDBRunQuery(config->dbh, "SELECT * from diffRun WHERE diff_id = %" PRId64, diff_id)) {
     209        if (!p_psDBRunQueryF(config->dbh, "SELECT * from diffRun WHERE diff_id = %" PRId64, diff_id)) {
    210210            psError(PS_ERR_UNKNOWN, false, "database error");
    211211            return false;
    … …  
    249249    }
    250250
    251     if (!p_psDBRunQuery(config->dbh, "SELECT count(diff_id) FROM diffRun JOIN diffInputSkyfile USING(diff_id) WHERE diff_id = %" PRId64, diff_id)) {
     251    if (!p_psDBRunQueryF(config->dbh, "SELECT count(diff_id) FROM diffRun JOIN diffInputSkyfile USING(diff_id) WHERE diff_id = %" PRId64, diff_id)) {
    252252        if (!psDBRollback(config->dbh)) {
    253253            psError(PS_ERR_UNKNOWN, false, "database error");
    … …  
    355355    }
    356356
    357     if (!p_psDBRunQuery(config->dbh, query, whereClause, whereClause, whereClause, whereClause)) {
     357    if (!p_psDBRunQueryF(config->dbh, query, whereClause, whereClause, whereClause, whereClause)) {
    358358        psError(PS_ERR_UNKNOWN, false, "database error");
    359359        psFree(whereClause);
    … …  
    737737
    738738    char *query = "UPDATE diffRun SET state = '%s' WHERE diff_id = %"PRId64;
    739     if (!p_psDBRunQuery(config->dbh, query, state, diff_id)) {
     739    if (!p_psDBRunQueryF(config->dbh, query, state, diff_id)) {
    740740        psError(PS_ERR_UNKNOWN, false,
    741741                "failed to change state for diff_id %"PRId64, diff_id);
    … …  
    829829
    830830    char *query = "UPDATE diffRun SET state = 'new' WHERE diff_id = '%" PRId64 "'";
    831     if (!p_psDBRunQuery(config->dbh, query, run->diff_id)) {
     831    if (!p_psDBRunQueryF(config->dbh, query, run->diff_id)) {
    832832        if (!psDBRollback(config->dbh)) {
    833833            psError(PS_ERR_UNKNOWN, false, "database error");
    … …  
    999999
    10001000
    1001     if (!p_psDBRunQuery(config->dbh, query, warpQuery, expQuery, diffQuery)) {
     1001    if (!p_psDBRunQueryF(config->dbh, query, warpQuery, expQuery, diffQuery)) {
    10021002        psError(PS_ERR_UNKNOWN, false, "database error");
    10031003        psFree(query);
    … …  
    10981098            return false;
    10991099        }
    1100         if (!p_psDBRunQuery(config->dbh, skycell_query, stackQuery, warp_id, filter, warpQuery)) {
     1100        if (!p_psDBRunQueryF(config->dbh, skycell_query, stackQuery, warp_id, filter, warpQuery)) {
    11011101            psError(PS_ERR_UNKNOWN, false, "database error");
    11021102            psFree(warpQuery);

  • trunk/ippTools/src/faketool.c

    r20748 r21402  
    868868    char *query = "DELETE FROM fakeMask WHERE label = '%s'";
    869869
    870     if (!p_psDBRunQuery(config->dbh, query, label)) {
     870    if (!p_psDBRunQueryF(config->dbh, query, label)) {
    871871        psError(PS_ERR_UNKNOWN, false, "database error");
    872872        return false;
    … …  
    11551155
    11561156    // note only updates if fakeRun.state = run_state
    1157     if (!p_psDBRunQuery(config->dbh, query, data_state, fake_id, class_id, run_state)) {
     1157    if (!p_psDBRunQueryF(config->dbh, query, data_state, fake_id, class_id, run_state)) {
    11581158        psError(PS_ERR_UNKNOWN, false, "database error");
    11591159        // rollback
    … …  
    11721172
    11731173    query = pxDataGet("faketool_change_exp_state.sql");
    1174     if (!p_psDBRunQuery(config->dbh, query, data_state, fake_id, data_state)) {
     1174    if (!p_psDBRunQueryF(config->dbh, query, data_state, fake_id, data_state)) {
    11751175        // rollback
    11761176        if (!psDBRollback(config->dbh)) {

  • trunk/ippTools/src/flatcorr.c

    r20397 r21402  
    365365    }
    366366
    367     if (!p_psDBRunQuery(config->dbh, query, (long long) corr_id, (long long) chip_id)) {
     367    if (!p_psDBRunQueryF(config->dbh, query, (long long) corr_id, (long long) chip_id)) {
    368368        psError(PS_ERR_UNKNOWN, false, "database error");
    369369        psFree(query);
    … …  
    513513    }
    514514
    515     if (!p_psDBRunQuery(config->dbh, query, (long long) corr_id, (long long) cam_id)) {
     515    if (!p_psDBRunQueryF(config->dbh, query, (long long) corr_id, (long long) cam_id)) {
    516516        psError(PS_ERR_UNKNOWN, false, "database error");
    517517        psFree(query);
    … …  
    589589    }
    590590
    591     if (!p_psDBRunQuery(config->dbh, query, corr_id)) {
     591    if (!p_psDBRunQueryF(config->dbh, query, corr_id)) {
    592592        psError(PS_ERR_UNKNOWN, false, "database error");
    593593        psFree(query);
    … …  
    648648    }
    649649
    650     if (!p_psDBRunQuery(config->dbh, query, chip_id)) {
     650    if (!p_psDBRunQueryF(config->dbh, query, chip_id)) {
    651651        psError(PS_ERR_UNKNOWN, false, "database error");
    652652        psFree(query);
    … …  
    685685    char *query = "UPDATE flatcorrRun SET state = 'full', hostname = '%s', fault = '%hd' WHERE corr_id = %" PRId64;
    686686
    687     if (!p_psDBRunQuery(config->dbh, query, hostname, code, corr_id)) {
     687    if (!p_psDBRunQueryF(config->dbh, query, hostname, code, corr_id)) {
    688688        psError(PS_ERR_UNKNOWN, false, "failed to change state for corr_id %" PRId64, corr_id);
    689689        return false;
    … …  
    727727    char *query = "UPDATE flatcorrRun SET state = '%s' WHERE corr_id = %" PRId64;
    728728
    729     if (!p_psDBRunQuery(config->dbh, query, state, corr_id)) {
     729    if (!p_psDBRunQueryF(config->dbh, query, state, corr_id)) {
    730730        psError(PS_ERR_UNKNOWN, false, "failed to change state for corr_id %" PRId64, corr_id);
    731731        return false;

  • trunk/ippTools/src/magicdstool.c

    r20973 r21402  
    159159        psFree(where);
    160160
    161         if (!p_psDBRunQuery(config->dbh, query, whereClause)) {
     161        if (!p_psDBRunQueryF(config->dbh, query, whereClause)) {
    162162            psError(PS_ERR_UNKNOWN, false, "database error");
    163163            psFree(whereClause);
    … …  
    215215
    216216
    217         if (!p_psDBRunQuery(config->dbh, query, magicSkyCellNumsWhere ? magicSkyCellNumsWhere : "")) {
     217        if (!p_psDBRunQueryF(config->dbh, query, magicSkyCellNumsWhere ? magicSkyCellNumsWhere : "")) {
    218218            psError(PS_ERR_UNKNOWN, false, "database error");
    219219            psFree(magicSkyCellNumsWhere);
    … …  
    298298        }
    299299
    300         if (!p_psDBRunQuery(config->dbh, thisInsert, magic_id, exp_id)) {
     300        if (!p_psDBRunQueryF(config->dbh, thisInsert, magic_id, exp_id)) {
    301301            psError(PS_ERR_UNKNOWN, false, "database error");
    302302            psFree(thisInsert);
    … …  
    560560    }
    561561
    562     if (!p_psDBRunQuery(config->dbh, query, magic_id)) {
     562    if (!p_psDBRunQueryF(config->dbh, query, magic_id)) {
    563563        psError(PS_ERR_UNKNOWN, false, "database error");
    564564        psFree(query);
    … …  
    692692    psFree(where);
    693693
    694     if (!p_psDBRunQuery(config->dbh, query, magic_ds_id)) {
     694    if (!p_psDBRunQueryF(config->dbh, query, magic_ds_id)) {
    695695        psError(PS_ERR_UNKNOWN, false, "database error");
    696696        psFree(query);
    … …  
    749749
    750750    char *query = "UPDATE magicDSRun SET state = '%s' WHERE magic_ds_id = %" PRId64;
    751     if (!p_psDBRunQuery(config->dbh, query, state, magic_ds_id)) {
     751    if (!p_psDBRunQueryF(config->dbh, query, state, magic_ds_id)) {
    752752        psError(PS_ERR_UNKNOWN, false,
    753753                "failed to change state for magic_id %" PRId64, magic_ds_id);

  • trunk/ippTools/src/magictool.c

    r21099 r21402  
    171171        }
    172172
    173         if (!p_psDBRunQuery(config->dbh, query, queryWhere)) {
     173        if (!p_psDBRunQueryF(config->dbh, query, queryWhere)) {
    174174            psError(PS_ERR_UNKNOWN, false, "database error");
    175175            psFree(queryWhere);
    … …  
    255255        }
    256256
    257         if (!p_psDBRunQuery(config->dbh, thisInsert, magic_id, exp_id)) {
     257        if (!p_psDBRunQueryF(config->dbh, thisInsert, magic_id, exp_id)) {
    258258            psError(PS_ERR_UNKNOWN, false, "database error");
    259259            psFree(thisInsert);
    … …  
    539539    if (code > 0) {
    540540        char *query = "UPDATE magicRun SET fault = %d, state = 'stop' WHERE magic_id = %" PRId64;
    541         if (!p_psDBRunQuery(config->dbh, query, code, magic_id)) {
     541        if (!p_psDBRunQueryF(config->dbh, query, code, magic_id)) {
    542542            psError(PS_ERR_UNKNOWN, false,
    543543                    "failed to set fault for magic_id %" PRId64, magic_id);
    … …  
    795795        whereClause = new;
    796796    }
    797     if (!p_psDBRunQuery(config->dbh, query, whereClause ? whereClause :  "")) {
     797    if (!p_psDBRunQueryF(config->dbh, query, whereClause ? whereClause :  "")) {
    798798        psError(PS_ERR_UNKNOWN, false, "database error");
    799799        psFree(whereClause);
    … …  
    14921492
    14931493    char *query = "UPDATE magicRun SET state = '%s' WHERE magic_id = %" PRId64;
    1494     if (!p_psDBRunQuery(config->dbh, query, state, magic_id)) {
     1494    if (!p_psDBRunQueryF(config->dbh, query, state, magic_id)) {
    14951495        psError(PS_ERR_UNKNOWN, false,
    14961496                "failed to change state for magic_id %" PRId64, magic_id);

  • trunk/ippTools/src/pstamptool.c

    r20151 r21402  
    231231                     " (state, uri, ds_id, fault)"
    232232                     " VALUES( 'new', '%s', %" PRId64 ", 0 )";
    233     if (!p_psDBRunQuery(config->dbh, query, uri, ds_id)) {
     233    if (!p_psDBRunQueryF(config->dbh, query, uri, ds_id)) {
    234234        psError(PS_ERR_UNKNOWN, false, "database error");
    235235        return false;
    … …  
    480480    // printf("Revert request %" PRId64 "\n", req_id);
    481481   
    482     if (!p_psDBRunQuery(config->dbh, "DELETE FROM pstampJob where req_id = %" PRId64, req_id)) {
    483         psError(PS_ERR_UNKNOWN, false, "database error");
    484         return false;
    485     }
    486     if (!p_psDBRunQuery(config->dbh,
     482    if (!p_psDBRunQueryF(config->dbh, "DELETE FROM pstampJob where req_id = %" PRId64, req_id)) {
     483        psError(PS_ERR_UNKNOWN, false, "database error");
     484        return false;
     485    }
     486    if (!p_psDBRunQueryF(config->dbh,
    487487        "UPDATE pstampRequest set state ='new', name=NULL, reqType=NULL, fault=0 where req_id = %" PRId64, req_id)) {
    488488        psError(PS_ERR_UNKNOWN, false, "database error");
    … …  
    535535    }
    536536
    537     if (!p_psDBRunQuery(config->dbh, query, req_id, rownum, stateString, job_type, uri, exp_id, outputBase, fault, argString)) {
     537    if (!p_psDBRunQueryF(config->dbh, query, req_id, rownum, stateString, job_type, uri, exp_id, outputBase, fault, argString)) {
    538538        psError(PS_ERR_UNKNOWN, false, "database error");
    539539        return false;
    … …  
    705705        " WHERE job_id = %" PRId64;
    706706   
    707     if (!p_psDBRunQuery(config->dbh, query, state, faultStr, job_id)) {
     707    if (!p_psDBRunQueryF(config->dbh, query, state, faultStr, job_id)) {
    708708        psError(PS_ERR_UNKNOWN, false, "database error");
    709709        psFree(query);

  • trunk/ippTools/src/pxcam.c

    r20542 r21402  
    134134
    135135    char *query = "UPDATE camRun SET state = '%s' WHERE cam_id = %" PRId64;
    136     if (!p_psDBRunQuery(config->dbh, query, state, cam_id)) {
     136    if (!p_psDBRunQueryF(config->dbh, query, state, cam_id)) {
    137137        psError(PS_ERR_UNKNOWN, false,
    138138                "failed to change state for cam_id %" PRId64, cam_id);
    … …  
    164164    }
    165165
    166     if (!p_psDBRunQuery(config->dbh, query, state)) {
     166    if (!p_psDBRunQueryF(config->dbh, query, state)) {
    167167        psFree(query);
    168168        psError(PS_ERR_UNKNOWN, false, "database error");
    … …  
    182182
    183183    char *query = "UPDATE camRun SET camRun.label = '%s' WHERE cam_id = %" PRId64;
    184     if (!p_psDBRunQuery(config->dbh, query, label, cam_id)) {
     184    if (!p_psDBRunQueryF(config->dbh, query, label, cam_id)) {
    185185        psError(PS_ERR_UNKNOWN, false,
    186186                "failed to change state for cam_id %" PRId64, cam_id);
    … …  
    204204    }
    205205
    206     if (!p_psDBRunQuery(config->dbh, query, label)) {
     206    if (!p_psDBRunQueryF(config->dbh, query, label)) {
    207207        psFree(query);
    208208        psError(PS_ERR_UNKNOWN, false, "database error");
    … …  
    242242    // XXX chip_id is being cast here work around psS64 have a different type
    243243    // different on 32/64
    244     if (!p_psDBRunQuery(config->dbh, query,
     244    if (!p_psDBRunQueryF(config->dbh, query,
    245245                "new", // state
    246246                workdir  ? workdir  : "NULL",

  • trunk/ippTools/src/pxchip.c

    r21308 r21402  
    140140
    141141    char *query = "UPDATE chipRun SET state = '%s' WHERE chip_id = %" PRId64;
    142     if (!p_psDBRunQuery(config->dbh, query, state, chip_id)) {
     142    if (!p_psDBRunQueryF(config->dbh, query, state, chip_id)) {
    143143        psError(PS_ERR_UNKNOWN, false,
    144144                "failed to change state for chip_id %" PRId64, chip_id);
    … …  
    170170    }
    171171
    172     if (!p_psDBRunQuery(config->dbh, query, state)) {
     172    if (!p_psDBRunQueryF(config->dbh, query, state)) {
    173173        psFree(query);
    174174        psError(PS_ERR_UNKNOWN, false, "database error");
    … …  
    188188
    189189    char *query = "UPDATE chipRun SET label = '%s' WHERE chip_id = %" PRId64;
    190     if (!p_psDBRunQuery(config->dbh, query, label, chip_id)) {
     190    if (!p_psDBRunQueryF(config->dbh, query, label, chip_id)) {
    191191        psError(PS_ERR_UNKNOWN, false,
    192192                "failed to change state for chip_id %" PRId64, chip_id);
    … …  
    211211    }
    212212
    213     if (!p_psDBRunQuery(config->dbh, query, label)) {
     213    if (!p_psDBRunQueryF(config->dbh, query, label)) {
    214214        psFree(query);
    215215        psError(PS_ERR_UNKNOWN, false, "database error");
    … …  
    269269                     "SELECT %" PRId64 ", class_id, 0 FROM rawImfile WHERE exp_id = %" PRId64;
    270270
    271     if (!p_psDBRunQuery(config->dbh, query, chip_id, exp_id)) {
     271    if (!p_psDBRunQueryF(config->dbh, query, chip_id, exp_id)) {
    272272        psError(PS_ERR_UNKNOWN, false, "database error");
    273273        // rollback

  • trunk/ippTools/src/pxfake.c

    r21097 r21402  
    4242
    4343    char *query = "UPDATE fakeRun SET state = '%s' WHERE fake_id = %" PRId64;
    44     if (!p_psDBRunQuery(config->dbh, query, state, fake_id)) {
     44    if (!p_psDBRunQueryF(config->dbh, query, state, fake_id)) {
    4545        psError(PS_ERR_UNKNOWN, false,
    4646                "failed to change state for fake_id %" PRId64, fake_id);
    … …  
    7272    }
    7373
    74     if (!p_psDBRunQuery(config->dbh, query, state)) {
     74    if (!p_psDBRunQueryF(config->dbh, query, state)) {
    7575        psFree(query);
    7676        psError(PS_ERR_UNKNOWN, false, "database error");
    … …  
    9090
    9191    char *query = "UPDATE fakeRun SET fakeRun.label = '%s' WHERE fake_id = %" PRId64;
    92     if (!p_psDBRunQuery(config->dbh, query, label, fake_id)) {
     92    if (!p_psDBRunQueryF(config->dbh, query, label, fake_id)) {
    9393        psError(PS_ERR_UNKNOWN, false,
    9494                "failed to change state for fake_id %" PRId64, fake_id);
    … …  
    113113    }
    114114
    115     if (!p_psDBRunQuery(config->dbh, query, label)) {
     115    if (!p_psDBRunQueryF(config->dbh, query, label)) {
    116116        psFree(query);
    117117        psError(PS_ERR_UNKNOWN, false, "database error");
    … …  
    153153    // XXX chip_id is being cast here work around psS64 have a different type
    154154    // different on 32/64
    155     if (!p_psDBRunQuery(config->dbh, query,
     155    if (!p_psDBRunQueryF(config->dbh, query,
    156156                "new", // state
    157157                workdir  ? workdir  : "NULL",

  • trunk/ippTools/src/pxregister.c

    r18336 r21402  
    5050
    5151    char *query = "UPDATE newExp SET state = '%s' WHERE exp_id = %"PRId64;
    52     if (!p_psDBRunQuery(config->dbh, query, state, exp_id)) {
     52    if (!p_psDBRunQueryF(config->dbh, query, state, exp_id)) {
    5353        psError(PS_ERR_UNKNOWN, false,
    5454                "failed to change state for exp_id %"PRId64, exp_id);

  • trunk/ippTools/src/pxwarp.c

    r20973 r21402  
    4141
    4242    char *query = "UPDATE warpRun SET state = '%s' WHERE warp_id = %" PRId64;
    43     if (!p_psDBRunQuery(config->dbh, query, state, warp_id)) {
     43    if (!p_psDBRunQueryF(config->dbh, query, state, warp_id)) {
    4444        psError(PS_ERR_UNKNOWN, false,
    4545                "failed to change state for warp_id %" PRId64, warp_id);
    … …  
    7272    }
    7373
    74     if (!p_psDBRunQuery(config->dbh, query, state)) {
     74    if (!p_psDBRunQueryF(config->dbh, query, state)) {
    7575        psFree(query);
    7676        psError(PS_ERR_UNKNOWN, false, "database error");
    … …  
    9090
    9191    char *query = "UPDATE warpRun SET warpRun.label = '%s' WHERE warp_id = %" PRId64;
    92     if (!p_psDBRunQuery(config->dbh, query, label, warp_id)) {
     92    if (!p_psDBRunQueryF(config->dbh, query, label, warp_id)) {
    9393        psError(PS_ERR_UNKNOWN, false,
    9494                "failed to change label for warp_id %" PRId64, warp_id);
    … …  
    113113    }
    114114
    115     if (!p_psDBRunQuery(config->dbh, query, label)) {
     115    if (!p_psDBRunQueryF(config->dbh, query, label)) {
    116116        psFree(query);
    117117        psError(PS_ERR_UNKNOWN, false, "database error");

  • trunk/ippTools/src/pzgetexp.c

    r18928 r21402  
    8585    if (!all) {
    8686        char *query = "SELECT * from summitExp WHERE camera = \"%s\" and TELESCOPE = \"%s\" ORDER BY dateobs DESC LIMIT 1";
    87         if (!p_psDBRunQuery(config->dbh, query, camera, telescope)) {
     87        if (!p_psDBRunQueryF(config->dbh, query, camera, telescope)) {
    8888            psError(PS_ERR_UNKNOWN, false, "database error");
    8989            return false;

  • trunk/ippTools/src/pzgetimfiles.c

    r20813 r21402  
    101101    if (status != 0) {
    102102        // mark the summitExp row as faulted
    103         if (!p_psDBRunQuery(config->dbh, "UPDATE summitExp SET fault = %d WHERE exp_name = '%s' AND camera = '%s' AND telescope = '%s'", WEXITSTATUS(status), filesetid, camera, telescope)) {
     103        if (!p_psDBRunQueryF(config->dbh, "UPDATE summitExp SET fault = %d WHERE exp_name = '%s' AND camera = '%s' AND telescope = '%s'", WEXITSTATUS(status), filesetid, camera, telescope)) {
    104104            psError(PS_ERR_UNKNOWN, false, "database error");
    105105        }
    … …  
    117117        // download an "empty" fileset.
    118118        // mark the summitExp row as faulted
    119         if (!p_psDBRunQuery(config->dbh, "UPDATE summitExp SET fault = %d WHERE exp_name = '%s' AND camera = '%s' AND telescope = '%s'", 250, filesetid, camera, telescope)) {
     119        if (!p_psDBRunQueryF(config->dbh, "UPDATE summitExp SET fault = %d WHERE exp_name = '%s' AND camera = '%s' AND telescope = '%s'", 250, filesetid, camera, telescope)) {
    120120                psError(PS_ERR_UNKNOWN, false, "database error");
    121121        }
    … …  
    145145            " AND camera = '%s'"
    146146            " AND telescope = '%s'";
    147         if (!p_psDBRunQuery(config->dbh, query, imfiles, filesetid, camera, telescope)) {
     147        if (!p_psDBRunQueryF(config->dbh, query, imfiles, filesetid, camera, telescope)) {
    148148            // rollback
    149149            if (!psDBRollback(config->dbh)) {
    … …  
    162162                "   AND camera = '%s'"
    163163                "   AND telescope = '%s'";
    164             if (!p_psDBRunQuery(config->dbh, query, filesetid, camera, telescope)) {
     164            if (!p_psDBRunQueryF(config->dbh, query, filesetid, camera, telescope)) {
    165165                // rollback
    166166                if (!psDBRollback(config->dbh)) {
    … …  
    281281            "   AND telescope = '%s'"
    282282            "   AND imfiles IS NULL";
    283         if (!p_psDBRunQuery(config->dbh, query, filesetid, camera, telescope, filesetid, camera, telescope)) {
     283        if (!p_psDBRunQueryF(config->dbh, query, filesetid, camera, telescope, filesetid, camera, telescope)) {
    284284            // rollback
    285285            if (!psDBRollback(config->dbh)) {

  • trunk/ippTools/src/pztool.c

    r20310 r21402  
    592592                "       AND pzDownloadImfile.telescope = '%s'";
    593593
    594             if (!p_psDBRunQuery(config->dbh, query, exp_id, doneExp->exp_name, doneExp->camera, doneExp->telescope)) {
     594            if (!p_psDBRunQueryF(config->dbh, query, exp_id, doneExp->exp_name, doneExp->camera, doneExp->telescope)) {
    595595                psError(PS_ERR_UNKNOWN, false, "database error");
    596596                psFree(doneExp);
    … …  
    915915
    916916    char *query = "UPDATE pzDownloadExp SET state = '%s' WHERE exp_name = '%s' and camera = '%s' and telescope = '%s'";
    917     if (!p_psDBRunQuery(config->dbh, query, state, exp_name, camera, telescope)) {
     917    if (!p_psDBRunQueryF(config->dbh, query, state, exp_name, camera, telescope)) {
    918918        psError(PS_ERR_UNKNOWN, false, "failed to change state for %s:%s:%s", exp_name, camera, telescope);
    919919        return false;

  • trunk/ippTools/src/regtool.c

    r20973 r21402  
    481481
    482482    // 1st arg: where hook, 2nd arg: limit hook
    483     if (!p_psDBRunQuery(config->dbh, query, "", limitString ? limitString : "")) {
     483    if (!p_psDBRunQueryF(config->dbh, query, "", limitString ? limitString : "")) {
    484484        // XXX PS_EXIT_PROG_ERROR (incorrect SQL) or SYS_ERROR (database comms)
    485485        psError(PXTOOLS_ERR_PROG, false, "database error");
    … …  
    630630
    631631    // 1st arg: where hook, 2nd arg: limit hook
    632     if (!p_psDBRunQuery(config->dbh, query, whereClause ? whereClause : "", "")) {
     632    if (!p_psDBRunQueryF(config->dbh, query, whereClause ? whereClause : "", "")) {
    633633        psError(PS_ERR_UNKNOWN, false, "database error");
    634634        psFree(whereClause);

  • trunk/ippTools/src/stacktool.c

    r19931 r21402  
    358358        // this insert needs to use exactly the same restrictions (race condition is probably not critical)
    359359        // the insert below seems to only restrict matches to the skycell, tess, and filter
    360         if ((randomLimit > 0 && !p_psDBRunQuery(config->dbh, thisInsert, skycell_id, filter, randomLimit)) ||
    361             (randomLimit <= 0 && !p_psDBRunQuery(config->dbh, thisInsert, skycell_id, filter))) {
     360        if ((randomLimit > 0 && !p_psDBRunQueryF(config->dbh, thisInsert, skycell_id, filter, randomLimit)) ||
     361            (randomLimit <= 0 && !p_psDBRunQueryF(config->dbh, thisInsert, skycell_id, filter))) {
    362362            psError(PS_ERR_UNKNOWN, false, "database error");
    363363            psFree(thisInsert);
    … …  
    968968
    969969    char *query = "UPDATE stackRun SET state = '%s' WHERE stack_id = %"PRId64;
    970     if (!p_psDBRunQuery(config->dbh, query, state, stack_id)) {
     970    if (!p_psDBRunQueryF(config->dbh, query, state, stack_id)) {
    971971        psError(PS_ERR_UNKNOWN, false,
    972972                "failed to change state for stack_id %"PRId64, stack_id);

  • trunk/ippTools/src/warptool.c

    r21308 r21402  
    746746        psS64 warp_id = item->data.S64;
    747747
    748         if (!p_psDBRunQuery(config->dbh, query, warp_id, skycell_id)) {
     748        if (!p_psDBRunQueryF(config->dbh, query, warp_id, skycell_id)) {
    749749            psError(PS_ERR_UNKNOWN, false, "database error");
    750750            return false;
    … …  
    13851385    char *query = "DELETE FROM warpMask WHERE label = '%s'";
    13861386
    1387     if (!p_psDBRunQuery(config->dbh, query, label)) {
     1387    if (!p_psDBRunQueryF(config->dbh, query, label)) {
    13881388        psError(PS_ERR_UNKNOWN, false, "database error");
    13891389        return false;
    … …  
    16201620
    16211621    // note only updates if warpRun.state = run_state
    1622     if (!p_psDBRunQuery(config->dbh, query, data_state, warp_id, skycell_id, run_state)) {
     1622    if (!p_psDBRunQueryF(config->dbh, query, data_state, warp_id, skycell_id, run_state)) {
    16231623        psError(PS_ERR_UNKNOWN, false, "database error");
    16241624        // rollback
    … …  
    16321632
    16331633    query = pxDataGet("warptool_change_run_state.sql");
    1634     if (!p_psDBRunQuery(config->dbh, query, data_state, warp_id, data_state)) {
     1634    if (!p_psDBRunQueryF(config->dbh, query, data_state, warp_id, data_state)) {
    16351635        // rollback
    16361636        if (!psDBRollback(config->dbh)) {
    … …  
    16721672    psString query = pxDataGet("warptool_updateskyfile.sql");
    16731673
    1674     if (!p_psDBRunQuery(config->dbh, query, code, warp_id, skycell_id)) {
     1674    if (!p_psDBRunQueryF(config->dbh, query, code, warp_id, skycell_id)) {
    16751675        psError(PS_ERR_UNKNOWN, false, "database error");
    16761676        return false;
Note: See TracChangeset for help on using the changeset viewer.