DBA Data[Home] [Help]

APPS.BSC_UPDATE_BASE_V2 dependencies on BSC_DBGEN_STD_METADATA

Line 43: h_partition_info BSC_DBGEN_STD_METADATA.clsTablePartition;

39:
40: h_proj_tbl_name VARCHAR2(30);
41: h_rowid_tbl_name VARCHAR2(30);
42:
43: h_partition_info BSC_DBGEN_STD_METADATA.clsTablePartition;
44: h_num_partitions NUMBER;
45: h_partition_names dbms_sql.varchar2_table;
46: h_batch_values dbms_sql.number_table;
47:

Line 164: h_list(1) := BSC_DBGEN_STD_METADATA.BSC_I_ROWID_TABLE;

160: h_proj_tbl_name := Get_Base_Proj_Tbl_Name(x_base_table);
161:
162: -- Get input table row id table name
163: h_list.delete;
164: h_list(1) := BSC_DBGEN_STD_METADATA.BSC_I_ROWID_TABLE;
165: h_values := BSC_DBGEN_METADATA_READER.Get_Table_Properties(x_input_table, h_list);
166: h_rowid_tbl_name := h_values(1);
167:
168: -- Get base table partitions

Line 707: bsc_dbgen_utils.add_string(h_sql, ' ('||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');

703: bsc_dbgen_utils.add_string(h_sql, ' */ into '||x_proj_table);
704: IF x_parallel_jobs = 'Y' THEN
705: bsc_dbgen_utils.add_string(h_sql, ' partition('||x_partition_name||')');
706: END IF;
707: bsc_dbgen_utils.add_string(h_sql, ' ('||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');
708: FOR h_i IN 1..x_num_key_columns LOOP
709: bsc_dbgen_utils.add_string(h_sql, x_key_columns(h_i)||', ');
710: END LOOP;
711: bsc_dbgen_utils.add_string(h_sql, 'year, type, period');

Line 727: bsc_dbgen_utils.add_string(h_sql, ' p.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');

723: bsc_dbgen_utils.add_string(h_sql, ' select');
724: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
725: bsc_dbgen_utils.add_string(h_sql, ' /*+ parallel(p) */');
726: END IF;
727: bsc_dbgen_utils.add_string(h_sql, ' p.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');
728: FOR h_i IN 1..x_num_key_columns LOOP
729: bsc_dbgen_utils.add_string(h_sql, 'p.key'||h_i||', ');
730: END LOOP;
731: bsc_dbgen_utils.add_string(h_sql, 'p.year, p.type, p.period');

Line 758: bsc_dbgen_utils.add_string(h_sql, ' p.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');

754: bsc_dbgen_utils.add_string(h_sql, ' select');
755: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
756: bsc_dbgen_utils.add_string(h_sql, ' /*+ parallel(p) parallel(tp) parallel(tr) parallel(pp) */');
757: END IF;
758: bsc_dbgen_utils.add_string(h_sql, ' p.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');
759: FOR h_i IN 1..x_num_key_columns LOOP
760: bsc_dbgen_utils.add_string(h_sql, 'p.key'||h_i||', ');
761: END LOOP;
762: bsc_dbgen_utils.add_string(h_sql, 'p.year, p.type, p.period');

Line 800: bsc_dbgen_utils.add_string(h_sql, ' a.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');

796: bsc_dbgen_utils.add_string(h_sql, ' from (select');
797: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
798: bsc_dbgen_utils.add_string(h_sql, ' /*+ parallel(a) parallel(bsc_tmp_all_periods) */');
799: END IF;
800: bsc_dbgen_utils.add_string(h_sql, ' a.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');
801: FOR h_i IN 1..x_num_key_columns LOOP
802: bsc_dbgen_utils.add_string(h_sql, 'a.'||x_key_columns(h_i)||' key'||h_i||', ');
803: END LOOP;
804: bsc_dbgen_utils.add_string(h_sql, 'bsc_tmp_all_periods.year, 0 type, bsc_tmp_all_periods.period');

Line 812: bsc_dbgen_utils.add_string(h_sql, ' distinct '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);

808: bsc_dbgen_utils.add_string(h_sql, ' from (select');
809: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
810: bsc_dbgen_utils.add_string(h_sql, ' /*+ parallel('||x_base_table||') */');
811: END IF;
812: bsc_dbgen_utils.add_string(h_sql, ' distinct '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
813: FOR h_i IN 1..x_num_key_columns LOOP
814: bsc_dbgen_utils.add_string(h_sql, ', '||x_key_columns(h_i));
815: END LOOP;
816: bsc_dbgen_utils.add_string(h_sql, ' from '||x_base_table);

Line 820: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);

816: bsc_dbgen_utils.add_string(h_sql, ' from '||x_base_table);
817: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN
818: bsc_dbgen_utils.add_string(h_sql, ' where periodicity_id = '||x_periodicity);
819: IF x_parallel_jobs = 'Y' THEN
820: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);
821: END IF;
822: ELSE
823: IF x_parallel_jobs = 'Y' THEN
824: bsc_dbgen_utils.add_string(h_sql, ' where '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);

Line 824: bsc_dbgen_utils.add_string(h_sql, ' where '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);

820: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);
821: END IF;
822: ELSE
823: IF x_parallel_jobs = 'Y' THEN
824: bsc_dbgen_utils.add_string(h_sql, ' where '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);
825: END IF;
826: END IF;
827: bsc_dbgen_utils.add_string(h_sql, ') a,');
828: IF h_yearly_flag <> 1 THEN

Line 874: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);

870: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN
871: bsc_dbgen_utils.add_string(h_sql, ' and periodicity_id = '||x_periodicity);
872: END IF;
873: IF x_parallel_jobs = 'Y' THEN
874: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);
875: END IF;
876: IF x_num_key_columns > 0 THEN
877: bsc_dbgen_utils.add_string(h_sql, ' group by '||x_key_columns(1));
878: FOR h_i IN 2..x_num_key_columns LOOP

Line 907: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);

903: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN
904: bsc_dbgen_utils.add_string(h_sql, ' and periodicity_id = '||x_periodicity);
905: END IF;
906: IF x_parallel_jobs = 'Y' THEN
907: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);
908: END IF;
909: IF x_num_key_columns > 0 THEN
910: bsc_dbgen_utils.add_string(h_sql, ' group by '||x_key_columns(1));
911: FOR h_i IN 2..x_num_key_columns LOOP

Line 939: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);

935: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN
936: bsc_dbgen_utils.add_string(h_sql, ' and periodicity_id = '||x_periodicity);
937: END IF;
938: IF x_parallel_jobs = 'Y' THEN
939: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);
940: END IF;
941: bsc_dbgen_utils.add_string(h_sql, ') pp'||
942: ' where');
943: FOR h_i IN 1..x_num_key_columns LOOP

Line 967: bsc_dbgen_utils.add_string(h_sql, ' p.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');

963: bsc_dbgen_utils.add_string(h_sql, ' select');
964: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
965: bsc_dbgen_utils.add_string(h_sql, ' /*+ parallel(p) parallel(b) */');
966: END IF;
967: bsc_dbgen_utils.add_string(h_sql, ' p.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');
968: FOR h_i IN 1..x_num_key_columns LOOP
969: bsc_dbgen_utils.add_string(h_sql, 'p.key'||h_i||', ');
970: END LOOP;
971: bsc_dbgen_utils.add_string(h_sql, 'p.year, p.type, p.period');

Line 989: bsc_dbgen_utils.add_string(h_sql, ' a.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');

985: bsc_dbgen_utils.add_string(h_sql, ' from (select');
986: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
987: bsc_dbgen_utils.add_string(h_sql, ' /*+ parallel(a) parallel(bsc_tmp_all_periods) */');
988: END IF;
989: bsc_dbgen_utils.add_string(h_sql, ' a.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');
990: FOR h_i IN 1..x_num_key_columns LOOP
991: bsc_dbgen_utils.add_string(h_sql, 'a.'||x_key_columns(h_i)||' key'||h_i||', ');
992: END LOOP;
993: bsc_dbgen_utils.add_string(h_sql, 'bsc_tmp_all_periods.year year, 0 type, bsc_tmp_all_periods.period period');

Line 1001: bsc_dbgen_utils.add_string(h_sql, ' distinct '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);

997: bsc_dbgen_utils.add_string(h_sql, ' from (select');
998: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
999: bsc_dbgen_utils.add_string(h_sql, ' /*+ parallel('||x_base_table||') */');
1000: END IF;
1001: bsc_dbgen_utils.add_string(h_sql, ' distinct '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
1002: FOR h_i IN 1..x_num_key_columns LOOP
1003: bsc_dbgen_utils.add_string(h_sql, ', '||x_key_columns(h_i));
1004: END LOOP;
1005: bsc_dbgen_utils.add_string(h_sql, ' from '||x_base_table);

Line 1009: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);

1005: bsc_dbgen_utils.add_string(h_sql, ' from '||x_base_table);
1006: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN
1007: bsc_dbgen_utils.add_string(h_sql, ' where periodicity_id = '||x_periodicity);
1008: IF x_parallel_jobs = 'Y' THEN
1009: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);
1010: END IF;
1011: ELSE
1012: IF x_parallel_jobs = 'Y' THEN
1013: bsc_dbgen_utils.add_string(h_sql, ' where '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);

Line 1013: bsc_dbgen_utils.add_string(h_sql, ' where '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);

1009: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);
1010: END IF;
1011: ELSE
1012: IF x_parallel_jobs = 'Y' THEN
1013: bsc_dbgen_utils.add_string(h_sql, ' where '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);
1014: END IF;
1015: END IF;
1016: bsc_dbgen_utils.add_string(h_sql, ') a,');
1017: IF h_yearly_flag <> 1 THEN

Line 1061: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);

1057: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN
1058: bsc_dbgen_utils.add_string(h_sql, ' and periodicity_id = '||x_periodicity);
1059: END IF;
1060: IF x_parallel_jobs = 'Y' THEN
1061: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = '||x_batch_value);
1062: END IF;
1063: bsc_dbgen_utils.add_string(h_sql, ') b'||
1064: ' where');
1065: FOR h_i IN 1..x_num_key_columns LOOP

Line 1073: ' group by p.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||',');

1069: ' p.period = b.period(+)');
1070: END IF;
1071: IF h_many_methods THEN
1072: bsc_dbgen_utils.add_string(h_sql, ') p'||
1073: ' group by p.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||',');
1074: FOR h_i IN 1..x_num_key_columns LOOP
1075: bsc_dbgen_utils.add_string(h_sql, ' p.key'||h_i||',');
1076: END LOOP;
1077: bsc_dbgen_utils.add_string(h_sql, ' p.year, p.type, p.period');

Line 1140: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :3');

1136: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN
1137: bsc_dbgen_utils.add_string(h_sql, ' and periodicity_id = :2');
1138: END IF;
1139: IF x_parallel_jobs = 'Y' THEN
1140: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :3');
1141: END IF;
1142: bsc_dbgen_utils.add_string(h_sql, ' union all'||
1143: ' select ');
1144: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN

Line 1163: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :6');

1159: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN
1160: bsc_dbgen_utils.add_string(h_sql, ' and periodicity_id = :5');
1161: END IF;
1162: IF x_parallel_jobs = 'Y' THEN
1163: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :6');
1164: END IF;
1165: bsc_dbgen_utils.add_string(h_sql, ') u'||
1166: ' where');
1167: IF h_yearly_flag = 1 THEN

Line 1189: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :14');

1185: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN
1186: bsc_dbgen_utils.add_string(h_sql, ' and p.periodicity_id = :13');
1187: END IF;
1188: IF x_parallel_jobs = 'Y' THEN
1189: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :14');
1190: END IF;
1191:
1192: FOR h_j IN h_init_per..h_end_per LOOP
1193: h_bind_vars_values.delete;

Line 1259: bsc_dbgen_utils.add_string(h_sql, ' ('||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');

1255: bsc_dbgen_utils.add_string(h_sql, ' */ into '||x_proj_table);
1256: IF x_parallel_jobs = 'Y' THEN
1257: bsc_dbgen_utils.add_string(h_sql, ' partition('||x_partition_name||')');
1258: END IF;
1259: bsc_dbgen_utils.add_string(h_sql, ' ('||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');
1260: FOR h_i IN 1..x_num_key_columns LOOP
1261: bsc_dbgen_utils.add_string(h_sql, x_key_columns(h_i)||', ');
1262: END LOOP;
1263: bsc_dbgen_utils.add_string(h_sql, 'year, type, period');

Line 1278: bsc_dbgen_utils.add_string(h_sql, ' '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');

1274: ' select');
1275: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
1276: bsc_dbgen_utils.add_string(h_sql, ' /*+ parallel(u) */');
1277: END IF;
1278: bsc_dbgen_utils.add_string(h_sql, ' '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');
1279: FOR h_i IN 1..x_num_key_columns LOOP
1280: bsc_dbgen_utils.add_string(h_sql, x_key_columns(h_i)||', ');
1281: END LOOP;
1282: IF h_yearly_flag = 1 THEN

Line 1301: bsc_dbgen_utils.add_string(h_sql, ' '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');

1297: ' select');
1298: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
1299: bsc_dbgen_utils.add_string(h_sql, ' /*+ parallel('||x_base_table||') */');
1300: END IF;
1301: bsc_dbgen_utils.add_string(h_sql, ' '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');
1302: FOR h_i IN 1..x_num_key_columns LOOP
1303: bsc_dbgen_utils.add_string(h_sql, x_key_columns(h_i)||', ');
1304: END LOOP;
1305: bsc_dbgen_utils.add_string(h_sql, ' year, type, period');

Line 1318: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :7');

1314: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN
1315: bsc_dbgen_utils.add_string(h_sql, ' and periodicity_id = :6');
1316: END IF;
1317: IF x_parallel_jobs = 'Y' THEN
1318: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :7');
1319: END IF;
1320: bsc_dbgen_utils.add_string(h_sql, ' union all'||
1321: ' select ');
1322: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN

Line 1325: bsc_dbgen_utils.add_string(h_sql, BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');

1321: ' select ');
1322: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
1323: bsc_dbgen_utils.add_string(h_sql, ' /*+ parallel('||x_proj_table||') */ ');
1324: END IF;
1325: bsc_dbgen_utils.add_string(h_sql, BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ');
1326: FOR h_i IN 1..x_num_key_columns LOOP
1327: bsc_dbgen_utils.add_string(h_sql, x_key_columns(h_i)||', ');
1328: END LOOP;
1329: bsc_dbgen_utils.add_string(h_sql, 'year, type, period');

Line 1342: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :10');

1338: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN
1339: bsc_dbgen_utils.add_string(h_sql, ' and periodicity_id = :9');
1340: END IF;
1341: IF x_parallel_jobs = 'Y' THEN
1342: bsc_dbgen_utils.add_string(h_sql, ' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :10');
1343: END IF;
1344: bsc_dbgen_utils.add_string(h_sql, ') u'||
1345: ' where');
1346: IF h_yearly_flag = 1 THEN

Line 1351: bsc_dbgen_utils.add_string(h_sql, ' group by '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);

1347: bsc_dbgen_utils.add_string(h_sql, ' (year between :11 AND :12)');
1348: ELSE
1349: bsc_dbgen_utils.add_string(h_sql, ' (year * 1000 + period) between (:11 * 1000 + :12) and (:13 * 1000 + :14)');
1350: END IF;
1351: bsc_dbgen_utils.add_string(h_sql, ' group by '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
1352: FOR h_i IN 1..x_num_key_columns LOOP
1353: bsc_dbgen_utils.add_string(h_sql, ', '||x_key_columns(h_i));
1354: END LOOP;
1355: IF BSC_APPS.bsc_mv AND (NOT x_aw_flag) THEN

Line 1568: bsc_dbgen_utils.add_string(h_sql, ', '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' number, row_id rowid);'||l_newline||

1564: FOR h_i IN 1..x_num_data_columns LOOP
1565: bsc_dbgen_utils.add_string(h_sql, ', '||x_data_columns(h_i)||' number'||l_newline||
1566: ', B_DATA'||h_i||' number');
1567: END LOOP;
1568: bsc_dbgen_utils.add_string(h_sql, ', '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' number, row_id rowid);'||l_newline||
1569: ' type bsc_b_t is table of bsc_b_r index by pls_integer;'||l_newline||
1570: ' type t_rowid_table is table of rowid index by pls_integer;'||l_newline||
1571: ' h_load_batch number;'||l_newline);
1572:

Line 1602: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||l_newline||

1598: bsc_dbgen_utils.add_string(h_sql, ', h_periodicity periodicity_id'||l_newline);
1599: FOR h_i IN 1..x_num_data_columns LOOP
1600: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||x_data_columns(h_i)||l_newline);
1601: END LOOP;
1602: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||l_newline||
1603: ' FROM (select /*+ordered*/ ');
1604: IF x_parallel_jobs = 'Y' THEN
1605: bsc_dbgen_utils.add_string(h_sql, 'h_batch_value '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
1606: ELSE

Line 1605: bsc_dbgen_utils.add_string(h_sql, 'h_batch_value '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);

1601: END LOOP;
1602: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||l_newline||
1603: ' FROM (select /*+ordered*/ ');
1604: IF x_parallel_jobs = 'Y' THEN
1605: bsc_dbgen_utils.add_string(h_sql, 'h_batch_value '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
1606: ELSE
1607: IF x_num_partitions > 0 THEN
1608: bsc_dbgen_utils.add_string(h_sql, ' dbms_utility.get_hash_value(');
1609: FOR h_i IN 1..x_num_key_columns LOOP

Line 1616: bsc_dbgen_utils.add_string(h_sql, ', 0, h_num_partitions) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);

1612: ELSE
1613: bsc_dbgen_utils.add_string(h_sql, '||''.''||'||x_key_columns(h_i)||l_newline);
1614: END IF;
1615: END LOOP;
1616: bsc_dbgen_utils.add_string(h_sql, ', 0, h_num_partitions) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
1617: ELSE
1618: bsc_dbgen_utils.add_string(h_sql, ' 0 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
1619: END IF;
1620: END IF;

Line 1618: bsc_dbgen_utils.add_string(h_sql, ' 0 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);

1614: END IF;
1615: END LOOP;
1616: bsc_dbgen_utils.add_string(h_sql, ', 0, h_num_partitions) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
1617: ELSE
1618: bsc_dbgen_utils.add_string(h_sql, ' 0 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
1619: END IF;
1620: END IF;
1621: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.*'||
1622: ' FROM '||x_rowid_table||', '||x_input_table||

Line 1624: ' '||x_rowid_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_load_batch');

1620: END IF;
1621: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.*'||
1622: ' FROM '||x_rowid_table||', '||x_input_table||
1623: ' WHERE '||x_rowid_table||'.row_id = '||x_input_table||'.rowid and'||
1624: ' '||x_rowid_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_load_batch');
1625: IF x_parallel_jobs = 'Y' THEN
1626: bsc_dbgen_utils.add_string(h_sql, ' and dbms_utility.get_hash_value(');
1627: FOR h_i IN 1..x_num_key_columns LOOP
1628: IF h_i = 1 THEN

Line 1682: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', '||x_base_table||'.rowid row_id'||

1678: FOR h_i IN 1..x_num_data_columns LOOP
1679: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||x_data_columns(h_i)||l_newline||
1680: ', '||x_base_table||'.'||x_data_columns(h_i));
1681: END LOOP;
1682: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', '||x_base_table||'.rowid row_id'||
1683: ' FROM (SELECT ');
1684: FOR h_i IN 1..x_num_key_columns LOOP
1685: bsc_dbgen_utils.add_string(h_sql, 'bsc_i_data.'||x_key_columns(h_i)||', '||l_newline);
1686: END LOOP;

Line 1691: bsc_dbgen_utils.add_string(h_sql, ', bsc_i_data.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||

1687: bsc_dbgen_utils.add_string(h_sql, 'bsc_i_data.YEAR, bsc_i_data.TYPE, bsc_i_data.PERIOD, bsc_i_data.periodicity_id');
1688: FOR h_i IN 1..x_num_data_columns LOOP
1689: bsc_dbgen_utils.add_string(h_sql, ', bsc_i_data.'||x_data_columns(h_i)||l_newline);
1690: END LOOP;
1691: bsc_dbgen_utils.add_string(h_sql, ', bsc_i_data.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||
1692: ' from bsc_i_data'||l_newline||
1693: ' union all'||l_newline||
1694: ' select '||l_newline);
1695: FOR h_i IN 1..x_num_key_columns LOOP

Line 1711: bsc_dbgen_utils.add_string(h_sql, ', bsc_i_data.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' '||

1707: ' '||x_data_columns(h_i));
1708: END IF;
1709: END LOOP;
1710: --Fix bug#5155523 do not use max(bsc_i_data.batch_column_name) instead add it to the group by
1711: bsc_dbgen_utils.add_string(h_sql, ', bsc_i_data.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' '||
1712: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||l_newline||
1713: ' from bsc_i_data, bsc_db_calendar_temp'||l_newline||
1714: ' where bsc_i_data.period = bsc_db_calendar_temp.lower_period and'||l_newline||
1715: ' bsc_i_data.year = bsc_db_calendar_temp.year'||l_newline||

Line 1712: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||l_newline||

1708: END IF;
1709: END LOOP;
1710: --Fix bug#5155523 do not use max(bsc_i_data.batch_column_name) instead add it to the group by
1711: bsc_dbgen_utils.add_string(h_sql, ', bsc_i_data.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' '||
1712: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||l_newline||
1713: ' from bsc_i_data, bsc_db_calendar_temp'||l_newline||
1714: ' where bsc_i_data.period = bsc_db_calendar_temp.lower_period and'||l_newline||
1715: ' bsc_i_data.year = bsc_db_calendar_temp.year'||l_newline||
1716: ' group by ');

Line 1721: ' BSC_DB_CALENDAR_TEMP.PERIODICITY_ID, BSC_I_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||l_newline||

1717: FOR h_i IN 1..x_num_key_columns LOOP
1718: bsc_dbgen_utils.add_string(h_sql, 'BSC_I_DATA.'||x_key_columns(h_i)||', ');
1719: END LOOP;
1720: bsc_dbgen_utils.add_string(h_sql, 'BSC_I_DATA.YEAR, BSC_I_DATA.TYPE, BSC_DB_CALENDAR_TEMP.UPPER_PERIOD,'||l_newline||
1721: ' BSC_DB_CALENDAR_TEMP.PERIODICITY_ID, BSC_I_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||l_newline||
1722: ') '||x_input_table||l_newline||
1723: ', (select * from '||x_base_table||l_newline);
1724: IF x_parallel_jobs = 'Y' THEN
1725: bsc_dbgen_utils.add_string(h_sql, ' where '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_batch_value');

Line 1725: bsc_dbgen_utils.add_string(h_sql, ' where '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_batch_value');

1721: ' BSC_DB_CALENDAR_TEMP.PERIODICITY_ID, BSC_I_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||l_newline||
1722: ') '||x_input_table||l_newline||
1723: ', (select * from '||x_base_table||l_newline);
1724: IF x_parallel_jobs = 'Y' THEN
1725: bsc_dbgen_utils.add_string(h_sql, ' where '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_batch_value');
1726: END IF;
1727: bsc_dbgen_utils.add_string(h_sql, ') '||x_base_table||l_newline||
1728: ' where ');
1729: FOR h_i IN 1..x_num_key_columns LOOP

Line 1768: bsc_dbgen_utils.add_string(h_sql, ', max('||x_base_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||') '||

1764: ', null B_DATA'||h_i);
1765:
1766: END IF;
1767: END LOOP;
1768: bsc_dbgen_utils.add_string(h_sql, ', max('||x_base_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||') '||
1769: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||
1770: ', chartorowid(tt.row_id) row_id'||
1771: ' from table(cast(v1_join_rollup as '||x_base_table||'_tt)) tt,'||
1772: ' bsc_db_calendar_temp, '||x_base_table||

Line 1769: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||

1765:
1766: END IF;
1767: END LOOP;
1768: bsc_dbgen_utils.add_string(h_sql, ', max('||x_base_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||') '||
1769: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||
1770: ', chartorowid(tt.row_id) row_id'||
1771: ' from table(cast(v1_join_rollup as '||x_base_table||'_tt)) tt,'||
1772: ' bsc_db_calendar_temp, '||x_base_table||
1773: ' where ');

Line 1785: bsc_dbgen_utils.add_string(h_sql, ' and '||x_base_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_batch_value'||l_newline);

1781: ' bsc_db_calendar_temp.year = '||x_base_table||'.year and'||l_newline||
1782: ' bsc_db_calendar_temp.lower_period = '||x_base_table||'.period and'||l_newline||
1783: ' '||x_base_table||'.periodicity_id = h_periodicity'||l_newline);
1784: IF x_parallel_jobs = 'Y' THEN
1785: bsc_dbgen_utils.add_string(h_sql, ' and '||x_base_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_batch_value'||l_newline);
1786: END IF;
1787: bsc_dbgen_utils.add_string(h_sql, ' group by '||l_newline);
1788: FOR h_i IN 1..x_num_key_columns LOOP
1789: bsc_dbgen_utils.add_string(h_sql, x_base_table||'.'||x_key_columns(h_i)||', ');

Line 1833: bsc_dbgen_utils.add_string(h_sql, 'b_lower.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_batch_value and ');

1829: bsc_dbgen_utils.add_string(h_sql, 'b_upper.rowid row_id'||
1830: ' from '||x_base_table||' b_lower, '||x_base_table||' b_upper'||l_newline||
1831: ' where '||l_newline);
1832: IF x_parallel_jobs = 'Y' THEN
1833: bsc_dbgen_utils.add_string(h_sql, 'b_lower.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_batch_value and ');
1834: END IF;
1835: bsc_dbgen_utils.add_string(h_sql, 'b_lower.periodicity_id(+) = p_lower_periodicity and'||l_newline||
1836: ' b_lower.year(+) = p_lower_year and'||l_newline||
1837: ' b_lower.period(+) = p_lower_period and '||l_newline);

Line 1839: bsc_dbgen_utils.add_string(h_sql, 'b_upper.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_batch_value and ');

1835: bsc_dbgen_utils.add_string(h_sql, 'b_lower.periodicity_id(+) = p_lower_periodicity and'||l_newline||
1836: ' b_lower.year(+) = p_lower_year and'||l_newline||
1837: ' b_lower.period(+) = p_lower_period and '||l_newline);
1838: IF x_parallel_jobs = 'Y' THEN
1839: bsc_dbgen_utils.add_string(h_sql, 'b_upper.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_batch_value and ');
1840: END IF;
1841: bsc_dbgen_utils.add_string(h_sql, 'b_upper.periodicity_id = p_upper_periodicity and'||l_newline||
1842: ' b_upper.year = p_upper_year and'||l_newline||
1843: ' b_upper.period = p_upper_period and '||l_newline);

Line 1986: ' i_batch(i_count):=v1(i).'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||';'||l_newline||

1982: END LOOP;
1983: bsc_dbgen_utils.add_string(h_sql, l_sql);
1984: l_sql := null;
1985: l_sql :=
1986: ' i_batch(i_count):=v1(i).'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||';'||l_newline||
1987: ' end if;'||l_newline||
1988: ' end loop;'||l_newline||
1989: ' forall i in 1..u_count'||l_newline||
1990: ' update '||x_base_table||l_newline;

Line 2024: l_sql := ', '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||')'||l_newline||

2020: l_sql := ', '||x_data_columns(h_i)||l_newline;
2021: bsc_dbgen_utils.add_string(h_sql, l_sql);
2022: END LOOP;
2023:
2024: l_sql := ', '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||')'||l_newline||
2025: ' values('||l_newline;
2026: FOR h_i IN 1..x_num_key_columns LOOP
2027: l_sql := l_sql||'i_'||x_key_columns(h_i)||'(i), ';
2028: END LOOP;

Line 2143: bsc_dbgen_utils.add_string(h_sql, ', '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' number, row_id rowid);'||

2139: FOR h_i IN 1..x_num_data_columns LOOP
2140: bsc_dbgen_utils.add_string(h_sql, ', '||x_data_columns(h_i)||' number'||
2141: ', B_DATA'||h_i||' number');
2142: END LOOP;
2143: bsc_dbgen_utils.add_string(h_sql, ', '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' number, row_id rowid);'||
2144: ' type bsc_b_t is table of bsc_b_r index by pls_integer;'||
2145: ' type t_rowid_table is table of rowid index by pls_integer;'||
2146: ' h_load_batch number;'||
2147: ' h_batch_value number;'||

Line 2160: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||

2156: FOR h_i IN 1..x_num_data_columns LOOP
2157: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||x_data_columns(h_i)||
2158: ', '||x_base_table||'.'||x_data_columns(h_i));
2159: END LOOP;
2160: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||
2161: ', '||x_base_table||'.rowid row_id'||
2162: ' FROM (SELECT ');
2163: FOR h_i IN 1..x_num_key_columns LOOP
2164: bsc_dbgen_utils.add_string(h_sql, x_key_dim_tables(h_i)||'.CODE '||x_key_columns(h_i)||', ');

Line 2179: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||

2175: END IF;
2176: FOR h_i IN 1..x_num_data_columns LOOP
2177: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||x_data_columns(h_i));
2178: END LOOP;
2179: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||
2180: ' FROM (SELECT /*+ ordered */ ');
2181: IF x_parallel_jobs = 'Y' THEN
2182: bsc_dbgen_utils.add_string(h_sql, 'h_batch_value '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
2183: ELSE

Line 2182: bsc_dbgen_utils.add_string(h_sql, 'h_batch_value '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);

2178: END LOOP;
2179: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||
2180: ' FROM (SELECT /*+ ordered */ ');
2181: IF x_parallel_jobs = 'Y' THEN
2182: bsc_dbgen_utils.add_string(h_sql, 'h_batch_value '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
2183: ELSE
2184: IF x_num_partitions > 0 THEN
2185: bsc_dbgen_utils.add_string(h_sql, ' dbms_utility.get_hash_value(');
2186: FOR h_i IN 1..x_num_key_columns LOOP

Line 2193: bsc_dbgen_utils.add_string(h_sql, ', 0, h_num_partitions) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);

2189: ELSE
2190: bsc_dbgen_utils.add_string(h_sql, '||''.''||'||x_key_columns(h_i));
2191: END IF;
2192: END LOOP;
2193: bsc_dbgen_utils.add_string(h_sql, ', 0, h_num_partitions) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
2194: ELSE
2195: bsc_dbgen_utils.add_string(h_sql, ' 0 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
2196: END IF;
2197: END IF;

Line 2195: bsc_dbgen_utils.add_string(h_sql, ' 0 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);

2191: END IF;
2192: END LOOP;
2193: bsc_dbgen_utils.add_string(h_sql, ', 0, h_num_partitions) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
2194: ELSE
2195: bsc_dbgen_utils.add_string(h_sql, ' 0 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME);
2196: END IF;
2197: END IF;
2198: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.*'||
2199: ' FROM '||x_rowid_table||', '||x_input_table||

Line 2201: ' '||x_rowid_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_load_batch');

2197: END IF;
2198: bsc_dbgen_utils.add_string(h_sql, ', '||x_input_table||'.*'||
2199: ' FROM '||x_rowid_table||', '||x_input_table||
2200: ' WHERE '||x_rowid_table||'.row_id = '||x_input_table||'.rowid and'||
2201: ' '||x_rowid_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_load_batch');
2202: IF x_parallel_jobs = 'Y' THEN
2203: bsc_dbgen_utils.add_string(h_sql, ' and dbms_utility.get_hash_value(');
2204: FOR h_i IN 1..x_num_key_columns LOOP
2205: IF h_i = 1 THEN

Line 2251: bsc_dbgen_utils.add_string(h_sql, ' where '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_batch_value');

2247: END IF;
2248: bsc_dbgen_utils.add_string(h_sql, ') '||x_input_table||
2249: ', (select * from '||x_base_table);
2250: IF x_parallel_jobs = 'Y' THEN
2251: bsc_dbgen_utils.add_string(h_sql, ' where '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = h_batch_value');
2252: END IF;
2253: bsc_dbgen_utils.add_string(h_sql, ') '||x_base_table||
2254: ' where ');
2255: FOR h_i IN 1..x_num_key_columns LOOP

Line 2354: ' i_BATCH(i_count) := v1(i).'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||';');

2350: FOR h_i IN 1..x_num_data_columns LOOP
2351: bsc_dbgen_utils.add_string(h_sql, ' i_data'||h_i||'(i_count) := v1(i).'||x_data_columns(h_i)||';');
2352: END LOOP;
2353: bsc_dbgen_utils.add_string(h_sql,
2354: ' i_BATCH(i_count) := v1(i).'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||';');
2355: IF x_aw_flag THEN
2356: IF h_yearly_flag = 1 THEN
2357: bsc_dbgen_utils.add_string(h_sql,
2358: ' if v1(i).year>'||x_current_fy||' then');

Line 2403: bsc_dbgen_utils.add_string(h_sql, ', '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||')'||

2399: END LOOP;
2400: IF x_aw_flag THEN
2401: bsc_dbgen_utils.add_string(h_sql, ', PROJECTION, CHANGE_VECTOR');
2402: END IF;
2403: bsc_dbgen_utils.add_string(h_sql, ', '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||')'||
2404: ' values(');
2405: FOR h_i IN 1..x_num_key_columns LOOP
2406: bsc_dbgen_utils.add_string(h_sql, 'i_'||x_key_columns(h_i)||'(i), ');
2407: END LOOP;

Line 2494: h_list(1) := BSC_DBGEN_STD_METADATA.BSC_B_PRJ_TABLE;

2490: h_list dbms_sql.varchar2_table;
2491: h_values dbms_sql.varchar2_table;
2492: BEGIN
2493: h_list.delete;
2494: h_list(1) := BSC_DBGEN_STD_METADATA.BSC_B_PRJ_TABLE;
2495: h_values := BSC_DBGEN_METADATA_READER.Get_Table_Properties(x_base_table, h_list);
2496: RETURN h_values(1);
2497: END Get_Base_Proj_Tbl_Name;
2498:

Line 2997: h_sql := h_sql||' ('||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';

2993: h_sql := h_sql||' */ INTO '||x_base_table;
2994: IF x_parallel_jobs = 'Y' THEN
2995: h_sql := h_sql||' PARTITION('||x_partition_name||')';
2996: END IF;
2997: h_sql := h_sql||' ('||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
2998: FOR h_i IN 1..x_num_key_columns LOOP
2999: h_sql := h_sql||x_key_columns(h_i)||', ';
3000: END LOOP;
3001: h_sql := h_sql||'YEAR, TYPE, PERIOD, PERIODICITY_ID';

Line 3019: h_sql := h_sql||' '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';

3015: h_sql := h_sql||' parallel(BSC_SYS_PERIODS)';
3016: END IF;
3017: h_sql := h_sql||' */';
3018: END IF;
3019: h_sql := h_sql||' '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
3020: FOR h_i IN 1..x_num_key_columns LOOP
3021: h_sql := h_sql||h_key_dim_tables(h_i)||'.CODE '||x_key_columns(h_i)||', ';
3022: END LOOP;
3023: IF h_calendar_source = 'BSC' THEN

Line 3044: h_sql := h_sql||' :2 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;

3040: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
3041: h_sql := h_sql||' /*+ parallel ('||x_input_table||') */';
3042: END IF;
3043: IF x_parallel_jobs = 'Y' THEN
3044: h_sql := h_sql||' :2 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;
3045: h_num_bind_vars := h_num_bind_vars + 1;
3046: h_bind_vars_values(h_num_bind_vars) := x_batch_value;
3047: ELSE
3048: IF x_num_partitions > 0 THEN

Line 3057: h_sql := h_sql||', 0, :2) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;

3053: ELSE
3054: h_sql := h_sql||'||''.''||'||x_key_columns(h_i);
3055: END IF;
3056: END LOOP;
3057: h_sql := h_sql||', 0, :2) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;
3058: h_num_bind_vars := h_num_bind_vars + 1;
3059: h_bind_vars_values(h_num_bind_vars) := x_num_partitions;
3060: ELSE
3061: h_sql := h_sql||' :2 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;

Line 3061: h_sql := h_sql||' :2 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;

3057: h_sql := h_sql||', 0, :2) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;
3058: h_num_bind_vars := h_num_bind_vars + 1;
3059: h_bind_vars_values(h_num_bind_vars) := x_num_partitions;
3060: ELSE
3061: h_sql := h_sql||' :2 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;
3062: h_num_bind_vars := h_num_bind_vars + 1;
3063: h_bind_vars_values(h_num_bind_vars) := 0;
3064: END IF;
3065: END IF;

Line 3124: h_sql := h_sql||' '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';

3120: ' SELECT';
3121: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
3122: h_sql := h_sql||' /*+ parallel ('||x_input_table||') */';
3123: END IF;
3124: h_sql := h_sql||' '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
3125: FOR h_i IN 1..x_num_key_columns LOOP
3126: h_sql := h_sql||x_input_table||'.'||x_key_columns(h_i)||', ';
3127: END LOOP;
3128: h_sql := h_sql||x_input_table||'.YEAR, '||x_input_table||'.TYPE, '||x_input_table||'.PERIOD, '||

Line 3139: h_sql := h_sql||' BSC_I_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';

3135: -- Fix bug#5155523 Do not use parallel hint on BSC_I_DATA
3136: --IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
3137: -- h_sql := h_sql||' /*+ parallel (BSC_I_DATA) */';
3138: --END IF;
3139: h_sql := h_sql||' BSC_I_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
3140: FOR h_i IN 1..x_num_key_columns LOOP
3141: h_sql := h_sql||'BSC_I_DATA.'||x_key_columns(h_i)||', ';
3142: END LOOP;
3143: h_sql := h_sql||'BSC_I_DATA.YEAR, BSC_I_DATA.TYPE, BSC_I_DATA.PERIOD, BSC_I_DATA.PERIODICITY_ID';

Line 3155: h_sql := h_sql||' BSC_I_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' '||

3151: --IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
3152: -- h_sql := h_sql||' /*+ parallel (BSC_I_DATA) parallel (BSC_DB_CALENDAR_TEMP) */';
3153: --END IF;
3154: --Fix bug#5155523 Do not use max(bsc_i_data.batch_column_name) instead add it to the group by
3155: h_sql := h_sql||' BSC_I_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' '||
3156: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
3157: FOR h_i IN 1..x_num_key_columns LOOP
3158: h_sql := h_sql||'BSC_I_DATA.'||x_key_columns(h_i)||', ';
3159: END LOOP;

Line 3156: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';

3152: -- h_sql := h_sql||' /*+ parallel (BSC_I_DATA) parallel (BSC_DB_CALENDAR_TEMP) */';
3153: --END IF;
3154: --Fix bug#5155523 Do not use max(bsc_i_data.batch_column_name) instead add it to the group by
3155: h_sql := h_sql||' BSC_I_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' '||
3156: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
3157: FOR h_i IN 1..x_num_key_columns LOOP
3158: h_sql := h_sql||'BSC_I_DATA.'||x_key_columns(h_i)||', ';
3159: END LOOP;
3160: h_sql := h_sql||'BSC_I_DATA.YEAR, BSC_I_DATA.TYPE, BSC_DB_CALENDAR_TEMP.UPPER_PERIOD PERIOD,'||

Line 3175: ' GROUP BY BSC_I_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';

3171: END LOOP;
3172: h_sql := h_sql||' FROM BSC_I_DATA, BSC_DB_CALENDAR_TEMP'||
3173: ' WHERE BSC_I_DATA.PERIOD = BSC_DB_CALENDAR_TEMP.LOWER_PERIOD AND'||
3174: ' BSC_I_DATA.YEAR = BSC_DB_CALENDAR_TEMP.YEAR'||
3175: ' GROUP BY BSC_I_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
3176: FOR h_i IN 1..x_num_key_columns LOOP
3177: h_sql := h_sql||'BSC_I_DATA.'||x_key_columns(h_i)||', ';
3178: END LOOP;
3179: h_sql := h_sql||'BSC_I_DATA.YEAR, BSC_I_DATA.TYPE, BSC_DB_CALENDAR_TEMP.UPPER_PERIOD,'||

Line 3198: h_sql := h_sql||' ('||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';

3194: h_sql := h_sql||' */ INTO '||x_base_table;
3195: IF x_parallel_jobs = 'Y' THEN
3196: h_sql := h_sql||' PARTITION('||x_partition_name||')';
3197: END IF;
3198: h_sql := h_sql||' ('||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
3199: FOR h_i IN 1..x_num_key_columns LOOP
3200: h_sql := h_sql||x_key_columns(h_i)||', ';
3201: END LOOP;
3202: h_sql := h_sql||'YEAR, TYPE, PERIOD';

Line 3222: h_sql := h_sql||' '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';

3218: h_sql := h_sql||' parallel(BSC_SYS_PERIODS)';
3219: END IF;
3220: h_sql := h_sql||' */';
3221: END IF;
3222: h_sql := h_sql||' '||x_input_table||'.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
3223: FOR h_i IN 1..x_num_key_columns LOOP
3224: h_sql := h_sql||h_key_dim_tables(h_i)||'.CODE, ';
3225: END LOOP;
3226: IF h_calendar_source = 'BSC' THEN

Line 3291: h_sql := h_sql||' :5 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;

3287: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
3288: h_sql := h_sql||' /*+ parallel ('||x_input_table||') */';
3289: END IF;
3290: IF x_parallel_jobs = 'Y' THEN
3291: h_sql := h_sql||' :5 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;
3292: h_num_bind_vars := h_num_bind_vars + 1;
3293: h_bind_vars_values(h_num_bind_vars) := x_batch_value;
3294: ELSE
3295: IF x_num_partitions > 0 THEN

Line 3304: h_sql := h_sql||', 0, :5) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;

3300: ELSE
3301: h_sql := h_sql||'||''.''||'||x_key_columns(h_i);
3302: END IF;
3303: END LOOP;
3304: h_sql := h_sql||', 0, :5) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;
3305: h_num_bind_vars := h_num_bind_vars + 1;
3306: h_bind_vars_values(h_num_bind_vars) := x_num_partitions;
3307: ELSE
3308: h_sql := h_sql||' :5 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;

Line 3308: h_sql := h_sql||' :5 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;

3304: h_sql := h_sql||', 0, :5) '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;
3305: h_num_bind_vars := h_num_bind_vars + 1;
3306: h_bind_vars_values(h_num_bind_vars) := x_num_partitions;
3307: ELSE
3308: h_sql := h_sql||' :5 '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME;
3309: h_num_bind_vars := h_num_bind_vars + 1;
3310: h_bind_vars_values(h_num_bind_vars) := 0;
3311: END IF;
3312: END IF;

Line 3418: h_sql := h_sql||' ('||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';

3414: h_sql := h_sql||' */ INTO '||x_base_table;
3415: IF x_parallel_jobs = 'Y' THEN
3416: h_sql := h_sql||' PARTITION('||x_partition_name||')';
3417: END IF;
3418: h_sql := h_sql||' ('||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
3419: FOR h_i IN 1..x_num_key_columns LOOP
3420: h_sql := h_sql||x_key_columns(h_i)||', ';
3421: END LOOP;
3422: h_sql := h_sql||'YEAR, TYPE, PERIOD, PERIODICITY_ID';

Line 3432: h_sql := h_sql||' MAX(BSC_B_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||') '||

3428: IF BSC_UPDATE_UTIL.is_parallel AND x_parallel_jobs = 'N' THEN
3429: -- Fix bug#5155523 Do not use parallel hint on BSC_DB_CALENDAR_TEMP
3430: h_sql := h_sql||' /*+ parallel (BSC_B_DATA) */';
3431: END IF;
3432: h_sql := h_sql||' MAX(BSC_B_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||') '||
3433: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
3434: FOR h_i IN 1..x_num_key_columns LOOP
3435: h_sql := h_sql||'BSC_B_DATA.'||x_key_columns(h_i)||', ';
3436: END LOOP;

Line 3433: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';

3429: -- Fix bug#5155523 Do not use parallel hint on BSC_DB_CALENDAR_TEMP
3430: h_sql := h_sql||' /*+ parallel (BSC_B_DATA) */';
3431: END IF;
3432: h_sql := h_sql||' MAX(BSC_B_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||') '||
3433: BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||', ';
3434: FOR h_i IN 1..x_num_key_columns LOOP
3435: h_sql := h_sql||'BSC_B_DATA.'||x_key_columns(h_i)||', ';
3436: END LOOP;
3437: h_sql := h_sql||'BSC_B_DATA.YEAR, BSC_B_DATA.TYPE, BSC_DB_CALENDAR_TEMP.UPPER_PERIOD PERIOD,'||

Line 3456: h_sql := h_sql||' AND BSC_B_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :2';

3452: ' AND BSC_B_DATA.YEAR = BSC_DB_CALENDAR_TEMP.YEAR';
3453: h_num_bind_vars := h_num_bind_vars + 1;
3454: h_bind_vars_values(h_num_bind_vars) := x_periodicity;
3455: IF x_parallel_jobs = 'Y' THEN
3456: h_sql := h_sql||' AND BSC_B_DATA.'||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :2';
3457: h_num_bind_vars := h_num_bind_vars + 1;
3458: h_bind_vars_values(h_num_bind_vars) := x_batch_value;
3459: END IF;
3460: h_sql := h_sql||' GROUP BY ';

Line 3720: h_sql := h_sql||' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :2';

3716: IF NOT x_correction_flag THEN
3717: -- Know if the base table has data or not
3718: h_sql := 'select count(*) from '||x_base_table||' where rownum < :1';
3719: IF x_parallel_jobs = 'Y' THEN
3720: h_sql := h_sql||' and '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :2';
3721: OPEN h_cursor FOR h_sql USING 2, x_batch_value;
3722: ELSE
3723: OPEN h_cursor FOR h_sql USING 2;
3724: END IF;

Line 3754: h_sql := h_sql||' AND '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :6';

3750: h_bind_vars_values(4) := x_current_period;
3751: h_bind_vars_values(5) := 0;
3752: h_num_bind_vars := 5;
3753: IF x_parallel_jobs = 'Y' THEN
3754: h_sql := h_sql||' AND '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :6';
3755: h_num_bind_vars := h_num_bind_vars + 1;
3756: h_bind_vars_values(h_num_bind_vars) := x_batch_value;
3757: END IF;
3758: BSC_UPDATE_UTIL.Execute_Immediate(h_sql, h_bind_vars_values, h_num_bind_vars);

Line 3833: h_sql := h_sql||' AND '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :2';

3829: h_sql := h_sql||' WHERE PERIODICITY_ID <> :1';
3830: h_num_bind_vars := h_num_bind_vars + 1;
3831: h_bind_vars_values(h_num_bind_vars) := x_periodicity;
3832: IF x_parallel_jobs = 'Y' THEN
3833: h_sql := h_sql||' AND '||BSC_DBGEN_STD_METADATA.BSC_BATCH_COLUMN_NAME||' = :2';
3834: h_num_bind_vars := h_num_bind_vars + 1;
3835: h_bind_vars_values(h_num_bind_vars) := x_batch_value;
3836: END IF;
3837: BSC_UPDATE_UTIL.Execute_Immediate(h_sql, h_bind_vars_values, h_num_bind_vars);