IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Ignore:
Timestamp:
Aug 14, 2006, 11:56:03 AM (20 years ago)
Author:
jhoblitt
Message:

VERSION 0.0.27

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/ippdb/src/ippdb.c

    r8306 r8319  
    87938793static void rawImfileRowFree(rawImfileRow *object);
    87948794
    8795 rawImfileRow *rawImfileRowAlloc(const char *exp_id, const char *class, const char *class_id, const char *uri, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang)
     8795rawImfileRow *rawImfileRowAlloc(const char *exp_id, const char *class, const char *class_id, const char *exp_type, const char *uri, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang)
    87968796{
    87978797    rawImfileRow    *object;
     
    88038803    object->class = psStringCopy(class);
    88048804    object->class_id = psStringCopy(class_id);
     8805    object->exp_type = psStringCopy(exp_type);
    88058806    object->uri = psStringCopy(uri);
    88068807    object->filter = psStringCopy(filter);
     
    88258826    psFree(object->class);
    88268827    psFree(object->class_id);
     8828    psFree(object->exp_type);
    88278829    psFree(object->uri);
    88288830    psFree(object->filter);
     
    88558857        return false;
    88568858    }
     8859    if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_type", 0, NULL, "64")) {
     8860        psError(PS_ERR_UNKNOWN, false, "failed to add item exp_type");
     8861        psFree(md);
     8862        return false;
     8863    }
    88578864    if (!psMetadataAddStr(md, PS_LIST_TAIL, "uri", 0, NULL, "255")) {
    88588865        psError(PS_ERR_UNKNOWN, false, "failed to add item uri");
     
    89338940}
    89348941
    8935 bool rawImfileInsert(psDB * dbh, const char *exp_id, const char *class, const char *class_id, const char *uri, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang)
     8942bool rawImfileInsert(psDB * dbh, const char *exp_id, const char *class, const char *class_id, const char *exp_type, const char *uri, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang)
    89368943{
    89378944    psMetadata      *md;
     
    89518958    if (!psMetadataAddStr(md, PS_LIST_TAIL, "class_id", 0, NULL, class_id)) {
    89528959        psError(PS_ERR_UNKNOWN, false, "failed to add item class_id");
     8960        psFree(md);
     8961        return false;
     8962    }
     8963    if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_type", 0, NULL, exp_type)) {
     8964        psError(PS_ERR_UNKNOWN, false, "failed to add item exp_type");
    89538965        psFree(md);
    89548966        return false;
     
    90409052    return deleted;
    90419053}
    9042 bool rawImfilePop(psDB *dbh, char **exp_id, char **class, char **class_id, char **uri, char **filter, psF32 *airmass, psF64 *ra, psF64 *decl, psF32 *exp_time, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, psF64 *alt, psF64 *az, psF32 *ccd_temp, psF64 *posang)
     9054bool rawImfilePop(psDB *dbh, char **exp_id, char **class, char **class_id, char **exp_type, char **uri, char **filter, psF32 *airmass, psF64 *ra, psF64 *decl, psF32 *exp_time, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, psF64 *alt, psF64 *az, psF32 *ccd_temp, psF64 *posang)
    90439055{
    90449056    psArray         *rowSet;
     
    91029114        return false;
    91039115    }
     9116    *exp_type = psMetadataLookupPtr(&status, row, "exp_type");
     9117    if (!status) {
     9118        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_type");
     9119        psFree(row);
     9120        return false;
     9121    }
    91049122    *uri = psMetadataLookupPtr(&status, row, "uri");
    91059123    if (!status) {
     
    91889206bool rawImfileInsertObject(psDB *dbh, rawImfileRow *object)
    91899207{
    9190     return rawImfileInsert(dbh, object->exp_id, object->class, object->class_id, object->uri, object->filter, object->airmass, object->ra, object->decl, object->exp_time, object->bg, object->bg_stdev, object->bg_mean_stdev, object->alt, object->az, object->ccd_temp, object->posang);
     9208    return rawImfileInsert(dbh, object->exp_id, object->class, object->class_id, object->exp_type, object->uri, object->filter, object->airmass, object->ra, object->decl, object->exp_time, object->bg, object->bg_stdev, object->bg_mean_stdev, object->alt, object->az, object->ccd_temp, object->posang);
    91919209}
    91929210
     
    92079225    char            class[256];
    92089226    char            class_id[256];
     9227    char            exp_type[256];
    92099228    char            uri[256];
    92109229    char            filter[256];
     
    92219240    psF64           posang;
    92229241
    9223     if (!rawImfilePop(dbh, (char **)&exp_id, (char **)&class, (char **)&class_id, (char **)&uri, (char **)&filter, &airmass, &ra, &decl, &exp_time, &bg, &bg_stdev, &bg_mean_stdev, &alt, &az, &ccd_temp, &posang)) {
     9242    if (!rawImfilePop(dbh, (char **)&exp_id, (char **)&class, (char **)&class_id, (char **)&exp_type, (char **)&uri, (char **)&filter, &airmass, &ra, &decl, &exp_time, &bg, &bg_stdev, &bg_mean_stdev, &alt, &az, &ccd_temp, &posang)) {
    92249243        psError(PS_ERR_UNKNOWN, false, "failed to pop a database row");
    92259244        return NULL;
    92269245    }
    92279246
    9228     return rawImfileRowAlloc(exp_id, class, class_id, uri, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang);
     9247    return rawImfileRowAlloc(exp_id, class, class_id, exp_type, uri, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang);
    92299248}
    92309249
     
    93409359        return NULL;
    93419360    }
     9361    if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_type", 0, NULL, object->exp_type)) {
     9362        psError(PS_ERR_UNKNOWN, false, "failed to add item exp_type");
     9363        psFree(md);
     9364        return NULL;
     9365    }
    93429366    if (!psMetadataAddStr(md, PS_LIST_TAIL, "uri", 0, NULL, object->uri)) {
    93439367        psError(PS_ERR_UNKNOWN, false, "failed to add item uri");
     
    94159439    char            *class;
    94169440    char            *class_id;
     9441    char            *exp_type;
    94179442    char            *uri;
    94189443    char            *filter;
     
    94449469        return false;
    94459470    }
     9471    exp_type = psMetadataLookupPtr(&status, md, "exp_type");
     9472    if (!status) {
     9473        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_type");
     9474        return false;
     9475    }
    94469476    uri = psMetadataLookupPtr(&status, md, "uri");
    94479477    if (!status) {
     
    95109540    }
    95119541
    9512     return rawImfileRowAlloc(exp_id, class, class_id, uri, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang);
     9542    return rawImfileRowAlloc(exp_id, class, class_id, exp_type, uri, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang);
    95139543}
    95149544psArray *rawImfileSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit)
     
    1346113491static void detProcessedImfileRowFree(detProcessedImfileRow *object);
    1346213492
    13463 detProcessedImfileRow *detProcessedImfileRowAlloc(psS32 det_id, const char *exp_id, const char *class_id, const char *uri, const char *recipe)
     13493detProcessedImfileRow *detProcessedImfileRowAlloc(psS32 det_id, const char *exp_id, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev)
    1346413494{
    1346513495    detProcessedImfileRow *object;
     
    1347313503    object->uri = psStringCopy(uri);
    1347413504    object->recipe = psStringCopy(recipe);
     13505    object->bg = bg;
     13506    object->bg_stdev = bg_stdev;
     13507    object->bg_mean_stdev = bg_mean_stdev;
    1347513508
    1347613509    return object;
     
    1352113554        return false;
    1352213555    }
     13556    if (!psMetadataAddF64(md, PS_LIST_TAIL, "bg", 0, NULL, 0.0)) {
     13557        psError(PS_ERR_UNKNOWN, false, "failed to add item bg");
     13558        psFree(md);
     13559        return false;
     13560    }
     13561    if (!psMetadataAddF64(md, PS_LIST_TAIL, "bg_stdev", 0, NULL, 0.0)) {
     13562        psError(PS_ERR_UNKNOWN, false, "failed to add item bg_stdev");
     13563        psFree(md);
     13564        return false;
     13565    }
     13566    if (!psMetadataAddF64(md, PS_LIST_TAIL, "bg_mean_stdev", 0, NULL, 0.0)) {
     13567        psError(PS_ERR_UNKNOWN, false, "failed to add item bg_mean_stdev");
     13568        psFree(md);
     13569        return false;
     13570    }
    1352313571
    1352413572    status = psDBCreateTable(dbh, DETPROCESSEDIMFILE_TABLE_NAME, md);
     
    1353413582}
    1353513583
    13536 bool detProcessedImfileInsert(psDB * dbh, psS32 det_id, const char *exp_id, const char *class_id, const char *uri, const char *recipe)
     13584bool detProcessedImfileInsert(psDB * dbh, psS32 det_id, const char *exp_id, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev)
    1353713585{
    1353813586    psMetadata      *md;
     
    1356213610    if (!psMetadataAddStr(md, PS_LIST_TAIL, "recipe", 0, NULL, recipe)) {
    1356313611        psError(PS_ERR_UNKNOWN, false, "failed to add item recipe");
     13612        psFree(md);
     13613        return false;
     13614    }
     13615    if (!psMetadataAddF64(md, PS_LIST_TAIL, "bg", 0, NULL, bg)) {
     13616        psError(PS_ERR_UNKNOWN, false, "failed to add item bg");
     13617        psFree(md);
     13618        return false;
     13619    }
     13620    if (!psMetadataAddF64(md, PS_LIST_TAIL, "bg_stdev", 0, NULL, bg_stdev)) {
     13621        psError(PS_ERR_UNKNOWN, false, "failed to add item bg_stdev");
     13622        psFree(md);
     13623        return false;
     13624    }
     13625    if (!psMetadataAddF64(md, PS_LIST_TAIL, "bg_mean_stdev", 0, NULL, bg_mean_stdev)) {
     13626        psError(PS_ERR_UNKNOWN, false, "failed to add item bg_mean_stdev");
    1356413627        psFree(md);
    1356513628        return false;
     
    1358613649    return deleted;
    1358713650}
    13588 bool detProcessedImfilePop(psDB *dbh, psS32 *det_id, char **exp_id, char **class_id, char **uri, char **recipe)
     13651bool detProcessedImfilePop(psDB *dbh, psS32 *det_id, char **exp_id, char **class_id, char **uri, char **recipe, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev)
    1358913652{
    1359013653    psArray         *rowSet;
     
    1366013723        return false;
    1366113724    }
     13725    *bg = psMetadataLookupF64(&status, row, "bg");
     13726    if (!status) {
     13727        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item bg");
     13728        psFree(row);
     13729        return false;
     13730    }
     13731    *bg_stdev = psMetadataLookupF64(&status, row, "bg_stdev");
     13732    if (!status) {
     13733        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item bg_stdev");
     13734        psFree(row);
     13735        return false;
     13736    }
     13737    *bg_mean_stdev = psMetadataLookupF64(&status, row, "bg_mean_stdev");
     13738    if (!status) {
     13739        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item bg_mean_stdev");
     13740        psFree(row);
     13741        return false;
     13742    }
    1366213743
    1366313744    psFree(row);
     
    1366813749bool detProcessedImfileInsertObject(psDB *dbh, detProcessedImfileRow *object)
    1366913750{
    13670     return detProcessedImfileInsert(dbh, object->det_id, object->exp_id, object->class_id, object->uri, object->recipe);
     13751    return detProcessedImfileInsert(dbh, object->det_id, object->exp_id, object->class_id, object->uri, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev);
    1367113752}
    1367213753
     
    1368913770    char            uri[256];
    1369013771    char            recipe[256];
    13691 
    13692     if (!detProcessedImfilePop(dbh, &det_id, (char **)&exp_id, (char **)&class_id, (char **)&uri, (char **)&recipe)) {
     13772    psF64           bg;
     13773    psF64           bg_stdev;
     13774    psF64           bg_mean_stdev;
     13775
     13776    if (!detProcessedImfilePop(dbh, &det_id, (char **)&exp_id, (char **)&class_id, (char **)&uri, (char **)&recipe, &bg, &bg_stdev, &bg_mean_stdev)) {
    1369313777        psError(PS_ERR_UNKNOWN, false, "failed to pop a database row");
    1369413778        return NULL;
    1369513779    }
    1369613780
    13697     return detProcessedImfileRowAlloc(det_id, exp_id, class_id, uri, recipe);
     13781    return detProcessedImfileRowAlloc(det_id, exp_id, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev);
    1369813782}
    1369913783
     
    1381913903        return NULL;
    1382013904    }
     13905    if (!psMetadataAddF64(md, PS_LIST_TAIL, "bg", 0, NULL, object->bg)) {
     13906        psError(PS_ERR_UNKNOWN, false, "failed to add item bg");
     13907        psFree(md);
     13908        return NULL;
     13909    }
     13910    if (!psMetadataAddF64(md, PS_LIST_TAIL, "bg_stdev", 0, NULL, object->bg_stdev)) {
     13911        psError(PS_ERR_UNKNOWN, false, "failed to add item bg_stdev");
     13912        psFree(md);
     13913        return NULL;
     13914    }
     13915    if (!psMetadataAddF64(md, PS_LIST_TAIL, "bg_mean_stdev", 0, NULL, object->bg_mean_stdev)) {
     13916        psError(PS_ERR_UNKNOWN, false, "failed to add item bg_mean_stdev");
     13917        psFree(md);
     13918        return NULL;
     13919    }
    1382113920
    1382213921    return md;
     
    1383113930    char            *uri;
    1383213931    char            *recipe;
     13932    psF64           bg;
     13933    psF64           bg_stdev;
     13934    psF64           bg_mean_stdev;
    1383313935
    1383413936    det_id = psMetadataLookupS32(&status, md, "det_id");
     
    1385713959        return false;
    1385813960    }
    13859 
    13860     return detProcessedImfileRowAlloc(det_id, exp_id, class_id, uri, recipe);
     13961    bg = psMetadataLookupF64(&status, md, "bg");
     13962    if (!status) {
     13963        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item bg");
     13964        return false;
     13965    }
     13966    bg_stdev = psMetadataLookupF64(&status, md, "bg_stdev");
     13967    if (!status) {
     13968        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item bg_stdev");
     13969        return false;
     13970    }
     13971    bg_mean_stdev = psMetadataLookupF64(&status, md, "bg_mean_stdev");
     13972    if (!status) {
     13973        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item bg_mean_stdev");
     13974        return false;
     13975    }
     13976
     13977    return detProcessedImfileRowAlloc(det_id, exp_id, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev);
    1386113978}
    1386213979psArray *detProcessedImfileSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit)
Note: See TracChangeset for help on using the changeset viewer.