The following lines contain the word 'select', 'insert', 'update' or 'delete':
SELECT task_status
INTO l_current_status
FROM fnd_oam_dscram_tasks
WHERE task_id = l_id
FOR UPDATE;
UPDATE fnd_oam_dscram_tasks
SET task_status = G_STATUS_STOPPING,
last_updated_by = fnd_global.user_id,
last_update_login = fnd_global.user_id,
last_update_date = SYSDATE
WHERE task_id = l_id;
SELECT bundle_status
INTO l_current_status
FROM fnd_oam_dscram_bundles
WHERE bundle_id = l_id
FOR UPDATE;
UPDATE fnd_oam_dscram_bundles
SET bundle_status = G_STATUS_STOPPING,
last_updated_by = fnd_global.user_id,
last_update_login = fnd_global.user_id,
last_update_date = SYSDATE
WHERE bundle_id = l_id;
SELECT run_status
INTO l_current_status
FROM fnd_oam_dscram_runs_b
WHERE run_id = l_id
FOR UPDATE;
UPDATE fnd_oam_dscram_runs_b
SET run_status = G_STATUS_STOPPING,
last_updated_by = fnd_global.user_id,
last_update_login = fnd_global.user_id,
last_update_date = SYSDATE
WHERE run_id = l_id;
PROCEDURE DELETE_STATS(p_object_type IN VARCHAR2,
p_object_id IN VARCHAR2)
IS
l_ctxt VARCHAR2(60) := PKG_NAME||'DELETE_STATS';
DELETE FROM fnd_oam_dscram_stats
WHERE source_object_type = p_object_type
AND source_object_id = p_object_id;
PROCEDURE DELETE_ARGS(p_object_type IN VARCHAR2,
p_object_id IN VARCHAR2)
IS
l_ctxt VARCHAR2(60) := PKG_NAME||'DELETE_ARGS';
SELECT arg_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_args_b
WHERE parent_type = p_object_type
AND parent_id = p_object_id;
DELETE FROM fnd_oam_dscram_args_b
WHERE arg_id = l_id;
DELETE FROM fnd_oam_dscram_args_tl
WHERE arg_id = l_id;
DELETE FROM fnd_oam_dscram_arg_values
WHERE arg_id = l_id;
FUNCTION DELETE_AD_DATA(p_run_id IN NUMBER,
p_unit_id IN NUMBER,
p_owner IN VARCHAR2,
p_table_name IN VARCHAR2)
RETURN BOOLEAN
IS
l_ctxt VARCHAR2(60) := PKG_NAME||'DELETE_AD_DATA';
SELECT update_id
BULK COLLECT INTO l_ids
FROM ad_parallel_updates
WHERE owner = p_owner
AND table_name = p_table_name
AND script_name = l_script_key;
fnd_oam_debug.log(1, l_ctxt, 'AD Update ID: '||l_id);
DELETE FROM ad_parallel_workers
WHERE update_id = l_id;
DELETE FROM ad_parallel_update_units
WHERE update_id = l_id;
DELETE FROM ad_parallel_updates
WHERE update_id = l_id;
FUNCTION DELETE_PLSQL(p_plsql_id IN NUMBER)
RETURN BOOLEAN
IS
l_ctxt VARCHAR2(60) := PKG_NAME||'DELETE_PLSQL';
DELETE_STATS(FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_PLSQL,
p_plsql_id);
DELETE_ARGS(FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_PLSQL,
p_plsql_id);
DELETE FROM fnd_oam_dscram_plsqls
WHERE plsql_id = p_plsql_id;
FUNCTION DELETE_DML(p_dml_id IN NUMBER)
RETURN BOOLEAN
IS
l_ctxt VARCHAR2(60) := PKG_NAME||'DELETE_DML';
DELETE_STATS(FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_DML,
p_dml_id);
DELETE_ARGS(FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_DML,
p_dml_id);
DELETE FROM fnd_oam_dscram_dmls
WHERE dml_id = p_dml_id;
FUNCTION DELETE_UNIT(p_run_id IN NUMBER,
p_unit_id IN NUMBER)
RETURN BOOLEAN
IS
l_ctxt VARCHAR2(60) := PKG_NAME||'DELETE_UNIT';
SELECT unit_type, unit_object_owner, unit_object_name
INTO l_unit_type, l_object_owner, l_object_name
FROM fnd_oam_dscram_units
WHERE unit_id = p_unit_id;
SELECT unit_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_units
WHERE concurrent_group_unit_id = p_unit_id;
IF NOT DELETE_UNIT(p_run_id,
l_ids(k)) THEN
fnd_oam_debug.log(2, l_ctxt, 'EXIT');
SELECT dml_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_dmls
WHERE unit_id = p_unit_id;
IF NOT DELETE_DML(l_ids(k)) THEN
fnd_oam_debug.log(2, l_ctxt, 'EXIT');
SELECT plsql_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_plsqls
WHERE unit_id = p_unit_id;
IF NOT DELETE_PLSQL(l_ids(k)) THEN
fnd_oam_debug.log(2, l_ctxt, 'EXIT');
IF NOT DELETE_AD_DATA(p_run_id,
p_unit_id,
l_object_owner,
l_object_name) THEN
fnd_oam_debug.log(2, l_ctxt, 'EXIT');
DELETE_STATS(FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_UNIT,
p_unit_id);
DELETE FROM fnd_oam_dscram_units
WHERE unit_id = p_unit_id;
FUNCTION DELETE_TASK(p_run_id IN NUMBER,
p_task_id IN NUMBER)
RETURN BOOLEAN
IS
l_ctxt VARCHAR2(60) := PKG_NAME||'DELETE_TASK';
SELECT unit_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_units
WHERE task_id = p_task_id
AND concurrent_group_unit_id IS NULL;
IF NOT DELETE_UNIT(p_run_id,
l_ids(k)) THEN
fnd_oam_debug.log(2, l_ctxt, 'EXIT');
DELETE_STATS(FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_TASK,
p_task_id);
DELETE FROM fnd_oam_dscram_tasks
WHERE task_id = p_task_id;
FUNCTION DELETE_BUNDLE(p_run_id IN NUMBER,
p_bundle_id IN NUMBER)
RETURN BOOLEAN
IS
l_ctxt VARCHAR2(60) := PKG_NAME||'DELETE_BUNDLE';
SELECT task_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_tasks
WHERE bundle_id = p_bundle_id;
IF NOT DELETE_TASK(p_run_id,
l_ids(k)) THEN
fnd_oam_debug.log(2, l_ctxt, 'EXIT');
DELETE_STATS(FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_BUNDLE,
p_bundle_id);
DELETE FROM fnd_oam_dscram_bundles
WHERE bundle_id = p_bundle_id;
FUNCTION DELETE_RUN(p_run_id IN NUMBER)
RETURN BOOLEAN
IS
l_ctxt VARCHAR2(60) := PKG_NAME||'DELETE_RUN';
SELECT bundle_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_bundles
WHERE RUN_ID = p_run_id;
IF NOT DELETE_BUNDLE(p_run_id,
l_ids(k)) THEN
l_retbool := FALSE;
DELETE_STATS(FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_RUN,
p_run_id);
DELETE_ARGS(FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_RUN,
p_run_id);
DELETE FROM fnd_oam_dscram_runs_b
WHERE run_id = p_run_id;
DELETE FROM fnd_oam_dscram_runs_tl
WHERE run_id = p_run_id;
SELECT count(*)
INTO k
FROM fnd_oam_dscram_runs_b;
SELECT count(*)
INTO k
FROM fnd_oam_dscram_runs_tl;
SELECT unit_id
INTO l_parent_id
FROM fnd_oam_dscram_plsqls
WHERE plsql_id = p_plsql_ids(k);
UPDATE fnd_oam_dscram_plsqls
SET finished_ret_sts = NULL
WHERE plsql_id = p_plsql_ids(k)
AND finished_ret_sts <> FND_API.G_RET_STS_SUCCESS;
SELECT unit_id
INTO l_parent_id
FROM fnd_oam_dscram_dmls
WHERE dml_id = p_dml_ids(k);
UPDATE fnd_oam_dscram_dmls
SET finished_ret_sts = NULL
WHERE dml_id = p_dml_ids(k)
AND finished_ret_sts <> FND_API.G_RET_STS_SUCCESS;
SELECT unit_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_units
WHERE concurrent_group_unit_id = p_unit_ids(k);
l_ids.DELETE;
SELECT dml_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_dmls
WHERE unit_id = p_unit_ids(k)
AND finished_ret_sts <> FND_API.G_RET_STS_SUCCESS;
l_ids.DELETE;
SELECT plsql_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_plsqls
WHERE unit_id = p_unit_ids(k)
AND finished_ret_sts <> FND_API.G_RET_STS_SUCCESS;
SELECT task_id
INTO l_parent_id
FROM fnd_oam_dscram_units
WHERE unit_id = p_unit_ids(k);
UPDATE fnd_oam_dscram_units
SET unit_status = G_STATUS_RESTARTABLE,
workers_assigned = 0
WHERE unit_id = p_unit_ids(k)
AND unit_status NOT IN (G_STATUS_PROCESSED, G_STATUS_SKIPPED, G_STATUS_NO_STATUS, G_STATUS_UNPROCESSED);
SELECT unit_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_units
WHERE task_id = p_task_ids(k)
AND unit_status NOT IN (G_STATUS_PROCESSED, G_STATUS_SKIPPED, G_STATUS_NO_STATUS, G_STATUS_UNPROCESSED);
SELECT bundle_id
INTO l_parent_id
FROM fnd_oam_dscram_tasks
WHERE task_id = p_task_ids(k);
UPDATE fnd_oam_dscram_tasks
SET task_status = G_STATUS_RESTARTABLE,
workers_assigned = 0
WHERE task_id = p_task_ids(k)
AND task_status NOT IN (G_STATUS_PROCESSED, G_STATUS_SKIPPED, G_STATUS_UNPROCESSED);
SELECT task_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_tasks
WHERE bundle_id = p_bundle_ids(k)
AND task_status NOT IN (G_STATUS_PROCESSED, G_STATUS_SKIPPED, G_STATUS_UNPROCESSED);
SELECT run_id
INTO l_parent_id
FROM fnd_oam_dscram_bundles
WHERE bundle_id = p_bundle_ids(k);
UPDATE fnd_oam_dscram_bundles
SET bundle_status = G_STATUS_RESTARTABLE,
workers_assigned = 0
WHERE bundle_id = p_bundle_ids(k)
AND bundle_status NOT IN (G_STATUS_PROCESSED, G_STATUS_SKIPPED, G_STATUS_UNPROCESSED);
SELECT bundle_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_bundles
WHERE run_id = p_run_ids(k)
AND bundle_status NOT IN (G_STATUS_PROCESSED, G_STATUS_SKIPPED, G_STATUS_UNPROCESSED);
UPDATE fnd_oam_dscram_runs_b
SET run_status = G_STATUS_RESTARTABLE
WHERE run_id = p_run_ids(k)
AND run_status NOT IN (G_STATUS_PROCESSED, G_STATUS_SKIPPED, G_STATUS_UNPROCESSED);
SELECT run_status
INTO l_status
FROM fnd_oam_dscram_runs_b
WHERE run_id = p_run_id;
SELECT bundle_id
BULK COLLECT INTO l_ids
FROM fnd_oam_dscram_bundles
WHERE RUN_ID = p_run_id;
UPDATE fnd_oam_dscram_runs_b
SET run_status = G_STATUS_RESTARTABLE
WHERE run_id = p_run_id;