IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Changeset 17216


Ignore:
Timestamp:
Mar 28, 2008, 3:57:39 PM (18 years ago)
Author:
jhoblitt
Message:

add camtool -revertprocessedexp query support

Location:
trunk/ippTools
Files:
5 edited

Legend:

Unmodified
Added
Removed

  • trunk/ippTools/share/camtool_reset_faulted_runs.sql

    r16985 r17216  
    1 UPDATE camRun, camProcessedExp SET camRun.state = 'run'
     1UPDATE camRun, camProcessedExp, chipRun, rawExp
     2SET camRun.state = 'run'
    23WHERE
    34    camRun.cam_id = camProcessedExp.cam_id
     5    AND camRun.chip_id = chipRun.chip_id
     6    AND chipRun.exp_id = rawExp.exp_id
    47    AND camProcessedExp.fault != 0

  • trunk/ippTools/share/camtool_revertprocessedexp.sql

    r14100 r17216  
    11DELETE FROM camProcessedExp
     2USING camProcessedExp, camRun, chipRun, rawExp
    23WHERE
    3     fault != 0
     4    camRun.cam_id = camProcessedExp.cam_id
     5    AND camRun.chip_id = chipRun.chip_id
     6    AND chipRun.exp_id = rawExp.exp_id
     7    AND camProcessedExp.fault != 0

  • trunk/ippTools/share/chiptool_revertprocessedimfile.sql

    r14099 r17216  
    11DELETE FROM chipProcessedImfile
     2USING chipProcessedImfile, rawExp
    23WHERE
    3     fault != 0
     4    rawExp.exp_id = chipProcessedImfile.exp_id
     5    AND chipProcessedImfile.fault != 0

  • trunk/ippTools/src/camtool.c

    r17171 r17216  
    159159    PXOPT_COPY_F32(config->args, where, "-solang_max", "solang", "<");
    160160
    161     if (!psListLength(where->list)) {
     161    if (!psListLength(where->list)
     162        && !psMetadataLookupBool(NULL, config->args, "-all")) {
    162163        psFree(where);
     164        where = NULL;
    163165        psError(PXTOOLS_ERR_DATA, false, "search parameters are required");
    164166        return false;
    … …  
    180182    }
    181183
    182     if (where) {
     184    if (where && psListLength(where->list)) {
    183185        psString whereClause = psDBGenerateWhereConditionSQL(where, "");
    184186        psFree(where);
    … …  
    337339    PXOPT_COPY_F32(config->args, where, "-solang_max", "solang", "<");
    338340
    339     if (!psListLength(where->list)) {
     341    if (!psListLength(where->list)
     342        && !psMetadataLookupBool(NULL, config->args, "-all")) {
    340343        psFree(where);
     344        where = NULL;
    341345        psError(PXTOOLS_ERR_DATA, false, "search parameters are required");
    342346        return false;
    … …  
    760764    PS_ASSERT_PTR_NON_NULL(config, false);
    761765
     766    PXOPT_LOOKUP_STR(cam_id, config->args, "-cam_id", false, false);
     767    PXOPT_LOOKUP_STR(chip_id, config->args, "-chip_id", false, false);
     768    PXOPT_LOOKUP_STR(exp_id, config->args, "-exp_id", false, false);
     769
     770    psMetadata *where = psMetadataAlloc();
     771    // convert cam_id into a psS64
     772    if (cam_id) {
     773        if (!psMetadataAddS64(where, PS_LIST_TAIL, "cam_id", 0, "==", (psS64)atoll(cam_id))) {
     774            psError(PS_ERR_UNKNOWN, false, "failed to add item cam_id");
     775            psFree(where);
     776            return false;
     777        }
     778    }
     779
     780    // convert chip_id into a psS64
     781    if (chip_id) {
     782        if (!psMetadataAddS64(where, PS_LIST_TAIL, "chip_id", 0, "==", (psS64)atoll(chip_id))) {
     783            psError(PS_ERR_UNKNOWN, false, "failed to add item chip_id");
     784            psFree(where);
     785            return false;
     786        }
     787    }
     788
     789    // convert exp_id into a psS64
     790    if (exp_id) {
     791        if (!psMetadataAddS64(where, PS_LIST_TAIL, "exp_id", 0, "==", (psS64)atoll(exp_id))) {
     792            psError(PS_ERR_UNKNOWN, false, "failed to add item exp_id");
     793            psFree(where);
     794            return false;
     795        }
     796    }
     797
     798    PXOPT_COPY_STR(config->args, where, "-exp_name", "exp_name", "==");
     799    PXOPT_COPY_STR(config->args, where, "-inst", "camera", "==");
     800    PXOPT_COPY_STR(config->args, where, "-telescope", "telescope", "==");
     801    PXOPT_COPY_TIME(config->args, where, "-dateobs_begin", "dateobs", ">=");
     802    PXOPT_COPY_TIME(config->args, where, "-dateobs_end", "dateobs", "<=");
     803    PXOPT_COPY_STR(config->args, where, "-exp_tag", "exp_tag", "==");
     804    PXOPT_COPY_STR(config->args, where, "-exp_type", "exp_type", "==");
     805    PXOPT_COPY_STR(config->args, where, "-filelevel", "filelevel", "==");
     806    PXOPT_COPY_STR(config->args, where, "-reduction", "reduction", "==");
     807    PXOPT_COPY_STR(config->args, where, "-filter", "filter", "==");
     808
     809    PXOPT_COPY_F64(config->args, where, "-airmass_min", "airmass", ">=");
     810    PXOPT_COPY_F64(config->args, where, "-airmass_max", "airmass", "<");
     811    PXOPT_COPY_F64(config->args, where, "-ra_min", "ra", ">=");
     812    PXOPT_COPY_F64(config->args, where, "-ra_max", "ra", "<");
     813    PXOPT_COPY_F64(config->args, where, "-decl_min", "decl", ">=");
     814    PXOPT_COPY_F64(config->args, where, "-decl_max", "decl", "<");
     815    PXOPT_COPY_F32(config->args, where, "-exp_time_min", "exp_time", ">=");
     816    PXOPT_COPY_F32(config->args, where, "-exp_time_max", "exp_time", "<");
     817    PXOPT_COPY_F32(config->args, where, "-sat_pixel_frac_min", "sat_pixel_frac", ">=");
     818    PXOPT_COPY_F32(config->args, where, "-sat_pixel_frac_max", "sat_pixel_frac", "<");
     819    PXOPT_COPY_F64(config->args, where, "-bg_min", "bt", ">=");
     820    PXOPT_COPY_F64(config->args, where, "-bg_max", "bt", "<");
     821    PXOPT_COPY_F64(config->args, where, "-bg_stdev_min", "bg_stdev", ">=");
     822    PXOPT_COPY_F64(config->args, where, "-bg_stdev_max", "bg_stdev", "<");
     823    PXOPT_COPY_F64(config->args, where, "-bg_mean_stdev_min", "bg_mean_stdev", ">=");
     824    PXOPT_COPY_F64(config->args, where, "-bg_mean_stdev_max", "bg_mean_stdev", "<");
     825    PXOPT_COPY_F64(config->args, where, "-alt_min", "alt", ">=");
     826    PXOPT_COPY_F64(config->args, where, "-alt_max", "alt", "<");
     827    PXOPT_COPY_F64(config->args, where, "-az_min", "az", ">=");
     828    PXOPT_COPY_F64(config->args, where, "-az_max", "az", "<");
     829    PXOPT_COPY_F32(config->args, where, "-ccd_temp_min", "ccd_temp", ">=");
     830    PXOPT_COPY_F32(config->args, where, "-ccd_temp_max", "ccd_temp", "<");
     831    PXOPT_COPY_F64(config->args, where, "-posang_min", "posang", ">=");
     832    PXOPT_COPY_F64(config->args, where, "-posang_max", "posang", "<");
     833    PXOPT_COPY_STR(config->args, where, "-object", "object", "==");
     834    PXOPT_COPY_F32(config->args, where, "-solang_min", "solang", ">=");
     835    PXOPT_COPY_F32(config->args, where, "-solang_max", "solang", "<");
     836
     837    if (!psListLength(where->list)
     838        && !psMetadataLookupBool(NULL, config->args, "-all")) {
     839        psFree(where);
     840        where = NULL;
     841        psError(PXTOOLS_ERR_DATA, false, "search parameters are required");
     842        return false;
     843    }
     844
    762845    if (!psDBTransaction(config->dbh)) {
    763846        psError(PS_ERR_UNKNOWN, false, "database error");
     847        psFree(where);
    764848        return false;
    765849    }
    … …  
    769853    if (!query) {
    770854        psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
    771         return false;
    772     }
    773 
    774     if (config->where) {
    775         psString whereClause = psDBGenerateWhereConditionSQL(config->where, "camProcessedExp");
     855        psFree(where);
     856        return false;
     857    }
     858
     859    if (where && psListLength(where->list)) {
     860        psString whereClause = psDBGenerateWhereConditionSQL(where, NULL);
    776861        psStringAppend(&query, " AND %s", whereClause);
    777862        psFree(whereClause);
    … …  
    785870        psError(PS_ERR_UNKNOWN, false, "database error");
    786871        psFree(query);
     872        psFree(where);
    787873        return false;
    788874    }
    … …  
    798884        }
    799885        psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
    800         return false;
    801     }
    802 
    803     if (config->where) {
    804         psString whereClause = psDBGenerateWhereConditionSQL(config->where, "camProcessedExp");
     886        psFree(where);
     887        return false;
     888    }
     889
     890    if (where && psListLength(where->list)) {
     891        psString whereClause = psDBGenerateWhereConditionSQL(config->where, NULL);
    805892        psStringAppend(&query, " AND %s", whereClause);
    806893        psFree(whereClause);
    … …  
    814901        psError(PS_ERR_UNKNOWN, false, "database error");
    815902        psFree(query);
     903        psFree(where);
    816904        return false;
    817905    }
    818906    psFree(query);
    819907}
    820 
    821     if (psDBAffectedRows(config->dbh) < 1) {
    822         // rollback
    823         if (!psDBRollback(config->dbh)) {
    824             psError(PS_ERR_UNKNOWN, false, "database error");
    825         }
    826         psError(PS_ERR_UNKNOWN, false, "should have affected atleast 1 row");
    827         return false;
    828     }
     908    psFree(where);
    829909
    830910    if (!psDBCommit(config->dbh)) {

  • trunk/ippTools/src/camtoolConfig.c

    r17171 r17216  
    142142    psMetadataAddStr(queueArgs, PS_LIST_TAIL, "-set_end_stage",  0,
    143143            "define end stage", NULL);
     144    psMetadataAddBool(queueArgs, PS_LIST_TAIL, "-all",  0,
     145            "allow everything to be queued without search terms", false);
    144146
    145147    // -updaterun
    … …  
    229231            "define max solar angle", NAN);
    230232
     233    psMetadataAddBool(updaterunArgs, PS_LIST_TAIL, "-all",  0,
     234            "allow everything to be queued without search terms", false);
    231235    psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-state", 0,
    232236            "set state", NULL);
    … …  
    337341    // -revertprocessedexp
    338342    psMetadata *revertprocessedexpArgs = psMetadataAlloc();
    339     psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-cam_id", 0,
    340             "search by camtool ID (required)", NULL);
    341     psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-chip_id", 0,
    342             "search by chiptool ID", NULL);
     343    // XXX need to allow multiple cam_ids
     344    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-cam_id",  0,
     345            "search by cam_id", NULL);
     346    // XXX need to allow multiple chip_ids
     347    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-chip_id",  0,
     348            "search by chip_id", NULL);
     349    // XXX need to allow multiple exp_ids
     350    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-exp_id",  0,
     351            "search by exp_id", NULL);
     352    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-exp_name",  0,
     353            "search by exp_name", NULL);
     354    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-inst",  0,
     355            "search for camera", NULL);
     356    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-telescope",  0,
     357            "search for telescope", NULL);
     358    psMetadataAddTime(revertprocessedexpArgs, PS_LIST_TAIL, "-dateobs_begin", 0,
     359            "search for exposures by time (>=)", NULL);
     360    psMetadataAddTime(revertprocessedexpArgs, PS_LIST_TAIL, "-dateobs_end", 0,
     361            "search for exposures by time (<)", NULL);
     362    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-exp_tag",  0,
     363            "search by exp_tag", NULL);
     364    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-exp_type",  0,
     365            "search by exp_type", NULL);
     366    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-filelevel",  0,
     367            "search by filelevel", NULL);
     368    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-reduction",  0,
     369            "search by reduction class", NULL);
     370    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-filter",  0,
     371            "search for filter", NULL);
     372    psMetadataAddF32(revertprocessedexpArgs, PS_LIST_TAIL, "-airmass_min",  0,
     373            "define min airmass", NAN);
     374    psMetadataAddF32(revertprocessedexpArgs, PS_LIST_TAIL, "-airmass_max",  0,
     375            "define max airmass", NAN);
     376    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-ra_min",  0,
     377            "define min", NAN);
     378    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-ra_max",  0,
     379            "define max", NAN);
     380    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-decl_min",  0,
     381            "define min", NAN);
     382    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-decl_max",  0,
     383            "define max", NAN);
     384    psMetadataAddF32(revertprocessedexpArgs, PS_LIST_TAIL, "-exp_time_min",  0,
     385            "define min", NAN);
     386    psMetadataAddF32(revertprocessedexpArgs, PS_LIST_TAIL, "-exp_time_max",  0,
     387            "define max", NAN);
     388    psMetadataAddF32(revertprocessedexpArgs, PS_LIST_TAIL, "-sat_pixel_frac_min",  0,
     389            "define max fraction of saturated pixels", NAN);
     390    psMetadataAddF32(revertprocessedexpArgs, PS_LIST_TAIL, "-sat_pixel_frac_max",  0,
     391            "define min fraction of saturated pixels", NAN);
     392    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-bg_min",  0,
     393            "define max", NAN);
     394    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-bg_max",  0,
     395            "define max", NAN);
     396    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-bg_stdev_min",  0,
     397            "define max", NAN);
     398    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-bg_stdev_max",  0,
     399            "define max", NAN);
     400    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-bg_mean_stdev_min",  0,
     401            "define max", NAN);
     402    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-bg_mean_stdev_max",  0,
     403            "define max", NAN);
     404    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-alt_min",  0,
     405            "define min", NAN);
     406    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-alt_max",  0,
     407            "define max", NAN);
     408    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-az_min",  0,
     409            "define min", NAN);
     410    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-az_max",  0,
     411            "define max", NAN);
     412    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-ccd_temp_min",  0,
     413            "define min ccd tempature", NAN);
     414    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-ccd_temp_max",  0,
     415            "define max ccd tempature", NAN);
     416    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-posang_min",  0,
     417            "define min rotator position angle", NAN);
     418    psMetadataAddF64(revertprocessedexpArgs, PS_LIST_TAIL, "-posang_max",  0,
     419            "define max rotator position angle", NAN);
     420    psMetadataAddStr(revertprocessedexpArgs, PS_LIST_TAIL, "-object",  0,
     421            "search by exposure object", NULL);
     422    psMetadataAddF32(revertprocessedexpArgs, PS_LIST_TAIL, "-solang_min",  0,
     423            "define min solar angle", NAN);
     424    psMetadataAddF32(revertprocessedexpArgs, PS_LIST_TAIL, "-solang_max",  0,
     425            "define max solar angle", NAN);
     426
     427    psMetadataAddBool(revertprocessedexpArgs, PS_LIST_TAIL, "-all",  0,
     428            "allow everything to be queued without search terms", false);
    343429    psMetadataAddS16(revertprocessedexpArgs, PS_LIST_TAIL, "-code",  0,
    344430            "search by fault code", 0);
     431
    345432
    346433    // -updateprocessedexp
Note: See TracChangeset for help on using the changeset viewer.