The following lines contain the word 'select', 'insert', 'update' or 'delete':
select target_id
from ben_dm_resolve_mappings bdm
where resolve_mapping_id = p_resolve_mapping_id
;
select target_id
from ben_dm_resolve_mappings bdm
where table_name = p_table_name
and column_name = p_source_column
and source_id = p_source_id
;
select target_id,
table_name,
source_id,
column_name,
business_group_name
from ben_dm_resolve_mappings
where target_id is not null
;
g_fk_maping_tbl.delete ;
procedure update_pk_mapping(
p_resolve_mapping_id in NUMBER DEFAULT null
,p_target_id in NUMBER
,p_table_name in VARCHAR2 DEFAULT null
,p_column_name in VARCHAR2 DEFAULT null
,p_source_id in NUMBER DEFAULT null
,p_source_column in VARCHAR2 DEFAULT null
,p_business_group_name in VARCHAR2 DEFAULT null
,p_table_id in NUMBER DEFAULT null
) is
l_proc varchar2(75) ;
select target_id
from ben_dm_resolve_mappings brm
where brm.resolve_mapping_id = p_resolve_mapping_id
;
select brm.resolve_mapping_id ,
brm.target_id
from ben_dm_resolve_mappings brm
where table_name = c_table_name
and source_id = p_source_id
and column_name = c_column_name
and business_group_name = p_business_group_name
;
select parent_id_column_name, -- confirm with sarju
parent_table_name
from ben_dm_hierarchies
where table_id = p_table_id
and column_name = p_source_column
;
l_proc := g_package || 'update_pk_mapping' ;
update ben_dm_resolve_mappings
set target_id = p_target_id
where resolve_mapping_id = l_resolve_mapping_id ;
ben_dm_utility.message('INFO',' update_pk_mapping ' || substr(sqlerrm ,1, 100) ,140);
end update_pk_mapping ;
,p_last_update_date in DATE DEFAULT NULl
,p_last_updated_by in NUMBER DEFAULT NULl
,p_last_update_login in NUMBER DEFAULT NULL
,p_created_by in NUMBER DEFAULT NULL
,p_creation_date in DATE DEFAULT NULL ) is
cursor c1 is
select table_name from
ben_dm_tables bdt
where bdt.table_id = p_table_id
;
select resolve_mapping_id
from ben_dm_resolve_mappings brm
where brm.table_name = c_table_name
and brm.column_name = p_column_name
and brm.source_id = p_source_id
and brm.business_group_name = p_business_group_name
;
hr_utility.set_location(' Inserting the value :'||l_proc, 20);
select BEN_DM_RESOLVE_MAPPINGS_S.nextval
into p_resolve_mapping_id from dual ;
insert into ben_dm_resolve_mappings
( resolve_mapping_id
,table_name
,column_name
,source_id
,source_key
,target_id
,business_group_name
,mapping_type
,resolve_mapping_id1
,resolve_mapping_id2
,resolve_mapping_id3
,resolve_mapping_id4
,resolve_mapping_id5
,resolve_mapping_id6
,resolve_mapping_id7
,last_update_date
,last_updated_by
,last_update_login
,created_by
,creation_date
) values
(p_resolve_mapping_id
,l_table_name
,p_column_name
,p_source_id
,p_source_key
,p_target_id
,p_business_group_name
,p_mapping_type
,p_resolve_mapping_id1
,p_resolve_mapping_id2
,p_resolve_mapping_id3
,p_resolve_mapping_id4
,p_resolve_mapping_id5
,p_resolve_mapping_id6
,p_resolve_mapping_id7
,p_last_update_date
,p_last_updated_by
,p_last_update_login
,p_created_by
,p_creation_date
) ;
select ben_dm_entity_results_s.nextval
into p_entity_result_id from dual ;
select business_group_id
into l_bg_id
from per_business_groups
where name = p_business_group_name;
procedure delete_process
(p_migration_id in number
,p_group_order in number) is
--
-- cursor to Fetch Data from BEN_DM_FILE_INPUT table.
--
cursor csr_get_inf is
select *
from ben_dm_input_file inf
where group_order = p_group_order
and person_type = 'P'
;
select person_id
from per_all_people_f
where business_group_id = c_business_group_id
and national_identifier = c_national_identifier;
l_proc varchar2(72) := g_package || 'delete_process';
l_person_table.delete;
ben_person_delete.delete_ben_rows(l_person_table(i));
hr_person_delete.delete_a_person(l_person_table(i), FALSE, SYSDATE);
,p_last_update_date in varchar2
,p_upload_table_name in varchar2
,p_table_alias in varchar2
,p_datetrack in varchar2
,p_derive_sql in varchar2
,p_surrogate_pk_column_name in varchar2
,p_short_name in varchar2
,p_sequence_name in varchar2
) is
cursor c1 is
select table_id
from ben_dm_tables
where table_name = p_table_name ;
hr_utility.set_location(' Insert :'||p_table_name, 10);
update ben_dm_tables
set table_name = p_table_name
,upload_table_name = p_upload_table_name
,table_alias = p_table_alias
,datetrack = p_datetrack
,derive_sql = p_derive_sql
,surrogate_pk_column_name = p_surrogate_pk_column_name
,short_name = p_short_name
,sequence_name = p_sequence_name
,last_update_date = sysdate
,last_updated_by = fnd_global.user_id
,last_update_login = fnd_global.login_id
where table_id = l_table_id ;
hr_utility.set_location(' Update :'||p_table_name, 10);
insert into ben_dm_tables
( table_id
,table_name
,upload_table_name
,table_alias
,datetrack
,derive_sql
,surrogate_pk_column_name
,short_name
,sequence_name
,last_update_date
,last_updated_by
,last_update_login
,created_by
,creation_date
) values
(
ben_dm_tables_s.nextval
,p_table_name
,p_upload_table_name
,p_table_alias
,p_datetrack
,p_derive_sql
,p_surrogate_pk_column_name
,p_short_name
,p_sequence_name
,sysdate
,fnd_global.user_id
,fnd_global.login_id
,fnd_global.user_id
,sysdate
) ;
,p_last_update_date in varchar2
) is
cursor c1 is
select table_id
from ben_dm_tables
where table_name = p_table_name ;
select table_order_id
from ben_dm_table_order
where table_id = l_table_id
-- and table_order = p_Table_order
;
hr_utility.set_location(' Insert :'||p_table_name, 10);
update ben_dm_table_order
set table_order = p_table_order
,last_update_date = sysdate
,last_updated_by = fnd_global.user_id
,last_update_login = fnd_global.login_id
where table_order_id = l_table_order_id
;
hr_utility.set_location(' Update :'||p_table_name, 10);
insert into ben_dm_table_order
(table_order_id
,table_id
,table_order
,last_update_date
,last_updated_by
,last_update_login
,created_by
,creation_date
) Values
(ben_dm_table_order_s.nextval
,l_table_id
,p_table_order
,sysdate
,fnd_global.user_id
,fnd_global.login_id
,fnd_global.user_id
,sysdate
);
,p_last_update_date in varchar2
,p_parent_table_name in varchar2
,p_parent_column_name in varchar2
,p_parent_id_column_name in varchar2
) is
cursor c1 is
select table_id
from ben_dm_tables
where table_name = p_table_name ;
select hierarchy_id
from ben_dm_hierarchies
where table_id = l_table_id
and column_name = p_column_name
;
hr_utility.set_location(' Insert :'||p_table_name, 10);
update ben_dm_hierarchies
set parent_table_name = p_parent_table_name
,parent_column_name = p_parent_column_name
,parent_id_column_name = p_parent_id_column_name
,last_update_date = sysdate
,last_updated_by = fnd_global.user_id
,last_update_login = fnd_global.login_id
where hierarchy_id = l_hierarchy_id
;
hr_utility.set_location(' Update :'||p_table_name, 10);
insert into ben_dm_hierarchies
( hierarchy_id
,hierarchy_type
,table_id
,column_name
,parent_table_name
,parent_column_name
,parent_id_column_name
,last_update_date
,last_updated_by
,last_update_login
,created_by
,creation_date
) values
( ben_dm_hierarchies_s.nextval
,p_hierarchy_type
,l_table_id
,p_column_name
,p_parent_table_name
,p_parent_column_name
,p_parent_id_column_name
,sysdate
,fnd_global.user_id
,fnd_global.login_id
,fnd_global.user_id
,sysdate
) ;
,p_last_update_date in varchar2
,p_entity_result_column_name in varchar2
) is
cursor c1 is
select table_id
from ben_dm_tables
where table_name = p_table_name ;
select column_mapping_id
from ben_dm_column_mappings
where table_id = l_table_id
and column_name = p_column_name
;
hr_utility.set_location(' Insert :'||p_table_name, 10);
update ben_dm_column_mappings
set entity_result_column_name = entity_result_column_name
where column_mapping_id = l_column_mapping_id
;
hr_utility.set_location(' Update :'||p_table_name, 10);
insert into ben_dm_column_mappings
( column_mapping_id
,table_id
,column_name
,ENTITY_RESULT_COLUMN_NAME
,last_update_date
,last_updated_by
,last_update_login
,created_by
,creation_date
) values
( ben_dm_column_mappings_s.nextval
,l_table_id
,p_column_name
,p_entity_result_column_name
,sysdate
,fnd_global.user_id
,fnd_global.login_id
,fnd_global.user_id
,sysdate
) ;
,p_LAST_UPDATE_DATE IN VARCHAR2
,p_OWNER IN VARCHAR2
,p_SECURITY_GROUP_ID IN VARCHAR2
)is
cursor c1 is
select 'x'
from hr_dm_phase_rules
where p_MIGRATION_TYPE = MIGRATION_TYPE
and p_PHASE_NAME = PHASE_NAME
and p_PREVIOUS_PHASE = PREVIOUS_PHASE
and p_NEXT_PHASE = NEXT_PHASE
and p_DATABASE_LOCATION = DATABASE_LOCATION
;
insert into hr_dm_phase_rules
( phase_rule_id
,MIGRATION_TYPE
,PHASE_NAME
,PREVIOUS_PHASE
,NEXT_PHASE
,DATABASE_LOCATION
,LAST_UPDATE_DATE
,LAST_UPDATED_BY
,LAST_UPDATE_LOGIN
,CREATED_BY
,CREATION_DATE
,SECURITY_GROUP_ID
) Values
( hr_dm_phase_rules_s.nextval
,p_MIGRATION_TYPE
,p_PHASE_NAME
,p_PREVIOUS_PHASE
,p_NEXT_PHASE
,p_DATABASE_LOCATION
,sysdate
,fnd_global.user_id
,fnd_global.login_id
,fnd_global.user_id
,sysdate
,p_SECURITY_GROUP_ID
) ;
Procedure update_gen_version (p_table_id in number
,p_version in varchar2
) is
l_proc varchar2(75) ;
l_proc := g_package || 'update_gen_version' ;
update ben_dm_tables
set GENERATOR_VERSION = replace(replace (p_version,' $Header:',''),' - ',':')
, LAST_GENERATED_DATE = sysdate
where table_id = p_table_id ;