File indexing completed on 2026-04-09 07:58:17
0001
0002 DROP TABLE "ATLAS_IDDS".contents
0003
0004 DROP TABLE "ATLAS_IDDS".wp2transforms
0005
0006 DROP TABLE "ATLAS_IDDS".collections
0007
0008 DROP TABLE "ATLAS_IDDS".processings
0009
0010 DROP TABLE "ATLAS_IDDS".workprogresses
0011
0012 DROP TABLE "ATLAS_IDDS".conditions
0013
0014 DROP TABLE "ATLAS_IDDS".meta_info
0015
0016 DROP TABLE "ATLAS_IDDS".throttlers
0017
0018 DROP TABLE "ATLAS_IDDS".events_archive
0019
0020 DROP TABLE "ATLAS_IDDS".events
0021
0022 DROP TABLE "ATLAS_IDDS".events_priority
0023
0024 DROP TABLE "ATLAS_IDDS".commands
0025
0026 DROP TABLE "ATLAS_IDDS".messages
0027
0028 DROP TABLE "ATLAS_IDDS".health
0029
0030 DROP TABLE "ATLAS_IDDS".contents_ext
0031
0032 DROP TABLE "ATLAS_IDDS".contents_update
0033
0034 DROP TABLE "ATLAS_IDDS".transforms
0035
0036 DROP TABLE "ATLAS_IDDS".requests
0037
0038 DROP SEQUENCE "ATLAS_IDDS"."REQUEST_ID_SEQ"
0039 DROP SEQUENCE "ATLAS_IDDS"."WORKPROGRESS_ID_SEQ"
0040 DROP SEQUENCE "ATLAS_IDDS"."TRANSFORM_ID_SEQ"
0041 DROP SEQUENCE "ATLAS_IDDS"."PROCESSING_ID_SEQ"
0042 DROP SEQUENCE "ATLAS_IDDS"."COLLECTION_ID_SEQ"
0043 DROP SEQUENCE "ATLAS_IDDS"."CONTENT_ID_SEQ"
0044 DROP SEQUENCE "ATLAS_IDDS"."HEALTH_ID_SEQ"
0045 DROP SEQUENCE "ATLAS_IDDS"."MESSAGE_ID_SEQ"
0046 DROP SEQUENCE "ATLAS_IDDS"."COMMAND_ID_SEQ"
0047 DROP SEQUENCE "ATLAS_IDDS"."EVENT_ID_SEQ"
0048 DROP SEQUENCE "ATLAS_IDDS"."THROTTLER_ID_SEQ"
0049 DROP SEQUENCE "ATLAS_IDDS"."METAINFO_ID_SEQ"
0050 DROP SEQUENCE "ATLAS_IDDS"."CONDITION_ID_SEQ"
0051
0052
0053 CREATE SEQUENCE "ATLAS_IDDS"."REQUEST_ID_SEQ"
0054
0055 CREATE TABLE "ATLAS_IDDS".requests (
0056 request_id NUMBER(19) NOT NULL,
0057 scope VARCHAR2(25 CHAR),
0058 name VARCHAR2(255 CHAR),
0059 requester VARCHAR2(20 CHAR),
0060 request_type INTEGER NOT NULL,
0061 username VARCHAR2(20 CHAR),
0062 userdn VARCHAR2(200 CHAR),
0063 transform_tag VARCHAR2(20 CHAR),
0064 workload_id INTEGER,
0065 priority INTEGER,
0066 status INTEGER NOT NULL,
0067 substatus INTEGER,
0068 oldstatus INTEGER,
0069 locking INTEGER NOT NULL,
0070 created_at DATE NOT NULL,
0071 updated_at DATE NOT NULL,
0072 next_poll_at DATE,
0073 accessed_at DATE,
0074 expired_at DATE,
0075 new_retries INTEGER,
0076 update_retries INTEGER,
0077 max_new_retries INTEGER,
0078 max_update_retries INTEGER,
0079 new_poll_period INTERVAL DAY TO SECOND,
0080 update_poll_period INTERVAL DAY TO SECOND,
0081 site VARCHAR2(50 CHAR),
0082 campaign VARCHAR2(50 CHAR),
0083 campaign_group VARCHAR2(250 CHAR),
0084 campaign_tag VARCHAR2(20 CHAR),
0085 errors VARCHAR2(1024 CHAR),
0086 request_metadata CLOB,
0087 processing_metadata CLOB,
0088 CONSTRAINT "REQUESTS_PK" PRIMARY KEY (request_id),
0089 CONSTRAINT "REQUESTS_STATUS_ID_NN" CHECK (status IS NOT NULL)
0090 ) PCTFREE 0;
0091
0092 CREATE INDEX "ATLAS_IDDS"."REQUESTS_SCOPE_NAME_IDX" ON "ATLAS_IDDS".requests (name, scope, workload_id);
0093
0094 CREATE INDEX "ATLAS_IDDS"."REQUESTS_STATUS_POLL_IDX" ON "ATLAS_IDDS".requests (status, priority, locking, updated_at, new_poll_period, update_poll_period, created_at, request_id);
0095
0096 CREATE INDEX "ATLAS_IDDS"."REQUESTS_STATUS_PRIO_IDX" ON "ATLAS_IDDS".requests (status, priority, request_id, locking, updated_at, next_poll_at, created_at);
0097
0098 CREATE INDEX "ATLAS_IDDS"."REQUESTS_STATUS_SITE" ON "ATLAS_IDDS".requests (status, site, request_id);
0099
0100 CREATE SEQUENCE "ATLAS_IDDS"."TRANSFORM_ID_SEQ"
0101
0102 CREATE TABLE "ATLAS_IDDS".transforms (
0103 transform_id NUMBER(19) NOT NULL,
0104 request_id NUMBER(19) NOT NULL,
0105 workload_id INTEGER,
0106 transform_type INTEGER NOT NULL,
0107 transform_tag VARCHAR2(20 CHAR),
0108 internal_id VARCHAR2(20 CHAR),
0109 priority INTEGER,
0110 safe2get_output_from_input INTEGER,
0111 status INTEGER NOT NULL,
0112 substatus INTEGER,
0113 oldstatus INTEGER,
0114 locking INTEGER NOT NULL,
0115 retries INTEGER,
0116 parent_transform_id NUMBER(19),
0117 previous_transform_id NUMBER(19),
0118 current_processing_id NUMBER(19),
0119 created_at DATE NOT NULL,
0120 updated_at DATE NOT NULL,
0121 next_poll_at DATE,
0122 started_at DATE,
0123 finished_at DATE,
0124 expired_at DATE,
0125 new_retries INTEGER,
0126 update_retries INTEGER,
0127 max_new_retries INTEGER,
0128 max_update_retries INTEGER,
0129 new_poll_period INTERVAL DAY TO SECOND,
0130 update_poll_period INTERVAL DAY TO SECOND,
0131 site VARCHAR2(50 CHAR),
0132 name VARCHAR2(255 CHAR),
0133 has_previous_conditions INTEGER,
0134 loop_index INTEGER,
0135 cloned_from NUMBER(19),
0136 triggered_conditions CLOB,
0137 untriggered_conditions CLOB,
0138 errors VARCHAR2(1024 CHAR),
0139 transform_metadata CLOB,
0140 running_metadata CLOB,
0141 CONSTRAINT "TRANSFORMS_PK" PRIMARY KEY (transform_id),
0142 CONSTRAINT "TRANSFORMS_STATUS_ID_NN" CHECK (status IS NOT NULL)
0143 ) PCTFREE 0;
0144
0145 CREATE INDEX "ATLAS_IDDS"."TRANSFORMS_TYPE_TAG_IDX" ON "ATLAS_IDDS".transforms (transform_type, transform_tag, transform_id);
0146
0147 CREATE INDEX "ATLAS_IDDS"."TRANSFORMS_STATUS_SITE" ON "ATLAS_IDDS".transforms (status, site, request_id, transform_id);
0148
0149 CREATE INDEX "ATLAS_IDDS"."TRANSFORMS_REQ_IDX" ON "ATLAS_IDDS".transforms (request_id, transform_id);
0150
0151 CREATE INDEX "ATLAS_IDDS"."TRANSFORMS_STATUS_POLL_IDX" ON "ATLAS_IDDS".transforms (status, locking, updated_at, new_poll_period, update_poll_period, created_at, transform_id);
0152
0153 CREATE INDEX "ATLAS_IDDS"."TRANSFORMS_STATUS_UPDATED_AT_IDX" ON "ATLAS_IDDS".transforms (status, locking, updated_at, next_poll_at, created_at);
0154
0155
0156 CREATE TABLE "ATLAS_IDDS".contents_update (
0157 content_id NUMBER(19) NOT NULL,
0158 substatus INTEGER,
0159 request_id NUMBER(19),
0160 transform_id NUMBER(19),
0161 workload_id INTEGER,
0162 fetch_status INTEGER NOT NULL,
0163 coll_id NUMBER(19),
0164 content_metadata VARCHAR2(100 CHAR),
0165 PRIMARY KEY (content_id)
0166 ) PCTFREE 0;
0167
0168
0169 CREATE TABLE "ATLAS_IDDS".contents_ext (
0170 content_id NUMBER(19) NOT NULL,
0171 transform_id NUMBER(19) NOT NULL,
0172 coll_id NUMBER(19) NOT NULL,
0173 request_id NUMBER(19) NOT NULL,
0174 workload_id INTEGER,
0175 map_id NUMBER(19) NOT NULL,
0176 status INTEGER NOT NULL,
0177 panda_id NUMBER(19),
0178 job_definition_id NUMBER(19),
0179 scheduler_id VARCHAR2(128 CHAR),
0180 pilot_id VARCHAR2(200 CHAR),
0181 creation_time DATE,
0182 modification_time DATE,
0183 start_time DATE,
0184 end_time DATE,
0185 prod_source_label VARCHAR2(20 CHAR),
0186 prod_user_id VARCHAR2(250 CHAR),
0187 assigned_priority INTEGER,
0188 current_priority INTEGER,
0189 attempt_nr INTEGER,
0190 max_attempt INTEGER,
0191 max_cpu_count INTEGER,
0192 max_cpu_unit VARCHAR2(32 CHAR),
0193 max_disk_count INTEGER,
0194 max_disk_unit VARCHAR2(10 CHAR),
0195 min_ram_count INTEGER,
0196 min_ram_unit VARCHAR2(10 CHAR),
0197 cpu_consumption_time INTEGER,
0198 cpu_consumption_unit VARCHAR2(128 CHAR),
0199 job_status VARCHAR2(10 CHAR),
0200 job_name VARCHAR2(255 CHAR),
0201 trans_exit_code INTEGER,
0202 pilot_error_code INTEGER,
0203 pilot_error_diag VARCHAR2(500 CHAR),
0204 exe_error_code INTEGER,
0205 exe_error_diag VARCHAR2(500 CHAR),
0206 sup_error_code INTEGER,
0207 sup_error_diag VARCHAR2(250 CHAR),
0208 ddm_error_code INTEGER,
0209 ddm_error_diag VARCHAR2(500 CHAR),
0210 brokerage_error_code INTEGER,
0211 brokerage_error_diag VARCHAR2(250 CHAR),
0212 job_dispatcher_error_code INTEGER,
0213 job_dispatcher_error_diag VARCHAR2(250 CHAR),
0214 task_buffer_error_code INTEGER,
0215 task_buffer_error_diag VARCHAR2(300 CHAR),
0216 computing_site VARCHAR2(128 CHAR),
0217 computing_element VARCHAR2(128 CHAR),
0218 grid VARCHAR2(50 CHAR),
0219 cloud VARCHAR2(50 CHAR),
0220 cpu_conversion FLOAT,
0221 task_id NUMBER(19),
0222 vo VARCHAR2(16 CHAR),
0223 pilot_timing VARCHAR2(100 CHAR),
0224 working_group VARCHAR2(20 CHAR),
0225 processing_type VARCHAR2(64 CHAR),
0226 prod_user_name VARCHAR2(60 CHAR),
0227 core_count INTEGER,
0228 n_input_files INTEGER,
0229 req_id NUMBER(19),
0230 jedi_task_id NUMBER(19),
0231 actual_core_count INTEGER,
0232 max_rss INTEGER,
0233 max_vmem INTEGER,
0234 max_swap INTEGER,
0235 max_pss INTEGER,
0236 avg_rss INTEGER,
0237 avg_vmem INTEGER,
0238 avg_swap INTEGER,
0239 avg_pss INTEGER,
0240 max_walltime INTEGER,
0241 disk_io INTEGER,
0242 failed_attempt INTEGER,
0243 hs06 INTEGER,
0244 hs06sec INTEGER,
0245 memory_leak VARCHAR2(10 CHAR),
0246 memory_leak_x2 VARCHAR2(10 CHAR),
0247 job_label VARCHAR2(20 CHAR),
0248 CONSTRAINT "CONTENTS_EXT_PK" PRIMARY KEY (content_id)
0249 ) PCTFREE 0;
0250
0251 CREATE INDEX "ATLAS_IDDS"."CONTENTS_EXT_RTM_IDX" ON "ATLAS_IDDS".contents_ext (request_id, transform_id, map_id);
0252
0253 CREATE INDEX "ATLAS_IDDS"."CONTENTS_EXT_RTF_IDX" ON "ATLAS_IDDS".contents_ext (request_id, transform_id, workload_id, coll_id, content_id, panda_id, status);
0254
0255 CREATE INDEX "ATLAS_IDDS"."CONTENTS_EXT_RTW_IDX" ON "ATLAS_IDDS".contents_ext (request_id, transform_id, workload_id);
0256
0257 CREATE SEQUENCE "ATLAS_IDDS"."HEALTH_ID_SEQ"
0258
0259 CREATE TABLE "ATLAS_IDDS".health (
0260 health_id NUMBER(19) NOT NULL,
0261 agent VARCHAR2(30 CHAR),
0262 hostname VARCHAR2(500 CHAR),
0263 pid INTEGER,
0264 status INTEGER NOT NULL,
0265 thread_id NUMBER(19),
0266 thread_name VARCHAR2(255 CHAR),
0267 payload VARCHAR2(2048 CHAR),
0268 created_at DATE,
0269 updated_at DATE,
0270 CONSTRAINT "HEALTH_PK" PRIMARY KEY (health_id),
0271 CONSTRAINT "HEALTH_UK" UNIQUE (agent, hostname, pid, thread_id)
0272 ) PCTFREE 0;
0273
0274 CREATE SEQUENCE "ATLAS_IDDS"."MESSAGE_ID_SEQ"
0275
0276 CREATE TABLE "ATLAS_IDDS".messages (
0277 msg_id NUMBER(19) NOT NULL,
0278 msg_type INTEGER NOT NULL,
0279 status INTEGER NOT NULL,
0280 substatus INTEGER,
0281 locking INTEGER NOT NULL,
0282 source INTEGER NOT NULL,
0283 destination INTEGER NOT NULL,
0284 request_id NUMBER(19),
0285 workload_id INTEGER,
0286 transform_id INTEGER,
0287 processing_id INTEGER,
0288 internal_id VARCHAR2(20 CHAR),
0289 num_contents INTEGER,
0290 retries INTEGER,
0291 fetching_id INTEGER,
0292 created_at DATE NOT NULL,
0293 updated_at DATE NOT NULL,
0294 poll_period INTERVAL DAY TO SECOND NOT NULL,
0295 msg_content CLOB,
0296 CONSTRAINT "MESSAGES_PK" PRIMARY KEY (msg_id)
0297 ) PCTFREE 0;
0298
0299 CREATE INDEX "ATLAS_IDDS"."MESSAGES_TYPE_STU_IDX" ON "ATLAS_IDDS".messages (msg_type, status, destination, retries, updated_at, created_at);
0300
0301 CREATE INDEX "ATLAS_IDDS"."MESSAGES_ST_IDX" ON "ATLAS_IDDS".messages (status, destination, created_at);
0302
0303 CREATE INDEX "ATLAS_IDDS"."MESSAGES_TYPE_ST_IDX" ON "ATLAS_IDDS".messages (msg_type, status, destination, request_id);
0304
0305 CREATE INDEX "ATLAS_IDDS"."MESSAGES_TYPE_ST_TF_IDX" ON "ATLAS_IDDS".messages (msg_type, status, destination, transform_id);
0306
0307 CREATE INDEX "ATLAS_IDDS"."MESSAGES_TYPE_ST_PR_IDX" ON "ATLAS_IDDS".messages (msg_type, status, destination, processing_id);
0308
0309 CREATE SEQUENCE "ATLAS_IDDS"."COMMAND_ID_SEQ"
0310
0311 CREATE TABLE "ATLAS_IDDS".commands (
0312 cmd_id NUMBER(19) NOT NULL,
0313 request_id NUMBER(19) NOT NULL,
0314 workload_id INTEGER,
0315 transform_id INTEGER,
0316 processing_id INTEGER,
0317 cmd_type INTEGER,
0318 status INTEGER NOT NULL,
0319 substatus INTEGER,
0320 locking INTEGER NOT NULL,
0321 username VARCHAR2(50 CHAR),
0322 retries INTEGER,
0323 source INTEGER,
0324 destination INTEGER,
0325 created_at DATE NOT NULL,
0326 updated_at DATE NOT NULL,
0327 cmd_content CLOB,
0328 errors VARCHAR2(1024 CHAR),
0329 CONSTRAINT "COMMANDS_PK" PRIMARY KEY (cmd_id)
0330 ) PCTFREE 0;
0331
0332 CREATE INDEX "ATLAS_IDDS"."COMMANDS_TYPE_ST_PR_IDX" ON "ATLAS_IDDS".commands (cmd_type, status, destination, processing_id);
0333
0334 CREATE INDEX "ATLAS_IDDS"."COMMANDS_TYPE_ST_IDX" ON "ATLAS_IDDS".commands (cmd_type, status, destination, request_id);
0335
0336 CREATE INDEX "ATLAS_IDDS"."COMMANDS_STATUS_IDX" ON "ATLAS_IDDS".commands (status, locking, updated_at);
0337
0338 CREATE INDEX "ATLAS_IDDS"."COMMANDS_TYPE_ST_TF_IDX" ON "ATLAS_IDDS".commands (cmd_type, status, destination, transform_id);
0339
0340
0341 CREATE TABLE "ATLAS_IDDS".events_priority (
0342 event_type INTEGER NOT NULL,
0343 event_actual_id INTEGER NOT NULL,
0344 priority INTEGER NOT NULL,
0345 last_processed_at DATE NOT NULL,
0346 updated_at DATE NOT NULL,
0347 CONSTRAINT "EVENTS_PR_PK" PRIMARY KEY (event_type, event_actual_id)
0348 ) PCTFREE 0;
0349
0350 CREATE SEQUENCE "ATLAS_IDDS"."EVENT_ID_SEQ"
0351
0352 CREATE TABLE "ATLAS_IDDS".events (
0353 event_id NUMBER(19) NOT NULL,
0354 event_type INTEGER NOT NULL,
0355 event_actual_id INTEGER NOT NULL,
0356 priority INTEGER,
0357 status INTEGER NOT NULL,
0358 created_at DATE NOT NULL,
0359 processing_at DATE,
0360 processed_at DATE,
0361 content CLOB,
0362 CONSTRAINT "EVENTS_PK" PRIMARY KEY (event_id)
0363 ) PCTFREE 0;
0364
0365
0366 CREATE TABLE "ATLAS_IDDS".events_archive (
0367 event_id NUMBER(19) NOT NULL,
0368 event_type INTEGER NOT NULL,
0369 event_actual_id INTEGER NOT NULL,
0370 priority INTEGER,
0371 status INTEGER NOT NULL,
0372 created_at DATE NOT NULL,
0373 processing_at DATE,
0374 processed_at DATE,
0375 content CLOB,
0376 CONSTRAINT "EVENTS_AR_PK" PRIMARY KEY (event_id)
0377 ) PCTFREE 0;
0378
0379 CREATE SEQUENCE "ATLAS_IDDS"."THROTTLER_ID_SEQ"
0380
0381 CREATE TABLE "ATLAS_IDDS".throttlers (
0382 throttler_id NUMBER(19) NOT NULL,
0383 site VARCHAR2(50 CHAR) NOT NULL,
0384 status INTEGER NOT NULL,
0385 num_requests INTEGER,
0386 num_transforms INTEGER,
0387 num_processings INTEGER,
0388 new_contents INTEGER,
0389 queue_contents INTEGER,
0390 created_at DATE NOT NULL,
0391 updated_at DATE NOT NULL,
0392 others CLOB,
0393 CONSTRAINT "THROTTLER_PK" PRIMARY KEY (throttler_id),
0394 CONSTRAINT "THROTTLER_SITE_UQ" UNIQUE (site)
0395 ) PCTFREE 0;
0396
0397 CREATE SEQUENCE "ATLAS_IDDS"."METAINFO_ID_SEQ"
0398
0399 CREATE TABLE "ATLAS_IDDS".meta_info (
0400 meta_id NUMBER(19) NOT NULL,
0401 name VARCHAR2(50 CHAR) NOT NULL,
0402 status INTEGER NOT NULL,
0403 created_at DATE NOT NULL,
0404 updated_at DATE NOT NULL,
0405 description VARCHAR2(1000 CHAR),
0406 meta_info CLOB,
0407 CONSTRAINT "METAINFO_PK" PRIMARY KEY (meta_id),
0408 CONSTRAINT "METAINFO_NAME_UQ" UNIQUE (name)
0409 ) PCTFREE 0;
0410
0411 CREATE SEQUENCE "ATLAS_IDDS"."CONDITION_ID_SEQ"
0412
0413 CREATE TABLE "ATLAS_IDDS".conditions (
0414 condition_id NUMBER(19) NOT NULL,
0415 request_id NUMBER(19) NOT NULL,
0416 internal_id VARCHAR2(20 CHAR),
0417 name VARCHAR2(250 CHAR),
0418 status INTEGER NOT NULL,
0419 substatus INTEGER,
0420 is_loop INTEGER,
0421 loop_index INTEGER,
0422 cloned_from NUMBER(19),
0423 created_at DATE NOT NULL,
0424 updated_at DATE NOT NULL,
0425 evaluate_result VARCHAR2(1000 CHAR),
0426 previous_transforms CLOB,
0427 following_transforms CLOB,
0428 condition CLOB,
0429 CONSTRAINT "CONDITION_PK" PRIMARY KEY (condition_id),
0430 CONSTRAINT "CONDITION_ID_UQ" UNIQUE (request_id, internal_id)
0431 ) PCTFREE 0;
0432
0433 CREATE SEQUENCE "ATLAS_IDDS"."WORKPROGRESS_ID_SEQ"
0434
0435 CREATE TABLE "ATLAS_IDDS".workprogresses (
0436 workprogress_id NUMBER(19) NOT NULL,
0437 request_id NUMBER(19),
0438 workload_id INTEGER,
0439 scope VARCHAR2(25 CHAR),
0440 name VARCHAR2(255 CHAR),
0441 priority INTEGER,
0442 status INTEGER,
0443 substatus INTEGER,
0444 locking INTEGER,
0445 created_at DATE,
0446 updated_at DATE,
0447 next_poll_at DATE,
0448 accessed_at DATE,
0449 expired_at DATE,
0450 errors VARCHAR2(1024 CHAR),
0451 workprogress_metadata CLOB,
0452 processing_metadata CLOB,
0453 CONSTRAINT "WORKPROGRESS_PK" PRIMARY KEY (workprogress_id),
0454 CONSTRAINT "REQ2WORKPROGRESS_REQ_ID_FK" FOREIGN KEY(request_id) REFERENCES "ATLAS_IDDS".requests (request_id),
0455 CONSTRAINT "WORKPROGRESS_STATUS_ID_NN" CHECK (status IS NOT NULL)
0456 ) PCTFREE 0;
0457
0458 CREATE INDEX "ATLAS_IDDS"."WORKPROGRESS_SCOPE_NAME_IDX" ON "ATLAS_IDDS".workprogresses (name, scope, workprogress_id);
0459
0460 CREATE INDEX "ATLAS_IDDS"."WORKPROGRESS_STATUS_PRIO_IDX" ON "ATLAS_IDDS".workprogresses (status, priority, workprogress_id, locking, updated_at, next_poll_at, created_at);
0461
0462 CREATE SEQUENCE "ATLAS_IDDS"."PROCESSING_ID_SEQ"
0463
0464 CREATE TABLE "ATLAS_IDDS".processings (
0465 processing_id NUMBER(19) NOT NULL,
0466 transform_id NUMBER(19) NOT NULL,
0467 request_id NUMBER(19) NOT NULL,
0468 workload_id INTEGER,
0469 processing_type INTEGER NOT NULL,
0470 status INTEGER NOT NULL,
0471 substatus INTEGER,
0472 oldstatus INTEGER,
0473 locking INTEGER NOT NULL,
0474 submitter VARCHAR2(20 CHAR),
0475 submitted_id INTEGER,
0476 granularity INTEGER,
0477 granularity_type INTEGER,
0478 created_at DATE NOT NULL,
0479 updated_at DATE NOT NULL,
0480 next_poll_at DATE,
0481 poller_updated_at DATE,
0482 submitted_at DATE,
0483 finished_at DATE,
0484 expired_at DATE,
0485 new_retries INTEGER,
0486 update_retries INTEGER,
0487 max_new_retries INTEGER,
0488 max_update_retries INTEGER,
0489 new_poll_period INTERVAL DAY TO SECOND,
0490 update_poll_period INTERVAL DAY TO SECOND,
0491 site VARCHAR2(50 CHAR),
0492 errors VARCHAR2(1024 CHAR),
0493 processing_metadata CLOB,
0494 running_metadata CLOB,
0495 output_metadata CLOB,
0496 CONSTRAINT "PROCESSINGS_PK" PRIMARY KEY (processing_id),
0497 CONSTRAINT "PROCESSINGS_TRANSFORM_ID_FK" FOREIGN KEY(transform_id) REFERENCES "ATLAS_IDDS".transforms (transform_id),
0498 CONSTRAINT "PROCESSINGS_STATUS_ID_NN" CHECK (status IS NOT NULL),
0499 CONSTRAINT "PROCESSINGS_TRANSFORM_ID_NN" CHECK (transform_id IS NOT NULL)
0500 ) PCTFREE 0;
0501
0502 CREATE INDEX "ATLAS_IDDS"."PROCESSINGS_STATUS_POLL_IDX" ON "ATLAS_IDDS".processings (status, processing_id, locking, updated_at, new_poll_period, update_poll_period, created_at);
0503
0504 CREATE INDEX "ATLAS_IDDS"."PROCESSINGS_STATUS_SITE" ON "ATLAS_IDDS".processings (status, site, request_id, transform_id, processing_id);
0505
0506 CREATE INDEX "ATLAS_IDDS"."PROCESSINGS_STATUS_UPDATED_IDX" ON "ATLAS_IDDS".processings (status, locking, updated_at, next_poll_at, created_at);
0507
0508 CREATE SEQUENCE "ATLAS_IDDS"."COLLECTION_ID_SEQ"
0509
0510 CREATE TABLE "ATLAS_IDDS".collections (
0511 coll_id NUMBER(19) NOT NULL,
0512 request_id NUMBER(19) NOT NULL,
0513 workload_id INTEGER,
0514 transform_id NUMBER(19) NOT NULL,
0515 coll_type INTEGER NOT NULL,
0516 relation_type INTEGER NOT NULL,
0517 scope VARCHAR2(25 CHAR),
0518 name VARCHAR2(255 CHAR),
0519 bytes INTEGER,
0520 status INTEGER NOT NULL,
0521 substatus INTEGER,
0522 locking INTEGER NOT NULL,
0523 total_files INTEGER,
0524 storage_id INTEGER,
0525 new_files INTEGER,
0526 processed_files INTEGER,
0527 processing_files INTEGER,
0528 failed_files INTEGER,
0529 missing_files INTEGER,
0530 ext_files INTEGER,
0531 processed_ext_files INTEGER,
0532 failed_ext_files INTEGER,
0533 missing_ext_files INTEGER,
0534 processing_id INTEGER,
0535 retries INTEGER,
0536 created_at DATE NOT NULL,
0537 updated_at DATE NOT NULL,
0538 next_poll_at DATE,
0539 accessed_at DATE,
0540 expired_at DATE,
0541 coll_metadata CLOB,
0542 CONSTRAINT "COLLECTIONS_PK" PRIMARY KEY (coll_id),
0543 CONSTRAINT "COLLECTIONS_NAME_SCOPE_UQ" UNIQUE (name, scope, transform_id, relation_type),
0544 CONSTRAINT "COLLECTIONS_TRANSFORM_ID_FK" FOREIGN KEY(transform_id) REFERENCES "ATLAS_IDDS".transforms (transform_id),
0545 CONSTRAINT "COLLECTIONS_STATUS_ID_NN" CHECK (status IS NOT NULL),
0546 CONSTRAINT "COLLECTIONS_TRANSFORM_ID_NN" CHECK (transform_id IS NOT NULL)
0547 ) PCTFREE 0;
0548
0549 CREATE INDEX "ATLAS_IDDS"."COLLECTIONS_TRANSFORM_IDX" ON "ATLAS_IDDS".collections (transform_id, coll_id);
0550
0551 CREATE INDEX "ATLAS_IDDS"."COLLECTIONS_STATUS_RELAT_IDX" ON "ATLAS_IDDS".collections (status, relation_type);
0552
0553 CREATE INDEX "ATLAS_IDDS"."COLLECTIONS_REQ_IDX" ON "ATLAS_IDDS".collections (request_id, transform_id, updated_at);
0554
0555 CREATE INDEX "ATLAS_IDDS"."COLLECTIONS_STATUS_UPDATED_IDX" ON "ATLAS_IDDS".collections (status, locking, updated_at, next_poll_at, created_at);
0556
0557
0558 CREATE TABLE "ATLAS_IDDS".wp2transforms (
0559 workprogress_id NUMBER(19) NOT NULL,
0560 transform_id NUMBER(19) NOT NULL,
0561 CONSTRAINT "WP2TRANSFORM_PK" PRIMARY KEY (workprogress_id, transform_id),
0562 CONSTRAINT "WP2TRANSFORM_WORK_ID_FK" FOREIGN KEY(workprogress_id) REFERENCES "ATLAS_IDDS".workprogresses (workprogress_id),
0563 CONSTRAINT "WP2TRANSFORM_TRANS_ID_FK" FOREIGN KEY(transform_id) REFERENCES "ATLAS_IDDS".transforms (transform_id)
0564 ) PCTFREE 0;
0565
0566 CREATE SEQUENCE "ATLAS_IDDS"."CONTENT_ID_SEQ"
0567
0568 CREATE TABLE "ATLAS_IDDS".contents (
0569 content_id NUMBER(19) NOT NULL,
0570 transform_id NUMBER(19) NOT NULL,
0571 coll_id NUMBER(19) NOT NULL,
0572 request_id NUMBER(19) NOT NULL,
0573 workload_id INTEGER,
0574 map_id NUMBER(19) NOT NULL,
0575 sub_map_id NUMBER(19),
0576 dep_sub_map_id NUMBER(19),
0577 content_dep_id NUMBER(19),
0578 scope VARCHAR2(25 CHAR),
0579 name VARCHAR2(4000 CHAR),
0580 name_md5 VARCHAR2(33 CHAR),
0581 scope_name_md5 VARCHAR2(33 CHAR),
0582 min_id INTEGER,
0583 max_id INTEGER,
0584 content_type INTEGER NOT NULL,
0585 content_relation_type INTEGER NOT NULL,
0586 status INTEGER NOT NULL,
0587 substatus INTEGER,
0588 locking INTEGER NOT NULL,
0589 bytes INTEGER,
0590 md5 VARCHAR2(32 CHAR),
0591 adler32 VARCHAR2(8 CHAR),
0592 processing_id INTEGER,
0593 storage_id INTEGER,
0594 retries INTEGER,
0595 external_coll_id NUMBER(19),
0596 external_content_id NUMBER(19),
0597 external_event_id NUMBER(19),
0598 external_event_status INTEGER,
0599 path VARCHAR2(4000 CHAR),
0600 created_at DATE,
0601 updated_at DATE,
0602 accessed_at DATE,
0603 expired_at DATE,
0604 content_metadata VARCHAR2(1000 CHAR),
0605 CONSTRAINT "CONTENTS_PK" PRIMARY KEY (content_id),
0606 CONSTRAINT "CONTENT_ID_UQ" UNIQUE (transform_id, coll_id, map_id, sub_map_id, dep_sub_map_id, content_relation_type, name_md5, scope_name_md5, min_id, max_id),
0607 CONSTRAINT "CONTENTS_TRANSFORM_ID_FK" FOREIGN KEY(transform_id) REFERENCES "ATLAS_IDDS".transforms (transform_id),
0608 CONSTRAINT "CONTENTS_COLL_ID_FK" FOREIGN KEY(coll_id) REFERENCES "ATLAS_IDDS".collections (coll_id),
0609 CONSTRAINT "CONTENTS_STATUS_ID_NN" CHECK (status IS NOT NULL),
0610 CONSTRAINT "CONTENTS_COLL_ID_NN" CHECK (coll_id IS NOT NULL)
0611 ) PCTFREE 0;
0612
0613 CREATE INDEX "ATLAS_IDDS"."CONTENTS_TF_IDX" ON "ATLAS_IDDS".contents (transform_id, request_id, coll_id, map_id, content_relation_type);
0614
0615 CREATE INDEX "ATLAS_IDDS"."CONTENTS_DEP_IDX" ON "ATLAS_IDDS".contents (request_id, transform_id, content_dep_id);
0616
0617 CREATE INDEX "ATLAS_IDDS"."CONTENTS_REQ_TF_COLL_IDX" ON "ATLAS_IDDS".contents (request_id, transform_id, workload_id, coll_id, content_relation_type, status, substatus);
0618
0619 CREATE INDEX "ATLAS_IDDS"."CONTENTS_ID_NAME_IDX" ON "ATLAS_IDDS".contents (coll_id, scope, md5('name');
0620 , status);
0621
0622 CREATE INDEX "ATLAS_IDDS"."CONTENTS_STATUS_UPDATED_IDX" ON "ATLAS_IDDS".contents (status, locking, updated_at, created_at);
0623
0624 CREATE INDEX "ATLAS_IDDS"."CONTENTS_REL_IDX" ON "ATLAS_IDDS".contents (request_id, content_relation_type, transform_id, substatus);
0625
