The following lines contain the word 'select', 'insert', 'update' or 'delete':
the records which have to be updated / deleted / inserted in JTF_RS_GROUP_RELATIONS.
After successful processing the row will be deleted from JTF_RS_CHGD_GRP_RELATIONS.
******************************************************************************************/
/* Package variables. */
G_PKG_NAME VARCHAR2(30) := 'JTF_RS_CONC_GRP_DENORM_PUB';
SELECT group_relate_id,
group_id,
related_group_id,
relation_type,
operation_flag,
rowid row_id
FROM JTF_RS_CHGD_GRP_RELATIONS
ORDER BY creation_date;
-- FOR UPDATE OF group_relate_id;
JTF_RS_GROUP_DENORM_PVT.INSERT_GROUPS
( P_API_VERSION => 1.0,
P_INIT_MSG_LIST => l_init_msg_list,
P_COMMIT => 'F',
P_GROUP_ID => l_grp.group_id,
X_RETURN_STATUS => l_return_status,
X_MSG_COUNT => l_msg_count,
X_MSG_DATA => l_msg_data);
-- JTF_RS_GROUP_DENORM_PVT.INSERT_GROUPS api (called above)
/* JTF_RS_REP_MGR_DENORM_PVT.INSERT_GRP_RELATIONS
( P_API_VERSION => 1.0,
P_INIT_MSG_LIST => l_init_msg_list,
P_COMMIT => l_commit,
P_GROUP_RELATE_ID => l_grp.group_relate_id,
X_RETURN_STATUS => l_return_status,
X_MSG_COUNT => l_msg_count,
X_MSG_DATA => l_msg_data);
JTF_RS_GROUP_DENORM_PVT.UPDATE_GROUPS
( P_API_VERSION => 1.0,
P_INIT_MSG_LIST => l_init_msg_list,
P_COMMIT => 'F',
P_GROUP_ID => l_grp.group_id,
X_RETURN_STATUS => l_return_status,
X_MSG_COUNT => l_msg_count,
X_MSG_DATA => l_msg_data);
JTF_RS_GROUP_DENORM_PVT.DELETE_GRP_RELATIONS
( P_API_VERSION => 1.0,
P_INIT_MSG_LIST => l_init_msg_list,
P_COMMIT => 'F',
P_group_relate_id => l_grp.group_relate_id,
P_GROUP_ID => l_grp.group_id,
P_RELATED_GROUP_ID => l_grp.related_group_id,
X_RETURN_STATUS => l_return_status,
X_MSG_COUNT => l_msg_count,
X_MSG_DATA => l_msg_data);
DELETE FROM JTF_RS_CHGD_GRP_RELATIONS
WHERE group_relate_id = l_grp.group_relate_id
AND rowid = l_grp.row_id ;