400: END;
401:
402: PROCEDURE generate_map_pkg_nolog IS
403: BEGIN
404: g_batch_size := nvl( FND_PROFILE.value('HZ_DQM_STAGE_BATCH_SIZE'), 200 );--Bug 10030313
405: HZ_GEN_PLSQL.new('HZ_STAGE_MAP_TRANSFORM', 'PACKAGE BODY');
406: l('CREATE OR REPLACE PACKAGE BODY HZ_STAGE_MAP_TRANSFORM AS');
407:
408: generate_declarations;
635:
636: PROCEDURE generate_map_pkg IS
637: BEGIN
638: log('Generating package body for HZ_STAGE_MAP_TRANSFORM');
639: g_batch_size := nvl( FND_PROFILE.value('HZ_DQM_STAGE_BATCH_SIZE'), 200 );--Bug 10030313
640: HZ_GEN_PLSQL.new('HZ_STAGE_MAP_TRANSFORM', 'PACKAGE BODY');
641: l('CREATE OR REPLACE PACKAGE BODY HZ_STAGE_MAP_TRANSFORM AS');
642:
643: generate_declarations;
1175: l_table_name VARCHAR2(255);
1176: BEGIN
1177: log ('--------------------------------------');
1178: -- If profile option is Optimal we FORCE A REBUILD.
1179: IF upper ( nvl( FND_PROFILE.value('HZ_DQM_INDEX_BUILD_TYPE'), 'Optimal') ) = upper('Optimal')
1180: THEN
1181: IF new_transformations_exist(p_entity)
1182: THEN
1183: log(' Chosen Profile Option is OPTIMAL');
1360: -- req_data will be null the first time, by default
1361: req_data := fnd_conc_global.request_data;
1362: IF (req_data IS NULL) THEN --Bug No: 4292425
1363: l_index_creation := nvl(p_index_creation,'PARALLEL');
1364: l_realtime_sync_value := nvl(FND_PROFILE.VALUE('HZ_DQM_ENABLE_REALTIME_SYNC'), 'Y'); --4915282
1365: IF p_num_workers IS NULL THEN
1366: l_num_workers:=1;
1367: ELSE
1368: l_num_workers := to_number(p_num_workers);
1408: generate_map_pkg;
1409: FOR I in 1..10 LOOP
1410: l_sub_requests(i) := 1;
1411: END LOOP;
1412: IF FND_PROFILE.value('HZ_DQM_INDEX_PARALLEL') IS NOT NULL THEN
1413: l_num_prll := FND_PROFILE.value('HZ_DQM_INDEX_PARALLEL');
1414: ELSE
1415: l_num_prll := NULL;
1416: END IF;
1409: FOR I in 1..10 LOOP
1410: l_sub_requests(i) := 1;
1411: END LOOP;
1412: IF FND_PROFILE.value('HZ_DQM_INDEX_PARALLEL') IS NOT NULL THEN
1413: l_num_prll := FND_PROFILE.value('HZ_DQM_INDEX_PARALLEL');
1414: ELSE
1415: l_num_prll := NULL;
1416: END IF;
1417: IF FND_PROFILE.value('HZ_DQM_INDEX_MEMORY') IS NOT NULL THEN
1413: l_num_prll := FND_PROFILE.value('HZ_DQM_INDEX_PARALLEL');
1414: ELSE
1415: l_num_prll := NULL;
1416: END IF;
1417: IF FND_PROFILE.value('HZ_DQM_INDEX_MEMORY') IS NOT NULL THEN
1418: l_idx_mem := FND_PROFILE.value('HZ_DQM_INDEX_MEMORY');
1419: ELSE
1420: BEGIN
1421: SELECT PAR_VALUE INTO l_idx_mem
1414: ELSE
1415: l_num_prll := NULL;
1416: END IF;
1417: IF FND_PROFILE.value('HZ_DQM_INDEX_MEMORY') IS NOT NULL THEN
1418: l_idx_mem := FND_PROFILE.value('HZ_DQM_INDEX_MEMORY');
1419: ELSE
1420: BEGIN
1421: SELECT PAR_VALUE INTO l_idx_mem
1422: FROM CTX_PARAMETERS
1455: l_command = 'STAGE_NEW_TRANSFORMATIONS' OR
1456: l_command = 'CREATE_MISSING_INVALID_INDEXES' THEN
1457:
1458: IF ((l_command = 'STAGE_ALL_DATA' OR l_command = 'STAGE_NEW_TRANSFORMATIONS') AND l_realtime_sync_value <> 'N') THEN
1459: l_profile_save := FND_PROFILE.save('HZ_DQM_ENABLE_REALTIME_SYNC','N','SITE'); -- Set sync method to BATCH. 4915282
1460: END IF;
1461:
1462: IF FND_PROFILE.value('HZ_DQM_INDEX_MEMORY') IS NOT NULL THEN
1463: l_idx_mem := FND_PROFILE.value('HZ_DQM_INDEX_MEMORY');
1458: IF ((l_command = 'STAGE_ALL_DATA' OR l_command = 'STAGE_NEW_TRANSFORMATIONS') AND l_realtime_sync_value <> 'N') THEN
1459: l_profile_save := FND_PROFILE.save('HZ_DQM_ENABLE_REALTIME_SYNC','N','SITE'); -- Set sync method to BATCH. 4915282
1460: END IF;
1461:
1462: IF FND_PROFILE.value('HZ_DQM_INDEX_MEMORY') IS NOT NULL THEN
1463: l_idx_mem := FND_PROFILE.value('HZ_DQM_INDEX_MEMORY');
1464: ELSE
1465: BEGIN
1466: SELECT PAR_VALUE INTO l_idx_mem
1459: l_profile_save := FND_PROFILE.save('HZ_DQM_ENABLE_REALTIME_SYNC','N','SITE'); -- Set sync method to BATCH. 4915282
1460: END IF;
1461:
1462: IF FND_PROFILE.value('HZ_DQM_INDEX_MEMORY') IS NOT NULL THEN
1463: l_idx_mem := FND_PROFILE.value('HZ_DQM_INDEX_MEMORY');
1464: ELSE
1465: BEGIN
1466: SELECT PAR_VALUE INTO l_idx_mem
1467: FROM CTX_PARAMETERS
1478: END;
1479: END;
1480: END IF;
1481:
1482: IF FND_PROFILE.value('HZ_DQM_INDEX_PARALLEL') IS NOT NULL THEN
1483: l_num_prll := FND_PROFILE.value('HZ_DQM_INDEX_PARALLEL');
1484: ELSE
1485: l_num_prll := NULL;
1486: END IF;
1479: END;
1480: END IF;
1481:
1482: IF FND_PROFILE.value('HZ_DQM_INDEX_PARALLEL') IS NOT NULL THEN
1483: l_num_prll := FND_PROFILE.value('HZ_DQM_INDEX_PARALLEL');
1484: ELSE
1485: l_num_prll := NULL;
1486: END IF;
1487:
2450: END IF;
2451: END IF;
2452: CLOSE c_sync;
2453: END IF;
2454: l_profile_save := FND_PROFILE.save('HZ_DQM_ENABLE_REALTIME_SYNC',l_realtime_sync_value,'SITE');
2455: END IF;
2456: --End of 4915282
2457: END IF;
2458: --End of Bug No : 4292425
2545:
2546: retcode := 0;
2547: l_worker_number := TO_NUMBER(p_worker_number);
2548: l_num_workers := TO_NUMBER(p_num_workers);
2549: l_batch_size := nvl( FND_PROFILE.value('HZ_DQM_STAGE_BATCH_SIZE'), 500 );
2550: IF l_worker_number = l_num_workers THEN
2551: l_worker_number := 0;
2552: END IF;
2553:
3146: BEGIN
3147:
3148: retcode := 0;
3149: l_command := p_command;
3150: l_parallel_degree := NVL(FND_PROFILE.VALUE('HZ_DQM_INDEX_PARALLEL'),1);
3151: l_parallel_str := ' PARALLEL '||l_parallel_degree||' ';
3152:
3153: log ('--------------------------------------');
3154: outandlog('Starting Concurrent Program ''Create DQM indexes''');