505: Token4 => 'PARAM3',
506: Token4Val => TO_CHAR(TargetAxisSetId));
507:
508: /* Get all the relevant records. */
509: CursorId := DBMS_SQL.open_cursor;
510: DBMS_SQL.parse(CursorId,
511: 'SELECT rowid, ledger_id, alc_ledger_currency' ||
512: ' FROM rg_report_axis_contents@' || G_LinkName ||
513: ' WHERE axis_seq = ' || TO_CHAR(SourceAxisSeq) ||
506: Token4Val => TO_CHAR(TargetAxisSetId));
507:
508: /* Get all the relevant records. */
509: CursorId := DBMS_SQL.open_cursor;
510: DBMS_SQL.parse(CursorId,
511: 'SELECT rowid, ledger_id, alc_ledger_currency' ||
512: ' FROM rg_report_axis_contents@' || G_LinkName ||
513: ' WHERE axis_seq = ' || TO_CHAR(SourceAxisSeq) ||
514: ' AND axis_set_id = ' || TO_CHAR(SourceAxisSetId),
511: 'SELECT rowid, ledger_id, alc_ledger_currency' ||
512: ' FROM rg_report_axis_contents@' || G_LinkName ||
513: ' WHERE axis_seq = ' || TO_CHAR(SourceAxisSeq) ||
514: ' AND axis_set_id = ' || TO_CHAR(SourceAxisSetId),
515: DBMS_SQL.v7);
516: DBMS_SQL.define_column_rowid(CursorId, 1, RecRowId);
517: DBMS_SQL.define_column(CursorId, 2, LedgerId);
518: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
519: ExecuteValue := DBMS_SQL.execute(CursorId);
512: ' FROM rg_report_axis_contents@' || G_LinkName ||
513: ' WHERE axis_seq = ' || TO_CHAR(SourceAxisSeq) ||
514: ' AND axis_set_id = ' || TO_CHAR(SourceAxisSetId),
515: DBMS_SQL.v7);
516: DBMS_SQL.define_column_rowid(CursorId, 1, RecRowId);
517: DBMS_SQL.define_column(CursorId, 2, LedgerId);
518: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
519: ExecuteValue := DBMS_SQL.execute(CursorId);
520: LOOP
513: ' WHERE axis_seq = ' || TO_CHAR(SourceAxisSeq) ||
514: ' AND axis_set_id = ' || TO_CHAR(SourceAxisSetId),
515: DBMS_SQL.v7);
516: DBMS_SQL.define_column_rowid(CursorId, 1, RecRowId);
517: DBMS_SQL.define_column(CursorId, 2, LedgerId);
518: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
519: ExecuteValue := DBMS_SQL.execute(CursorId);
520: LOOP
521: /* For each record, check the ledger info and insert the record. */
514: ' AND axis_set_id = ' || TO_CHAR(SourceAxisSetId),
515: DBMS_SQL.v7);
516: DBMS_SQL.define_column_rowid(CursorId, 1, RecRowId);
517: DBMS_SQL.define_column(CursorId, 2, LedgerId);
518: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
519: ExecuteValue := DBMS_SQL.execute(CursorId);
520: LOOP
521: /* For each record, check the ledger info and insert the record. */
522: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
515: DBMS_SQL.v7);
516: DBMS_SQL.define_column_rowid(CursorId, 1, RecRowId);
517: DBMS_SQL.define_column(CursorId, 2, LedgerId);
518: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
519: ExecuteValue := DBMS_SQL.execute(CursorId);
520: LOOP
521: /* For each record, check the ledger info and insert the record. */
522: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
523: DBMS_SQL.column_value_rowid(CursorId, 1, RecRowId);
518: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
519: ExecuteValue := DBMS_SQL.execute(CursorId);
520: LOOP
521: /* For each record, check the ledger info and insert the record. */
522: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
523: DBMS_SQL.column_value_rowid(CursorId, 1, RecRowId);
524: DBMS_SQL.column_value(CursorId, 2, LedgerId);
525: DBMS_SQL.column_value(CursorId, 3, LedgerCurrency);
526:
519: ExecuteValue := DBMS_SQL.execute(CursorId);
520: LOOP
521: /* For each record, check the ledger info and insert the record. */
522: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
523: DBMS_SQL.column_value_rowid(CursorId, 1, RecRowId);
524: DBMS_SQL.column_value(CursorId, 2, LedgerId);
525: DBMS_SQL.column_value(CursorId, 3, LedgerCurrency);
526:
527: IF (LedgerId IS NOT NULL) THEN
520: LOOP
521: /* For each record, check the ledger info and insert the record. */
522: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
523: DBMS_SQL.column_value_rowid(CursorId, 1, RecRowId);
524: DBMS_SQL.column_value(CursorId, 2, LedgerId);
525: DBMS_SQL.column_value(CursorId, 3, LedgerCurrency);
526:
527: IF (LedgerId IS NOT NULL) THEN
528: RG_XFER_UTILS_PKG.get_target_ldg_from_source_ldg(
521: /* For each record, check the ledger info and insert the record. */
522: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
523: DBMS_SQL.column_value_rowid(CursorId, 1, RecRowId);
524: DBMS_SQL.column_value(CursorId, 2, LedgerId);
525: DBMS_SQL.column_value(CursorId, 3, LedgerCurrency);
526:
527: IF (LedgerId IS NOT NULL) THEN
528: RG_XFER_UTILS_PKG.get_target_ldg_from_source_ldg(
529: LedgerId, LedgerName, LedgerCurrency);
568: /* No more rows */
569: EXIT;
570: END IF;
571: END LOOP;
572: DBMS_SQL.close_cursor(CursorId);
573:
574: RG_XFER_UTILS_PKG.display_log(
575: MsgLevel => G_ML_Full,
576: MsgName => 'RG_XFER_L_EXIT_ROUTINE',
627: 'SELECT segment_name FROM rg_report_axis_sets@' ||
628: G_LinkName || ' WHERE axis_set_id = ' ||
629: TO_CHAR(SourceAxisSetId), 30);
630:
631: CursorId := DBMS_SQL.open_cursor;
632: DBMS_SQL.parse(CursorId,
633: 'SELECT axis_seq, segment_override_value,' ||
634: ' override_alc_ledger_currency FROM rg_report_axes@' ||
635: G_LinkName || ' WHERE axis_set_id =' ||
628: G_LinkName || ' WHERE axis_set_id = ' ||
629: TO_CHAR(SourceAxisSetId), 30);
630:
631: CursorId := DBMS_SQL.open_cursor;
632: DBMS_SQL.parse(CursorId,
633: 'SELECT axis_seq, segment_override_value,' ||
634: ' override_alc_ledger_currency FROM rg_report_axes@' ||
635: G_LinkName || ' WHERE axis_set_id =' ||
636: TO_CHAR(SourceAxisSetId),
633: 'SELECT axis_seq, segment_override_value,' ||
634: ' override_alc_ledger_currency FROM rg_report_axes@' ||
635: G_LinkName || ' WHERE axis_set_id =' ||
636: TO_CHAR(SourceAxisSetId),
637: DBMS_SQL.v7);
638: DBMS_SQL.define_column(CursorId, 1, AxisSeq);
639: DBMS_SQL.define_column(CursorId, 2, OverrideVal, 60);
640: DBMS_SQL.define_column(CursorId, 3, OverrideCurr, 15);
641: ExecuteValue := DBMS_SQL.execute(CursorId);
634: ' override_alc_ledger_currency FROM rg_report_axes@' ||
635: G_LinkName || ' WHERE axis_set_id =' ||
636: TO_CHAR(SourceAxisSetId),
637: DBMS_SQL.v7);
638: DBMS_SQL.define_column(CursorId, 1, AxisSeq);
639: DBMS_SQL.define_column(CursorId, 2, OverrideVal, 60);
640: DBMS_SQL.define_column(CursorId, 3, OverrideCurr, 15);
641: ExecuteValue := DBMS_SQL.execute(CursorId);
642: LOOP
635: G_LinkName || ' WHERE axis_set_id =' ||
636: TO_CHAR(SourceAxisSetId),
637: DBMS_SQL.v7);
638: DBMS_SQL.define_column(CursorId, 1, AxisSeq);
639: DBMS_SQL.define_column(CursorId, 2, OverrideVal, 60);
640: DBMS_SQL.define_column(CursorId, 3, OverrideCurr, 15);
641: ExecuteValue := DBMS_SQL.execute(CursorId);
642: LOOP
643: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
636: TO_CHAR(SourceAxisSetId),
637: DBMS_SQL.v7);
638: DBMS_SQL.define_column(CursorId, 1, AxisSeq);
639: DBMS_SQL.define_column(CursorId, 2, OverrideVal, 60);
640: DBMS_SQL.define_column(CursorId, 3, OverrideCurr, 15);
641: ExecuteValue := DBMS_SQL.execute(CursorId);
642: LOOP
643: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
644: DBMS_SQL.column_value(CursorId, 1, AxisSeq);
637: DBMS_SQL.v7);
638: DBMS_SQL.define_column(CursorId, 1, AxisSeq);
639: DBMS_SQL.define_column(CursorId, 2, OverrideVal, 60);
640: DBMS_SQL.define_column(CursorId, 3, OverrideCurr, 15);
641: ExecuteValue := DBMS_SQL.execute(CursorId);
642: LOOP
643: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
644: DBMS_SQL.column_value(CursorId, 1, AxisSeq);
645: DBMS_SQL.column_value(CursorId, 2, OverrideVal);
639: DBMS_SQL.define_column(CursorId, 2, OverrideVal, 60);
640: DBMS_SQL.define_column(CursorId, 3, OverrideCurr, 15);
641: ExecuteValue := DBMS_SQL.execute(CursorId);
642: LOOP
643: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
644: DBMS_SQL.column_value(CursorId, 1, AxisSeq);
645: DBMS_SQL.column_value(CursorId, 2, OverrideVal);
646: DBMS_SQL.column_value(CursorId, 3, OverrideCurr);
647:
640: DBMS_SQL.define_column(CursorId, 3, OverrideCurr, 15);
641: ExecuteValue := DBMS_SQL.execute(CursorId);
642: LOOP
643: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
644: DBMS_SQL.column_value(CursorId, 1, AxisSeq);
645: DBMS_SQL.column_value(CursorId, 2, OverrideVal);
646: DBMS_SQL.column_value(CursorId, 3, OverrideCurr);
647:
648: IF (AxisSegmentName = 'LEDGER_SEGMENT') THEN
641: ExecuteValue := DBMS_SQL.execute(CursorId);
642: LOOP
643: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
644: DBMS_SQL.column_value(CursorId, 1, AxisSeq);
645: DBMS_SQL.column_value(CursorId, 2, OverrideVal);
646: DBMS_SQL.column_value(CursorId, 3, OverrideCurr);
647:
648: IF (AxisSegmentName = 'LEDGER_SEGMENT') THEN
649: LedgerId := TO_NUMBER(OverrideVal);
642: LOOP
643: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
644: DBMS_SQL.column_value(CursorId, 1, AxisSeq);
645: DBMS_SQL.column_value(CursorId, 2, OverrideVal);
646: DBMS_SQL.column_value(CursorId, 3, OverrideCurr);
647:
648: IF (AxisSegmentName = 'LEDGER_SEGMENT') THEN
649: LedgerId := TO_NUMBER(OverrideVal);
650: IF (OverrideVal IS NOT NULL) THEN
759: Token1Val=> TO_CHAR(TargetExceptionId));
760: RG_XFER_UTILS_PKG.insert_rows(
761: SQLString, TargetAxisSetId, UseCOAId=>FALSE);
762:
763: TempCursorId := DBMS_SQL.open_cursor;
764: DBMS_SQL.parse(
765: TempCursorId,
766: 'SELECT exception_id FROM rg_report_exception_flags@' || G_LinkName||
767: ' WHERE axis_set_id = ' || TO_CHAR(SourceAxisSetId) ||
760: RG_XFER_UTILS_PKG.insert_rows(
761: SQLString, TargetAxisSetId, UseCOAId=>FALSE);
762:
763: TempCursorId := DBMS_SQL.open_cursor;
764: DBMS_SQL.parse(
765: TempCursorId,
766: 'SELECT exception_id FROM rg_report_exception_flags@' || G_LinkName||
767: ' WHERE axis_set_id = ' || TO_CHAR(SourceAxisSetId) ||
768: ' AND axis_seq = ' || TO_CHAR(AxisSeq),
765: TempCursorId,
766: 'SELECT exception_id FROM rg_report_exception_flags@' || G_LinkName||
767: ' WHERE axis_set_id = ' || TO_CHAR(SourceAxisSetId) ||
768: ' AND axis_seq = ' || TO_CHAR(AxisSeq),
769: DBMS_SQL.v7);
770: DBMS_SQL.define_column(TempCursorId, 1, SourceExceptionId);
771: ExecuteValue := DBMS_SQL.execute_and_fetch(TempCursorId);
772: IF (ExecuteValue > 0) THEN
773: DBMS_SQL.column_value(TempCursorId, 1, SourceExceptionId);
766: 'SELECT exception_id FROM rg_report_exception_flags@' || G_LinkName||
767: ' WHERE axis_set_id = ' || TO_CHAR(SourceAxisSetId) ||
768: ' AND axis_seq = ' || TO_CHAR(AxisSeq),
769: DBMS_SQL.v7);
770: DBMS_SQL.define_column(TempCursorId, 1, SourceExceptionId);
771: ExecuteValue := DBMS_SQL.execute_and_fetch(TempCursorId);
772: IF (ExecuteValue > 0) THEN
773: DBMS_SQL.column_value(TempCursorId, 1, SourceExceptionId);
774: SQLString := ExceptionsString || G_LinkName ||
767: ' WHERE axis_set_id = ' || TO_CHAR(SourceAxisSetId) ||
768: ' AND axis_seq = ' || TO_CHAR(AxisSeq),
769: DBMS_SQL.v7);
770: DBMS_SQL.define_column(TempCursorId, 1, SourceExceptionId);
771: ExecuteValue := DBMS_SQL.execute_and_fetch(TempCursorId);
772: IF (ExecuteValue > 0) THEN
773: DBMS_SQL.column_value(TempCursorId, 1, SourceExceptionId);
774: SQLString := ExceptionsString || G_LinkName ||
775: ' WHERE exception_id = ' || TO_CHAR(SourceExceptionId);
769: DBMS_SQL.v7);
770: DBMS_SQL.define_column(TempCursorId, 1, SourceExceptionId);
771: ExecuteValue := DBMS_SQL.execute_and_fetch(TempCursorId);
772: IF (ExecuteValue > 0) THEN
773: DBMS_SQL.column_value(TempCursorId, 1, SourceExceptionId);
774: SQLString := ExceptionsString || G_LinkName ||
775: ' WHERE exception_id = ' || TO_CHAR(SourceExceptionId);
776: RG_XFER_UTILS_PKG.substitute_tokens(
777: SQLString,
781: SQLString,
782: TargetAxisSetId,
783: UseCOAId=>FALSE);
784: END IF;
785: DBMS_SQL.close_cursor(TempCursorId);
786: END IF;
787:
788: ELSE
789: /* No more rows */
789: /* No more rows */
790: EXIT;
791: END IF;
792: END LOOP;
793: DBMS_SQL.close_cursor(CursorId);
794:
795: RG_XFER_UTILS_PKG.display_log(
796: MsgLevel => G_ML_Full,
797: MsgName => 'RG_XFER_L_EXIT_ROUTINE',
829: Token3 => 'PARAM2',
830: Token3Val => TO_CHAR(TargetColumnSetId));
831:
832: /* Get the header from the source database and store it in a variable */
833: CursorId := DBMS_SQL.open_cursor;
834: DBMS_SQL.parse(CursorId,
835: 'SELECT column_set_header FROM rg_report_axis_sets@' ||
836: G_LinkName || ' WHERE axis_set_id = ' ||
837: TO_CHAR(SourceColumnSetId),
830: Token3Val => TO_CHAR(TargetColumnSetId));
831:
832: /* Get the header from the source database and store it in a variable */
833: CursorId := DBMS_SQL.open_cursor;
834: DBMS_SQL.parse(CursorId,
835: 'SELECT column_set_header FROM rg_report_axis_sets@' ||
836: G_LinkName || ' WHERE axis_set_id = ' ||
837: TO_CHAR(SourceColumnSetId),
838: DBMS_SQL.v7);
834: DBMS_SQL.parse(CursorId,
835: 'SELECT column_set_header FROM rg_report_axis_sets@' ||
836: G_LinkName || ' WHERE axis_set_id = ' ||
837: TO_CHAR(SourceColumnSetId),
838: DBMS_SQL.v7);
839: DBMS_SQL.define_column(CursorId, 1, Header, 7000);
840: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
841: DBMS_SQL.column_value(CursorId, 1, Header);
842: DBMS_SQL.close_cursor(CursorId);
835: 'SELECT column_set_header FROM rg_report_axis_sets@' ||
836: G_LinkName || ' WHERE axis_set_id = ' ||
837: TO_CHAR(SourceColumnSetId),
838: DBMS_SQL.v7);
839: DBMS_SQL.define_column(CursorId, 1, Header, 7000);
840: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
841: DBMS_SQL.column_value(CursorId, 1, Header);
842: DBMS_SQL.close_cursor(CursorId);
843:
836: G_LinkName || ' WHERE axis_set_id = ' ||
837: TO_CHAR(SourceColumnSetId),
838: DBMS_SQL.v7);
839: DBMS_SQL.define_column(CursorId, 1, Header, 7000);
840: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
841: DBMS_SQL.column_value(CursorId, 1, Header);
842: DBMS_SQL.close_cursor(CursorId);
843:
844: /* Transfer the header from the variable to the target database */
837: TO_CHAR(SourceColumnSetId),
838: DBMS_SQL.v7);
839: DBMS_SQL.define_column(CursorId, 1, Header, 7000);
840: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
841: DBMS_SQL.column_value(CursorId, 1, Header);
842: DBMS_SQL.close_cursor(CursorId);
843:
844: /* Transfer the header from the variable to the target database */
845: CursorId := DBMS_SQL.open_cursor;
838: DBMS_SQL.v7);
839: DBMS_SQL.define_column(CursorId, 1, Header, 7000);
840: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
841: DBMS_SQL.column_value(CursorId, 1, Header);
842: DBMS_SQL.close_cursor(CursorId);
843:
844: /* Transfer the header from the variable to the target database */
845: CursorId := DBMS_SQL.open_cursor;
846: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
841: DBMS_SQL.column_value(CursorId, 1, Header);
842: DBMS_SQL.close_cursor(CursorId);
843:
844: /* Transfer the header from the variable to the target database */
845: CursorId := DBMS_SQL.open_cursor;
846: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
847: DBMS_SQL.bind_variable(CursorId, ':header', Header);
848: DBMS_SQL.bind_variable(CursorId, ':id', TargetColumnSetId);
849: ExecuteValue := DBMS_SQL.execute(CursorId);
842: DBMS_SQL.close_cursor(CursorId);
843:
844: /* Transfer the header from the variable to the target database */
845: CursorId := DBMS_SQL.open_cursor;
846: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
847: DBMS_SQL.bind_variable(CursorId, ':header', Header);
848: DBMS_SQL.bind_variable(CursorId, ':id', TargetColumnSetId);
849: ExecuteValue := DBMS_SQL.execute(CursorId);
850: DBMS_SQL.close_cursor(CursorId);
843:
844: /* Transfer the header from the variable to the target database */
845: CursorId := DBMS_SQL.open_cursor;
846: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
847: DBMS_SQL.bind_variable(CursorId, ':header', Header);
848: DBMS_SQL.bind_variable(CursorId, ':id', TargetColumnSetId);
849: ExecuteValue := DBMS_SQL.execute(CursorId);
850: DBMS_SQL.close_cursor(CursorId);
851:
844: /* Transfer the header from the variable to the target database */
845: CursorId := DBMS_SQL.open_cursor;
846: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
847: DBMS_SQL.bind_variable(CursorId, ':header', Header);
848: DBMS_SQL.bind_variable(CursorId, ':id', TargetColumnSetId);
849: ExecuteValue := DBMS_SQL.execute(CursorId);
850: DBMS_SQL.close_cursor(CursorId);
851:
852: RG_XFER_UTILS_PKG.display_log(
845: CursorId := DBMS_SQL.open_cursor;
846: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
847: DBMS_SQL.bind_variable(CursorId, ':header', Header);
848: DBMS_SQL.bind_variable(CursorId, ':id', TargetColumnSetId);
849: ExecuteValue := DBMS_SQL.execute(CursorId);
850: DBMS_SQL.close_cursor(CursorId);
851:
852: RG_XFER_UTILS_PKG.display_log(
853: MsgLevel => G_ML_Full,
846: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
847: DBMS_SQL.bind_variable(CursorId, ':header', Header);
848: DBMS_SQL.bind_variable(CursorId, ':id', TargetColumnSetId);
849: ExecuteValue := DBMS_SQL.execute(CursorId);
850: DBMS_SQL.close_cursor(CursorId);
851:
852: RG_XFER_UTILS_PKG.display_log(
853: MsgLevel => G_ML_Full,
854: MsgName => 'RG_XFER_L_EXIT_ROUTINE',
889: Token3 => 'PARAM2',
890: Token3Val => TO_CHAR(TargetContentSetId));
891:
892: /* Insert the detail records for the specified content set. */
893: CursorId := DBMS_SQL.open_cursor;
894: DBMS_SQL.parse(CursorId,
895: 'SELECT rowid, ledger_id, alc_ledger_currency' ||
896: ' FROM rg_report_content_overrides@' || G_LinkName ||
897: ' WHERE content_set_id = ' || TO_CHAR(SourceContentSetId),
890: Token3Val => TO_CHAR(TargetContentSetId));
891:
892: /* Insert the detail records for the specified content set. */
893: CursorId := DBMS_SQL.open_cursor;
894: DBMS_SQL.parse(CursorId,
895: 'SELECT rowid, ledger_id, alc_ledger_currency' ||
896: ' FROM rg_report_content_overrides@' || G_LinkName ||
897: ' WHERE content_set_id = ' || TO_CHAR(SourceContentSetId),
898: DBMS_SQL.v7);
894: DBMS_SQL.parse(CursorId,
895: 'SELECT rowid, ledger_id, alc_ledger_currency' ||
896: ' FROM rg_report_content_overrides@' || G_LinkName ||
897: ' WHERE content_set_id = ' || TO_CHAR(SourceContentSetId),
898: DBMS_SQL.v7);
899: DBMS_SQL.define_column_rowid(CursorId, 1, RecRowId);
900: DBMS_SQL.define_column(CursorId, 2, LedgerId);
901: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
902: ExecuteValue := DBMS_SQL.execute(CursorId);
895: 'SELECT rowid, ledger_id, alc_ledger_currency' ||
896: ' FROM rg_report_content_overrides@' || G_LinkName ||
897: ' WHERE content_set_id = ' || TO_CHAR(SourceContentSetId),
898: DBMS_SQL.v7);
899: DBMS_SQL.define_column_rowid(CursorId, 1, RecRowId);
900: DBMS_SQL.define_column(CursorId, 2, LedgerId);
901: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
902: ExecuteValue := DBMS_SQL.execute(CursorId);
903: LOOP
896: ' FROM rg_report_content_overrides@' || G_LinkName ||
897: ' WHERE content_set_id = ' || TO_CHAR(SourceContentSetId),
898: DBMS_SQL.v7);
899: DBMS_SQL.define_column_rowid(CursorId, 1, RecRowId);
900: DBMS_SQL.define_column(CursorId, 2, LedgerId);
901: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
902: ExecuteValue := DBMS_SQL.execute(CursorId);
903: LOOP
904: /* For each record, check the ledger info and insert the record. */
897: ' WHERE content_set_id = ' || TO_CHAR(SourceContentSetId),
898: DBMS_SQL.v7);
899: DBMS_SQL.define_column_rowid(CursorId, 1, RecRowId);
900: DBMS_SQL.define_column(CursorId, 2, LedgerId);
901: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
902: ExecuteValue := DBMS_SQL.execute(CursorId);
903: LOOP
904: /* For each record, check the ledger info and insert the record. */
905: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
898: DBMS_SQL.v7);
899: DBMS_SQL.define_column_rowid(CursorId, 1, RecRowId);
900: DBMS_SQL.define_column(CursorId, 2, LedgerId);
901: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
902: ExecuteValue := DBMS_SQL.execute(CursorId);
903: LOOP
904: /* For each record, check the ledger info and insert the record. */
905: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
906: DBMS_SQL.column_value_rowid(CursorId, 1, RecRowId);
901: DBMS_SQL.define_column(CursorId, 3, LedgerCurrency, 15);
902: ExecuteValue := DBMS_SQL.execute(CursorId);
903: LOOP
904: /* For each record, check the ledger info and insert the record. */
905: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
906: DBMS_SQL.column_value_rowid(CursorId, 1, RecRowId);
907: DBMS_SQL.column_value(CursorId, 2, LedgerId);
908: DBMS_SQL.column_value(CursorId, 3, LedgerCurrency);
909:
902: ExecuteValue := DBMS_SQL.execute(CursorId);
903: LOOP
904: /* For each record, check the ledger info and insert the record. */
905: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
906: DBMS_SQL.column_value_rowid(CursorId, 1, RecRowId);
907: DBMS_SQL.column_value(CursorId, 2, LedgerId);
908: DBMS_SQL.column_value(CursorId, 3, LedgerCurrency);
909:
910: IF (LedgerId IS NOT NULL) THEN
903: LOOP
904: /* For each record, check the ledger info and insert the record. */
905: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
906: DBMS_SQL.column_value_rowid(CursorId, 1, RecRowId);
907: DBMS_SQL.column_value(CursorId, 2, LedgerId);
908: DBMS_SQL.column_value(CursorId, 3, LedgerCurrency);
909:
910: IF (LedgerId IS NOT NULL) THEN
911: RG_XFER_UTILS_PKG.get_target_ldg_from_source_ldg(
904: /* For each record, check the ledger info and insert the record. */
905: IF (DBMS_SQL.fetch_rows(CursorId) > 0) THEN
906: DBMS_SQL.column_value_rowid(CursorId, 1, RecRowId);
907: DBMS_SQL.column_value(CursorId, 2, LedgerId);
908: DBMS_SQL.column_value(CursorId, 3, LedgerCurrency);
909:
910: IF (LedgerId IS NOT NULL) THEN
911: RG_XFER_UTILS_PKG.get_target_ldg_from_source_ldg(
912: LedgerId, LedgerName, LedgerCurrency);
952: /* No more rows */
953: EXIT;
954: END IF;
955: END LOOP;
956: DBMS_SQL.close_cursor(CursorId);
957:
958: RG_XFER_UTILS_PKG.display_log(
959: MsgLevel => G_ML_Full,
960: MsgName => 'RG_XFER_L_EXIT_ROUTINE',
994: ' AND a.element_id = e.element_id';
995:
996: RG_XFER_UTILS_PKG.display_string(SQLString);
997:
998: CursorId := DBMS_SQL.open_cursor;
999: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1000: DBMS_SQL.define_column(CursorId, 1, Id);
1001: DBMS_SQL.define_column(CursorId, 2, SourceIdName, 240);
1002: DBMS_SQL.define_column(CursorId, 3, SourceTaxId);
995:
996: RG_XFER_UTILS_PKG.display_string(SQLString);
997:
998: CursorId := DBMS_SQL.open_cursor;
999: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1000: DBMS_SQL.define_column(CursorId, 1, Id);
1001: DBMS_SQL.define_column(CursorId, 2, SourceIdName, 240);
1002: DBMS_SQL.define_column(CursorId, 3, SourceTaxId);
1003: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
996: RG_XFER_UTILS_PKG.display_string(SQLString);
997:
998: CursorId := DBMS_SQL.open_cursor;
999: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1000: DBMS_SQL.define_column(CursorId, 1, Id);
1001: DBMS_SQL.define_column(CursorId, 2, SourceIdName, 240);
1002: DBMS_SQL.define_column(CursorId, 3, SourceTaxId);
1003: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1004: IF (ExecuteValue > 0) THEN
997:
998: CursorId := DBMS_SQL.open_cursor;
999: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1000: DBMS_SQL.define_column(CursorId, 1, Id);
1001: DBMS_SQL.define_column(CursorId, 2, SourceIdName, 240);
1002: DBMS_SQL.define_column(CursorId, 3, SourceTaxId);
1003: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1004: IF (ExecuteValue > 0) THEN
1005: DBMS_SQL.column_value(CursorId, 1, Id);
998: CursorId := DBMS_SQL.open_cursor;
999: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1000: DBMS_SQL.define_column(CursorId, 1, Id);
1001: DBMS_SQL.define_column(CursorId, 2, SourceIdName, 240);
1002: DBMS_SQL.define_column(CursorId, 3, SourceTaxId);
1003: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1004: IF (ExecuteValue > 0) THEN
1005: DBMS_SQL.column_value(CursorId, 1, Id);
1006: DBMS_SQL.column_value(CursorId, 2, SourceIdName);
999: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1000: DBMS_SQL.define_column(CursorId, 1, Id);
1001: DBMS_SQL.define_column(CursorId, 2, SourceIdName, 240);
1002: DBMS_SQL.define_column(CursorId, 3, SourceTaxId);
1003: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1004: IF (ExecuteValue > 0) THEN
1005: DBMS_SQL.column_value(CursorId, 1, Id);
1006: DBMS_SQL.column_value(CursorId, 2, SourceIdName);
1007: DBMS_SQL.column_value(CursorId, 3, SourceTaxId);
1001: DBMS_SQL.define_column(CursorId, 2, SourceIdName, 240);
1002: DBMS_SQL.define_column(CursorId, 3, SourceTaxId);
1003: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1004: IF (ExecuteValue > 0) THEN
1005: DBMS_SQL.column_value(CursorId, 1, Id);
1006: DBMS_SQL.column_value(CursorId, 2, SourceIdName);
1007: DBMS_SQL.column_value(CursorId, 3, SourceTaxId);
1008: ELSE
1009: Id := NULL;
1002: DBMS_SQL.define_column(CursorId, 3, SourceTaxId);
1003: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1004: IF (ExecuteValue > 0) THEN
1005: DBMS_SQL.column_value(CursorId, 1, Id);
1006: DBMS_SQL.column_value(CursorId, 2, SourceIdName);
1007: DBMS_SQL.column_value(CursorId, 3, SourceTaxId);
1008: ELSE
1009: Id := NULL;
1010: SourceIdName := 'NULL';
1003: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1004: IF (ExecuteValue > 0) THEN
1005: DBMS_SQL.column_value(CursorId, 1, Id);
1006: DBMS_SQL.column_value(CursorId, 2, SourceIdName);
1007: DBMS_SQL.column_value(CursorId, 3, SourceTaxId);
1008: ELSE
1009: Id := NULL;
1010: SourceIdName := 'NULL';
1011: END IF;
1008: ELSE
1009: Id := NULL;
1010: SourceIdName := 'NULL';
1011: END IF;
1012: DBMS_SQL.close_cursor(CursorId);
1013:
1014: IF (Id IS NULL) THEN
1015: IdValue := 'NULL';
1016: ELSE
1022: ' RG_XBRL_TAXONOMIES' || '@'|| G_LinkName || ' ref_table ' ||
1023: 'WHERE ref_table.taxonomy_id ' || '= '|| TO_CHAR(SourceTaxId);
1024:
1025: RG_XFER_UTILS_PKG.display_string(SQLString);
1026: CursorId := DBMS_SQL.open_cursor;
1027: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1028: DBMS_SQL.define_column(CursorId, 1, RefObjectName, 240);
1029: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1030: IF (ExecuteValue > 0) THEN
1023: 'WHERE ref_table.taxonomy_id ' || '= '|| TO_CHAR(SourceTaxId);
1024:
1025: RG_XFER_UTILS_PKG.display_string(SQLString);
1026: CursorId := DBMS_SQL.open_cursor;
1027: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1028: DBMS_SQL.define_column(CursorId, 1, RefObjectName, 240);
1029: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1030: IF (ExecuteValue > 0) THEN
1031: DBMS_SQL.column_value(CursorId, 1, RefObjectName);
1024:
1025: RG_XFER_UTILS_PKG.display_string(SQLString);
1026: CursorId := DBMS_SQL.open_cursor;
1027: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1028: DBMS_SQL.define_column(CursorId, 1, RefObjectName, 240);
1029: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1030: IF (ExecuteValue > 0) THEN
1031: DBMS_SQL.column_value(CursorId, 1, RefObjectName);
1032: ELSE
1025: RG_XFER_UTILS_PKG.display_string(SQLString);
1026: CursorId := DBMS_SQL.open_cursor;
1027: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1028: DBMS_SQL.define_column(CursorId, 1, RefObjectName, 240);
1029: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1030: IF (ExecuteValue > 0) THEN
1031: DBMS_SQL.column_value(CursorId, 1, RefObjectName);
1032: ELSE
1033: RefObjectName := '';
1027: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1028: DBMS_SQL.define_column(CursorId, 1, RefObjectName, 240);
1029: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1030: IF (ExecuteValue > 0) THEN
1031: DBMS_SQL.column_value(CursorId, 1, RefObjectName);
1032: ELSE
1033: RefObjectName := '';
1034: END IF;
1035: DBMS_SQL.close_cursor(CursorId);
1031: DBMS_SQL.column_value(CursorId, 1, RefObjectName);
1032: ELSE
1033: RefObjectName := '';
1034: END IF;
1035: DBMS_SQL.close_cursor(CursorId);
1036: TaxAlias := RefObjectName;
1037:
1038: RG_XFER_UTILS_PKG.copy_adjust_string(TempValue, TaxAlias);
1039: ValueString := '''' || TempValue || '''';
1052: ' AND element_identifier ' || '=' || ValueString;
1053:
1054: RG_XFER_UTILS_PKG.display_string(SQLString);
1055:
1056: CursorId := DBMS_SQL.open_cursor;
1057: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1058: DBMS_SQL.define_column(CursorId, 1, TargetId);
1059: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1060: IF (ExecuteValue > 0) THEN
1053:
1054: RG_XFER_UTILS_PKG.display_string(SQLString);
1055:
1056: CursorId := DBMS_SQL.open_cursor;
1057: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1058: DBMS_SQL.define_column(CursorId, 1, TargetId);
1059: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1060: IF (ExecuteValue > 0) THEN
1061: DBMS_SQL.column_value(CursorId, 1, TargetId);
1054: RG_XFER_UTILS_PKG.display_string(SQLString);
1055:
1056: CursorId := DBMS_SQL.open_cursor;
1057: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1058: DBMS_SQL.define_column(CursorId, 1, TargetId);
1059: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1060: IF (ExecuteValue > 0) THEN
1061: DBMS_SQL.column_value(CursorId, 1, TargetId);
1062: ELSE
1055:
1056: CursorId := DBMS_SQL.open_cursor;
1057: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1058: DBMS_SQL.define_column(CursorId, 1, TargetId);
1059: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1060: IF (ExecuteValue > 0) THEN
1061: DBMS_SQL.column_value(CursorId, 1, TargetId);
1062: ELSE
1063: TargetId := NULL;
1057: DBMS_SQL.parse(CursorId, SQLString, DBMS_SQL.v7);
1058: DBMS_SQL.define_column(CursorId, 1, TargetId);
1059: ExecuteValue := DBMS_SQL.execute_and_fetch(CursorId);
1060: IF (ExecuteValue > 0) THEN
1061: DBMS_SQL.column_value(CursorId, 1, TargetId);
1062: ELSE
1063: TargetId := NULL;
1064: END IF;
1065:
1062: ELSE
1063: TargetId := NULL;
1064: END IF;
1065:
1066: DBMS_SQL.close_cursor(CursorId);
1067: IdValue := TO_CHAR(TargetId);
1068:
1069: END IF;
1070: END get_element_target_id;