DBA Data[Home] [Help]

APPS.AD_PARALLEL_UPDATES_PKG dependencies on AD_PARALLEL_UPDATE_UNITS

Line 367: from ad_parallel_update_units

363: end if;
364:
365: select nvl(max(unit_id), 0)
366: into l_unit_id
367: from ad_parallel_update_units
368: where update_id = l_update_info.update_id;
369:
370: FOR erec IN c_ext
371: LOOP

Line 403: INSERT INTO ad_parallel_update_units(

399:
400: if (j = 100 or
401: i = num_units) then
402: FORALL k IN 1..j
403: INSERT INTO ad_parallel_update_units(
404: unit_id, update_id,
405: data_object_id,
406: relative_fno, start_block, end_block,
407: status

Line 492: ' INSERT INTO ad_parallel_update_units '||

488: 'from the supplied SQL statement. ');
489: end if;
490:
491: EXECUTE IMMEDIATE
492: ' INSERT INTO ad_parallel_update_units '||
493: ' (update_id, unit_id, start_id, end_id, status) '||
494: ' SELECT :update_id update_id, '||
495: ' unit_id+1 unit_id, '||
496: ' min(id_value) start_id_value, '||

Line 513: 'INSERT INTO ad_parallel_update_units '||

509: exception
510: when others then
511: raise_application_error(-20001,
512: SQLERRM||'. SQL statement is : '||
513: 'INSERT INTO ad_parallel_update_units '||
514: ' (update_id, unit_id, start_id, end_id, status) '||
515: ' select :update_id, unit_id, start_id_value, end_id_value, :status '||
516: ' from ( '||
517: X_SQL_Stmt||

Line 592: insert into ad_parallel_update_units(

588: unit_id_tab(i) := i;
589: END LOOP;
590:
591: FORALL i in 1..X_num_workers
592: insert into ad_parallel_update_units(
593: unit_id, update_id,
594: start_id, end_id,
595: status
596: )

Line 626: insert into ad_parallel_update_units(

622: l_unit_start_id > l_table_end_id)
623: then
624:
625: FORALL i in 1..l_num_units
626: insert into ad_parallel_update_units(
627: unit_id, update_id,
628: start_id, end_id,
629: status
630: )

Line 747: delete from ad_parallel_update_units

743: --
744: -- to be safe, delete any rows that may have been inserted
745: --
746: if (l_update_id is not null) then
747: delete from ad_parallel_update_units
748: where update_id = l_update_id;
749: end if;
750:
751: debug_info('Populate information : ');

Line 790: from ad_parallel_update_units

786: into l_unproc_units_exist
787: from sys.dual
788: where exists (
789: select 1
790: from ad_parallel_update_units
791: where update_id = l_update_id
792: and status in (UNASSIGNED_STATUS, ASSIGNED_STATUS));
793: exception
794: when no_data_found then

Line 816: update ad_parallel_update_units

812: --
813: -- recover all units in ASSIGNED_STATUS by returning them
814: -- to the UNASSIGNED_STATUS pool
815: --
816: update ad_parallel_update_units
817: set status = UNASSIGNED_STATUS,
818: worker_id = null
819: where update_id = l_update_id
820: and status = ASSIGNED_STATUS

Line 1025: delete from ad_parallel_update_units

1021: where worker_id = l_worker_id
1022: and update_id = l_update_info.update_id;
1023:
1024: if (g_cache.processed_mode = DELETE_PROCESSED_UNITS) then
1025: delete from ad_parallel_update_units
1026: where update_id = l_update_info.update_id
1027: and unit_id between l_start_unit_id and l_end_unit_id;
1028: else
1029: update ad_parallel_update_units

Line 1029: update ad_parallel_update_units

1025: delete from ad_parallel_update_units
1026: where update_id = l_update_info.update_id
1027: and unit_id between l_start_unit_id and l_end_unit_id;
1028: else
1029: update ad_parallel_update_units
1030: set status = decode(l_update_info.update_type,
1031: ROWID_RANGE, PROCESSED_STATUS,
1032: decode(X_last_id,
1033: end_id, PROCESSED_STATUS,

Line 1124: update ad_parallel_update_units

1120: --
1121: -- Set status to ASSIGNED_STATUS
1122: --
1123:
1124: update ad_parallel_update_units
1125: set status = ASSIGNED_STATUS,
1126: worker_id = X_worker_id,
1127: start_date = nvl(start_date, sysdate)
1128: where update_id = l_update_info.update_id

Line 1219: l_unit_rec ad_parallel_update_units%rowtype;

1215: l_end_rowid rowid;
1216: l_start_unit_id number;
1217: l_end_unit_id number;
1218: l_last_processed_unit number;
1219: l_unit_rec ad_parallel_update_units%rowtype;
1220:
1221: l_worker_id NUMBER;
1222: l_update_info update_info_type;
1223:

Line 1226: from ad_parallel_update_units

1222: l_update_info update_info_type;
1223:
1224: cursor c_range(p_update_id number) is
1225: select /*+ FIRST_ROWS +*/ *
1226: from ad_parallel_update_units
1227: where update_id = p_update_id
1228: and status = UNASSIGNED_STATUS
1229: for update of status
1230: skip locked;

Line 1326: l_unit_rec ad_parallel_update_units%rowtype;

1322: l_start_id number;
1323: l_end_id number;
1324: l_start_unit_id number;
1325: l_end_unit_id number;
1326: l_unit_rec ad_parallel_update_units%rowtype;
1327: l_batch_size number;
1328:
1329: l_status varchar2(30);
1330:

Line 1336: from ad_parallel_update_units

1332: l_update_info update_info_type;
1333:
1334: cursor c_range(p_update_id in number) is
1335: select /*+ FIRST_ROWS +*/ *
1336: from ad_parallel_update_units
1337: where update_id = p_update_id
1338: and status = UNASSIGNED_STATUS
1339: for update of status
1340: skip locked;

Line 1393: from ad_parallel_update_units

1389: -- check the actual unit to find out if it has already been processed
1390: --
1391: select status
1392: into l_status
1393: from ad_parallel_update_units
1394: where update_id = l_update_info.update_id
1395: and unit_id = l_start_unit_id;
1396:
1397: --

Line 1473: update AD_PARALLEL_UPDATE_UNITS

1469: else
1470:
1471: /* set unit as processed if ID values are null. */
1472:
1473: update AD_PARALLEL_UPDATE_UNITS
1474: set STATUS = PROCESSED_STATUS
1475: where update_id = l_update_info.update_id
1476: and unit_id = l_unit_rec.unit_id;
1477:

Line 1503: from ad_parallel_update_units u

1499: and table_name = nvl(upper(X_table), table_name)
1500: and script_name = nvl(X_script, script_name)
1501: and not exists (
1502: select update_id
1503: from ad_parallel_update_units u
1504: where u.update_id = p.update_id
1505: and u.status in ('A', 'U'));
1506: begin
1507: for c_rec in c_purge loop

Line 1509: -- delete from ad_parallel_update_units

1505: and u.status in ('A', 'U'));
1506: begin
1507: for c_rec in c_purge loop
1508: --
1509: -- delete from ad_parallel_update_units
1510: --
1511: delete from ad_parallel_update_units
1512: where update_id = c_rec.update_id;
1513:

Line 1511: delete from ad_parallel_update_units

1507: for c_rec in c_purge loop
1508: --
1509: -- delete from ad_parallel_update_units
1510: --
1511: delete from ad_parallel_update_units
1512: where update_id = c_rec.update_id;
1513:
1514: --
1515: -- delete from ad_parallel_workers

Line 1568: delete from ad_parallel_update_units

1564:
1565: delete from ad_parallel_workers
1566: where update_id = l_update_id;
1567:
1568: delete from ad_parallel_update_units
1569: where update_id = l_update_id;
1570:
1571: delete from ad_parallel_updates
1572: where update_id = l_update_id;

Line 1609: from ad_parallel_update_units pun

1605: and update_type = ROWID_RANGE
1606: and initialized_flag = 'Y'
1607: and exists (
1608: select 'Unprocessed units exist'
1609: from ad_parallel_update_units pun
1610: where pun.update_id = pu.update_id
1611: and pun.status in (UNASSIGNED_STATUS, ASSIGNED_STATUS));
1612: begin
1613:

Line 1629: -- delete from ad_parallel_update_units

1625: set initialized_flag = 'N'
1626: where update_id = crec.update_id;
1627:
1628: --
1629: -- delete from ad_parallel_update_units
1630: --
1631: delete from ad_parallel_update_units
1632: where update_id = crec.update_id;
1633:

Line 1631: delete from ad_parallel_update_units

1627:
1628: --
1629: -- delete from ad_parallel_update_units
1630: --
1631: delete from ad_parallel_update_units
1632: where update_id = crec.update_id;
1633:
1634: delete from ad_parallel_workers
1635: where update_id = crec.update_id;