- Timestamp:
- Jul 30, 2010, 9:31:50 AM (16 years ago)
- Location:
- branches/eam_branches/ipp-20100621/ippTools/src
- Files:
-
- 2 edited
-
. (modified) (1 prop)
-
stacktool.c (modified) (17 diffs)
Legend:
- Unmodified
- Added
- Removed
-
branches/eam_branches/ipp-20100621/ippTools/src
- Property svn:ignore
-
old new 39 39 warptool 40 40 staticskytool 41 41 bgtool 42 42 diffphottool
-
- Property svn:ignore
-
branches/eam_branches/ipp-20100621/ippTools/src/stacktool.c
r28376 r28794 78 78 MODECASE(STACKTOOL_MODE_ADDSUMSKYFILE, addsumskyfileMode); 79 79 MODECASE(STACKTOOL_MODE_SUMSKYFILE, sumskyfileMode); 80 MODECASE(STACKTOOL_MODE_SASSSKYFILE, sassskyfileMode);80 MODECASE(STACKTOOL_MODE_SASSSKYFILE, sassskyfileMode); 81 81 MODECASE(STACKTOOL_MODE_REVERTSUMSKYFILE, revertsumskyfileMode); 82 MODECASE(STACKTOOL_MODE_TOSUMMARY, tosummaryMode);83 MODECASE(STACKTOOL_MODE_ADDSUMMARY, addsummaryMode);82 MODECASE(STACKTOOL_MODE_TOSUMMARY, tosummaryMode); 83 MODECASE(STACKTOOL_MODE_ADDSUMMARY, addsummaryMode); 84 84 MODECASE(STACKTOOL_MODE_PENDINGCLEANUPRUN, pendingcleanuprunMode); 85 85 MODECASE(STACKTOOL_MODE_PENDINGCLEANUPSKYFILE, pendingcleanupskyfileMode); … … 155 155 156 156 printf("%" PRId64 " %s %s %s %s\n",psMetadataLookupS64(NULL,row,"sass_id"), 157 psMetadataLookupStr(NULL,row,"data_group"),158 psMetadataLookupStr(NULL,row,"tess_id"),159 psMetadataLookupStr(NULL,row,"filter"),160 psMetadataLookupStr(NULL,row,"projection_cell"));157 psMetadataLookupStr(NULL,row,"data_group"), 158 psMetadataLookupStr(NULL,row,"tess_id"), 159 psMetadataLookupStr(NULL,row,"filter"), 160 psMetadataLookupStr(NULL,row,"projection_cell")); 161 161 162 162 if (psMetadataLookupS64(NULL,row,"sass_id") == PS_MAX_S64) { … … 170 170 psMetadataAddStr(outrow,PS_LIST_TAIL,"filter",PS_META_REPLACE,"",psMetadataLookupStr(NULL,row,"filter")); 171 171 psMetadataAddStr(outrow,PS_LIST_TAIL,"projection_cell",PS_META_REPLACE,"", 172 psMetadataLookupStr(NULL,row,"projection_cell"));172 psMetadataLookupStr(NULL,row,"projection_cell")); 173 173 } 174 174 printf("%" PRId64 " %s %s %s %s\n",psMetadataLookupS64(NULL,outrow,"sass_id"), 175 psMetadataLookupStr(NULL,outrow,"data_group"),176 psMetadataLookupStr(NULL,outrow,"tess_id"),177 psMetadataLookupStr(NULL,outrow,"filter"),178 psMetadataLookupStr(NULL,outrow,"projection_cell"));179 175 psMetadataLookupStr(NULL,outrow,"data_group"), 176 psMetadataLookupStr(NULL,outrow,"tess_id"), 177 psMetadataLookupStr(NULL,outrow,"filter"), 178 psMetadataLookupStr(NULL,outrow,"projection_cell")); 179 180 180 181 181 psFree(output); … … 184 184 return(sassRow); 185 185 } 186 187 188 189 186 187 188 189 190 190 191 191 … … 239 239 PXOPT_COPY_F32(config->args, where, "-select_zpt_obs_min", "camProcessedExp.zpt_obs", ">="); 240 240 PXOPT_COPY_F32(config->args, where, "-select_zpt_obs_max", "camProcessedExp.zpt_obs", "<="); 241 PXOPT_COPY_F32(config->args, where, "-select_astrom", "sqrt(POWER(camProcessedExp.sigma_ra, 2) + POWER(camProcessedExp.sigma_dec, 2))", "<="); 241 242 242 243 PXOPT_COPY_STR(config->args, where, "-select_exp_type", "rawExp.exp_type", "=="); … … 483 484 psFree(run); 484 485 485 //CZW Add an association entry here.486 // Define the requested association, and insert it if it doesn't already exist487 stackAssociationRow *association = pxStackAssociationDefine(config,stack_id);488 psS64 sass_id;489 if (!association->sass_id) {490 psTrace("stacktool.association",2,"No required Association found. Adding.");491 492 if (!stackAssociationInsertObject(config->dbh,association)) {493 if (!psDBRollback(config->dbh)) {494 psError(PS_ERR_UNKNOWN, false, "database error");495 }496 psError(PS_ERR_UNKNOWN, false, "database error");497 psFree(output);498 psFree(run);499 psFree(insert);500 psFree(list);501 psFree(association);502 if (!psDBRollback(config->dbh)) {503 psError(PS_ERR_UNKNOWN, false, "database error");504 }505 return(false);506 }507 sass_id = psDBLastInsertID(config->dbh);508 association->sass_id = sass_id;509 }510 // Insert the map entry for this row.511 stackAssociationMapRow *maprow = stackAssociationMapRowAlloc(sass_id,stack_id);512 if (!stackAssociationMapInsertObject(config->dbh,maprow)) {513 if (!psDBRollback(config->dbh)) {514 psError(PS_ERR_UNKNOWN, false, "database error");515 }516 psError(PS_ERR_UNKNOWN, false, "database error");517 psFree(output);518 psFree(run);519 psFree(insert);520 psFree(list);521 psFree(association);522 if (!psDBRollback(config->dbh)) {523 psError(PS_ERR_UNKNOWN, false, "database error");524 }525 return(false);526 }527 528 486 //CZW Add an association entry here. 487 // Define the requested association, and insert it if it doesn't already exist 488 stackAssociationRow *association = pxStackAssociationDefine(config,stack_id); 489 psS64 sass_id; 490 if (!association->sass_id) { 491 psTrace("stacktool.association",2,"No required Association found. Adding."); 492 493 if (!stackAssociationInsertObject(config->dbh,association)) { 494 if (!psDBRollback(config->dbh)) { 495 psError(PS_ERR_UNKNOWN, false, "database error"); 496 } 497 psError(PS_ERR_UNKNOWN, false, "database error"); 498 psFree(output); 499 psFree(run); 500 psFree(insert); 501 psFree(list); 502 psFree(association); 503 if (!psDBRollback(config->dbh)) { 504 psError(PS_ERR_UNKNOWN, false, "database error"); 505 } 506 return(false); 507 } 508 sass_id = psDBLastInsertID(config->dbh); 509 association->sass_id = sass_id; 510 } 511 // Insert the map entry for this row. 512 stackAssociationMapRow *maprow = stackAssociationMapRowAlloc(sass_id,stack_id); 513 if (!stackAssociationMapInsertObject(config->dbh,maprow)) { 514 if (!psDBRollback(config->dbh)) { 515 psError(PS_ERR_UNKNOWN, false, "database error"); 516 } 517 psError(PS_ERR_UNKNOWN, false, "database error"); 518 psFree(output); 519 psFree(run); 520 psFree(insert); 521 psFree(list); 522 psFree(association); 523 if (!psDBRollback(config->dbh)) { 524 psError(PS_ERR_UNKNOWN, false, "database error"); 525 } 526 return(false); 527 } 528 529 529 530 // Create a suitable insertion query for this run 530 531 psString thisInsert = psStringCopy(insert); … … 685 686 686 687 //CZW Add an association entry here. 687 688 688 689 // insert the stackInputSkyfile rows 689 690 psListIterator *iter = psListIteratorAlloc(warp_ids->data.list, 0, false); … … 740 741 PXOPT_COPY_STR(config->args, where, "-label", "stackRun.label", "=="); 741 742 PXOPT_COPY_STR(config->args, where, "-state", "stackRun.state", "=="); 742 PXOPT_COPY_S TR(config->args, where, "-sass_id", "stackAssociationMap.sass_id", "==");743 PXOPT_COPY_S64(config->args, where, "-sass_id", "stackAssociationMap.sass_id", "=="); 743 744 if (!psListLength(where->list)) { 744 745 psFree(where); … … 1348 1349 static bool tosummaryMode(pxConfig *config) { 1349 1350 PS_ASSERT_PTR_NON_NULL(config, NULL); 1350 1351 1351 1352 psMetadata *where = psMetadataAlloc(); 1352 1353 PXOPT_COPY_S64(config->args, where, "-stack_id", "stackSumSkyfile.warp_id", "=="); … … 1357 1358 pxAddLabelSearchArgs (config, where, "-label", "stackRun.label", "LIKE"); 1358 1359 pxAddLabelSearchArgs (config, where, "-data_group", "stackRun.data_group", "LIKE"); 1359 1360 1360 1361 PXOPT_LOOKUP_BOOL(all, config->args, "-all", false); 1361 1362 1362 1363 PXOPT_LOOKUP_U64(limit, config->args, "-limit", false, false); 1363 1364 PXOPT_LOOKUP_BOOL(simple, config->args, "-simple", false); 1364 1365 1365 1366 // find all rawImfiles matching the default query 1366 1367 psString query = pxDataGet("stacktool_tosummary.sql"); … … 1380 1381 return false; 1381 1382 } 1382 1383 1383 1384 psFree(where); 1384 1385 … … 1408 1409 psError(PXTOOLS_ERR_PROG, false, "unknown error"); 1409 1410 } 1410 1411 1411 1412 return false; 1412 1413 } … … 1416 1417 return true; 1417 1418 } 1418 1419 1419 1420 if (psArrayLength(output)) { 1420 1421 // negative simple so the default is true … … 1425 1426 } 1426 1427 } 1427 1428 1428 1429 psFree(output); 1429 1430 return(true); … … 1447 1448 } 1448 1449 psS64 numUpdated = psDBAffectedRows(config->dbh); 1449 1450 1450 1451 if (numUpdated != 1) { 1451 1452 psError(PS_ERR_UNKNOWN, false, "should have affected 1 row"); … … 1453 1454 return false; 1454 1455 } 1455 1456 1456 1457 psFree(query); 1457 1458 1458 1459 // Print anything here? 1459 1460 1460 1461 return(true); 1461 1462 } … … 1471 1472 PXOPT_COPY_S64(config->args, where, "-stack_id", "stackRun.stack_id", "=="); 1472 1473 PXOPT_COPY_S64(config->args, where, "-sass_id", "stackAssociationMap.sass_id", "=="); 1473 1474 1474 1475 pxAddLabelSearchArgs (config, where, "-label", "stackRun.label", "=="); 1475 1476
Note:
See TracChangeset
for help on using the changeset viewer.
