Changeset 11733 for trunk/ippdb/src/ippdb.c
- Timestamp:
- Feb 9, 2007, 12:13:45 PM (19 years ago)
- File:
-
- 1 edited
-
trunk/ippdb/src/ippdb.c (modified) (112 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/ippdb/src/ippdb.c
r11720 r11733 3678 3678 return false; 3679 3679 } 3680 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, " NOT NULL", 0)) {3680 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 3681 3681 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 3682 3682 psFree(md); … … 4388 4388 return false; 4389 4389 } 4390 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, " NOT NULL", 0)) {4390 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 4391 4391 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 4392 4392 psFree(md); … … 4927 4927 static void p1PendingExpRowFree(p1PendingExpRow *object); 4928 4928 4929 p1PendingExpRow *p1PendingExpRowAlloc(const char *exp_tag, const char *recipe, psS32 p1_version)4929 p1PendingExpRow *p1PendingExpRowAlloc(const char *exp_tag, psS32 p1_version, const char *recipe) 4930 4930 { 4931 4931 p1PendingExpRow *_object; … … 4935 4935 4936 4936 _object->exp_tag = psStringCopy(exp_tag); 4937 _object->p1_version = p1_version; 4937 4938 _object->recipe = psStringCopy(recipe); 4938 _object->p1_version = p1_version;4939 4939 4940 4940 return _object; … … 4955 4955 return false; 4956 4956 } 4957 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, "Primary Key", 0)) { 4958 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 4959 psFree(md); 4960 return false; 4961 } 4957 4962 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, "64")) { 4958 4963 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); … … 4960 4965 return false; 4961 4966 } 4962 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, 0)) {4963 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version");4964 psFree(md);4965 return false;4966 }4967 4967 4968 4968 bool status = psDBCreateTable(dbh, P1PENDINGEXP_TABLE_NAME, md); … … 4978 4978 } 4979 4979 4980 bool p1PendingExpInsert(psDB * dbh, const char *exp_tag, const char *recipe, psS32 p1_version)4980 bool p1PendingExpInsert(psDB * dbh, const char *exp_tag, psS32 p1_version, const char *recipe) 4981 4981 { 4982 4982 psMetadata *md = psMetadataAlloc(); … … 4986 4986 return false; 4987 4987 } 4988 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, p1_version)) { 4989 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 4990 psFree(md); 4991 return false; 4992 } 4988 4993 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, recipe)) { 4989 4994 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); 4990 psFree(md);4991 return false;4992 }4993 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, p1_version)) {4994 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version");4995 4995 psFree(md); 4996 4996 return false; … … 5019 5019 bool p1PendingExpInsertObject(psDB *dbh, p1PendingExpRow *object) 5020 5020 { 5021 return p1PendingExpInsert(dbh, object->exp_tag, object-> recipe, object->p1_version);5021 return p1PendingExpInsert(dbh, object->exp_tag, object->p1_version, object->recipe); 5022 5022 } 5023 5023 … … 5097 5097 return false; 5098 5098 } 5099 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, object->p1_version)) { 5100 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 5101 psFree(md); 5102 return false; 5103 } 5099 5104 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, object->recipe)) { 5100 5105 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); … … 5102 5107 return false; 5103 5108 } 5104 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, object->p1_version)) {5105 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version");5106 psFree(md);5107 return false;5108 }5109 5109 5110 5110 … … 5121 5121 return false; 5122 5122 } 5123 psS32 p1_version = psMetadataLookupS32(&status, md, "p1_version"); 5124 if (!status) { 5125 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p1_version"); 5126 return false; 5127 } 5123 5128 char* recipe = psMetadataLookupPtr(&status, md, "recipe"); 5124 5129 if (!status) { … … 5126 5131 return false; 5127 5132 } 5128 psS32 p1_version = psMetadataLookupS32(&status, md, "p1_version"); 5129 if (!status) { 5130 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p1_version"); 5131 return false; 5132 } 5133 5134 return p1PendingExpRowAlloc(exp_tag, recipe, p1_version); 5133 5134 return p1PendingExpRowAlloc(exp_tag, p1_version, recipe); 5135 5135 } 5136 5136 psArray *p1PendingExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 5244 5244 static void p2PendingExpRowFree(p2PendingExpRow *object); 5245 5245 5246 p2PendingExpRow *p2PendingExpRowAlloc(const char *exp_tag, const char *recipe, psS32 p1_version, psS32 p2_version, const char *label)5246 p2PendingExpRow *p2PendingExpRowAlloc(const char *exp_tag, psS32 p2_version, psS32 p1_version, const char *label, const char *recipe) 5247 5247 { 5248 5248 p2PendingExpRow *_object; … … 5252 5252 5253 5253 _object->exp_tag = psStringCopy(exp_tag); 5254 _object->p2_version = p2_version; 5255 _object->p1_version = p1_version; 5256 _object->label = psStringCopy(label); 5254 5257 _object->recipe = psStringCopy(recipe); 5255 _object->p1_version = p1_version;5256 _object->p2_version = p2_version;5257 _object->label = psStringCopy(label);5258 5258 5259 5259 return _object; … … 5263 5263 { 5264 5264 psFree(object->exp_tag); 5265 psFree(object->label); 5265 5266 psFree(object->recipe); 5266 psFree(object->label);5267 5267 } 5268 5268 … … 5275 5275 return false; 5276 5276 } 5277 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, "Primary Key", 0)) { 5278 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 5279 psFree(md); 5280 return false; 5281 } 5282 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, 0)) { 5283 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 5284 psFree(md); 5285 return false; 5286 } 5287 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, "key", "64")) { 5288 psError(PS_ERR_UNKNOWN, false, "failed to add item label"); 5289 psFree(md); 5290 return false; 5291 } 5277 5292 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, "64")) { 5278 5293 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); … … 5280 5295 return false; 5281 5296 } 5282 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, 0)) {5283 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version");5284 psFree(md);5285 return false;5286 }5287 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, 0)) {5288 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");5289 psFree(md);5290 return false;5291 }5292 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, "key", "64")) {5293 psError(PS_ERR_UNKNOWN, false, "failed to add item label");5294 psFree(md);5295 return false;5296 }5297 5297 5298 5298 bool status = psDBCreateTable(dbh, P2PENDINGEXP_TABLE_NAME, md); … … 5308 5308 } 5309 5309 5310 bool p2PendingExpInsert(psDB * dbh, const char *exp_tag, const char *recipe, psS32 p1_version, psS32 p2_version, const char *label)5310 bool p2PendingExpInsert(psDB * dbh, const char *exp_tag, psS32 p2_version, psS32 p1_version, const char *label, const char *recipe) 5311 5311 { 5312 5312 psMetadata *md = psMetadataAlloc(); … … 5316 5316 return false; 5317 5317 } 5318 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, p2_version)) { 5319 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 5320 psFree(md); 5321 return false; 5322 } 5323 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, p1_version)) { 5324 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 5325 psFree(md); 5326 return false; 5327 } 5328 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, NULL, label)) { 5329 psError(PS_ERR_UNKNOWN, false, "failed to add item label"); 5330 psFree(md); 5331 return false; 5332 } 5318 5333 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, recipe)) { 5319 5334 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); 5320 psFree(md);5321 return false;5322 }5323 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, p1_version)) {5324 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version");5325 psFree(md);5326 return false;5327 }5328 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, p2_version)) {5329 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");5330 psFree(md);5331 return false;5332 }5333 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, NULL, label)) {5334 psError(PS_ERR_UNKNOWN, false, "failed to add item label");5335 5335 psFree(md); 5336 5336 return false; … … 5359 5359 bool p2PendingExpInsertObject(psDB *dbh, p2PendingExpRow *object) 5360 5360 { 5361 return p2PendingExpInsert(dbh, object->exp_tag, object-> recipe, object->p1_version, object->p2_version, object->label);5361 return p2PendingExpInsert(dbh, object->exp_tag, object->p2_version, object->p1_version, object->label, object->recipe); 5362 5362 } 5363 5363 … … 5437 5437 return false; 5438 5438 } 5439 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, object->p2_version)) { 5440 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 5441 psFree(md); 5442 return false; 5443 } 5444 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, object->p1_version)) { 5445 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 5446 psFree(md); 5447 return false; 5448 } 5449 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, NULL, object->label)) { 5450 psError(PS_ERR_UNKNOWN, false, "failed to add item label"); 5451 psFree(md); 5452 return false; 5453 } 5439 5454 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, object->recipe)) { 5440 5455 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); … … 5442 5457 return false; 5443 5458 } 5444 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, object->p1_version)) {5445 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version");5446 psFree(md);5447 return false;5448 }5449 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, object->p2_version)) {5450 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");5451 psFree(md);5452 return false;5453 }5454 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, NULL, object->label)) {5455 psError(PS_ERR_UNKNOWN, false, "failed to add item label");5456 psFree(md);5457 return false;5458 }5459 5459 5460 5460 … … 5471 5471 return false; 5472 5472 } 5473 psS32 p2_version = psMetadataLookupS32(&status, md, "p2_version"); 5474 if (!status) { 5475 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p2_version"); 5476 return false; 5477 } 5478 psS32 p1_version = psMetadataLookupS32(&status, md, "p1_version"); 5479 if (!status) { 5480 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p1_version"); 5481 return false; 5482 } 5483 char* label = psMetadataLookupPtr(&status, md, "label"); 5484 if (!status) { 5485 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item label"); 5486 return false; 5487 } 5473 5488 char* recipe = psMetadataLookupPtr(&status, md, "recipe"); 5474 5489 if (!status) { … … 5476 5491 return false; 5477 5492 } 5478 psS32 p1_version = psMetadataLookupS32(&status, md, "p1_version"); 5479 if (!status) { 5480 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p1_version"); 5481 return false; 5482 } 5483 psS32 p2_version = psMetadataLookupS32(&status, md, "p2_version"); 5484 if (!status) { 5485 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p2_version"); 5486 return false; 5487 } 5488 char* label = psMetadataLookupPtr(&status, md, "label"); 5489 if (!status) { 5490 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item label"); 5491 return false; 5492 } 5493 5494 return p2PendingExpRowAlloc(exp_tag, recipe, p1_version, p2_version, label); 5493 5494 return p2PendingExpRowAlloc(exp_tag, p2_version, p1_version, label, recipe); 5495 5495 } 5496 5496 psArray *p2PendingExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 5604 5604 static void p2PendingImfileRowFree(p2PendingImfileRow *object); 5605 5605 5606 p2PendingImfileRow *p2PendingImfileRowAlloc(const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psS32 p1_version, psS32 p2_version)5606 p2PendingImfileRow *p2PendingImfileRowAlloc(const char *exp_tag, psS32 p2_version, psS32 p1_version, const char *class_id, const char *recipe, const char *uri) 5607 5607 { 5608 5608 p2PendingImfileRow *_object; … … 5612 5612 5613 5613 _object->exp_tag = psStringCopy(exp_tag); 5614 _object->p2_version = p2_version; 5615 _object->p1_version = p1_version; 5614 5616 _object->class_id = psStringCopy(class_id); 5617 _object->recipe = psStringCopy(recipe); 5615 5618 _object->uri = psStringCopy(uri); 5616 _object->recipe = psStringCopy(recipe);5617 _object->p1_version = p1_version;5618 _object->p2_version = p2_version;5619 5619 5620 5620 return _object; … … 5625 5625 psFree(object->exp_tag); 5626 5626 psFree(object->class_id); 5627 psFree(object->recipe); 5627 5628 psFree(object->uri); 5628 psFree(object->recipe);5629 5629 } 5630 5630 … … 5637 5637 return false; 5638 5638 } 5639 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, "Primary Key", 0)) { 5640 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 5641 psFree(md); 5642 return false; 5643 } 5644 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, 0)) { 5645 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 5646 psFree(md); 5647 return false; 5648 } 5639 5649 if (!psMetadataAdd(md, PS_LIST_TAIL, "class_id", PS_DATA_STRING, "Primary Key", "64")) { 5640 5650 psError(PS_ERR_UNKNOWN, false, "failed to add item class_id"); … … 5642 5652 return false; 5643 5653 } 5654 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, "64")) { 5655 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); 5656 psFree(md); 5657 return false; 5658 } 5644 5659 if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, "255")) { 5645 5660 psError(PS_ERR_UNKNOWN, false, "failed to add item uri"); … … 5647 5662 return false; 5648 5663 } 5649 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, "64")) {5650 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe");5651 psFree(md);5652 return false;5653 }5654 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, 0)) {5655 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version");5656 psFree(md);5657 return false;5658 }5659 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, 0)) {5660 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");5661 psFree(md);5662 return false;5663 }5664 5664 5665 5665 bool status = psDBCreateTable(dbh, P2PENDINGIMFILE_TABLE_NAME, md); … … 5675 5675 } 5676 5676 5677 bool p2PendingImfileInsert(psDB * dbh, const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psS32 p1_version, psS32 p2_version)5677 bool p2PendingImfileInsert(psDB * dbh, const char *exp_tag, psS32 p2_version, psS32 p1_version, const char *class_id, const char *recipe, const char *uri) 5678 5678 { 5679 5679 psMetadata *md = psMetadataAlloc(); … … 5683 5683 return false; 5684 5684 } 5685 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, p2_version)) { 5686 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 5687 psFree(md); 5688 return false; 5689 } 5690 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, p1_version)) { 5691 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 5692 psFree(md); 5693 return false; 5694 } 5685 5695 if (!psMetadataAdd(md, PS_LIST_TAIL, "class_id", PS_DATA_STRING, NULL, class_id)) { 5686 5696 psError(PS_ERR_UNKNOWN, false, "failed to add item class_id"); … … 5688 5698 return false; 5689 5699 } 5700 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, recipe)) { 5701 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); 5702 psFree(md); 5703 return false; 5704 } 5690 5705 if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, uri)) { 5691 5706 psError(PS_ERR_UNKNOWN, false, "failed to add item uri"); 5692 psFree(md);5693 return false;5694 }5695 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, recipe)) {5696 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe");5697 psFree(md);5698 return false;5699 }5700 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, p1_version)) {5701 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version");5702 psFree(md);5703 return false;5704 }5705 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, p2_version)) {5706 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");5707 5707 psFree(md); 5708 5708 return false; … … 5731 5731 bool p2PendingImfileInsertObject(psDB *dbh, p2PendingImfileRow *object) 5732 5732 { 5733 return p2PendingImfileInsert(dbh, object->exp_tag, object-> class_id, object->uri, object->recipe, object->p1_version, object->p2_version);5733 return p2PendingImfileInsert(dbh, object->exp_tag, object->p2_version, object->p1_version, object->class_id, object->recipe, object->uri); 5734 5734 } 5735 5735 … … 5809 5809 return false; 5810 5810 } 5811 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, object->p2_version)) { 5812 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 5813 psFree(md); 5814 return false; 5815 } 5816 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, object->p1_version)) { 5817 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 5818 psFree(md); 5819 return false; 5820 } 5811 5821 if (!psMetadataAdd(md, PS_LIST_TAIL, "class_id", PS_DATA_STRING, NULL, object->class_id)) { 5812 5822 psError(PS_ERR_UNKNOWN, false, "failed to add item class_id"); … … 5814 5824 return false; 5815 5825 } 5826 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, object->recipe)) { 5827 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); 5828 psFree(md); 5829 return false; 5830 } 5816 5831 if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, object->uri)) { 5817 5832 psError(PS_ERR_UNKNOWN, false, "failed to add item uri"); … … 5819 5834 return false; 5820 5835 } 5821 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, object->recipe)) {5822 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe");5823 psFree(md);5824 return false;5825 }5826 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, object->p1_version)) {5827 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version");5828 psFree(md);5829 return false;5830 }5831 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, object->p2_version)) {5832 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");5833 psFree(md);5834 return false;5835 }5836 5836 5837 5837 … … 5848 5848 return false; 5849 5849 } 5850 psS32 p2_version = psMetadataLookupS32(&status, md, "p2_version"); 5851 if (!status) { 5852 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p2_version"); 5853 return false; 5854 } 5855 psS32 p1_version = psMetadataLookupS32(&status, md, "p1_version"); 5856 if (!status) { 5857 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p1_version"); 5858 return false; 5859 } 5850 5860 char* class_id = psMetadataLookupPtr(&status, md, "class_id"); 5851 5861 if (!status) { … … 5853 5863 return false; 5854 5864 } 5865 char* recipe = psMetadataLookupPtr(&status, md, "recipe"); 5866 if (!status) { 5867 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item recipe"); 5868 return false; 5869 } 5855 5870 char* uri = psMetadataLookupPtr(&status, md, "uri"); 5856 5871 if (!status) { … … 5858 5873 return false; 5859 5874 } 5860 char* recipe = psMetadataLookupPtr(&status, md, "recipe"); 5861 if (!status) { 5862 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item recipe"); 5863 return false; 5864 } 5865 psS32 p1_version = psMetadataLookupS32(&status, md, "p1_version"); 5866 if (!status) { 5867 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p1_version"); 5868 return false; 5869 } 5870 psS32 p2_version = psMetadataLookupS32(&status, md, "p2_version"); 5871 if (!status) { 5872 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p2_version"); 5873 return false; 5874 } 5875 5876 return p2PendingImfileRowAlloc(exp_tag, class_id, uri, recipe, p1_version, p2_version); 5875 5876 return p2PendingImfileRowAlloc(exp_tag, p2_version, p1_version, class_id, recipe, uri); 5877 5877 } 5878 5878 psArray *p2PendingImfileSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 5986 5986 static void p2ProcessedExpRowFree(p2ProcessedExpRow *object); 5987 5987 5988 p2ProcessedExpRow *p2ProcessedExpRowAlloc(const char *exp_tag, psS32 p 1_version, psS32 p2_version, const char *label)5988 p2ProcessedExpRow *p2ProcessedExpRowAlloc(const char *exp_tag, psS32 p2_version, psS32 p1_version, const char *label) 5989 5989 { 5990 5990 p2ProcessedExpRow *_object; … … 5994 5994 5995 5995 _object->exp_tag = psStringCopy(exp_tag); 5996 _object->p2_version = p2_version; 5996 5997 _object->p1_version = p1_version; 5997 _object->p2_version = p2_version;5998 5998 _object->label = psStringCopy(label); 5999 5999 … … 6015 6015 return false; 6016 6016 } 6017 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, "Primary Key", 0)) { 6018 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 6019 psFree(md); 6020 return false; 6021 } 6017 6022 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, 0)) { 6018 6023 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); … … 6020 6025 return false; 6021 6026 } 6022 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, 0)) {6023 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");6024 psFree(md);6025 return false;6026 }6027 6027 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, "key", "64")) { 6028 6028 psError(PS_ERR_UNKNOWN, false, "failed to add item label"); … … 6043 6043 } 6044 6044 6045 bool p2ProcessedExpInsert(psDB * dbh, const char *exp_tag, psS32 p 1_version, psS32 p2_version, const char *label)6045 bool p2ProcessedExpInsert(psDB * dbh, const char *exp_tag, psS32 p2_version, psS32 p1_version, const char *label) 6046 6046 { 6047 6047 psMetadata *md = psMetadataAlloc(); … … 6051 6051 return false; 6052 6052 } 6053 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, p2_version)) { 6054 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 6055 psFree(md); 6056 return false; 6057 } 6053 6058 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, p1_version)) { 6054 6059 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 6055 psFree(md);6056 return false;6057 }6058 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, p2_version)) {6059 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");6060 6060 psFree(md); 6061 6061 return false; … … 6089 6089 bool p2ProcessedExpInsertObject(psDB *dbh, p2ProcessedExpRow *object) 6090 6090 { 6091 return p2ProcessedExpInsert(dbh, object->exp_tag, object->p 1_version, object->p2_version, object->label);6091 return p2ProcessedExpInsert(dbh, object->exp_tag, object->p2_version, object->p1_version, object->label); 6092 6092 } 6093 6093 … … 6167 6167 return false; 6168 6168 } 6169 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, object->p2_version)) { 6170 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 6171 psFree(md); 6172 return false; 6173 } 6169 6174 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, object->p1_version)) { 6170 6175 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); … … 6172 6177 return false; 6173 6178 } 6174 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, object->p2_version)) {6175 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");6176 psFree(md);6177 return false;6178 }6179 6179 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, NULL, object->label)) { 6180 6180 psError(PS_ERR_UNKNOWN, false, "failed to add item label"); … … 6196 6196 return false; 6197 6197 } 6198 psS32 p2_version = psMetadataLookupS32(&status, md, "p2_version"); 6199 if (!status) { 6200 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p2_version"); 6201 return false; 6202 } 6198 6203 psS32 p1_version = psMetadataLookupS32(&status, md, "p1_version"); 6199 6204 if (!status) { … … 6201 6206 return false; 6202 6207 } 6203 psS32 p2_version = psMetadataLookupS32(&status, md, "p2_version");6204 if (!status) {6205 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p2_version");6206 return false;6207 }6208 6208 char* label = psMetadataLookupPtr(&status, md, "label"); 6209 6209 if (!status) { … … 6212 6212 } 6213 6213 6214 return p2ProcessedExpRowAlloc(exp_tag, p 1_version, p2_version, label);6214 return p2ProcessedExpRowAlloc(exp_tag, p2_version, p1_version, label); 6215 6215 } 6216 6216 psArray *p2ProcessedExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 6598 6598 static void p2ProcessedImfileRowFree(p2ProcessedImfileRow *object); 6599 6599 6600 p2ProcessedImfileRow *p2ProcessedImfileRowAlloc(const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, psS32 p1_version, psS32 p2_version, psS16 fault)6600 p2ProcessedImfileRow *p2ProcessedImfileRowAlloc(const char *exp_tag, psS32 p2_version, psS32 p1_version, const char *class_id, const char *recipe, const char *uri, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, psS16 fault) 6601 6601 { 6602 6602 p2ProcessedImfileRow *_object; … … 6606 6606 6607 6607 _object->exp_tag = psStringCopy(exp_tag); 6608 _object->p2_version = p2_version; 6609 _object->p1_version = p1_version; 6608 6610 _object->class_id = psStringCopy(class_id); 6611 _object->recipe = psStringCopy(recipe); 6609 6612 _object->uri = psStringCopy(uri); 6610 _object->recipe = psStringCopy(recipe);6611 6613 _object->bg = bg; 6612 6614 _object->bg_stdev = bg_stdev; … … 6614 6616 _object->b1_uri = psStringCopy(b1_uri); 6615 6617 _object->b2_uri = psStringCopy(b2_uri); 6616 _object->p1_version = p1_version;6617 _object->p2_version = p2_version;6618 6618 _object->fault = fault; 6619 6619 … … 6625 6625 psFree(object->exp_tag); 6626 6626 psFree(object->class_id); 6627 psFree(object->recipe); 6627 6628 psFree(object->uri); 6628 psFree(object->recipe);6629 6629 psFree(object->b1_uri); 6630 6630 psFree(object->b2_uri); … … 6639 6639 return false; 6640 6640 } 6641 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, "Primary Key", 0)) { 6642 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 6643 psFree(md); 6644 return false; 6645 } 6646 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, 0)) { 6647 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 6648 psFree(md); 6649 return false; 6650 } 6641 6651 if (!psMetadataAdd(md, PS_LIST_TAIL, "class_id", PS_DATA_STRING, "Primary Key", "64")) { 6642 6652 psError(PS_ERR_UNKNOWN, false, "failed to add item class_id"); … … 6644 6654 return false; 6645 6655 } 6656 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, "64")) { 6657 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); 6658 psFree(md); 6659 return false; 6660 } 6646 6661 if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, "255")) { 6647 6662 psError(PS_ERR_UNKNOWN, false, "failed to add item uri"); … … 6649 6664 return false; 6650 6665 } 6651 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, "64")) {6652 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe");6653 psFree(md);6654 return false;6655 }6656 6666 if (!psMetadataAdd(md, PS_LIST_TAIL, "bg", PS_DATA_F64, NULL, 0.0)) { 6657 6667 psError(PS_ERR_UNKNOWN, false, "failed to add item bg"); … … 6679 6689 return false; 6680 6690 } 6681 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, 0)) { 6682 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 6683 psFree(md); 6684 return false; 6685 } 6686 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, 0)) { 6687 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 6688 psFree(md); 6689 return false; 6690 } 6691 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "NOT NULL", 0)) { 6691 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 6692 6692 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 6693 6693 psFree(md); … … 6707 6707 } 6708 6708 6709 bool p2ProcessedImfileInsert(psDB * dbh, const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, psS32 p1_version, psS32 p2_version, psS16 fault)6709 bool p2ProcessedImfileInsert(psDB * dbh, const char *exp_tag, psS32 p2_version, psS32 p1_version, const char *class_id, const char *recipe, const char *uri, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, psS16 fault) 6710 6710 { 6711 6711 psMetadata *md = psMetadataAlloc(); … … 6715 6715 return false; 6716 6716 } 6717 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, p2_version)) { 6718 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 6719 psFree(md); 6720 return false; 6721 } 6722 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, p1_version)) { 6723 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 6724 psFree(md); 6725 return false; 6726 } 6717 6727 if (!psMetadataAdd(md, PS_LIST_TAIL, "class_id", PS_DATA_STRING, NULL, class_id)) { 6718 6728 psError(PS_ERR_UNKNOWN, false, "failed to add item class_id"); … … 6720 6730 return false; 6721 6731 } 6732 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, recipe)) { 6733 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); 6734 psFree(md); 6735 return false; 6736 } 6722 6737 if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, uri)) { 6723 6738 psError(PS_ERR_UNKNOWN, false, "failed to add item uri"); … … 6725 6740 return false; 6726 6741 } 6727 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, recipe)) {6728 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe");6729 psFree(md);6730 return false;6731 }6732 6742 if (!psMetadataAdd(md, PS_LIST_TAIL, "bg", PS_DATA_F64, NULL, bg)) { 6733 6743 psError(PS_ERR_UNKNOWN, false, "failed to add item bg"); … … 6752 6762 if (!psMetadataAdd(md, PS_LIST_TAIL, "b2_uri", PS_DATA_STRING, NULL, b2_uri)) { 6753 6763 psError(PS_ERR_UNKNOWN, false, "failed to add item b2_uri"); 6754 psFree(md);6755 return false;6756 }6757 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, p1_version)) {6758 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version");6759 psFree(md);6760 return false;6761 }6762 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, p2_version)) {6763 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");6764 6764 psFree(md); 6765 6765 return false; … … 6793 6793 bool p2ProcessedImfileInsertObject(psDB *dbh, p2ProcessedImfileRow *object) 6794 6794 { 6795 return p2ProcessedImfileInsert(dbh, object->exp_tag, object-> class_id, object->uri, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev, object->b1_uri, object->b2_uri, object->p1_version, object->p2_version, object->fault);6795 return p2ProcessedImfileInsert(dbh, object->exp_tag, object->p2_version, object->p1_version, object->class_id, object->recipe, object->uri, object->bg, object->bg_stdev, object->bg_mean_stdev, object->b1_uri, object->b2_uri, object->fault); 6796 6796 } 6797 6797 … … 6871 6871 return false; 6872 6872 } 6873 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, object->p2_version)) { 6874 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 6875 psFree(md); 6876 return false; 6877 } 6878 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, object->p1_version)) { 6879 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version"); 6880 psFree(md); 6881 return false; 6882 } 6873 6883 if (!psMetadataAdd(md, PS_LIST_TAIL, "class_id", PS_DATA_STRING, NULL, object->class_id)) { 6874 6884 psError(PS_ERR_UNKNOWN, false, "failed to add item class_id"); … … 6876 6886 return false; 6877 6887 } 6888 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, object->recipe)) { 6889 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe"); 6890 psFree(md); 6891 return false; 6892 } 6878 6893 if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, object->uri)) { 6879 6894 psError(PS_ERR_UNKNOWN, false, "failed to add item uri"); … … 6881 6896 return false; 6882 6897 } 6883 if (!psMetadataAdd(md, PS_LIST_TAIL, "recipe", PS_DATA_STRING, NULL, object->recipe)) {6884 psError(PS_ERR_UNKNOWN, false, "failed to add item recipe");6885 psFree(md);6886 return false;6887 }6888 6898 if (!psMetadataAdd(md, PS_LIST_TAIL, "bg", PS_DATA_F64, NULL, object->bg)) { 6889 6899 psError(PS_ERR_UNKNOWN, false, "failed to add item bg"); … … 6911 6921 return false; 6912 6922 } 6913 if (!psMetadataAdd(md, PS_LIST_TAIL, "p1_version", PS_DATA_S32, NULL, object->p1_version)) {6914 psError(PS_ERR_UNKNOWN, false, "failed to add item p1_version");6915 psFree(md);6916 return false;6917 }6918 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, object->p2_version)) {6919 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");6920 psFree(md);6921 return false;6922 }6923 6923 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, NULL, object->fault)) { 6924 6924 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); … … 6940 6940 return false; 6941 6941 } 6942 psS32 p2_version = psMetadataLookupS32(&status, md, "p2_version"); 6943 if (!status) { 6944 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p2_version"); 6945 return false; 6946 } 6947 psS32 p1_version = psMetadataLookupS32(&status, md, "p1_version"); 6948 if (!status) { 6949 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p1_version"); 6950 return false; 6951 } 6942 6952 char* class_id = psMetadataLookupPtr(&status, md, "class_id"); 6943 6953 if (!status) { … … 6945 6955 return false; 6946 6956 } 6957 char* recipe = psMetadataLookupPtr(&status, md, "recipe"); 6958 if (!status) { 6959 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item recipe"); 6960 return false; 6961 } 6947 6962 char* uri = psMetadataLookupPtr(&status, md, "uri"); 6948 6963 if (!status) { … … 6950 6965 return false; 6951 6966 } 6952 char* recipe = psMetadataLookupPtr(&status, md, "recipe");6953 if (!status) {6954 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item recipe");6955 return false;6956 }6957 6967 psF64 bg = psMetadataLookupF64(&status, md, "bg"); 6958 6968 if (!status) { … … 6980 6990 return false; 6981 6991 } 6982 psS32 p1_version = psMetadataLookupS32(&status, md, "p1_version");6983 if (!status) {6984 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p1_version");6985 return false;6986 }6987 psS32 p2_version = psMetadataLookupS32(&status, md, "p2_version");6988 if (!status) {6989 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p2_version");6990 return false;6991 }6992 6992 psS16 fault = psMetadataLookupS16(&status, md, "fault"); 6993 6993 if (!status) { … … 6996 6996 } 6997 6997 6998 return p2ProcessedImfileRowAlloc(exp_tag, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri, p1_version, p2_version, fault);6998 return p2ProcessedImfileRowAlloc(exp_tag, p2_version, p1_version, class_id, recipe, uri, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri, fault); 6999 6999 } 7000 7000 psArray *p2ProcessedImfileSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 7108 7108 static void p3PendingExpRowFree(p3PendingExpRow *object); 7109 7109 7110 p3PendingExpRow *p3PendingExpRowAlloc(const char *exp_tag, psS32 p 2_version, psS32 p3_version, const char *label)7110 p3PendingExpRow *p3PendingExpRowAlloc(const char *exp_tag, psS32 p3_version, psS32 p2_version, const char *label) 7111 7111 { 7112 7112 p3PendingExpRow *_object; … … 7116 7116 7117 7117 _object->exp_tag = psStringCopy(exp_tag); 7118 _object->p3_version = p3_version; 7118 7119 _object->p2_version = p2_version; 7119 _object->p3_version = p3_version;7120 7120 _object->label = psStringCopy(label); 7121 7121 … … 7137 7137 return false; 7138 7138 } 7139 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, "Primary Key", 0)) { 7140 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version"); 7141 psFree(md); 7142 return false; 7143 } 7139 7144 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, 0)) { 7140 7145 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); … … 7142 7147 return false; 7143 7148 } 7144 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, NULL, 0)) {7145 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version");7146 psFree(md);7147 return false;7148 }7149 7149 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, "key", "64")) { 7150 7150 psError(PS_ERR_UNKNOWN, false, "failed to add item label"); … … 7165 7165 } 7166 7166 7167 bool p3PendingExpInsert(psDB * dbh, const char *exp_tag, psS32 p 2_version, psS32 p3_version, const char *label)7167 bool p3PendingExpInsert(psDB * dbh, const char *exp_tag, psS32 p3_version, psS32 p2_version, const char *label) 7168 7168 { 7169 7169 psMetadata *md = psMetadataAlloc(); … … 7173 7173 return false; 7174 7174 } 7175 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, NULL, p3_version)) { 7176 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version"); 7177 psFree(md); 7178 return false; 7179 } 7175 7180 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, p2_version)) { 7176 7181 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 7177 psFree(md);7178 return false;7179 }7180 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, NULL, p3_version)) {7181 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version");7182 7182 psFree(md); 7183 7183 return false; … … 7211 7211 bool p3PendingExpInsertObject(psDB *dbh, p3PendingExpRow *object) 7212 7212 { 7213 return p3PendingExpInsert(dbh, object->exp_tag, object->p 2_version, object->p3_version, object->label);7213 return p3PendingExpInsert(dbh, object->exp_tag, object->p3_version, object->p2_version, object->label); 7214 7214 } 7215 7215 … … 7289 7289 return false; 7290 7290 } 7291 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, NULL, object->p3_version)) { 7292 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version"); 7293 psFree(md); 7294 return false; 7295 } 7291 7296 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, object->p2_version)) { 7292 7297 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); … … 7294 7299 return false; 7295 7300 } 7296 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, NULL, object->p3_version)) {7297 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version");7298 psFree(md);7299 return false;7300 }7301 7301 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, NULL, object->label)) { 7302 7302 psError(PS_ERR_UNKNOWN, false, "failed to add item label"); … … 7318 7318 return false; 7319 7319 } 7320 psS32 p3_version = psMetadataLookupS32(&status, md, "p3_version"); 7321 if (!status) { 7322 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p3_version"); 7323 return false; 7324 } 7320 7325 psS32 p2_version = psMetadataLookupS32(&status, md, "p2_version"); 7321 7326 if (!status) { … … 7323 7328 return false; 7324 7329 } 7325 psS32 p3_version = psMetadataLookupS32(&status, md, "p3_version");7326 if (!status) {7327 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p3_version");7328 return false;7329 }7330 7330 char* label = psMetadataLookupPtr(&status, md, "label"); 7331 7331 if (!status) { … … 7334 7334 } 7335 7335 7336 return p3PendingExpRowAlloc(exp_tag, p 2_version, p3_version, label);7336 return p3PendingExpRowAlloc(exp_tag, p3_version, p2_version, label); 7337 7337 } 7338 7338 psArray *p3PendingExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 7446 7446 static void p3ProcessedExpRowFree(p3ProcessedExpRow *object); 7447 7447 7448 p3ProcessedExpRow *p3ProcessedExpRowAlloc(const char *exp_tag, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF32 sigma_ra, psF32 sigma_dec, psS32 nastro, const char *b1_uri, const char *b2_uri, psF32 zp_mean, psF32 zp_stdev, psS32 p2_version, psS32 p3_version, const char *label, psS16 fault)7448 p3ProcessedExpRow *p3ProcessedExpRowAlloc(const char *exp_tag, psS32 p3_version, psS32 p2_version, const char *label, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF32 sigma_ra, psF32 sigma_dec, psS32 nastro, const char *b1_uri, const char *b2_uri, psF32 zp_mean, psF32 zp_stdev, psS16 fault) 7449 7449 { 7450 7450 p3ProcessedExpRow *_object; … … 7454 7454 7455 7455 _object->exp_tag = psStringCopy(exp_tag); 7456 _object->p3_version = p3_version; 7457 _object->p2_version = p2_version; 7458 _object->label = psStringCopy(label); 7456 7459 _object->uri = psStringCopy(uri); 7457 7460 _object->recipe = psStringCopy(recipe); … … 7466 7469 _object->zp_mean = zp_mean; 7467 7470 _object->zp_stdev = zp_stdev; 7468 _object->p2_version = p2_version;7469 _object->p3_version = p3_version;7470 _object->label = psStringCopy(label);7471 7471 _object->fault = fault; 7472 7472 … … 7477 7477 { 7478 7478 psFree(object->exp_tag); 7479 psFree(object->label); 7479 7480 psFree(object->uri); 7480 7481 psFree(object->recipe); 7481 7482 psFree(object->b1_uri); 7482 7483 psFree(object->b2_uri); 7483 psFree(object->label);7484 7484 } 7485 7485 … … 7492 7492 return false; 7493 7493 } 7494 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, "Primary Key", 0)) { 7495 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version"); 7496 psFree(md); 7497 return false; 7498 } 7499 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, 0)) { 7500 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 7501 psFree(md); 7502 return false; 7503 } 7504 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, "key", "64")) { 7505 psError(PS_ERR_UNKNOWN, false, "failed to add item label"); 7506 psFree(md); 7507 return false; 7508 } 7494 7509 if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, "255")) { 7495 7510 psError(PS_ERR_UNKNOWN, false, "failed to add item uri"); … … 7552 7567 return false; 7553 7568 } 7554 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, 0)) { 7555 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 7556 psFree(md); 7557 return false; 7558 } 7559 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, NULL, 0)) { 7560 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version"); 7561 psFree(md); 7562 return false; 7563 } 7564 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, "key", "64")) { 7565 psError(PS_ERR_UNKNOWN, false, "failed to add item label"); 7566 psFree(md); 7567 return false; 7568 } 7569 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "NOT NULL", 0)) { 7569 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 7570 7570 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 7571 7571 psFree(md); … … 7585 7585 } 7586 7586 7587 bool p3ProcessedExpInsert(psDB * dbh, const char *exp_tag, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF32 sigma_ra, psF32 sigma_dec, psS32 nastro, const char *b1_uri, const char *b2_uri, psF32 zp_mean, psF32 zp_stdev, psS32 p2_version, psS32 p3_version, const char *label, psS16 fault)7587 bool p3ProcessedExpInsert(psDB * dbh, const char *exp_tag, psS32 p3_version, psS32 p2_version, const char *label, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF32 sigma_ra, psF32 sigma_dec, psS32 nastro, const char *b1_uri, const char *b2_uri, psF32 zp_mean, psF32 zp_stdev, psS16 fault) 7588 7588 { 7589 7589 psMetadata *md = psMetadataAlloc(); … … 7593 7593 return false; 7594 7594 } 7595 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, NULL, p3_version)) { 7596 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version"); 7597 psFree(md); 7598 return false; 7599 } 7600 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, p2_version)) { 7601 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 7602 psFree(md); 7603 return false; 7604 } 7605 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, NULL, label)) { 7606 psError(PS_ERR_UNKNOWN, false, "failed to add item label"); 7607 psFree(md); 7608 return false; 7609 } 7595 7610 if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, uri)) { 7596 7611 psError(PS_ERR_UNKNOWN, false, "failed to add item uri"); … … 7650 7665 if (!psMetadataAdd(md, PS_LIST_TAIL, "zp_stdev", PS_DATA_F32, NULL, zp_stdev)) { 7651 7666 psError(PS_ERR_UNKNOWN, false, "failed to add item zp_stdev"); 7652 psFree(md);7653 return false;7654 }7655 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, p2_version)) {7656 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");7657 psFree(md);7658 return false;7659 }7660 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, NULL, p3_version)) {7661 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version");7662 psFree(md);7663 return false;7664 }7665 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, NULL, label)) {7666 psError(PS_ERR_UNKNOWN, false, "failed to add item label");7667 7667 psFree(md); 7668 7668 return false; … … 7696 7696 bool p3ProcessedExpInsertObject(psDB *dbh, p3ProcessedExpRow *object) 7697 7697 { 7698 return p3ProcessedExpInsert(dbh, object->exp_tag, object-> uri, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev, object->sigma_ra, object->sigma_dec, object->nastro, object->b1_uri, object->b2_uri, object->zp_mean, object->zp_stdev, object->p2_version, object->p3_version, object->label, object->fault);7698 return p3ProcessedExpInsert(dbh, object->exp_tag, object->p3_version, object->p2_version, object->label, object->uri, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev, object->sigma_ra, object->sigma_dec, object->nastro, object->b1_uri, object->b2_uri, object->zp_mean, object->zp_stdev, object->fault); 7699 7699 } 7700 7700 … … 7774 7774 return false; 7775 7775 } 7776 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, NULL, object->p3_version)) { 7777 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version"); 7778 psFree(md); 7779 return false; 7780 } 7781 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, object->p2_version)) { 7782 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version"); 7783 psFree(md); 7784 return false; 7785 } 7786 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, NULL, object->label)) { 7787 psError(PS_ERR_UNKNOWN, false, "failed to add item label"); 7788 psFree(md); 7789 return false; 7790 } 7776 7791 if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, object->uri)) { 7777 7792 psError(PS_ERR_UNKNOWN, false, "failed to add item uri"); … … 7834 7849 return false; 7835 7850 } 7836 if (!psMetadataAdd(md, PS_LIST_TAIL, "p2_version", PS_DATA_S32, NULL, object->p2_version)) {7837 psError(PS_ERR_UNKNOWN, false, "failed to add item p2_version");7838 psFree(md);7839 return false;7840 }7841 if (!psMetadataAdd(md, PS_LIST_TAIL, "p3_version", PS_DATA_S32, NULL, object->p3_version)) {7842 psError(PS_ERR_UNKNOWN, false, "failed to add item p3_version");7843 psFree(md);7844 return false;7845 }7846 if (!psMetadataAdd(md, PS_LIST_TAIL, "label", PS_DATA_STRING, NULL, object->label)) {7847 psError(PS_ERR_UNKNOWN, false, "failed to add item label");7848 psFree(md);7849 return false;7850 }7851 7851 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, NULL, object->fault)) { 7852 7852 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); … … 7868 7868 return false; 7869 7869 } 7870 psS32 p3_version = psMetadataLookupS32(&status, md, "p3_version"); 7871 if (!status) { 7872 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p3_version"); 7873 return false; 7874 } 7875 psS32 p2_version = psMetadataLookupS32(&status, md, "p2_version"); 7876 if (!status) { 7877 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p2_version"); 7878 return false; 7879 } 7880 char* label = psMetadataLookupPtr(&status, md, "label"); 7881 if (!status) { 7882 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item label"); 7883 return false; 7884 } 7870 7885 char* uri = psMetadataLookupPtr(&status, md, "uri"); 7871 7886 if (!status) { … … 7928 7943 return false; 7929 7944 } 7930 psS32 p2_version = psMetadataLookupS32(&status, md, "p2_version");7931 if (!status) {7932 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p2_version");7933 return false;7934 }7935 psS32 p3_version = psMetadataLookupS32(&status, md, "p3_version");7936 if (!status) {7937 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item p3_version");7938 return false;7939 }7940 char* label = psMetadataLookupPtr(&status, md, "label");7941 if (!status) {7942 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item label");7943 return false;7944 }7945 7945 psS16 fault = psMetadataLookupS16(&status, md, "fault"); 7946 7946 if (!status) { … … 7949 7949 } 7950 7950 7951 return p3ProcessedExpRowAlloc(exp_tag, uri, recipe, bg, bg_stdev, bg_mean_stdev, sigma_ra, sigma_dec, nastro, b1_uri, b2_uri, zp_mean, zp_stdev, p2_version, p3_version, label, fault);7951 return p3ProcessedExpRowAlloc(exp_tag, p3_version, p2_version, label, uri, recipe, bg, bg_stdev, bg_mean_stdev, sigma_ra, sigma_dec, nastro, b1_uri, b2_uri, zp_mean, zp_stdev, fault); 7952 7952 } 7953 7953 psArray *p3ProcessedExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 9505 9505 return false; 9506 9506 } 9507 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, " NOT NULL", 0)) {9507 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 9508 9508 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 9509 9509 psFree(md); … … 9980 9980 return false; 9981 9981 } 9982 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, " NOT NULL", 0)) {9982 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 9983 9983 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 9984 9984 psFree(md); … … 10424 10424 return false; 10425 10425 } 10426 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, " NOT NULL", 0)) {10426 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 10427 10427 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 10428 10428 psFree(md); … … 10842 10842 return false; 10843 10843 } 10844 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, " NOT NULL", 0)) {10844 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 10845 10845 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 10846 10846 psFree(md); … … 11233 11233 return false; 11234 11234 } 11235 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, " NOT NULL", 0)) {11235 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 11236 11236 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 11237 11237 psFree(md); … … 11692 11692 return false; 11693 11693 } 11694 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, " NOT NULL", 0)) {11694 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 11695 11695 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 11696 11696 psFree(md); … … 12157 12157 return false; 12158 12158 } 12159 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, " NOT NULL", 0)) {12159 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 12160 12160 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 12161 12161 psFree(md); … … 12659 12659 return false; 12660 12660 } 12661 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, " NOT NULL", 0)) {12661 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 12662 12662 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 12663 12663 psFree(md); … … 13118 13118 return false; 13119 13119 } 13120 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, " NOT NULL", 0)) {13120 if (!psMetadataAdd(md, PS_LIST_TAIL, "fault", PS_DATA_S16, "Key NOT NULL", 0)) { 13121 13121 psError(PS_ERR_UNKNOWN, false, "failed to add item fault"); 13122 13122 psFree(md);
Note:
See TracChangeset
for help on using the changeset viewer.
