DBA Data[Home] [Help]

APPS.AD_ZD_TABLE dependencies on DBMS_PARALLEL_EXECUTE

Line 1493: dbms_parallel_execute.create_task(l_task_name);

1489: -- create task, handle possible conflicting task
1490: l_task_name := x_trigger_name;
1491: begin
1492: log(c_module, 'STATEMENT', 'Create task: '||l_task_name);
1493: dbms_parallel_execute.create_task(l_task_name);
1494: exception
1495: when duplicate_task_error then
1496: log(c_module, 'STATEMENT', 'Drop duplicate task: '||l_task_name);
1497: dbms_parallel_execute.drop_task(l_task_name);

Line 1497: dbms_parallel_execute.drop_task(l_task_name);

1493: dbms_parallel_execute.create_task(l_task_name);
1494: exception
1495: when duplicate_task_error then
1496: log(c_module, 'STATEMENT', 'Drop duplicate task: '||l_task_name);
1497: dbms_parallel_execute.drop_task(l_task_name);
1498: log(c_module, 'STATEMENT', 'Create task (retry): '||l_task_name);
1499: dbms_parallel_execute.create_task(l_task_name);
1500: end;
1501:

Line 1499: dbms_parallel_execute.create_task(l_task_name);

1495: when duplicate_task_error then
1496: log(c_module, 'STATEMENT', 'Drop duplicate task: '||l_task_name);
1497: dbms_parallel_execute.drop_task(l_task_name);
1498: log(c_module, 'STATEMENT', 'Create task (retry): '||l_task_name);
1499: dbms_parallel_execute.create_task(l_task_name);
1500: end;
1501:
1502: dbms_parallel_execute.create_chunks_by_rowid(
1503: l_task_name, x_table_owner, x_table_name, true, 10000);

Line 1502: dbms_parallel_execute.create_chunks_by_rowid(

1498: log(c_module, 'STATEMENT', 'Create task (retry): '||l_task_name);
1499: dbms_parallel_execute.create_task(l_task_name);
1500: end;
1501:
1502: dbms_parallel_execute.create_chunks_by_rowid(
1503: l_task_name, x_table_owner, x_table_name, true, 10000);
1504:
1505: -- 'apply_crossedition_trigger' parameter is required to make cross edition trigger fire
1506: -- 'parallel_level' of null uses default parallelism.

Line 1507: dbms_parallel_execute.run_task(

1503: l_task_name, x_table_owner, x_table_name, true, 10000);
1504:
1505: -- 'apply_crossedition_trigger' parameter is required to make cross edition trigger fire
1506: -- 'parallel_level' of null uses default parallelism.
1507: dbms_parallel_execute.run_task(
1508: l_task_name, l_stmt, dbms_sql.native,
1509: apply_crossedition_trigger=>'"'||x_trigger_name ||'"', parallel_level=>null);
1510:
1511: -- If any error, Try again

Line 1512: l_status := dbms_parallel_execute.task_status(l_task_name);

1508: l_task_name, l_stmt, dbms_sql.native,
1509: apply_crossedition_trigger=>'"'||x_trigger_name ||'"', parallel_level=>null);
1510:
1511: -- If any error, Try again
1512: l_status := dbms_parallel_execute.task_status(l_task_name);
1513: if (l_status = dbms_parallel_execute.processed_with_error or
1514: l_status = dbms_parallel_execute.crashed ) then
1515: log(c_module, 'WARNING', 'Update failed, status='||to_char(l_status)||', Retrying...');
1516: dbms_parallel_execute.resume_task(l_task_name);

Line 1513: if (l_status = dbms_parallel_execute.processed_with_error or

1509: apply_crossedition_trigger=>'"'||x_trigger_name ||'"', parallel_level=>null);
1510:
1511: -- If any error, Try again
1512: l_status := dbms_parallel_execute.task_status(l_task_name);
1513: if (l_status = dbms_parallel_execute.processed_with_error or
1514: l_status = dbms_parallel_execute.crashed ) then
1515: log(c_module, 'WARNING', 'Update failed, status='||to_char(l_status)||', Retrying...');
1516: dbms_parallel_execute.resume_task(l_task_name);
1517: end if;

Line 1514: l_status = dbms_parallel_execute.crashed ) then

1510:
1511: -- If any error, Try again
1512: l_status := dbms_parallel_execute.task_status(l_task_name);
1513: if (l_status = dbms_parallel_execute.processed_with_error or
1514: l_status = dbms_parallel_execute.crashed ) then
1515: log(c_module, 'WARNING', 'Update failed, status='||to_char(l_status)||', Retrying...');
1516: dbms_parallel_execute.resume_task(l_task_name);
1517: end if;
1518:

Line 1516: dbms_parallel_execute.resume_task(l_task_name);

1512: l_status := dbms_parallel_execute.task_status(l_task_name);
1513: if (l_status = dbms_parallel_execute.processed_with_error or
1514: l_status = dbms_parallel_execute.crashed ) then
1515: log(c_module, 'WARNING', 'Update failed, status='||to_char(l_status)||', Retrying...');
1516: dbms_parallel_execute.resume_task(l_task_name);
1517: end if;
1518:
1519: -- If still error, report problem
1520: l_status := dbms_parallel_execute.task_status(l_task_name);

Line 1520: l_status := dbms_parallel_execute.task_status(l_task_name);

1516: dbms_parallel_execute.resume_task(l_task_name);
1517: end if;
1518:
1519: -- If still error, report problem
1520: l_status := dbms_parallel_execute.task_status(l_task_name);
1521: if (l_status = dbms_parallel_execute.processed_with_error or
1522: l_status = dbms_parallel_execute.crashed ) then
1523: error(c_module, 'Update failed, status = '||to_char(l_status));
1524: end if;

Line 1521: if (l_status = dbms_parallel_execute.processed_with_error or

1517: end if;
1518:
1519: -- If still error, report problem
1520: l_status := dbms_parallel_execute.task_status(l_task_name);
1521: if (l_status = dbms_parallel_execute.processed_with_error or
1522: l_status = dbms_parallel_execute.crashed ) then
1523: error(c_module, 'Update failed, status = '||to_char(l_status));
1524: end if;
1525:

Line 1522: l_status = dbms_parallel_execute.crashed ) then

1518:
1519: -- If still error, report problem
1520: l_status := dbms_parallel_execute.task_status(l_task_name);
1521: if (l_status = dbms_parallel_execute.processed_with_error or
1522: l_status = dbms_parallel_execute.crashed ) then
1523: error(c_module, 'Update failed, status = '||to_char(l_status));
1524: end if;
1525:
1526: log(c_module, 'STATEMENT', 'Successful Parallel Update, dropping task: '||l_task_name);

Line 1527: dbms_parallel_execute.drop_task(l_task_name);

1523: error(c_module, 'Update failed, status = '||to_char(l_status));
1524: end if;
1525:
1526: log(c_module, 'STATEMENT', 'Successful Parallel Update, dropping task: '||l_task_name);
1527: dbms_parallel_execute.drop_task(l_task_name);
1528:
1529: -- re-enable conflict triggers
1530: -- TODO: Enable only those triggers which were DISABLED by this API.
1531: for crec in c_conflict_triggers(x_table_owner, x_table_name) loop

Line 1542: dbms_parallel_execute.drop_task(l_task_name);

1538: exception
1539: when others then
1540: l_error := sqlerrm;
1541: begin
1542: dbms_parallel_execute.drop_task(l_task_name);
1543: exception
1544: when others then null;
1545: end;
1546: error(c_module, l_error);