2737: -- and keep the cursor open throughout our processing --
2738: -----------------------------------------------------------
2739: IF (l_priv_func_cursor_id IS NULL) THEN
2740:
2741: l_priv_func_cursor_id := DBMS_SQL.Open_Cursor;
2742: l_dynamic_sql :=
2743: 'BEGIN '||
2744: p_privilege_predicate_api_name||
2745: '(:obj_name, :party_id, :priv_name, :table_alias, :predicate); END;';
2743: 'BEGIN '||
2744: p_privilege_predicate_api_name||
2745: '(:obj_name, :party_id, :priv_name, :table_alias, :predicate); END;';
2746:
2747: DBMS_SQL.Parse(l_priv_func_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
2748:
2749: --------------------------------------------------------------
2750: -- These variables will not change across calls, so we only --
2751: -- need to bind them the first time we parse the statement --
2749: --------------------------------------------------------------
2750: -- These variables will not change across calls, so we only --
2751: -- need to bind them the first time we parse the statement --
2752: --------------------------------------------------------------
2753: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':obj_name', p_object_name);
2754: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':party_id', G_HZ_PARTY_ID);
2755: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':table_alias', 'UAI2');
2756: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':predicate', l_priv_predicate, 32767);
2757:
2750: -- These variables will not change across calls, so we only --
2751: -- need to bind them the first time we parse the statement --
2752: --------------------------------------------------------------
2753: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':obj_name', p_object_name);
2754: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':party_id', G_HZ_PARTY_ID);
2755: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':table_alias', 'UAI2');
2756: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':predicate', l_priv_predicate, 32767);
2757:
2758: END IF;
2751: -- need to bind them the first time we parse the statement --
2752: --------------------------------------------------------------
2753: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':obj_name', p_object_name);
2754: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':party_id', G_HZ_PARTY_ID);
2755: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':table_alias', 'UAI2');
2756: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':predicate', l_priv_predicate, 32767);
2757:
2758: END IF;
2759:
2752: --------------------------------------------------------------
2753: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':obj_name', p_object_name);
2754: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':party_id', G_HZ_PARTY_ID);
2755: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':table_alias', 'UAI2');
2756: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':predicate', l_priv_predicate, 32767);
2757:
2758: END IF;
2759:
2760: IF (l_view_priv_to_check IS NOT NULL) THEN
2760: IF (l_view_priv_to_check IS NOT NULL) THEN
2761:
2762: code_debug(' Checking for View privelege '||l_view_priv_to_check,2);
2763:
2764: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':priv_name', l_view_priv_to_check);
2765: l_dummy := DBMS_SQL.Execute(l_priv_func_cursor_id);
2766:
2767: DBMS_SQL.Variable_Value(l_priv_func_cursor_id, ':predicate', l_priv_predicate);
2768:
2761:
2762: code_debug(' Checking for View privelege '||l_view_priv_to_check,2);
2763:
2764: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':priv_name', l_view_priv_to_check);
2765: l_dummy := DBMS_SQL.Execute(l_priv_func_cursor_id);
2766:
2767: DBMS_SQL.Variable_Value(l_priv_func_cursor_id, ':predicate', l_priv_predicate);
2768:
2769: code_debug(' The View privlege predicate is :'||l_priv_predicate,3);
2763:
2764: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':priv_name', l_view_priv_to_check);
2765: l_dummy := DBMS_SQL.Execute(l_priv_func_cursor_id);
2766:
2767: DBMS_SQL.Variable_Value(l_priv_func_cursor_id, ':predicate', l_priv_predicate);
2768:
2769: code_debug(' The View privlege predicate is :'||l_priv_predicate,3);
2770:
2771: ----------------------------------------------------------
2774: IF (l_priv_predicate IS NULL) THEN
2775: l_priv_predicate := '1=1';
2776: END IF;
2777: --------------------------------------------------------------
2778: -- We needn't use DBMS_SQL here because this statement will --
2779: -- change too much in each loop (because of the predicate) --
2780: -- for us to gain anything by keeping the cursor open --
2781: --------------------------------------------------------------
2782: EXECUTE IMMEDIATE
2806: IF (l_edit_priv_to_check IS NOT NULL) THEN
2807:
2808: code_debug(' Checking for Edit privelege '||l_edit_priv_to_check,2);
2809:
2810: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':priv_name', l_edit_priv_to_check);
2811: l_dummy := DBMS_SQL.Execute(l_priv_func_cursor_id);
2812: DBMS_SQL.Variable_Value(l_priv_func_cursor_id, ':predicate', l_priv_predicate);
2813:
2814: code_debug(' The Edit privlege predicate is :'||l_priv_predicate,3);
2807:
2808: code_debug(' Checking for Edit privelege '||l_edit_priv_to_check,2);
2809:
2810: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':priv_name', l_edit_priv_to_check);
2811: l_dummy := DBMS_SQL.Execute(l_priv_func_cursor_id);
2812: DBMS_SQL.Variable_Value(l_priv_func_cursor_id, ':predicate', l_priv_predicate);
2813:
2814: code_debug(' The Edit privlege predicate is :'||l_priv_predicate,3);
2815:
2808: code_debug(' Checking for Edit privelege '||l_edit_priv_to_check,2);
2809:
2810: DBMS_SQL.Bind_Variable(l_priv_func_cursor_id, ':priv_name', l_edit_priv_to_check);
2811: l_dummy := DBMS_SQL.Execute(l_priv_func_cursor_id);
2812: DBMS_SQL.Variable_Value(l_priv_func_cursor_id, ':predicate', l_priv_predicate);
2813:
2814: code_debug(' The Edit privlege predicate is :'||l_priv_predicate,3);
2815:
2816: --------------------------------------------------------------
2813:
2814: code_debug(' The Edit privlege predicate is :'||l_priv_predicate,3);
2815:
2816: --------------------------------------------------------------
2817: -- As above, we needn't use DBMS_SQL because the statement --
2818: -- changes too much in each loop (because of the predicate) --
2819: -- for us to gain anything by keeping the cursor open --
2820: --------------------------------------------------------------
2821:
2995: code_debug(' This attribute has an indipendednt value set, validating for value set id -'||l_attr_metadata_rec.VALUE_SET_ID ,2);
2996:
2997: IF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_NUMBER_DATA_TYPE) THEN
2998: IF (l_ivs_num_cursor_id IS NULL) THEN
2999: l_ivs_num_cursor_id := DBMS_SQL.Open_Cursor;
3000: l_dynamic_sql :=
3001: 'UPDATE '||p_interface_table_name||'
3002: SET ATTR_VALUE_NUM = TO_NUMBER(NVL(ATTR_VALUE_NUM,
3003: (SELECT DISTINCT FLEX_VALUE
3036: AND ATTR_INT_NAME = :attr_int_name
3037: AND (ATTR_DISP_VALUE IS NOT NULL OR ATTR_VALUE_NUM IS NOT NULL)
3038: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
3039:
3040: DBMS_SQL.Parse(l_ivs_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3041:
3042: -----------------------------------------------------------
3043: -- Data set ID will not change across calls, so we only --
3044: -- need to bind it the first time we parse the statement --
3042: -----------------------------------------------------------
3043: -- Data set ID will not change across calls, so we only --
3044: -- need to bind it the first time we parse the statement --
3045: -----------------------------------------------------------
3046: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':data_set_id', p_data_set_id);
3047:
3048: END IF;
3049: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3050: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3045: -----------------------------------------------------------
3046: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':data_set_id', p_data_set_id);
3047:
3048: END IF;
3049: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3050: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3051: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3052: l_dummy := DBMS_SQL.Execute(l_ivs_num_cursor_id);
3053:
3046: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':data_set_id', p_data_set_id);
3047:
3048: END IF;
3049: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3050: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3051: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3052: l_dummy := DBMS_SQL.Execute(l_ivs_num_cursor_id);
3053:
3054: ELSIF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE) THEN
3047:
3048: END IF;
3049: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3050: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3051: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3052: l_dummy := DBMS_SQL.Execute(l_ivs_num_cursor_id);
3053:
3054: ELSIF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE) THEN
3055: IF (l_ivs_date_cursor_id IS NULL) THEN
3048: END IF;
3049: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3050: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3051: DBMS_SQL.Bind_Variable(l_ivs_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3052: l_dummy := DBMS_SQL.Execute(l_ivs_num_cursor_id);
3053:
3054: ELSIF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE) THEN
3055: IF (l_ivs_date_cursor_id IS NULL) THEN
3056:
3053:
3054: ELSIF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE) THEN
3055: IF (l_ivs_date_cursor_id IS NULL) THEN
3056:
3057: l_ivs_date_cursor_id := DBMS_SQL.Open_Cursor;
3058: l_dynamic_sql :=
3059: 'UPDATE '||p_interface_table_name||'
3060: SET ATTR_VALUE_DATE = NVL(ATTR_VALUE_DATE,
3061: (SELECT DISTINCT TRUNC(EGO_USER_ATTRS_BULK_PVT.Get_Date(FLEX_VALUE,'''||EGO_USER_ATTRS_COMMON_PVT.G_DATE_FORMAT||'''))
3094: AND ATTR_INT_NAME = :attr_int_name
3095: AND (ATTR_DISP_VALUE IS NOT NULL OR ATTR_VALUE_DATE IS NOT NULL)
3096: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
3097:
3098: DBMS_SQL.Parse(l_ivs_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3099:
3100: -----------------------------------------------------------
3101: -- Data set ID will not change across calls, so we only --
3102: -- need to bind it the first time we parse the statement --
3100: -----------------------------------------------------------
3101: -- Data set ID will not change across calls, so we only --
3102: -- need to bind it the first time we parse the statement --
3103: -----------------------------------------------------------
3104: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':data_set_id', p_data_set_id);
3105: END IF;
3106:
3107: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3108: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3103: -----------------------------------------------------------
3104: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':data_set_id', p_data_set_id);
3105: END IF;
3106:
3107: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3108: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3109: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3110: l_dummy := DBMS_SQL.Execute(l_ivs_date_cursor_id);
3111:
3104: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':data_set_id', p_data_set_id);
3105: END IF;
3106:
3107: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3108: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3109: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3110: l_dummy := DBMS_SQL.Execute(l_ivs_date_cursor_id);
3111:
3112: ELSIF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
3105: END IF;
3106:
3107: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3108: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3109: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3110: l_dummy := DBMS_SQL.Execute(l_ivs_date_cursor_id);
3111:
3112: ELSIF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
3113:
3106:
3107: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3108: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3109: DBMS_SQL.Bind_Variable(l_ivs_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3110: l_dummy := DBMS_SQL.Execute(l_ivs_date_cursor_id);
3111:
3112: ELSIF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
3113:
3114: IF (l_ivs_date_time_cursor_id IS NULL) THEN
3112: ELSIF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
3113:
3114: IF (l_ivs_date_time_cursor_id IS NULL) THEN
3115:
3116: l_ivs_date_time_cursor_id := DBMS_SQL.Open_Cursor;
3117: l_dynamic_sql :=
3118: 'UPDATE '||p_interface_table_name||'
3119: SET ATTR_VALUE_DATE = NVL(ATTR_VALUE_DATE,EGO_USER_ATTRS_BULK_PVT.Get_Date(
3120: (SELECT DISTINCT FLEX_VALUE
3154: AND ATTR_INT_NAME = :attr_int_name
3155: AND (ATTR_DISP_VALUE IS NOT NULL OR ATTR_VALUE_DATE IS NOT NULL)
3156: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
3157:
3158: DBMS_SQL.Parse(l_ivs_date_time_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3159:
3160: -----------------------------------------------------------
3161: -- Data set ID will not change across calls, so we only --
3162: -- need to bind it the first time we parse the statement --
3160: -----------------------------------------------------------
3161: -- Data set ID will not change across calls, so we only --
3162: -- need to bind it the first time we parse the statement --
3163: -----------------------------------------------------------
3164: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':data_set_id', p_data_set_id);
3165:
3166: END IF;
3167:
3168: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3164: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':data_set_id', p_data_set_id);
3165:
3166: END IF;
3167:
3168: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3169: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3170: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3171: l_dummy := DBMS_SQL.Execute(l_ivs_date_time_cursor_id);
3172:
3165:
3166: END IF;
3167:
3168: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3169: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3170: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3171: l_dummy := DBMS_SQL.Execute(l_ivs_date_time_cursor_id);
3172:
3173: ELSE -- must be Char or Trans Text
3166: END IF;
3167:
3168: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3169: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3170: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3171: l_dummy := DBMS_SQL.Execute(l_ivs_date_time_cursor_id);
3172:
3173: ELSE -- must be Char or Trans Text
3174:
3167:
3168: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3169: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3170: DBMS_SQL.Bind_Variable(l_ivs_date_time_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3171: l_dummy := DBMS_SQL.Execute(l_ivs_date_time_cursor_id);
3172:
3173: ELSE -- must be Char or Trans Text
3174:
3175: IF (l_ivs_char_cursor_id IS NULL) THEN
3173: ELSE -- must be Char or Trans Text
3174:
3175: IF (l_ivs_char_cursor_id IS NULL) THEN
3176:
3177: l_ivs_char_cursor_id := DBMS_SQL.Open_Cursor;
3178: l_dynamic_sql :=
3179: 'UPDATE '||p_interface_table_name||'
3180: SET ATTR_VALUE_STR = (NVL(ATTR_VALUE_STR,
3181: (SELECT DISTINCT FLEX_VALUE
3215: AND ATTR_INT_NAME = :attr_int_name
3216: AND (ATTR_DISP_VALUE IS NOT NULL OR ATTR_VALUE_STR IS NOT NULL)
3217: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
3218:
3219: DBMS_SQL.Parse(l_ivs_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3220:
3221: -----------------------------------------------------------
3222: -- Data set ID will not change across calls, so we only --
3223: -- need to bind it the first time we parse the statement --
3221: -----------------------------------------------------------
3222: -- Data set ID will not change across calls, so we only --
3223: -- need to bind it the first time we parse the statement --
3224: -----------------------------------------------------------
3225: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':data_set_id', p_data_set_id);
3226:
3227: END IF;
3228:
3229: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3225: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':data_set_id', p_data_set_id);
3226:
3227: END IF;
3228:
3229: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3230: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3231: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3232: l_dummy := DBMS_SQL.Execute(l_ivs_char_cursor_id);
3233:
3226:
3227: END IF;
3228:
3229: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3230: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3231: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3232: l_dummy := DBMS_SQL.Execute(l_ivs_char_cursor_id);
3233:
3234: END IF;
3227: END IF;
3228:
3229: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3230: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3231: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3232: l_dummy := DBMS_SQL.Execute(l_ivs_char_cursor_id);
3233:
3234: END IF;
3235: ELSIF (l_attr_metadata_rec.VALIDATION_TYPE = EGO_EXT_FWK_PUB.G_TABLE_VALIDATION_CODE) THEN
3228:
3229: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':value_set_id', l_attr_metadata_rec.VALUE_SET_ID);
3230: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':attr_int_name', l_attr_metadata_rec.ATTR_INT_NAME);
3231: DBMS_SQL.Bind_Variable(l_ivs_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3232: l_dummy := DBMS_SQL.Execute(l_ivs_char_cursor_id);
3233:
3234: END IF;
3235: ELSIF (l_attr_metadata_rec.VALIDATION_TYPE = EGO_EXT_FWK_PUB.G_TABLE_VALIDATION_CODE) THEN
3236:
3256: ------------------------------------------------------------------------------------
3257: IF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_NUMBER_DATA_TYPE) THEN
3258:
3259: IF (l_nvs_num_cursor_id is NULL) THEN
3260: l_nvs_num_cursor_id := DBMS_SQL.Open_Cursor;
3261: l_dynamic_sql :=
3262: 'UPDATE '||p_interface_table_name||'
3263: SET ATTR_VALUE_NUM = DECODE(EGO_USER_ATTRS_BULK_PVT.Get_Datatype_Error_Val(ATTR_DISP_VALUE, :attr_datatype),0,NVL(TO_NUMBER(ATTR_DISP_VALUE),ATTR_VALUE_NUM),NULL),
3264: PROCESS_STATUS = PROCESS_STATUS +
3274: AND ATTR_INT_NAME = :attr_internal_name
3275: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3276: AND (ATTR_DISP_VALUE IS NOT NULL OR ATTR_VALUE_NUM IS NOT NULL)';
3277:
3278: DBMS_SQL.Parse(l_nvs_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3279: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':data_set_id', p_data_set_id);
3280:
3281: END IF;
3282: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':uom_class', l_attr_metadata_rec.UOM_CLASS);
3275: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3276: AND (ATTR_DISP_VALUE IS NOT NULL OR ATTR_VALUE_NUM IS NOT NULL)';
3277:
3278: DBMS_SQL.Parse(l_nvs_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3279: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':data_set_id', p_data_set_id);
3280:
3281: END IF;
3282: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':uom_class', l_attr_metadata_rec.UOM_CLASS);
3283: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3278: DBMS_SQL.Parse(l_nvs_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3279: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':data_set_id', p_data_set_id);
3280:
3281: END IF;
3282: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':uom_class', l_attr_metadata_rec.UOM_CLASS);
3283: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3284: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3285: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3286: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3279: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':data_set_id', p_data_set_id);
3280:
3281: END IF;
3282: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':uom_class', l_attr_metadata_rec.UOM_CLASS);
3283: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3284: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3285: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3286: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3287: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3280:
3281: END IF;
3282: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':uom_class', l_attr_metadata_rec.UOM_CLASS);
3283: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3284: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3285: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3286: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3287: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3288:
3281: END IF;
3282: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':uom_class', l_attr_metadata_rec.UOM_CLASS);
3283: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3284: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3285: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3286: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3287: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3288:
3289: l_dummy := DBMS_SQL.Execute(l_nvs_num_cursor_id);
3282: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':uom_class', l_attr_metadata_rec.UOM_CLASS);
3283: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3284: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3285: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3286: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3287: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3288:
3289: l_dummy := DBMS_SQL.Execute(l_nvs_num_cursor_id);
3290:
3283: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3284: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3285: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3286: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3287: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3288:
3289: l_dummy := DBMS_SQL.Execute(l_nvs_num_cursor_id);
3290:
3291: ELSIF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE) THEN
3285: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3286: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3287: DBMS_SQL.Bind_Variable(l_nvs_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3288:
3289: l_dummy := DBMS_SQL.Execute(l_nvs_num_cursor_id);
3290:
3291: ELSIF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE) THEN
3292:
3293: IF (l_nvs_date_cursor_id IS NULL) THEN
3290:
3291: ELSIF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE) THEN
3292:
3293: IF (l_nvs_date_cursor_id IS NULL) THEN
3294: l_nvs_date_cursor_id := DBMS_SQL.Open_Cursor;
3295: l_dynamic_sql :=
3296: 'UPDATE '||p_interface_table_name||'
3297: SET ATTR_VALUE_DATE = TRUNC(NVL(EGO_USER_ATTRS_BULK_PVT.Get_Date(ATTR_DISP_VALUE),ATTR_VALUE_DATE)),--WE SHOULD REMOVE THE TIME PART FROM THE DATE IF DATATYPE IS NOT DATE TIME
3298: PROCESS_STATUS = PROCESS_STATUS +
3304: AND ATTR_INT_NAME = :attr_internal_name
3305: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3306: AND (ATTR_DISP_VALUE IS NOT NULL OR ATTR_VALUE_DATE IS NOT NULL)';
3307:
3308: DBMS_SQL.Parse(l_nvs_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3309: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':data_set_id', p_data_set_id);
3310:
3311: END IF;
3312:
3305: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3306: AND (ATTR_DISP_VALUE IS NOT NULL OR ATTR_VALUE_DATE IS NOT NULL)';
3307:
3308: DBMS_SQL.Parse(l_nvs_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3309: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':data_set_id', p_data_set_id);
3310:
3311: END IF;
3312:
3313: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3309: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':data_set_id', p_data_set_id);
3310:
3311: END IF;
3312:
3313: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3314: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3315: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3316: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3317: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3310:
3311: END IF;
3312:
3313: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3314: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3315: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3316: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3317: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3318: l_dummy := DBMS_SQL.Execute(l_nvs_date_cursor_id);
3311: END IF;
3312:
3313: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3314: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3315: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3316: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3317: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3318: l_dummy := DBMS_SQL.Execute(l_nvs_date_cursor_id);
3319:
3312:
3313: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3314: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3315: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3316: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3317: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3318: l_dummy := DBMS_SQL.Execute(l_nvs_date_cursor_id);
3319:
3320: ELSIF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
3313: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3314: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3315: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3316: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3317: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3318: l_dummy := DBMS_SQL.Execute(l_nvs_date_cursor_id);
3319:
3320: ELSIF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
3321:
3314: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3315: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3316: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3317: DBMS_SQL.Bind_Variable(l_nvs_date_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3318: l_dummy := DBMS_SQL.Execute(l_nvs_date_cursor_id);
3319:
3320: ELSIF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
3321:
3322: IF (l_nvs_datetime_cursor_id is NULL) THEN
3319:
3320: ELSIF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
3321:
3322: IF (l_nvs_datetime_cursor_id is NULL) THEN
3323: l_nvs_datetime_cursor_id := DBMS_SQL.Open_Cursor;
3324: l_dynamic_sql :=
3325: 'UPDATE '||p_interface_table_name||'
3326: SET ATTR_VALUE_DATE = NVL(EGO_USER_ATTRS_BULK_PVT.Get_Date(ATTR_DISP_VALUE,'''||EGO_USER_ATTRS_COMMON_PVT.G_DATE_FORMAT||'''),ATTR_VALUE_DATE),
3327: PROCESS_STATUS = PROCESS_STATUS +
3333: AND ATTR_INT_NAME = :attr_internal_name
3334: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3335: AND (ATTR_DISP_VALUE IS NOT NULL OR ATTR_VALUE_DATE IS NOT NULL)';
3336:
3337: DBMS_SQL.Parse(l_nvs_datetime_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3338: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':data_set_id', p_data_set_id);
3339:
3340: END IF;
3341:
3334: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3335: AND (ATTR_DISP_VALUE IS NOT NULL OR ATTR_VALUE_DATE IS NOT NULL)';
3336:
3337: DBMS_SQL.Parse(l_nvs_datetime_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3338: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':data_set_id', p_data_set_id);
3339:
3340: END IF;
3341:
3342: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3338: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':data_set_id', p_data_set_id);
3339:
3340: END IF;
3341:
3342: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3343: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3344: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3345: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3346: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3339:
3340: END IF;
3341:
3342: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3343: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3344: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3345: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3346: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3347:
3340: END IF;
3341:
3342: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3343: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3344: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3345: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3346: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3347:
3348: l_dummy := DBMS_SQL.Execute(l_nvs_datetime_cursor_id);
3341:
3342: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3343: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3344: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3345: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3346: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3347:
3348: l_dummy := DBMS_SQL.Execute(l_nvs_datetime_cursor_id);
3349:
3342: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_datatype', l_attr_metadata_rec.DATA_TYPE);
3343: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3344: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3345: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3346: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3347:
3348: l_dummy := DBMS_SQL.Execute(l_nvs_datetime_cursor_id);
3349:
3350: ELSE -- must be char and translateble text
3344: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3345: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_min_allowed_val', l_attr_metadata_rec.MINIMUM_VALUE);
3346: DBMS_SQL.Bind_Variable(l_nvs_datetime_cursor_id, ':attr_max_allowed_val', l_attr_metadata_rec.MAXIMUM_VALUE);
3347:
3348: l_dummy := DBMS_SQL.Execute(l_nvs_datetime_cursor_id);
3349:
3350: ELSE -- must be char and translateble text
3351: IF (l_nvs_char_cursor_id is NULL) THEN
3352:
3349:
3350: ELSE -- must be char and translateble text
3351: IF (l_nvs_char_cursor_id is NULL) THEN
3352:
3353: l_nvs_char_cursor_id := DBMS_SQL.Open_Cursor;
3354: l_dynamic_sql :=
3355: 'UPDATE '||p_interface_table_name||'
3356: SET ATTR_VALUE_STR = ATTR_DISP_VALUE
3357: WHERE DATA_SET_ID = :data_set_id
3360: AND ATTR_INT_NAME = :attr_internal_name
3361: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3362: AND ATTR_DISP_VALUE IS NOT NULL';
3363:
3364: DBMS_SQL.Parse(l_nvs_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3365: DBMS_SQL.Bind_Variable(l_nvs_char_cursor_id, ':data_set_id', p_data_set_id);
3366:
3367: END IF;
3368:
3361: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3362: AND ATTR_DISP_VALUE IS NOT NULL';
3363:
3364: DBMS_SQL.Parse(l_nvs_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3365: DBMS_SQL.Bind_Variable(l_nvs_char_cursor_id, ':data_set_id', p_data_set_id);
3366:
3367: END IF;
3368:
3369: DBMS_SQL.Bind_Variable(l_nvs_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3365: DBMS_SQL.Bind_Variable(l_nvs_char_cursor_id, ':data_set_id', p_data_set_id);
3366:
3367: END IF;
3368:
3369: DBMS_SQL.Bind_Variable(l_nvs_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3370: DBMS_SQL.Bind_Variable(l_nvs_char_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3371:
3372: l_dummy := DBMS_SQL.Execute(l_nvs_char_cursor_id);
3373:
3366:
3367: END IF;
3368:
3369: DBMS_SQL.Bind_Variable(l_nvs_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3370: DBMS_SQL.Bind_Variable(l_nvs_char_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3371:
3372: l_dummy := DBMS_SQL.Execute(l_nvs_char_cursor_id);
3373:
3374: END IF;
3368:
3369: DBMS_SQL.Bind_Variable(l_nvs_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3370: DBMS_SQL.Bind_Variable(l_nvs_char_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3371:
3372: l_dummy := DBMS_SQL.Execute(l_nvs_char_cursor_id);
3373:
3374: END IF;
3375: END IF;
3376:
3385:
3386: --------- FOR NUMBER DATATYPE
3387: IF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_NUMBER_DATA_TYPE) THEN
3388: IF (l_max_size_num_cursor IS NULL) THEN
3389: l_max_size_num_cursor := DBMS_SQL.Open_Cursor;
3390: l_dynamic_sql :=
3391: 'UPDATE '||p_interface_table_name||'
3392: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_MAX_LENGTH_VIOLATION||'
3393: WHERE DATA_SET_ID = :data_set_id
3396: AND ATTR_INT_NAME = :attr_internal_name
3397: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3398: AND ATTR_VALUE_NUM IS NOT NULL
3399: AND LENGTH(ATTR_VALUE_NUM) > :max_allowed_size';
3400: DBMS_SQL.Parse(l_max_size_num_cursor, l_dynamic_sql, DBMS_SQL.NATIVE);
3401: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':data_set_id', p_data_set_id);
3402:
3403: END IF;
3404:
3397: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3398: AND ATTR_VALUE_NUM IS NOT NULL
3399: AND LENGTH(ATTR_VALUE_NUM) > :max_allowed_size';
3400: DBMS_SQL.Parse(l_max_size_num_cursor, l_dynamic_sql, DBMS_SQL.NATIVE);
3401: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':data_set_id', p_data_set_id);
3402:
3403: END IF;
3404:
3405: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3401: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':data_set_id', p_data_set_id);
3402:
3403: END IF;
3404:
3405: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3406: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3407: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':max_allowed_size', l_attr_metadata_rec.MAXIMUM_SIZE);
3408: l_dummy := DBMS_SQL.Execute(l_max_size_num_cursor);
3409: --------- FOR CHAR OR TRANSLATEBLE TEXT DATATYPE
3402:
3403: END IF;
3404:
3405: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3406: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3407: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':max_allowed_size', l_attr_metadata_rec.MAXIMUM_SIZE);
3408: l_dummy := DBMS_SQL.Execute(l_max_size_num_cursor);
3409: --------- FOR CHAR OR TRANSLATEBLE TEXT DATATYPE
3410: ELSIF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_CHAR_DATA_TYPE OR
3403: END IF;
3404:
3405: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3406: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3407: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':max_allowed_size', l_attr_metadata_rec.MAXIMUM_SIZE);
3408: l_dummy := DBMS_SQL.Execute(l_max_size_num_cursor);
3409: --------- FOR CHAR OR TRANSLATEBLE TEXT DATATYPE
3410: ELSIF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_CHAR_DATA_TYPE OR
3411: l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_TRANS_TEXT_DATA_TYPE) THEN
3404:
3405: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3406: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3407: DBMS_SQL.Bind_Variable(l_max_size_num_cursor, ':max_allowed_size', l_attr_metadata_rec.MAXIMUM_SIZE);
3408: l_dummy := DBMS_SQL.Execute(l_max_size_num_cursor);
3409: --------- FOR CHAR OR TRANSLATEBLE TEXT DATATYPE
3410: ELSIF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_CHAR_DATA_TYPE OR
3411: l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_TRANS_TEXT_DATA_TYPE) THEN
3412:
3410: ELSIF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_CHAR_DATA_TYPE OR
3411: l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_TRANS_TEXT_DATA_TYPE) THEN
3412:
3413: IF ( l_max_size_char_cursor IS NULL) THEN
3414: l_max_size_char_cursor := DBMS_SQL.Open_Cursor;
3415: l_dynamic_sql :=
3416: 'UPDATE '||p_interface_table_name||'
3417: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_MAX_LENGTH_VIOLATION||'
3418: WHERE DATA_SET_ID = :data_set_id
3421: AND ATTR_INT_NAME = :attr_internal_name
3422: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3423: AND ATTR_VALUE_STR IS NOT NULL
3424: AND LENGTH(ATTR_VALUE_STR) > :max_allowed_size';
3425: DBMS_SQL.Parse(l_max_size_char_cursor, l_dynamic_sql, DBMS_SQL.NATIVE);
3426: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':data_set_id', p_data_set_id);
3427:
3428: END IF;
3429: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3422: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3423: AND ATTR_VALUE_STR IS NOT NULL
3424: AND LENGTH(ATTR_VALUE_STR) > :max_allowed_size';
3425: DBMS_SQL.Parse(l_max_size_char_cursor, l_dynamic_sql, DBMS_SQL.NATIVE);
3426: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':data_set_id', p_data_set_id);
3427:
3428: END IF;
3429: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3430: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3425: DBMS_SQL.Parse(l_max_size_char_cursor, l_dynamic_sql, DBMS_SQL.NATIVE);
3426: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':data_set_id', p_data_set_id);
3427:
3428: END IF;
3429: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3430: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3431: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':max_allowed_size', l_attr_metadata_rec.MAXIMUM_SIZE);
3432:
3433: l_dummy := DBMS_SQL.Execute(l_max_size_char_cursor);
3426: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':data_set_id', p_data_set_id);
3427:
3428: END IF;
3429: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3430: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3431: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':max_allowed_size', l_attr_metadata_rec.MAXIMUM_SIZE);
3432:
3433: l_dummy := DBMS_SQL.Execute(l_max_size_char_cursor);
3434:
3427:
3428: END IF;
3429: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3430: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3431: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':max_allowed_size', l_attr_metadata_rec.MAXIMUM_SIZE);
3432:
3433: l_dummy := DBMS_SQL.Execute(l_max_size_char_cursor);
3434:
3435: END IF;
3429: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3430: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3431: DBMS_SQL.Bind_Variable(l_max_size_char_cursor, ':max_allowed_size', l_attr_metadata_rec.MAXIMUM_SIZE);
3432:
3433: l_dummy := DBMS_SQL.Execute(l_max_size_char_cursor);
3434:
3435: END IF;
3436: END IF;
3437:
3445:
3446: --------- FOR NUMBER DATATYPE
3447: IF(l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_NUMBER_DATA_TYPE) THEN
3448: IF (l_colcheck_num_cursor_id IS NULL) THEN
3449: l_colcheck_num_cursor_id := DBMS_SQL.Open_Cursor;
3450: l_dynamic_sql :=
3451: 'UPDATE '||p_interface_table_name||'
3452: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_DATA_IN_WRONG_COL||'
3453: WHERE DATA_SET_ID = :data_set_id
3457: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3458: AND ATTR_VALUE_NUM IS NULL
3459: AND ATTR_DISP_VALUE IS NULL
3460: AND (ATTR_VALUE_STR IS NOT NULL OR ATTR_VALUE_DATE IS NOT NULL)' ;
3461: DBMS_SQL.Parse(l_colcheck_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3462: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':data_set_id', p_data_set_id);
3463: END IF;
3464:
3465: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3458: AND ATTR_VALUE_NUM IS NULL
3459: AND ATTR_DISP_VALUE IS NULL
3460: AND (ATTR_VALUE_STR IS NOT NULL OR ATTR_VALUE_DATE IS NOT NULL)' ;
3461: DBMS_SQL.Parse(l_colcheck_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3462: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':data_set_id', p_data_set_id);
3463: END IF;
3464:
3465: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3466: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3461: DBMS_SQL.Parse(l_colcheck_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3462: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':data_set_id', p_data_set_id);
3463: END IF;
3464:
3465: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3466: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3467:
3468: l_dummy := DBMS_SQL.Execute(l_colcheck_num_cursor_id);
3469:
3462: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':data_set_id', p_data_set_id);
3463: END IF;
3464:
3465: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3466: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3467:
3468: l_dummy := DBMS_SQL.Execute(l_colcheck_num_cursor_id);
3469:
3470: --------- FOR DATE/DATETIME DATATYPE
3464:
3465: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3466: DBMS_SQL.Bind_Variable(l_colcheck_num_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3467:
3468: l_dummy := DBMS_SQL.Execute(l_colcheck_num_cursor_id);
3469:
3470: --------- FOR DATE/DATETIME DATATYPE
3471: ELSIF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE OR l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
3472: IF (l_colcheck_date_cursor_id IS NULL) THEN
3469:
3470: --------- FOR DATE/DATETIME DATATYPE
3471: ELSIF (l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE OR l_attr_metadata_rec.DATA_TYPE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
3472: IF (l_colcheck_date_cursor_id IS NULL) THEN
3473: l_colcheck_date_cursor_id := DBMS_SQL.Open_Cursor;
3474: l_dynamic_sql :=
3475: 'UPDATE '||p_interface_table_name||'
3476: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_DATA_IN_WRONG_COL||'
3477: WHERE DATA_SET_ID = :data_set_id
3481: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3482: AND ATTR_VALUE_DATE IS NULL
3483: AND ATTR_DISP_VALUE IS NULL
3484: AND (ATTR_VALUE_STR IS NOT NULL OR ATTR_VALUE_NUM IS NOT NULL)' ;
3485: DBMS_SQL.Parse(l_colcheck_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3486: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':data_set_id', p_data_set_id);
3487: END IF;
3488:
3489: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3482: AND ATTR_VALUE_DATE IS NULL
3483: AND ATTR_DISP_VALUE IS NULL
3484: AND (ATTR_VALUE_STR IS NOT NULL OR ATTR_VALUE_NUM IS NOT NULL)' ;
3485: DBMS_SQL.Parse(l_colcheck_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3486: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':data_set_id', p_data_set_id);
3487: END IF;
3488:
3489: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3490: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3485: DBMS_SQL.Parse(l_colcheck_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3486: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':data_set_id', p_data_set_id);
3487: END IF;
3488:
3489: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3490: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3491:
3492: l_dummy := DBMS_SQL.Execute(l_colcheck_date_cursor_id);
3493: --------- FOR CHAR/TRANSLATEBLE TEXT DATATYPE
3486: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':data_set_id', p_data_set_id);
3487: END IF;
3488:
3489: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3490: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3491:
3492: l_dummy := DBMS_SQL.Execute(l_colcheck_date_cursor_id);
3493: --------- FOR CHAR/TRANSLATEBLE TEXT DATATYPE
3494: ELSE
3488:
3489: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3490: DBMS_SQL.Bind_Variable(l_colcheck_date_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3491:
3492: l_dummy := DBMS_SQL.Execute(l_colcheck_date_cursor_id);
3493: --------- FOR CHAR/TRANSLATEBLE TEXT DATATYPE
3494: ELSE
3495: IF (l_colcheck_char_cursor_id IS NULL) THEN
3496: l_colcheck_char_cursor_id := DBMS_SQL.Open_Cursor;
3492: l_dummy := DBMS_SQL.Execute(l_colcheck_date_cursor_id);
3493: --------- FOR CHAR/TRANSLATEBLE TEXT DATATYPE
3494: ELSE
3495: IF (l_colcheck_char_cursor_id IS NULL) THEN
3496: l_colcheck_char_cursor_id := DBMS_SQL.Open_Cursor;
3497: l_dynamic_sql :=
3498: 'UPDATE '||p_interface_table_name||'
3499: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_DATA_IN_WRONG_COL||'
3500: WHERE DATA_SET_ID = :data_set_id
3504: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
3505: AND ATTR_VALUE_STR IS NULL
3506: AND ATTR_DISP_VALUE IS NULL
3507: AND (ATTR_VALUE_NUM IS NOT NULL OR ATTR_VALUE_DATE IS NOT NULL)' ;
3508: DBMS_SQL.Parse(l_colcheck_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3509: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':data_set_id', p_data_set_id);
3510: END IF;
3511:
3512: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3505: AND ATTR_VALUE_STR IS NULL
3506: AND ATTR_DISP_VALUE IS NULL
3507: AND (ATTR_VALUE_NUM IS NOT NULL OR ATTR_VALUE_DATE IS NOT NULL)' ;
3508: DBMS_SQL.Parse(l_colcheck_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3509: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':data_set_id', p_data_set_id);
3510: END IF;
3511:
3512: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3513: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3508: DBMS_SQL.Parse(l_colcheck_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
3509: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':data_set_id', p_data_set_id);
3510: END IF;
3511:
3512: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3513: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3514:
3515: l_dummy := DBMS_SQL.Execute(l_colcheck_char_cursor_id);
3516:
3509: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':data_set_id', p_data_set_id);
3510: END IF;
3511:
3512: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3513: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3514:
3515: l_dummy := DBMS_SQL.Execute(l_colcheck_char_cursor_id);
3516:
3517: END IF;
3511:
3512: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':attr_group_int_name', l_attr_metadata_rec.ATTR_GROUP_INT_NAME);
3513: DBMS_SQL.Bind_Variable(l_colcheck_char_cursor_id, ':attr_internal_name', l_attr_metadata_rec.ATTR_INT_NAME);
3514:
3515: l_dummy := DBMS_SQL.Execute(l_colcheck_char_cursor_id);
3516:
3517: END IF;
3518:
3519: END IF; -- if not previously processed
3550: code_debug(' After the ATTR LEVEL validation loop ' ,1);
3551:
3552: -- CLOSING ALL OPEN CURSORS
3553: IF (l_priv_func_cursor_id IS NOT NULL) THEN
3554: DBMS_SQL.Close_Cursor(l_priv_func_cursor_id);
3555: END IF;
3556: IF (l_ivs_num_cursor_id IS NOT NULL) THEN
3557: DBMS_SQL.Close_Cursor(l_ivs_num_cursor_id);
3558: END IF;
3553: IF (l_priv_func_cursor_id IS NOT NULL) THEN
3554: DBMS_SQL.Close_Cursor(l_priv_func_cursor_id);
3555: END IF;
3556: IF (l_ivs_num_cursor_id IS NOT NULL) THEN
3557: DBMS_SQL.Close_Cursor(l_ivs_num_cursor_id);
3558: END IF;
3559: IF (l_ivs_date_cursor_id IS NOT NULL) THEN
3560: DBMS_SQL.Close_Cursor(l_ivs_date_cursor_id);
3561: END IF;
3556: IF (l_ivs_num_cursor_id IS NOT NULL) THEN
3557: DBMS_SQL.Close_Cursor(l_ivs_num_cursor_id);
3558: END IF;
3559: IF (l_ivs_date_cursor_id IS NOT NULL) THEN
3560: DBMS_SQL.Close_Cursor(l_ivs_date_cursor_id);
3561: END IF;
3562: IF (l_ivs_date_time_cursor_id IS NOT NULL) THEN
3563: DBMS_SQL.Close_Cursor(l_ivs_date_time_cursor_id);
3564: END IF;
3559: IF (l_ivs_date_cursor_id IS NOT NULL) THEN
3560: DBMS_SQL.Close_Cursor(l_ivs_date_cursor_id);
3561: END IF;
3562: IF (l_ivs_date_time_cursor_id IS NOT NULL) THEN
3563: DBMS_SQL.Close_Cursor(l_ivs_date_time_cursor_id);
3564: END IF;
3565: IF (l_ivs_char_cursor_id IS NOT NULL) THEN
3566: DBMS_SQL.Close_Cursor(l_ivs_char_cursor_id);
3567: END IF;
3562: IF (l_ivs_date_time_cursor_id IS NOT NULL) THEN
3563: DBMS_SQL.Close_Cursor(l_ivs_date_time_cursor_id);
3564: END IF;
3565: IF (l_ivs_char_cursor_id IS NOT NULL) THEN
3566: DBMS_SQL.Close_Cursor(l_ivs_char_cursor_id);
3567: END IF;
3568: IF (l_nvs_num_cursor_id IS NOT NULL) THEN
3569: DBMS_SQL.Close_Cursor(l_nvs_num_cursor_id);
3570: END IF;
3565: IF (l_ivs_char_cursor_id IS NOT NULL) THEN
3566: DBMS_SQL.Close_Cursor(l_ivs_char_cursor_id);
3567: END IF;
3568: IF (l_nvs_num_cursor_id IS NOT NULL) THEN
3569: DBMS_SQL.Close_Cursor(l_nvs_num_cursor_id);
3570: END IF;
3571: IF (l_nvs_date_cursor_id IS NOT NULL) THEN
3572: DBMS_SQL.Close_Cursor(l_nvs_date_cursor_id);
3573: END IF;
3568: IF (l_nvs_num_cursor_id IS NOT NULL) THEN
3569: DBMS_SQL.Close_Cursor(l_nvs_num_cursor_id);
3570: END IF;
3571: IF (l_nvs_date_cursor_id IS NOT NULL) THEN
3572: DBMS_SQL.Close_Cursor(l_nvs_date_cursor_id);
3573: END IF;
3574: IF (l_nvs_datetime_cursor_id IS NOT NULL) THEN
3575: DBMS_SQL.Close_Cursor(l_nvs_datetime_cursor_id);
3576: END IF;
3571: IF (l_nvs_date_cursor_id IS NOT NULL) THEN
3572: DBMS_SQL.Close_Cursor(l_nvs_date_cursor_id);
3573: END IF;
3574: IF (l_nvs_datetime_cursor_id IS NOT NULL) THEN
3575: DBMS_SQL.Close_Cursor(l_nvs_datetime_cursor_id);
3576: END IF;
3577: IF (l_nvs_char_cursor_id IS NOT NULL) THEN
3578: DBMS_SQL.Close_Cursor(l_nvs_char_cursor_id);
3579: END IF;
3574: IF (l_nvs_datetime_cursor_id IS NOT NULL) THEN
3575: DBMS_SQL.Close_Cursor(l_nvs_datetime_cursor_id);
3576: END IF;
3577: IF (l_nvs_char_cursor_id IS NOT NULL) THEN
3578: DBMS_SQL.Close_Cursor(l_nvs_char_cursor_id);
3579: END IF;
3580: IF (l_max_size_char_cursor IS NOT NULL) THEN
3581: DBMS_SQL.Close_Cursor(l_max_size_char_cursor);
3582: END IF;
3577: IF (l_nvs_char_cursor_id IS NOT NULL) THEN
3578: DBMS_SQL.Close_Cursor(l_nvs_char_cursor_id);
3579: END IF;
3580: IF (l_max_size_char_cursor IS NOT NULL) THEN
3581: DBMS_SQL.Close_Cursor(l_max_size_char_cursor);
3582: END IF;
3583: IF (l_max_size_num_cursor IS NOT NULL) THEN
3584: DBMS_SQL.Close_Cursor(l_max_size_num_cursor);
3585: END IF;
3580: IF (l_max_size_char_cursor IS NOT NULL) THEN
3581: DBMS_SQL.Close_Cursor(l_max_size_char_cursor);
3582: END IF;
3583: IF (l_max_size_num_cursor IS NOT NULL) THEN
3584: DBMS_SQL.Close_Cursor(l_max_size_num_cursor);
3585: END IF;
3586: IF (l_colcheck_num_cursor_id IS NOT NULL) THEN
3587: DBMS_SQL.Close_Cursor(l_colcheck_num_cursor_id);
3588: END IF;
3583: IF (l_max_size_num_cursor IS NOT NULL) THEN
3584: DBMS_SQL.Close_Cursor(l_max_size_num_cursor);
3585: END IF;
3586: IF (l_colcheck_num_cursor_id IS NOT NULL) THEN
3587: DBMS_SQL.Close_Cursor(l_colcheck_num_cursor_id);
3588: END IF;
3589: IF (l_colcheck_char_cursor_id IS NOT NULL) THEN
3590: DBMS_SQL.Close_Cursor(l_colcheck_char_cursor_id);
3591: END IF;
3586: IF (l_colcheck_num_cursor_id IS NOT NULL) THEN
3587: DBMS_SQL.Close_Cursor(l_colcheck_num_cursor_id);
3588: END IF;
3589: IF (l_colcheck_char_cursor_id IS NOT NULL) THEN
3590: DBMS_SQL.Close_Cursor(l_colcheck_char_cursor_id);
3591: END IF;
3592: IF (l_colcheck_date_cursor_id IS NOT NULL) THEN
3593: DBMS_SQL.Close_Cursor(l_colcheck_date_cursor_id);
3594: END IF;
3589: IF (l_colcheck_char_cursor_id IS NOT NULL) THEN
3590: DBMS_SQL.Close_Cursor(l_colcheck_char_cursor_id);
3591: END IF;
3592: IF (l_colcheck_date_cursor_id IS NOT NULL) THEN
3593: DBMS_SQL.Close_Cursor(l_colcheck_date_cursor_id);
3594: END IF;
3595:
3596: IF (p_validate) THEN -- *p_validate-IF-1.75*
3597: -------------------------------------------------------------------------------------
4011: code_debug(' The TVS query constructed is :'||l_tvs_select ,3);
4012:
4013: IF(l_tvs_metadata_fetched = FALSE) THEN
4014: IF (l_bad_bindattrs_tvs_cursor_id IS NULL) THEN
4015: l_bad_bindattrs_tvs_cursor_id := DBMS_SQL.Open_Cursor;
4016: l_dynamic_sql :=
4017: 'UPDATE '||p_interface_table_name||'
4018: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_BAD_ATTRS_IN_TVS_WHERE||'
4019: WHERE DATA_SET_ID = :data_set_id
4019: WHERE DATA_SET_ID = :data_set_id
4020: AND ATTR_INT_NAME = :attr_internal_name
4021: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4022:
4023: DBMS_SQL.Parse(l_bad_bindattrs_tvs_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4024: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':data_set_id', p_data_set_id);
4025: END IF;
4026:
4027: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4020: AND ATTR_INT_NAME = :attr_internal_name
4021: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4022:
4023: DBMS_SQL.Parse(l_bad_bindattrs_tvs_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4024: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':data_set_id', p_data_set_id);
4025: END IF;
4026:
4027: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4028: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4023: DBMS_SQL.Parse(l_bad_bindattrs_tvs_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4024: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':data_set_id', p_data_set_id);
4025: END IF;
4026:
4027: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4028: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4029:
4030: l_dummy := DBMS_SQL.Execute(l_bad_bindattrs_tvs_cursor_id);
4031:
4024: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':data_set_id', p_data_set_id);
4025: END IF;
4026:
4027: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4028: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4029:
4030: l_dummy := DBMS_SQL.Execute(l_bad_bindattrs_tvs_cursor_id);
4031:
4032: ELSE -- now we do the interface table update since we are sure we have the metadata for bound variables
4026:
4027: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4028: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4029:
4030: l_dummy := DBMS_SQL.Execute(l_bad_bindattrs_tvs_cursor_id);
4031:
4032: ELSE -- now we do the interface table update since we are sure we have the metadata for bound variables
4033: /*
4034: Note: we are assuming that the setup is correct i.e. the column of the TVS are of correct data type
4070:
4071: EXCEPTION
4072: WHEN OTHERS THEN
4073: IF (l_bad_tvs_sql_cursor_id IS NULL) THEN
4074: l_bad_tvs_sql_cursor_id := DBMS_SQL.Open_Cursor;
4075: l_dynamic_sql :=
4076: 'UPDATE '||p_interface_table_name||'
4077: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_BAD_TVS_SETUP||'
4078: WHERE DATA_SET_ID = :data_set_id
4078: WHERE DATA_SET_ID = :data_set_id
4079: AND ATTR_INT_NAME = :attr_internal_name
4080: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4081:
4082: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4083: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4084: END IF;
4085: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4086: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4079: AND ATTR_INT_NAME = :attr_internal_name
4080: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4081:
4082: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4083: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4084: END IF;
4085: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4086: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4087: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4081:
4082: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4083: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4084: END IF;
4085: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4086: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4087: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4088: END;
4089:
4082: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4083: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4084: END IF;
4085: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4086: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4087: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4088: END;
4089:
4090: ELSIF (l_attr_metadata_table(y).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE OR l_attr_metadata_table(y).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
4083: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4084: END IF;
4085: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4086: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4087: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4088: END;
4089:
4090: ELSIF (l_attr_metadata_table(y).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE OR l_attr_metadata_table(y).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
4091:
4119: USING p_data_set_id;
4120: EXCEPTION
4121: WHEN OTHERS THEN
4122: IF (l_bad_tvs_sql_cursor_id IS NULL) THEN
4123: l_bad_tvs_sql_cursor_id := DBMS_SQL.Open_Cursor;
4124: l_dynamic_sql :=
4125: 'UPDATE '||p_interface_table_name||'
4126: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_BAD_TVS_SETUP||'
4127: WHERE DATA_SET_ID = :data_set_id
4127: WHERE DATA_SET_ID = :data_set_id
4128: AND ATTR_INT_NAME = :attr_internal_name
4129: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4130:
4131: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4132: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4133: END IF;
4134: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4135: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4128: AND ATTR_INT_NAME = :attr_internal_name
4129: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4130:
4131: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4132: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4133: END IF;
4134: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4135: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4136: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4130:
4131: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4132: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4133: END IF;
4134: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4135: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4136: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4137: END;
4138: ELSE
4131: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4132: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4133: END IF;
4134: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4135: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4136: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4137: END;
4138: ELSE
4139: /* l_dynamic_sql :=
4132: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4133: END IF;
4134: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4135: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4136: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4137: END;
4138: ELSE
4139: /* l_dynamic_sql :=
4140: 'UPDATE '||p_interface_table_name||' UAI1
4182: USING p_data_set_id;
4183: EXCEPTION
4184: WHEN OTHERS THEN
4185: IF (l_bad_tvs_sql_cursor_id IS NULL) THEN
4186: l_bad_tvs_sql_cursor_id := DBMS_SQL.Open_Cursor;
4187: l_dynamic_sql :=
4188: 'UPDATE '||p_interface_table_name||'
4189: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_BAD_TVS_SETUP||'
4190: WHERE DATA_SET_ID = :data_set_id
4190: WHERE DATA_SET_ID = :data_set_id
4191: AND ATTR_INT_NAME = :attr_internal_name
4192: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4193:
4194: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4195: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4196: END IF;
4197: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4198: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4191: AND ATTR_INT_NAME = :attr_internal_name
4192: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4193:
4194: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4195: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4196: END IF;
4197: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4198: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4199: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4193:
4194: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4195: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4196: END IF;
4197: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4198: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4199: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4200: END;
4201: END IF;
4194: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4195: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4196: END IF;
4197: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4198: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4199: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4200: END;
4201: END IF;
4202: END IF; --l_attr_metadata fetched TRUE/FALSE
4195: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4196: END IF;
4197: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4198: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table(y).ATTR_NAME);
4199: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4200: END;
4201: END IF;
4202: END IF; --l_attr_metadata fetched TRUE/FALSE
4203: END IF; -- if validation_code is TVS
4279: code_debug(' Attribute '||l_attr_metadata_table_1(z).ATTR_NAME|| ' has a default value or is a required attribute' ,2);
4280: --------- FOR NUMBER DATATYPE
4281: IF(l_attr_metadata_table_1(z).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_NUMBER_DATA_TYPE) THEN
4282: IF (l_default_num_cursor_id IS NULL) THEN
4283: l_default_num_cursor_id := DBMS_SQL.Open_Cursor;
4284: l_dynamic_sql :=
4285: 'INSERT INTO '||p_interface_table_name||' ( TRANSACTION_ID,
4286: PROCESS_STATUS ,
4287: DATA_SET_ID ,
4308: AND PROCESS_STATUS = '||G_PS_IN_PROCESS|| '
4309: AND BITAND(PROCESS_STATUS, '||G_PS_NO_PRIVILEGES||') = 0
4310: AND TRANSACTION_TYPE = '''|| EGO_USER_ATTRS_DATA_PVT.G_CREATE_MODE||'''
4311: GROUP BY DATA_SET_ID,ROW_IDENTIFIER,'|| l_concat_pk_cols_sel ||' ATTR_GROUP_ID' ;
4312: DBMS_SQL.Parse(l_default_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4313: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':data_set_id', p_data_set_id);
4314: END IF;
4315:
4316: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4309: AND BITAND(PROCESS_STATUS, '||G_PS_NO_PRIVILEGES||') = 0
4310: AND TRANSACTION_TYPE = '''|| EGO_USER_ATTRS_DATA_PVT.G_CREATE_MODE||'''
4311: GROUP BY DATA_SET_ID,ROW_IDENTIFIER,'|| l_concat_pk_cols_sel ||' ATTR_GROUP_ID' ;
4312: DBMS_SQL.Parse(l_default_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4313: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':data_set_id', p_data_set_id);
4314: END IF;
4315:
4316: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4317: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4312: DBMS_SQL.Parse(l_default_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4313: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':data_set_id', p_data_set_id);
4314: END IF;
4315:
4316: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4317: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4318: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':default_value', l_attr_metadata_table_1(z).DEFAULT_VALUE);
4319: l_dummy := DBMS_SQL.Execute(l_default_num_cursor_id);
4320: -- We need to add the attr in the distinct attrs table, since now we have to process this one also
4313: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':data_set_id', p_data_set_id);
4314: END IF;
4315:
4316: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4317: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4318: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':default_value', l_attr_metadata_table_1(z).DEFAULT_VALUE);
4319: l_dummy := DBMS_SQL.Execute(l_default_num_cursor_id);
4320: -- We need to add the attr in the distinct attrs table, since now we have to process this one also
4321: IF (l_attr_metadata_table_1(z).DEFAULT_VALUE IS NOT NULL AND l_dummy > 0 ) THEN
4314: END IF;
4315:
4316: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4317: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4318: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':default_value', l_attr_metadata_table_1(z).DEFAULT_VALUE);
4319: l_dummy := DBMS_SQL.Execute(l_default_num_cursor_id);
4320: -- We need to add the attr in the distinct attrs table, since now we have to process this one also
4321: IF (l_attr_metadata_table_1(z).DEFAULT_VALUE IS NOT NULL AND l_dummy > 0 ) THEN
4322: l_dist_attr_in_data_set_rec.ATTR_GROUP_ID := l_attr_metadata_table_1(z).ATTR_GROUP_ID;
4315:
4316: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4317: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4318: DBMS_SQL.Bind_Variable(l_default_num_cursor_id, ':default_value', l_attr_metadata_table_1(z).DEFAULT_VALUE);
4319: l_dummy := DBMS_SQL.Execute(l_default_num_cursor_id);
4320: -- We need to add the attr in the distinct attrs table, since now we have to process this one also
4321: IF (l_attr_metadata_table_1(z).DEFAULT_VALUE IS NOT NULL AND l_dummy > 0 ) THEN
4322: l_dist_attr_in_data_set_rec.ATTR_GROUP_ID := l_attr_metadata_table_1(z).ATTR_GROUP_ID;
4323: l_dist_attr_in_data_set_rec.ATTR_INT_NAME := l_attr_metadata_table_1(z).ATTR_NAME;
4329: --------- FOR DATE DATATYPE
4330: ELSIF(l_attr_metadata_table_1(z).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE OR
4331: l_attr_metadata_table_1(z).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
4332: IF (l_default_date_cursor_id IS NULL) THEN
4333: l_default_date_cursor_id := DBMS_SQL.Open_Cursor;
4334: l_dynamic_sql :=
4335: 'INSERT INTO '||p_interface_table_name||' ( TRANSACTION_ID,
4336: PROCESS_STATUS ,
4337: DATA_SET_ID ,
4358: AND PROCESS_STATUS = '||G_PS_IN_PROCESS|| '
4359: AND BITAND(PROCESS_STATUS, '||G_PS_NO_PRIVILEGES||') = 0
4360: AND TRANSACTION_TYPE = '''|| EGO_USER_ATTRS_DATA_PVT.G_CREATE_MODE||'''
4361: GROUP BY DATA_SET_ID,ROW_IDENTIFIER,'|| l_concat_pk_cols_sel ||' ATTR_GROUP_ID' ;
4362: DBMS_SQL.Parse(l_default_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4363: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':data_set_id', p_data_set_id);
4364: END IF;
4365:
4366: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4359: AND BITAND(PROCESS_STATUS, '||G_PS_NO_PRIVILEGES||') = 0
4360: AND TRANSACTION_TYPE = '''|| EGO_USER_ATTRS_DATA_PVT.G_CREATE_MODE||'''
4361: GROUP BY DATA_SET_ID,ROW_IDENTIFIER,'|| l_concat_pk_cols_sel ||' ATTR_GROUP_ID' ;
4362: DBMS_SQL.Parse(l_default_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4363: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':data_set_id', p_data_set_id);
4364: END IF;
4365:
4366: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4367: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4362: DBMS_SQL.Parse(l_default_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4363: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':data_set_id', p_data_set_id);
4364: END IF;
4365:
4366: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4367: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4368: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':default_value', Get_Date(l_attr_metadata_table_1(z).DEFAULT_VALUE));
4369: -- bug 3902395
4370: -- l_dummy := DBMS_SQL.Execute(l_default_num_cursor_id);
4363: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':data_set_id', p_data_set_id);
4364: END IF;
4365:
4366: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4367: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4368: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':default_value', Get_Date(l_attr_metadata_table_1(z).DEFAULT_VALUE));
4369: -- bug 3902395
4370: -- l_dummy := DBMS_SQL.Execute(l_default_num_cursor_id);
4371: l_dummy := DBMS_SQL.Execute(l_default_date_cursor_id);
4364: END IF;
4365:
4366: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4367: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4368: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':default_value', Get_Date(l_attr_metadata_table_1(z).DEFAULT_VALUE));
4369: -- bug 3902395
4370: -- l_dummy := DBMS_SQL.Execute(l_default_num_cursor_id);
4371: l_dummy := DBMS_SQL.Execute(l_default_date_cursor_id);
4372: -- We need to add the attr in the distinct attrs table, since now we have to process this one also
4366: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4367: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4368: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':default_value', Get_Date(l_attr_metadata_table_1(z).DEFAULT_VALUE));
4369: -- bug 3902395
4370: -- l_dummy := DBMS_SQL.Execute(l_default_num_cursor_id);
4371: l_dummy := DBMS_SQL.Execute(l_default_date_cursor_id);
4372: -- We need to add the attr in the distinct attrs table, since now we have to process this one also
4373: IF (l_attr_metadata_table_1(z).DEFAULT_VALUE IS NOT NULL AND SQL%ROWCOUNT > 0 ) THEN
4374: l_dist_attr_in_data_set_rec.ATTR_GROUP_ID := l_attr_metadata_table_1(z).ATTR_GROUP_ID;
4367: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4368: DBMS_SQL.Bind_Variable(l_default_date_cursor_id, ':default_value', Get_Date(l_attr_metadata_table_1(z).DEFAULT_VALUE));
4369: -- bug 3902395
4370: -- l_dummy := DBMS_SQL.Execute(l_default_num_cursor_id);
4371: l_dummy := DBMS_SQL.Execute(l_default_date_cursor_id);
4372: -- We need to add the attr in the distinct attrs table, since now we have to process this one also
4373: IF (l_attr_metadata_table_1(z).DEFAULT_VALUE IS NOT NULL AND SQL%ROWCOUNT > 0 ) THEN
4374: l_dist_attr_in_data_set_rec.ATTR_GROUP_ID := l_attr_metadata_table_1(z).ATTR_GROUP_ID;
4375: l_dist_attr_in_data_set_rec.ATTR_INT_NAME := l_attr_metadata_table_1(z).ATTR_NAME;
4380:
4381: --------- FOR CHAR/TRANS DATATYPE
4382: ELSE
4383: IF (l_default_char_cursor_id IS NULL) THEN
4384: l_default_char_cursor_id := DBMS_SQL.Open_Cursor;
4385: l_dynamic_sql :=
4386: 'INSERT INTO '||p_interface_table_name||' ( TRANSACTION_ID,
4387: PROCESS_STATUS ,
4388: DATA_SET_ID ,
4409: AND PROCESS_STATUS = '||G_PS_IN_PROCESS|| '
4410: AND BITAND(PROCESS_STATUS, '||G_PS_NO_PRIVILEGES||') = 0
4411: AND TRANSACTION_TYPE = '''|| EGO_USER_ATTRS_DATA_PVT.G_CREATE_MODE||'''
4412: GROUP BY DATA_SET_ID,ROW_IDENTIFIER,'|| l_concat_pk_cols_sel ||' ATTR_GROUP_ID' ;
4413: DBMS_SQL.Parse(l_default_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4414: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':data_set_id', p_data_set_id);
4415: END IF;
4416:
4417: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4410: AND BITAND(PROCESS_STATUS, '||G_PS_NO_PRIVILEGES||') = 0
4411: AND TRANSACTION_TYPE = '''|| EGO_USER_ATTRS_DATA_PVT.G_CREATE_MODE||'''
4412: GROUP BY DATA_SET_ID,ROW_IDENTIFIER,'|| l_concat_pk_cols_sel ||' ATTR_GROUP_ID' ;
4413: DBMS_SQL.Parse(l_default_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4414: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':data_set_id', p_data_set_id);
4415: END IF;
4416:
4417: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4418: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4413: DBMS_SQL.Parse(l_default_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4414: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':data_set_id', p_data_set_id);
4415: END IF;
4416:
4417: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4418: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4419: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':default_value', l_attr_metadata_table_1(z).DEFAULT_VALUE);
4420:
4421: l_dummy := DBMS_SQL.Execute(l_default_char_cursor_id);
4414: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':data_set_id', p_data_set_id);
4415: END IF;
4416:
4417: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4418: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4419: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':default_value', l_attr_metadata_table_1(z).DEFAULT_VALUE);
4420:
4421: l_dummy := DBMS_SQL.Execute(l_default_char_cursor_id);
4422: -- We need to add the attr in the distinct attrs table, since now we have to process this one also
4415: END IF;
4416:
4417: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4418: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4419: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':default_value', l_attr_metadata_table_1(z).DEFAULT_VALUE);
4420:
4421: l_dummy := DBMS_SQL.Execute(l_default_char_cursor_id);
4422: -- We need to add the attr in the distinct attrs table, since now we have to process this one also
4423: IF (l_attr_metadata_table_1(z).DEFAULT_VALUE IS NOT NULL AND l_dummy > 0 ) THEN
4417: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4418: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4419: DBMS_SQL.Bind_Variable(l_default_char_cursor_id, ':default_value', l_attr_metadata_table_1(z).DEFAULT_VALUE);
4420:
4421: l_dummy := DBMS_SQL.Execute(l_default_char_cursor_id);
4422: -- We need to add the attr in the distinct attrs table, since now we have to process this one also
4423: IF (l_attr_metadata_table_1(z).DEFAULT_VALUE IS NOT NULL AND l_dummy > 0 ) THEN
4424: l_dist_attr_in_data_set_rec.ATTR_GROUP_ID := l_attr_metadata_table_1(z).ATTR_GROUP_ID;
4425: l_dist_attr_in_data_set_rec.ATTR_INT_NAME := l_attr_metadata_table_1(z).ATTR_NAME;
4444:
4445: --------- FOR NUMBER DATATYPE
4446: IF(l_attr_metadata_table_1(z).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_NUMBER_DATA_TYPE) THEN
4447: IF (l_req_num_cursor_id IS NULL) THEN
4448: l_req_num_cursor_id := DBMS_SQL.Open_Cursor;
4449: l_dynamic_sql :=
4450: 'UPDATE '||p_interface_table_name||'
4451: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_REQUIRED_ATTRIBUTE||'
4452: WHERE DATA_SET_ID = :data_set_id
4455: AND ATTR_INT_NAME = :attr_internal_name
4456: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
4457: AND ATTR_VALUE_NUM IS NULL
4458: AND ATTR_DISP_VALUE IS NULL ' ;--BugFix : 4171705
4459: DBMS_SQL.Parse(l_req_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4460: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':data_set_id', p_data_set_id);
4461: END IF;
4462:
4463: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4456: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
4457: AND ATTR_VALUE_NUM IS NULL
4458: AND ATTR_DISP_VALUE IS NULL ' ;--BugFix : 4171705
4459: DBMS_SQL.Parse(l_req_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4460: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':data_set_id', p_data_set_id);
4461: END IF;
4462:
4463: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4464: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4459: DBMS_SQL.Parse(l_req_num_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4460: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':data_set_id', p_data_set_id);
4461: END IF;
4462:
4463: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4464: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4465:
4466: l_dummy := DBMS_SQL.Execute(l_req_num_cursor_id);
4467:
4460: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':data_set_id', p_data_set_id);
4461: END IF;
4462:
4463: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4464: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4465:
4466: l_dummy := DBMS_SQL.Execute(l_req_num_cursor_id);
4467:
4468: --------- FOR DATE AND DATE TIME DATATYPE
4462:
4463: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4464: DBMS_SQL.Bind_Variable(l_req_num_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4465:
4466: l_dummy := DBMS_SQL.Execute(l_req_num_cursor_id);
4467:
4468: --------- FOR DATE AND DATE TIME DATATYPE
4469: ELSIF (l_attr_metadata_table_1(z).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE OR l_attr_metadata_table_1(z).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
4470: IF (l_req_date_cursor_id IS NULL) THEN
4467:
4468: --------- FOR DATE AND DATE TIME DATATYPE
4469: ELSIF (l_attr_metadata_table_1(z).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE OR l_attr_metadata_table_1(z).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
4470: IF (l_req_date_cursor_id IS NULL) THEN
4471: l_req_date_cursor_id := DBMS_SQL.Open_Cursor;
4472: l_dynamic_sql :=
4473: 'UPDATE '||p_interface_table_name||'
4474: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_REQUIRED_ATTRIBUTE||'
4475: WHERE DATA_SET_ID = :data_set_id
4478: AND ATTR_INT_NAME = :attr_internal_name
4479: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
4480: AND ATTR_VALUE_DATE IS NULL
4481: AND ATTR_DISP_VALUE IS NULL ' ;--BugFix : 4171705
4482: DBMS_SQL.Parse(l_req_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4483: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':data_set_id', p_data_set_id);
4484: END IF;
4485:
4486: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4479: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
4480: AND ATTR_VALUE_DATE IS NULL
4481: AND ATTR_DISP_VALUE IS NULL ' ;--BugFix : 4171705
4482: DBMS_SQL.Parse(l_req_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4483: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':data_set_id', p_data_set_id);
4484: END IF;
4485:
4486: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4487: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4482: DBMS_SQL.Parse(l_req_date_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4483: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':data_set_id', p_data_set_id);
4484: END IF;
4485:
4486: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4487: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4488:
4489: l_dummy := DBMS_SQL.Execute(l_req_date_cursor_id);
4490: --------- FOR CHAR AND TRANSLATEBLE TEXT DATATYPE
4483: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':data_set_id', p_data_set_id);
4484: END IF;
4485:
4486: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4487: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4488:
4489: l_dummy := DBMS_SQL.Execute(l_req_date_cursor_id);
4490: --------- FOR CHAR AND TRANSLATEBLE TEXT DATATYPE
4491: ELSE
4485:
4486: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4487: DBMS_SQL.Bind_Variable(l_req_date_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4488:
4489: l_dummy := DBMS_SQL.Execute(l_req_date_cursor_id);
4490: --------- FOR CHAR AND TRANSLATEBLE TEXT DATATYPE
4491: ELSE
4492: IF (l_req_char_cursor_id IS NULL) THEN
4493: l_req_char_cursor_id := DBMS_SQL.Open_Cursor;
4489: l_dummy := DBMS_SQL.Execute(l_req_date_cursor_id);
4490: --------- FOR CHAR AND TRANSLATEBLE TEXT DATATYPE
4491: ELSE
4492: IF (l_req_char_cursor_id IS NULL) THEN
4493: l_req_char_cursor_id := DBMS_SQL.Open_Cursor;
4494: l_dynamic_sql :=
4495: 'UPDATE '||p_interface_table_name||'
4496: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_REQUIRED_ATTRIBUTE||'
4497: WHERE DATA_SET_ID = :data_set_id
4500: AND ATTR_INT_NAME = :attr_internal_name
4501: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
4502: AND ATTR_VALUE_STR IS NULL
4503: AND ATTR_DISP_VALUE IS NULL ' ;--BugFix : 4171705
4504: DBMS_SQL.Parse(l_req_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4505: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':data_set_id', p_data_set_id);
4506: END IF;
4507:
4508: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4501: AND ATTR_GROUP_INT_NAME = :attr_group_int_name
4502: AND ATTR_VALUE_STR IS NULL
4503: AND ATTR_DISP_VALUE IS NULL ' ;--BugFix : 4171705
4504: DBMS_SQL.Parse(l_req_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4505: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':data_set_id', p_data_set_id);
4506: END IF;
4507:
4508: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4509: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4504: DBMS_SQL.Parse(l_req_char_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4505: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':data_set_id', p_data_set_id);
4506: END IF;
4507:
4508: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4509: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4510:
4511: l_dummy := DBMS_SQL.Execute(l_req_char_cursor_id);
4512: END IF;
4505: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':data_set_id', p_data_set_id);
4506: END IF;
4507:
4508: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4509: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4510:
4511: l_dummy := DBMS_SQL.Execute(l_req_char_cursor_id);
4512: END IF;
4513: END IF;--Required flag
4507:
4508: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':attr_group_int_name', l_attr_metadata_table_1(z).ATTR_GROUP_NAME);
4509: DBMS_SQL.Bind_Variable(l_req_char_cursor_id, ':attr_internal_name', l_attr_metadata_table_1(z).ATTR_NAME);
4510:
4511: l_dummy := DBMS_SQL.Execute(l_req_char_cursor_id);
4512: END IF;
4513: END IF;--Required flag
4514: END IF;
4515: END LOOP;
4722: code_debug(' The TVS select constructed is :'||l_tvs_select ,3);
4723:
4724: IF (l_tvs_metadata_fetched = FALSE) THEN
4725: IF (l_bad_bindattrs_tvs_cursor_id IS NULL) THEN
4726: l_bad_bindattrs_tvs_cursor_id := DBMS_SQL.Open_Cursor;
4727: l_dynamic_sql :=
4728: 'UPDATE '||p_interface_table_name||'
4729: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_BAD_ATTRS_IN_TVS_WHERE||'
4730: WHERE DATA_SET_ID = :data_set_id
4730: WHERE DATA_SET_ID = :data_set_id
4731: AND ATTR_INT_NAME = :attr_internal_name
4732: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4733:
4734: DBMS_SQL.Parse(l_bad_bindattrs_tvs_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4735: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':data_set_id', p_data_set_id);
4736: END IF;
4737:
4738: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4731: AND ATTR_INT_NAME = :attr_internal_name
4732: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4733:
4734: DBMS_SQL.Parse(l_bad_bindattrs_tvs_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4735: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':data_set_id', p_data_set_id);
4736: END IF;
4737:
4738: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4739: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4734: DBMS_SQL.Parse(l_bad_bindattrs_tvs_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4735: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':data_set_id', p_data_set_id);
4736: END IF;
4737:
4738: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4739: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4740: l_dummy := DBMS_SQL.Execute(l_bad_bindattrs_tvs_cursor_id);
4741: ELSE -- now we do the interface table update since we are sure we have the metadata for bound variables
4742:
4735: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':data_set_id', p_data_set_id);
4736: END IF;
4737:
4738: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4739: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4740: l_dummy := DBMS_SQL.Execute(l_bad_bindattrs_tvs_cursor_id);
4741: ELSE -- now we do the interface table update since we are sure we have the metadata for bound variables
4742:
4743: /*
4736: END IF;
4737:
4738: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4739: DBMS_SQL.Bind_Variable(l_bad_bindattrs_tvs_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4740: l_dummy := DBMS_SQL.Execute(l_bad_bindattrs_tvs_cursor_id);
4741: ELSE -- now we do the interface table update since we are sure we have the metadata for bound variables
4742:
4743: /*
4744: Note: we are assuming that the setup is correct i.e. the column of the TVS are of correct data type
4775:
4776: BEGIN
4777: --EXECUTE IMMEDIATE l_dynamic_sql_1;
4778: IF (l_sr_tvs_num_cursor_id1 IS NULL) THEN
4779: l_sr_tvs_num_cursor_id1 := DBMS_SQL.Open_Cursor;
4780: END IF;
4781: DBMS_SQL.Parse(l_sr_tvs_num_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4782: DBMS_SQL.Bind_Variable(l_sr_tvs_num_cursor_id1, ':data_set_id', p_data_set_id);
4783: l_dummy := DBMS_SQL.Execute(l_sr_tvs_num_cursor_id1);
4777: --EXECUTE IMMEDIATE l_dynamic_sql_1;
4778: IF (l_sr_tvs_num_cursor_id1 IS NULL) THEN
4779: l_sr_tvs_num_cursor_id1 := DBMS_SQL.Open_Cursor;
4780: END IF;
4781: DBMS_SQL.Parse(l_sr_tvs_num_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4782: DBMS_SQL.Bind_Variable(l_sr_tvs_num_cursor_id1, ':data_set_id', p_data_set_id);
4783: l_dummy := DBMS_SQL.Execute(l_sr_tvs_num_cursor_id1);
4784:
4785: --EXECUTE IMMEDIATE l_dynamic_sql;
4778: IF (l_sr_tvs_num_cursor_id1 IS NULL) THEN
4779: l_sr_tvs_num_cursor_id1 := DBMS_SQL.Open_Cursor;
4780: END IF;
4781: DBMS_SQL.Parse(l_sr_tvs_num_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4782: DBMS_SQL.Bind_Variable(l_sr_tvs_num_cursor_id1, ':data_set_id', p_data_set_id);
4783: l_dummy := DBMS_SQL.Execute(l_sr_tvs_num_cursor_id1);
4784:
4785: --EXECUTE IMMEDIATE l_dynamic_sql;
4786: IF (l_sr_tvs_num_cursor_id2 IS NULL) THEN
4779: l_sr_tvs_num_cursor_id1 := DBMS_SQL.Open_Cursor;
4780: END IF;
4781: DBMS_SQL.Parse(l_sr_tvs_num_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4782: DBMS_SQL.Bind_Variable(l_sr_tvs_num_cursor_id1, ':data_set_id', p_data_set_id);
4783: l_dummy := DBMS_SQL.Execute(l_sr_tvs_num_cursor_id1);
4784:
4785: --EXECUTE IMMEDIATE l_dynamic_sql;
4786: IF (l_sr_tvs_num_cursor_id2 IS NULL) THEN
4787: l_sr_tvs_num_cursor_id2 := DBMS_SQL.Open_Cursor;
4783: l_dummy := DBMS_SQL.Execute(l_sr_tvs_num_cursor_id1);
4784:
4785: --EXECUTE IMMEDIATE l_dynamic_sql;
4786: IF (l_sr_tvs_num_cursor_id2 IS NULL) THEN
4787: l_sr_tvs_num_cursor_id2 := DBMS_SQL.Open_Cursor;
4788: END IF;
4789: DBMS_SQL.Parse(l_sr_tvs_num_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4790: DBMS_SQL.Bind_Variable(l_sr_tvs_num_cursor_id2, ':data_set_id', p_data_set_id);
4791: l_dummy := DBMS_SQL.Execute(l_sr_tvs_num_cursor_id2);
4785: --EXECUTE IMMEDIATE l_dynamic_sql;
4786: IF (l_sr_tvs_num_cursor_id2 IS NULL) THEN
4787: l_sr_tvs_num_cursor_id2 := DBMS_SQL.Open_Cursor;
4788: END IF;
4789: DBMS_SQL.Parse(l_sr_tvs_num_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4790: DBMS_SQL.Bind_Variable(l_sr_tvs_num_cursor_id2, ':data_set_id', p_data_set_id);
4791: l_dummy := DBMS_SQL.Execute(l_sr_tvs_num_cursor_id2);
4792:
4793: EXCEPTION
4786: IF (l_sr_tvs_num_cursor_id2 IS NULL) THEN
4787: l_sr_tvs_num_cursor_id2 := DBMS_SQL.Open_Cursor;
4788: END IF;
4789: DBMS_SQL.Parse(l_sr_tvs_num_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4790: DBMS_SQL.Bind_Variable(l_sr_tvs_num_cursor_id2, ':data_set_id', p_data_set_id);
4791: l_dummy := DBMS_SQL.Execute(l_sr_tvs_num_cursor_id2);
4792:
4793: EXCEPTION
4794: WHEN OTHERS THEN
4787: l_sr_tvs_num_cursor_id2 := DBMS_SQL.Open_Cursor;
4788: END IF;
4789: DBMS_SQL.Parse(l_sr_tvs_num_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4790: DBMS_SQL.Bind_Variable(l_sr_tvs_num_cursor_id2, ':data_set_id', p_data_set_id);
4791: l_dummy := DBMS_SQL.Execute(l_sr_tvs_num_cursor_id2);
4792:
4793: EXCEPTION
4794: WHEN OTHERS THEN
4795: IF (l_bad_tvs_sql_cursor_id IS NULL) THEN
4792:
4793: EXCEPTION
4794: WHEN OTHERS THEN
4795: IF (l_bad_tvs_sql_cursor_id IS NULL) THEN
4796: l_bad_tvs_sql_cursor_id := DBMS_SQL.Open_Cursor;
4797: l_dynamic_sql :=
4798: 'UPDATE '||p_interface_table_name||'
4799: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_BAD_TVS_SETUP||'
4800: WHERE DATA_SET_ID = :data_set_id
4800: WHERE DATA_SET_ID = :data_set_id
4801: AND ATTR_INT_NAME = :attr_internal_name
4802: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4803:
4804: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4805: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4806: END IF;
4807: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4808: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4801: AND ATTR_INT_NAME = :attr_internal_name
4802: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4803:
4804: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4805: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4806: END IF;
4807: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4808: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4809: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4803:
4804: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4805: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4806: END IF;
4807: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4808: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4809: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4810: END;
4811:
4804: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4805: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4806: END IF;
4807: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4808: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4809: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4810: END;
4811:
4812: ELSIF (l_attr_metadata_table_sr(x).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE OR l_attr_metadata_table_sr(x).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
4805: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4806: END IF;
4807: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4808: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4809: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4810: END;
4811:
4812: ELSIF (l_attr_metadata_table_sr(x).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_DATA_TYPE OR l_attr_metadata_table_sr(x).DATA_TYPE_CODE = EGO_EXT_FWK_PUB.G_DATE_TIME_DATA_TYPE) THEN
4813:
4838: BEGIN
4839:
4840: --EXECUTE IMMEDIATE l_dynamic_sql_1;
4841: IF (l_sr_tvs_date_cursor_id1 IS NULL) THEN
4842: l_sr_tvs_date_cursor_id1 := DBMS_SQL.Open_Cursor;
4843: END IF;
4844: DBMS_SQL.Parse(l_sr_tvs_date_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4845: DBMS_SQL.Bind_Variable(l_sr_tvs_date_cursor_id1, ':data_set_id', p_data_set_id);
4846: l_dummy := DBMS_SQL.Execute(l_sr_tvs_date_cursor_id1);
4840: --EXECUTE IMMEDIATE l_dynamic_sql_1;
4841: IF (l_sr_tvs_date_cursor_id1 IS NULL) THEN
4842: l_sr_tvs_date_cursor_id1 := DBMS_SQL.Open_Cursor;
4843: END IF;
4844: DBMS_SQL.Parse(l_sr_tvs_date_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4845: DBMS_SQL.Bind_Variable(l_sr_tvs_date_cursor_id1, ':data_set_id', p_data_set_id);
4846: l_dummy := DBMS_SQL.Execute(l_sr_tvs_date_cursor_id1);
4847:
4848: --EXECUTE IMMEDIATE l_dynamic_sql;
4841: IF (l_sr_tvs_date_cursor_id1 IS NULL) THEN
4842: l_sr_tvs_date_cursor_id1 := DBMS_SQL.Open_Cursor;
4843: END IF;
4844: DBMS_SQL.Parse(l_sr_tvs_date_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4845: DBMS_SQL.Bind_Variable(l_sr_tvs_date_cursor_id1, ':data_set_id', p_data_set_id);
4846: l_dummy := DBMS_SQL.Execute(l_sr_tvs_date_cursor_id1);
4847:
4848: --EXECUTE IMMEDIATE l_dynamic_sql;
4849: IF (l_sr_tvs_date_cursor_id2 IS NULL) THEN
4842: l_sr_tvs_date_cursor_id1 := DBMS_SQL.Open_Cursor;
4843: END IF;
4844: DBMS_SQL.Parse(l_sr_tvs_date_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4845: DBMS_SQL.Bind_Variable(l_sr_tvs_date_cursor_id1, ':data_set_id', p_data_set_id);
4846: l_dummy := DBMS_SQL.Execute(l_sr_tvs_date_cursor_id1);
4847:
4848: --EXECUTE IMMEDIATE l_dynamic_sql;
4849: IF (l_sr_tvs_date_cursor_id2 IS NULL) THEN
4850: l_sr_tvs_date_cursor_id2 := DBMS_SQL.Open_Cursor;
4846: l_dummy := DBMS_SQL.Execute(l_sr_tvs_date_cursor_id1);
4847:
4848: --EXECUTE IMMEDIATE l_dynamic_sql;
4849: IF (l_sr_tvs_date_cursor_id2 IS NULL) THEN
4850: l_sr_tvs_date_cursor_id2 := DBMS_SQL.Open_Cursor;
4851: END IF;
4852: DBMS_SQL.Parse(l_sr_tvs_date_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4853: DBMS_SQL.Bind_Variable(l_sr_tvs_date_cursor_id2, ':data_set_id', p_data_set_id);
4854: l_dummy := DBMS_SQL.Execute(l_sr_tvs_date_cursor_id2);
4848: --EXECUTE IMMEDIATE l_dynamic_sql;
4849: IF (l_sr_tvs_date_cursor_id2 IS NULL) THEN
4850: l_sr_tvs_date_cursor_id2 := DBMS_SQL.Open_Cursor;
4851: END IF;
4852: DBMS_SQL.Parse(l_sr_tvs_date_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4853: DBMS_SQL.Bind_Variable(l_sr_tvs_date_cursor_id2, ':data_set_id', p_data_set_id);
4854: l_dummy := DBMS_SQL.Execute(l_sr_tvs_date_cursor_id2);
4855:
4856: EXCEPTION
4849: IF (l_sr_tvs_date_cursor_id2 IS NULL) THEN
4850: l_sr_tvs_date_cursor_id2 := DBMS_SQL.Open_Cursor;
4851: END IF;
4852: DBMS_SQL.Parse(l_sr_tvs_date_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4853: DBMS_SQL.Bind_Variable(l_sr_tvs_date_cursor_id2, ':data_set_id', p_data_set_id);
4854: l_dummy := DBMS_SQL.Execute(l_sr_tvs_date_cursor_id2);
4855:
4856: EXCEPTION
4857: WHEN OTHERS THEN
4850: l_sr_tvs_date_cursor_id2 := DBMS_SQL.Open_Cursor;
4851: END IF;
4852: DBMS_SQL.Parse(l_sr_tvs_date_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4853: DBMS_SQL.Bind_Variable(l_sr_tvs_date_cursor_id2, ':data_set_id', p_data_set_id);
4854: l_dummy := DBMS_SQL.Execute(l_sr_tvs_date_cursor_id2);
4855:
4856: EXCEPTION
4857: WHEN OTHERS THEN
4858: IF (l_bad_tvs_sql_cursor_id IS NULL) THEN
4855:
4856: EXCEPTION
4857: WHEN OTHERS THEN
4858: IF (l_bad_tvs_sql_cursor_id IS NULL) THEN
4859: l_bad_tvs_sql_cursor_id := DBMS_SQL.Open_Cursor;
4860: l_dynamic_sql :=
4861: 'UPDATE '||p_interface_table_name||'
4862: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_BAD_TVS_SETUP||'
4863: WHERE DATA_SET_ID = :data_set_id
4863: WHERE DATA_SET_ID = :data_set_id
4864: AND ATTR_INT_NAME = :attr_internal_name
4865: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4866:
4867: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4868: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4869: END IF;
4870: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4871: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4864: AND ATTR_INT_NAME = :attr_internal_name
4865: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4866:
4867: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4868: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4869: END IF;
4870: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4871: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4872: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4866:
4867: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4868: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4869: END IF;
4870: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4871: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4872: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4873: END;
4874: ELSE
4867: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4868: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4869: END IF;
4870: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4871: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4872: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4873: END;
4874: ELSE
4875: l_dynamic_sql_1 :=
4868: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4869: END IF;
4870: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4871: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4872: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4873: END;
4874: ELSE
4875: l_dynamic_sql_1 :=
4876: 'UPDATE '||p_interface_table_name||' UAI1
4897: -- need to mark the row as errored due to bad TVS setup.
4898: BEGIN
4899: --EXECUTE IMMEDIATE l_dynamic_sql_1;
4900: IF (l_sr_tvs_str_cursor_id1 IS NULL) THEN
4901: l_sr_tvs_str_cursor_id1 := DBMS_SQL.Open_Cursor;
4902: END IF;
4903: DBMS_SQL.Parse(l_sr_tvs_str_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4904: DBMS_SQL.Bind_Variable(l_sr_tvs_str_cursor_id1, ':data_set_id', p_data_set_id);
4905: l_dummy := DBMS_SQL.Execute(l_sr_tvs_str_cursor_id1);
4899: --EXECUTE IMMEDIATE l_dynamic_sql_1;
4900: IF (l_sr_tvs_str_cursor_id1 IS NULL) THEN
4901: l_sr_tvs_str_cursor_id1 := DBMS_SQL.Open_Cursor;
4902: END IF;
4903: DBMS_SQL.Parse(l_sr_tvs_str_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4904: DBMS_SQL.Bind_Variable(l_sr_tvs_str_cursor_id1, ':data_set_id', p_data_set_id);
4905: l_dummy := DBMS_SQL.Execute(l_sr_tvs_str_cursor_id1);
4906:
4907: --EXECUTE IMMEDIATE l_dynamic_sql;
4900: IF (l_sr_tvs_str_cursor_id1 IS NULL) THEN
4901: l_sr_tvs_str_cursor_id1 := DBMS_SQL.Open_Cursor;
4902: END IF;
4903: DBMS_SQL.Parse(l_sr_tvs_str_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4904: DBMS_SQL.Bind_Variable(l_sr_tvs_str_cursor_id1, ':data_set_id', p_data_set_id);
4905: l_dummy := DBMS_SQL.Execute(l_sr_tvs_str_cursor_id1);
4906:
4907: --EXECUTE IMMEDIATE l_dynamic_sql;
4908: IF (l_sr_tvs_str_cursor_id2 IS NULL) THEN
4901: l_sr_tvs_str_cursor_id1 := DBMS_SQL.Open_Cursor;
4902: END IF;
4903: DBMS_SQL.Parse(l_sr_tvs_str_cursor_id1, l_dynamic_sql_1, DBMS_SQL.NATIVE);
4904: DBMS_SQL.Bind_Variable(l_sr_tvs_str_cursor_id1, ':data_set_id', p_data_set_id);
4905: l_dummy := DBMS_SQL.Execute(l_sr_tvs_str_cursor_id1);
4906:
4907: --EXECUTE IMMEDIATE l_dynamic_sql;
4908: IF (l_sr_tvs_str_cursor_id2 IS NULL) THEN
4909: l_sr_tvs_str_cursor_id2 := DBMS_SQL.Open_Cursor;
4905: l_dummy := DBMS_SQL.Execute(l_sr_tvs_str_cursor_id1);
4906:
4907: --EXECUTE IMMEDIATE l_dynamic_sql;
4908: IF (l_sr_tvs_str_cursor_id2 IS NULL) THEN
4909: l_sr_tvs_str_cursor_id2 := DBMS_SQL.Open_Cursor;
4910: END IF;
4911: DBMS_SQL.Parse(l_sr_tvs_str_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4912: DBMS_SQL.Bind_Variable(l_sr_tvs_str_cursor_id2, ':data_set_id', p_data_set_id);
4913: l_dummy := DBMS_SQL.Execute(l_sr_tvs_str_cursor_id2);
4907: --EXECUTE IMMEDIATE l_dynamic_sql;
4908: IF (l_sr_tvs_str_cursor_id2 IS NULL) THEN
4909: l_sr_tvs_str_cursor_id2 := DBMS_SQL.Open_Cursor;
4910: END IF;
4911: DBMS_SQL.Parse(l_sr_tvs_str_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4912: DBMS_SQL.Bind_Variable(l_sr_tvs_str_cursor_id2, ':data_set_id', p_data_set_id);
4913: l_dummy := DBMS_SQL.Execute(l_sr_tvs_str_cursor_id2);
4914:
4915: EXCEPTION
4908: IF (l_sr_tvs_str_cursor_id2 IS NULL) THEN
4909: l_sr_tvs_str_cursor_id2 := DBMS_SQL.Open_Cursor;
4910: END IF;
4911: DBMS_SQL.Parse(l_sr_tvs_str_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4912: DBMS_SQL.Bind_Variable(l_sr_tvs_str_cursor_id2, ':data_set_id', p_data_set_id);
4913: l_dummy := DBMS_SQL.Execute(l_sr_tvs_str_cursor_id2);
4914:
4915: EXCEPTION
4916: WHEN OTHERS THEN
4909: l_sr_tvs_str_cursor_id2 := DBMS_SQL.Open_Cursor;
4910: END IF;
4911: DBMS_SQL.Parse(l_sr_tvs_str_cursor_id2, l_dynamic_sql, DBMS_SQL.NATIVE);
4912: DBMS_SQL.Bind_Variable(l_sr_tvs_str_cursor_id2, ':data_set_id', p_data_set_id);
4913: l_dummy := DBMS_SQL.Execute(l_sr_tvs_str_cursor_id2);
4914:
4915: EXCEPTION
4916: WHEN OTHERS THEN
4917: IF (l_bad_tvs_sql_cursor_id IS NULL) THEN
4914:
4915: EXCEPTION
4916: WHEN OTHERS THEN
4917: IF (l_bad_tvs_sql_cursor_id IS NULL) THEN
4918: l_bad_tvs_sql_cursor_id := DBMS_SQL.Open_Cursor;
4919: l_dynamic_sql :=
4920: 'UPDATE '||p_interface_table_name||'
4921: SET PROCESS_STATUS = PROCESS_STATUS + '||G_PS_BAD_TVS_SETUP||'
4922: WHERE DATA_SET_ID = :data_set_id
4922: WHERE DATA_SET_ID = :data_set_id
4923: AND ATTR_INT_NAME = :attr_internal_name
4924: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4925:
4926: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4927: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4928: END IF;
4929: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4930: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4923: AND ATTR_INT_NAME = :attr_internal_name
4924: AND ATTR_GROUP_INT_NAME = :attr_group_int_name';
4925:
4926: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4927: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4928: END IF;
4929: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4930: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4931: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4925:
4926: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4927: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4928: END IF;
4929: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4930: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4931: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4932: END;
4933: END IF;
4926: DBMS_SQL.Parse(l_bad_tvs_sql_cursor_id, l_dynamic_sql, DBMS_SQL.NATIVE);
4927: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4928: END IF;
4929: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4930: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4931: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4932: END;
4933: END IF;
4934: END IF; --l_attr_metadata TRUE/FALSE
4927: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':data_set_id', p_data_set_id);
4928: END IF;
4929: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_group_int_name', l_attr_group_metadata_obj.ATTR_GROUP_NAME);
4930: DBMS_SQL.Bind_Variable(l_bad_tvs_sql_cursor_id, ':attr_internal_name', l_attr_metadata_table_sr(x).ATTR_NAME);
4931: l_dummy := DBMS_SQL.Execute(l_bad_tvs_sql_cursor_id);
4932: END;
4933: END IF;
4934: END IF; --l_attr_metadata TRUE/FALSE
4935: END IF; -- if validation_code is TVS
5437: );
5438: EXCEPTION
5439: WHEN EGO_USER_ATTRS_COMMON_PVT.G_SUBSCRIPTION_EXC THEN
5440: IF (l_pre_event_failed_cursor_id IS NULL) THEN
5441: l_pre_event_failed_cursor_id := DBMS_SQL.Open_Cursor;
5442: END IF;
5443: DBMS_SQL.Parse(l_pre_event_failed_cursor_id, l_pre_event_failed_sql, DBMS_SQL.NATIVE);
5444:
5445: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':data_set_id', p_data_set_id);
5439: WHEN EGO_USER_ATTRS_COMMON_PVT.G_SUBSCRIPTION_EXC THEN
5440: IF (l_pre_event_failed_cursor_id IS NULL) THEN
5441: l_pre_event_failed_cursor_id := DBMS_SQL.Open_Cursor;
5442: END IF;
5443: DBMS_SQL.Parse(l_pre_event_failed_cursor_id, l_pre_event_failed_sql, DBMS_SQL.NATIVE);
5444:
5445: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':data_set_id', p_data_set_id);
5446: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':attr_group_int_name', l_ag_deflatened_row.ATTR_GROUP_INT_NAME);
5447:
5441: l_pre_event_failed_cursor_id := DBMS_SQL.Open_Cursor;
5442: END IF;
5443: DBMS_SQL.Parse(l_pre_event_failed_cursor_id, l_pre_event_failed_sql, DBMS_SQL.NATIVE);
5444:
5445: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':data_set_id', p_data_set_id);
5446: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':attr_group_int_name', l_ag_deflatened_row.ATTR_GROUP_INT_NAME);
5447:
5448: IF(l_pk1_column_name IS NOT NULL ) THEN
5449: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk1_value',l_ag_deflatened_row.PK1) ;
5442: END IF;
5443: DBMS_SQL.Parse(l_pre_event_failed_cursor_id, l_pre_event_failed_sql, DBMS_SQL.NATIVE);
5444:
5445: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':data_set_id', p_data_set_id);
5446: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':attr_group_int_name', l_ag_deflatened_row.ATTR_GROUP_INT_NAME);
5447:
5448: IF(l_pk1_column_name IS NOT NULL ) THEN
5449: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk1_value',l_ag_deflatened_row.PK1) ;
5450: END IF;
5445: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':data_set_id', p_data_set_id);
5446: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':attr_group_int_name', l_ag_deflatened_row.ATTR_GROUP_INT_NAME);
5447:
5448: IF(l_pk1_column_name IS NOT NULL ) THEN
5449: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk1_value',l_ag_deflatened_row.PK1) ;
5450: END IF;
5451: IF(l_pk2_column_name IS NOT NULL ) THEN
5452: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk2_value',l_ag_deflatened_row.PK2) ;
5453: END IF;
5448: IF(l_pk1_column_name IS NOT NULL ) THEN
5449: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk1_value',l_ag_deflatened_row.PK1) ;
5450: END IF;
5451: IF(l_pk2_column_name IS NOT NULL ) THEN
5452: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk2_value',l_ag_deflatened_row.PK2) ;
5453: END IF;
5454: IF(l_pk3_column_name IS NOT NULL ) THEN
5455: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk3_value',l_ag_deflatened_row.PK3) ;
5456: END IF;
5451: IF(l_pk2_column_name IS NOT NULL ) THEN
5452: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk2_value',l_ag_deflatened_row.PK2) ;
5453: END IF;
5454: IF(l_pk3_column_name IS NOT NULL ) THEN
5455: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk3_value',l_ag_deflatened_row.PK3) ;
5456: END IF;
5457: IF(l_pk4_column_name IS NOT NULL ) THEN
5458: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk4_value',l_ag_deflatened_row.PK4) ;
5459: END IF;
5454: IF(l_pk3_column_name IS NOT NULL ) THEN
5455: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk3_value',l_ag_deflatened_row.PK3) ;
5456: END IF;
5457: IF(l_pk4_column_name IS NOT NULL ) THEN
5458: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk4_value',l_ag_deflatened_row.PK4) ;
5459: END IF;
5460: IF(l_pk5_column_name IS NOT NULL ) THEN
5461: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk5_value',l_ag_deflatened_row.PK5) ;
5462: END IF;
5457: IF(l_pk4_column_name IS NOT NULL ) THEN
5458: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk4_value',l_ag_deflatened_row.PK4) ;
5459: END IF;
5460: IF(l_pk5_column_name IS NOT NULL ) THEN
5461: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk5_value',l_ag_deflatened_row.PK5) ;
5462: END IF;
5463:
5464: IF(l_data_level_col_exists) THEN
5465: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5461: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk5_value',l_ag_deflatened_row.PK5) ;
5462: END IF;
5463:
5464: IF(l_data_level_col_exists) THEN
5465: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5466: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5467: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5468: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5469: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5462: END IF;
5463:
5464: IF(l_data_level_col_exists) THEN
5465: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5466: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5467: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5468: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5469: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5470: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5463:
5464: IF(l_data_level_col_exists) THEN
5465: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5466: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5467: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5468: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5469: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5470: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5471: ELSE
5464: IF(l_data_level_col_exists) THEN
5465: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5466: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5467: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5468: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5469: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5470: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5471: ELSE
5472: IF(l_data_level_column_1 IS NOT NULL ) THEN
5465: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5466: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5467: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5468: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5469: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5470: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5471: ELSE
5472: IF(l_data_level_column_1 IS NOT NULL ) THEN
5473: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl1_value',l_ag_deflatened_row.DL1) ;
5466: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5467: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5468: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5469: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5470: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5471: ELSE
5472: IF(l_data_level_column_1 IS NOT NULL ) THEN
5473: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl1_value',l_ag_deflatened_row.DL1) ;
5474: END IF;
5469: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5470: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5471: ELSE
5472: IF(l_data_level_column_1 IS NOT NULL ) THEN
5473: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl1_value',l_ag_deflatened_row.DL1) ;
5474: END IF;
5475: IF(l_data_level_column_2 IS NOT NULL ) THEN
5476: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl2_value',l_ag_deflatened_row.DL2) ;
5477: END IF;
5472: IF(l_data_level_column_1 IS NOT NULL ) THEN
5473: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl1_value',l_ag_deflatened_row.DL1) ;
5474: END IF;
5475: IF(l_data_level_column_2 IS NOT NULL ) THEN
5476: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl2_value',l_ag_deflatened_row.DL2) ;
5477: END IF;
5478: IF(l_data_level_column_3 IS NOT NULL ) THEN
5479: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl3_value',l_ag_deflatened_row.DL3) ;
5480: END IF;
5475: IF(l_data_level_column_2 IS NOT NULL ) THEN
5476: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl2_value',l_ag_deflatened_row.DL2) ;
5477: END IF;
5478: IF(l_data_level_column_3 IS NOT NULL ) THEN
5479: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl3_value',l_ag_deflatened_row.DL3) ;
5480: END IF;
5481: END IF;
5482:
5483: l_dummy := DBMS_SQL.Execute(l_pre_event_failed_cursor_id);
5479: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl3_value',l_ag_deflatened_row.DL3) ;
5480: END IF;
5481: END IF;
5482:
5483: l_dummy := DBMS_SQL.Execute(l_pre_event_failed_cursor_id);
5484: DBMS_SQL.Close_Cursor (l_pre_event_failed_cursor_id);
5485:
5486: END;
5487: END LOOP;--iteration in l_dynamic_cursor ends
5480: END IF;
5481: END IF;
5482:
5483: l_dummy := DBMS_SQL.Execute(l_pre_event_failed_cursor_id);
5484: DBMS_SQL.Close_Cursor (l_pre_event_failed_cursor_id);
5485:
5486: END;
5487: END LOOP;--iteration in l_dynamic_cursor ends
5488:
5610: );
5611: EXCEPTION
5612: WHEN EGO_USER_ATTRS_COMMON_PVT.G_SUBSCRIPTION_EXC THEN
5613: IF (l_pre_event_failed_cursor_id IS NULL) THEN
5614: l_pre_event_failed_cursor_id := DBMS_SQL.Open_Cursor;
5615: END IF;
5616:
5617: DBMS_SQL.Parse(l_pre_event_failed_cursor_id, l_pre_event_failed_sql, DBMS_SQL.NATIVE);
5618:
5613: IF (l_pre_event_failed_cursor_id IS NULL) THEN
5614: l_pre_event_failed_cursor_id := DBMS_SQL.Open_Cursor;
5615: END IF;
5616:
5617: DBMS_SQL.Parse(l_pre_event_failed_cursor_id, l_pre_event_failed_sql, DBMS_SQL.NATIVE);
5618:
5619: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':data_set_id', p_data_set_id);
5620: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':attr_group_int_name', l_ag_deflatened_row.ATTR_GROUP_INT_NAME);
5621:
5615: END IF;
5616:
5617: DBMS_SQL.Parse(l_pre_event_failed_cursor_id, l_pre_event_failed_sql, DBMS_SQL.NATIVE);
5618:
5619: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':data_set_id', p_data_set_id);
5620: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':attr_group_int_name', l_ag_deflatened_row.ATTR_GROUP_INT_NAME);
5621:
5622: IF(l_pk1_column_name IS NOT NULL ) THEN
5623: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk1_value',l_ag_deflatened_row.PK1) ;
5616:
5617: DBMS_SQL.Parse(l_pre_event_failed_cursor_id, l_pre_event_failed_sql, DBMS_SQL.NATIVE);
5618:
5619: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':data_set_id', p_data_set_id);
5620: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':attr_group_int_name', l_ag_deflatened_row.ATTR_GROUP_INT_NAME);
5621:
5622: IF(l_pk1_column_name IS NOT NULL ) THEN
5623: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk1_value',l_ag_deflatened_row.PK1) ;
5624: END IF;
5619: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':data_set_id', p_data_set_id);
5620: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id, ':attr_group_int_name', l_ag_deflatened_row.ATTR_GROUP_INT_NAME);
5621:
5622: IF(l_pk1_column_name IS NOT NULL ) THEN
5623: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk1_value',l_ag_deflatened_row.PK1) ;
5624: END IF;
5625: IF(l_pk2_column_name IS NOT NULL ) THEN
5626: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk2_value',l_ag_deflatened_row.PK2) ;
5627: END IF;
5622: IF(l_pk1_column_name IS NOT NULL ) THEN
5623: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk1_value',l_ag_deflatened_row.PK1) ;
5624: END IF;
5625: IF(l_pk2_column_name IS NOT NULL ) THEN
5626: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk2_value',l_ag_deflatened_row.PK2) ;
5627: END IF;
5628: IF(l_pk3_column_name IS NOT NULL ) THEN
5629: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk3_value',l_ag_deflatened_row.PK3) ;
5630: END IF;
5625: IF(l_pk2_column_name IS NOT NULL ) THEN
5626: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk2_value',l_ag_deflatened_row.PK2) ;
5627: END IF;
5628: IF(l_pk3_column_name IS NOT NULL ) THEN
5629: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk3_value',l_ag_deflatened_row.PK3) ;
5630: END IF;
5631: IF(l_pk4_column_name IS NOT NULL ) THEN
5632: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk4_value',l_ag_deflatened_row.PK4) ;
5633: END IF;
5628: IF(l_pk3_column_name IS NOT NULL ) THEN
5629: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk3_value',l_ag_deflatened_row.PK3) ;
5630: END IF;
5631: IF(l_pk4_column_name IS NOT NULL ) THEN
5632: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk4_value',l_ag_deflatened_row.PK4) ;
5633: END IF;
5634: IF(l_pk5_column_name IS NOT NULL ) THEN
5635: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk5_value',l_ag_deflatened_row.PK5) ;
5636: END IF;
5631: IF(l_pk4_column_name IS NOT NULL ) THEN
5632: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk4_value',l_ag_deflatened_row.PK4) ;
5633: END IF;
5634: IF(l_pk5_column_name IS NOT NULL ) THEN
5635: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk5_value',l_ag_deflatened_row.PK5) ;
5636: END IF;
5637:
5638: IF(l_data_level_col_exists) THEN
5639: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5635: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':pk5_value',l_ag_deflatened_row.PK5) ;
5636: END IF;
5637:
5638: IF(l_data_level_col_exists) THEN
5639: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5640: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5641: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5642: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5643: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5636: END IF;
5637:
5638: IF(l_data_level_col_exists) THEN
5639: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5640: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5641: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5642: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5643: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5644: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5637:
5638: IF(l_data_level_col_exists) THEN
5639: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5640: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5641: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5642: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5643: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5644: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5645: ELSE
5638: IF(l_data_level_col_exists) THEN
5639: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5640: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5641: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5642: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5643: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5644: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5645: ELSE
5646: IF(l_data_level_column_1 IS NOT NULL ) THEN
5639: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_id',l_ag_deflatened_row.DATA_LEVEL_ID) ;
5640: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5641: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5642: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5643: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5644: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5645: ELSE
5646: IF(l_data_level_column_1 IS NOT NULL ) THEN
5647: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl1_value',l_ag_deflatened_row.DL1) ;
5640: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk1_val',l_ag_deflatened_row.DL1) ;
5641: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk2_val',l_ag_deflatened_row.DL2) ;
5642: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk3_val',l_ag_deflatened_row.DL3) ;
5643: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5644: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5645: ELSE
5646: IF(l_data_level_column_1 IS NOT NULL ) THEN
5647: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl1_value',l_ag_deflatened_row.DL1) ;
5648: END IF;
5643: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk4_val',l_ag_deflatened_row.DL4) ;
5644: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl_pk5_val',l_ag_deflatened_row.DL5) ;
5645: ELSE
5646: IF(l_data_level_column_1 IS NOT NULL ) THEN
5647: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl1_value',l_ag_deflatened_row.DL1) ;
5648: END IF;
5649: IF(l_data_level_column_2 IS NOT NULL ) THEN
5650: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl2_value',l_ag_deflatened_row.DL2) ;
5651: END IF;
5646: IF(l_data_level_column_1 IS NOT NULL ) THEN
5647: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl1_value',l_ag_deflatened_row.DL1) ;
5648: END IF;
5649: IF(l_data_level_column_2 IS NOT NULL ) THEN
5650: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl2_value',l_ag_deflatened_row.DL2) ;
5651: END IF;
5652: IF(l_data_level_column_3 IS NOT NULL ) THEN
5653: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl3_value',l_ag_deflatened_row.DL3) ;
5654: END IF;
5649: IF(l_data_level_column_2 IS NOT NULL ) THEN
5650: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl2_value',l_ag_deflatened_row.DL2) ;
5651: END IF;
5652: IF(l_data_level_column_3 IS NOT NULL ) THEN
5653: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl3_value',l_ag_deflatened_row.DL3) ;
5654: END IF;
5655: END IF;
5656:
5657: l_dummy := DBMS_SQL.Execute(l_pre_event_failed_cursor_id);
5653: DBMS_SQL.Bind_Variable(l_pre_event_failed_cursor_id,':dl3_value',l_ag_deflatened_row.DL3) ;
5654: END IF;
5655: END IF;
5656:
5657: l_dummy := DBMS_SQL.Execute(l_pre_event_failed_cursor_id);
5658: DBMS_SQL.Close_Cursor (l_pre_event_failed_cursor_id);
5659:
5660: END;
5661:
5654: END IF;
5655: END IF;
5656:
5657: l_dummy := DBMS_SQL.Execute(l_pre_event_failed_cursor_id);
5658: DBMS_SQL.Close_Cursor (l_pre_event_failed_cursor_id);
5659:
5660: END;
5661:
5662: END LOOP;--iteration in l_dynamic_cursor ends
6924: END IF;
6925: END IF;
6926:
6927: IF (l_req_num_cursor_id) IS NOT NULL THEN
6928: DBMS_SQL.Close_Cursor(l_req_num_cursor_id);
6929: END IF;
6930: IF (l_req_char_cursor_id) IS NOT NULL THEN
6931: DBMS_SQL.Close_Cursor(l_req_char_cursor_id);
6932: END IF;
6927: IF (l_req_num_cursor_id) IS NOT NULL THEN
6928: DBMS_SQL.Close_Cursor(l_req_num_cursor_id);
6929: END IF;
6930: IF (l_req_char_cursor_id) IS NOT NULL THEN
6931: DBMS_SQL.Close_Cursor(l_req_char_cursor_id);
6932: END IF;
6933: IF (l_req_date_cursor_id) IS NOT NULL THEN
6934: DBMS_SQL.Close_Cursor(l_req_date_cursor_id);
6935: END IF;
6930: IF (l_req_char_cursor_id) IS NOT NULL THEN
6931: DBMS_SQL.Close_Cursor(l_req_char_cursor_id);
6932: END IF;
6933: IF (l_req_date_cursor_id) IS NOT NULL THEN
6934: DBMS_SQL.Close_Cursor(l_req_date_cursor_id);
6935: END IF;
6936: IF (l_default_num_cursor_id) IS NOT NULL THEN
6937: DBMS_SQL.Close_Cursor(l_default_num_cursor_id);
6938: END IF;
6933: IF (l_req_date_cursor_id) IS NOT NULL THEN
6934: DBMS_SQL.Close_Cursor(l_req_date_cursor_id);
6935: END IF;
6936: IF (l_default_num_cursor_id) IS NOT NULL THEN
6937: DBMS_SQL.Close_Cursor(l_default_num_cursor_id);
6938: END IF;
6939: IF (l_default_date_cursor_id) IS NOT NULL THEN
6940: DBMS_SQL.Close_Cursor(l_default_date_cursor_id);
6941: END IF;
6936: IF (l_default_num_cursor_id) IS NOT NULL THEN
6937: DBMS_SQL.Close_Cursor(l_default_num_cursor_id);
6938: END IF;
6939: IF (l_default_date_cursor_id) IS NOT NULL THEN
6940: DBMS_SQL.Close_Cursor(l_default_date_cursor_id);
6941: END IF;
6942: IF (l_default_char_cursor_id) IS NOT NULL THEN
6943: DBMS_SQL.Close_Cursor(l_default_char_cursor_id);
6944: END IF;
6939: IF (l_default_date_cursor_id) IS NOT NULL THEN
6940: DBMS_SQL.Close_Cursor(l_default_date_cursor_id);
6941: END IF;
6942: IF (l_default_char_cursor_id) IS NOT NULL THEN
6943: DBMS_SQL.Close_Cursor(l_default_char_cursor_id);
6944: END IF;
6945: IF (l_bad_tvs_sql_cursor_id) IS NOT NULL THEN
6946: DBMS_SQL.Close_Cursor(l_bad_tvs_sql_cursor_id);
6947: END IF;
6942: IF (l_default_char_cursor_id) IS NOT NULL THEN
6943: DBMS_SQL.Close_Cursor(l_default_char_cursor_id);
6944: END IF;
6945: IF (l_bad_tvs_sql_cursor_id) IS NOT NULL THEN
6946: DBMS_SQL.Close_Cursor(l_bad_tvs_sql_cursor_id);
6947: END IF;
6948:
6949: IF (l_sr_tvs_num_cursor_id1) IS NOT NULL THEN
6950: DBMS_SQL.Close_Cursor(l_sr_tvs_num_cursor_id1);
6946: DBMS_SQL.Close_Cursor(l_bad_tvs_sql_cursor_id);
6947: END IF;
6948:
6949: IF (l_sr_tvs_num_cursor_id1) IS NOT NULL THEN
6950: DBMS_SQL.Close_Cursor(l_sr_tvs_num_cursor_id1);
6951: END IF;
6952: IF (l_sr_tvs_num_cursor_id2) IS NOT NULL THEN
6953: DBMS_SQL.Close_Cursor(l_sr_tvs_num_cursor_id2);
6954: END IF;
6949: IF (l_sr_tvs_num_cursor_id1) IS NOT NULL THEN
6950: DBMS_SQL.Close_Cursor(l_sr_tvs_num_cursor_id1);
6951: END IF;
6952: IF (l_sr_tvs_num_cursor_id2) IS NOT NULL THEN
6953: DBMS_SQL.Close_Cursor(l_sr_tvs_num_cursor_id2);
6954: END IF;
6955: IF (l_sr_tvs_date_cursor_id1) IS NOT NULL THEN
6956: DBMS_SQL.Close_Cursor(l_sr_tvs_date_cursor_id1);
6957: END IF;
6952: IF (l_sr_tvs_num_cursor_id2) IS NOT NULL THEN
6953: DBMS_SQL.Close_Cursor(l_sr_tvs_num_cursor_id2);
6954: END IF;
6955: IF (l_sr_tvs_date_cursor_id1) IS NOT NULL THEN
6956: DBMS_SQL.Close_Cursor(l_sr_tvs_date_cursor_id1);
6957: END IF;
6958: IF (l_sr_tvs_date_cursor_id2) IS NOT NULL THEN
6959: DBMS_SQL.Close_Cursor(l_sr_tvs_date_cursor_id2);
6960: END IF;
6955: IF (l_sr_tvs_date_cursor_id1) IS NOT NULL THEN
6956: DBMS_SQL.Close_Cursor(l_sr_tvs_date_cursor_id1);
6957: END IF;
6958: IF (l_sr_tvs_date_cursor_id2) IS NOT NULL THEN
6959: DBMS_SQL.Close_Cursor(l_sr_tvs_date_cursor_id2);
6960: END IF;
6961: IF (l_sr_tvs_str_cursor_id1) IS NOT NULL THEN
6962: DBMS_SQL.Close_Cursor(l_sr_tvs_str_cursor_id1);
6963: END IF;
6958: IF (l_sr_tvs_date_cursor_id2) IS NOT NULL THEN
6959: DBMS_SQL.Close_Cursor(l_sr_tvs_date_cursor_id2);
6960: END IF;
6961: IF (l_sr_tvs_str_cursor_id1) IS NOT NULL THEN
6962: DBMS_SQL.Close_Cursor(l_sr_tvs_str_cursor_id1);
6963: END IF;
6964: IF (l_sr_tvs_str_cursor_id2) IS NOT NULL THEN
6965: DBMS_SQL.Close_Cursor(l_sr_tvs_str_cursor_id2);
6966: END IF;
6961: IF (l_sr_tvs_str_cursor_id1) IS NOT NULL THEN
6962: DBMS_SQL.Close_Cursor(l_sr_tvs_str_cursor_id1);
6963: END IF;
6964: IF (l_sr_tvs_str_cursor_id2) IS NOT NULL THEN
6965: DBMS_SQL.Close_Cursor(l_sr_tvs_str_cursor_id2);
6966: END IF;
6967:
6968: IF (l_tvs_char_cursor_id) IS NOT NULL THEN
6969: DBMS_SQL.Close_Cursor(l_tvs_char_cursor_id);
6965: DBMS_SQL.Close_Cursor(l_sr_tvs_str_cursor_id2);
6966: END IF;
6967:
6968: IF (l_tvs_char_cursor_id) IS NOT NULL THEN
6969: DBMS_SQL.Close_Cursor(l_tvs_char_cursor_id);
6970: END IF;
6971: IF (l_tvs_num_cursor_id) IS NOT NULL THEN
6972: DBMS_SQL.Close_Cursor(l_tvs_num_cursor_id);
6973: END IF;
6968: IF (l_tvs_char_cursor_id) IS NOT NULL THEN
6969: DBMS_SQL.Close_Cursor(l_tvs_char_cursor_id);
6970: END IF;
6971: IF (l_tvs_num_cursor_id) IS NOT NULL THEN
6972: DBMS_SQL.Close_Cursor(l_tvs_num_cursor_id);
6973: END IF;
6974: IF (l_tvs_date_cursor_id) IS NOT NULL THEN
6975: DBMS_SQL.Close_Cursor(l_tvs_date_cursor_id);
6976: END IF;
6971: IF (l_tvs_num_cursor_id) IS NOT NULL THEN
6972: DBMS_SQL.Close_Cursor(l_tvs_num_cursor_id);
6973: END IF;
6974: IF (l_tvs_date_cursor_id) IS NOT NULL THEN
6975: DBMS_SQL.Close_Cursor(l_tvs_date_cursor_id);
6976: END IF;
6977: IF (l_bad_bindattrs_tvs_cursor_id) IS NOT NULL THEN
6978: DBMS_SQL.Close_Cursor(l_bad_bindattrs_tvs_cursor_id);
6979: END IF;
6974: IF (l_tvs_date_cursor_id) IS NOT NULL THEN
6975: DBMS_SQL.Close_Cursor(l_tvs_date_cursor_id);
6976: END IF;
6977: IF (l_bad_bindattrs_tvs_cursor_id) IS NOT NULL THEN
6978: DBMS_SQL.Close_Cursor(l_bad_bindattrs_tvs_cursor_id);
6979: END IF;
6980:
6981: --------------------------------------------------
6982: -- MARKING ALL THE ROWS AS 3 WHICH HAVE ERRORED --
9244: ---------------------------------
9245: -- Executing the Final DML --
9246: ----------------------------------
9247: IF(l_dyn_cursor IS NULL ) THEN
9248: l_dyn_cursor := DBMS_SQL.Open_Cursor;
9249: END IF;
9250: DBMS_SQL.Parse(l_dyn_cursor, l_dynamic_sql, DBMS_SQL.NATIVE);
9251: DBMS_SQL.Bind_Variable(l_dyn_cursor, ':data_set_id', p_data_set_id);
9252: l_dummy := DBMS_SQL.Execute(l_dyn_cursor);
9246: ----------------------------------
9247: IF(l_dyn_cursor IS NULL ) THEN
9248: l_dyn_cursor := DBMS_SQL.Open_Cursor;
9249: END IF;
9250: DBMS_SQL.Parse(l_dyn_cursor, l_dynamic_sql, DBMS_SQL.NATIVE);
9251: DBMS_SQL.Bind_Variable(l_dyn_cursor, ':data_set_id', p_data_set_id);
9252: l_dummy := DBMS_SQL.Execute(l_dyn_cursor);
9253: END LOOP; --Ending the loop for distinct AG's
9254:
9247: IF(l_dyn_cursor IS NULL ) THEN
9248: l_dyn_cursor := DBMS_SQL.Open_Cursor;
9249: END IF;
9250: DBMS_SQL.Parse(l_dyn_cursor, l_dynamic_sql, DBMS_SQL.NATIVE);
9251: DBMS_SQL.Bind_Variable(l_dyn_cursor, ':data_set_id', p_data_set_id);
9252: l_dummy := DBMS_SQL.Execute(l_dyn_cursor);
9253: END LOOP; --Ending the loop for distinct AG's
9254:
9255: IF (l_dyn_cursor IS NOT NULL) THEN
9248: l_dyn_cursor := DBMS_SQL.Open_Cursor;
9249: END IF;
9250: DBMS_SQL.Parse(l_dyn_cursor, l_dynamic_sql, DBMS_SQL.NATIVE);
9251: DBMS_SQL.Bind_Variable(l_dyn_cursor, ':data_set_id', p_data_set_id);
9252: l_dummy := DBMS_SQL.Execute(l_dyn_cursor);
9253: END LOOP; --Ending the loop for distinct AG's
9254:
9255: IF (l_dyn_cursor IS NOT NULL) THEN
9256: DBMS_SQL.Close_Cursor(l_dyn_cursor);
9252: l_dummy := DBMS_SQL.Execute(l_dyn_cursor);
9253: END LOOP; --Ending the loop for distinct AG's
9254:
9255: IF (l_dyn_cursor IS NOT NULL) THEN
9256: DBMS_SQL.Close_Cursor(l_dyn_cursor);
9257: END IF;
9258:
9259: --------------------------------
9260: -- Standard check of p_commit --