0

私は、ファイルを読み込み、ファイルの各行に対してOracleストアドプロシージャを呼び出し、プロシージャからの戻り値に基づいてファイルの名前を変更し、ファイルをサーバーに移動するプロジェクトに取り組んでいます。私はそれをすべて機能させましたが、何らかの理由で、プロシージャは呼び出された最初の2回だけ値を返します。その後、何も返ってこない。ループ内の接続を閉じて再度開いてみましたが、それは役に立ちません。私もそうする必要はありません。

無実のサーバーを保護するために名前が変更されました。

Do While Not endOfData
    Dim dataRecord As String = dataReader1.GetRecord
    If dataRecord = "End of Data" Then
        endOfData = True
    Else
        ' Read in record '
        indexRec = indexLoader.LoadPointerIndex(dataRecord, PointerIndexRecordType.Original)

        'Format date values '
        effdate = indexRec.EffDate.ToString("M/dd/yyyy")
        dir = "/" & easyFile & "/" & indexRec.EffDate.Year & "/" & indexRec.EffDate.Month & "/"


        'Connect to Oracle '
        Dim conn As New OracleConnection(connString)
        conn.Open()
        'Call proc with indexRec values '
        Dim myCMD As New OracleCommand()
        myCMD.Connection = conn
        myCMD.CommandText = "SCHEMA.PROC"
        myCMD.CommandType = CommandType.StoredProcedure
        'Setup Parameters '
        myCMD.Parameters.Add("P_CONTRACT_ID", OracleDbType.Varchar2, 10, Nothing, ParameterDirection.Input).Value = indexRec.Contract
        myCMD.Parameters.Add("P_EFFT_DATE", OracleDbType.Date, ParameterDirection.Input).Value = indexRec.EffDate
        myCMD.Parameters.Add("P_DIRECTORY", OracleDbType.Varchar2, 18, Nothing, ParameterDirection.Input).Value = dir
        myCMD.Parameters.Add("P_FILENAME_OUT", OracleDbType.Varchar2, 13, Nothing, ParameterDirection.Output)

        myCMD.ExecuteNonQuery()

        Result = CType(myCMD.Parameters("P_FILENAME_OUT").Value.ToString, String)
        myCMD.Dispose()
        conn.Close()
        conn.Dispose()

        'Rename PDF based on returned result '
        My.Computer.FileSystem.RenameFile(rootDirectory & "\" & configSettings.appFolder & "\" & indexRec.Contract & ".pdf", Result)

        'Verify that folder exists on server '
        sFolder = sDir & indexRec.EffDate.Year & "\" & indexRec.EffDate.Month
        If (Not Directory.Exists(sFolder)) Then
            Directory.CreateDirectory(sDir & indexRec.EffDate.Year & "\" & indexRec.EffDate.Month)
        End If

        'Move PDF to proper folder '
        My.Computer.FileSystem.CopyFile(rootDirectory & "\" & configSettings.appFolder & "\" & Result, sFolder & "\" & Result)
    End If
Loop

これが別のチームが管理するProcです。

create or replace
PROCEDURE PROC(P_CONTRACT_ID  IN VARCHAR2,
               P_EFFT_DATE    IN DATE,
               P_DIRECTORY    IN VARCHAR2,
               P_FILENAME_OUT OUT VARCHAR2)
--*****************************************************
    -- Name: PROC
    -- Purpose: Insert a contract statement                                       
    -- Authored by: 
    -- Created on: 
    -- Modifications:
    -- Seq Who Date Description
    -- ----------------------------------------------------
    -- 001 DAT 08/27/2012 Initial Release
    --*****************************************************
 AS

    V_CONTRACT_UID       NUMBER;
    V_CORRESPONDENCE_UID NUMBER;
    V_DEL_COUNT          NUMBER;
    V_NEW_FILE_URL       VARCHAR2(254);

BEGIN

    --Get the contract_uid
    SELECT CONTRACT_UID
       INTO V_CONTRACT_UID
       FROM ODS.CONTRACTS
       WHERE CONTRACT_ID = P_CONTRACT_ID;

    --If existing, delete the entry and add (dont do a merge).
    SELECT COUNT(CORRESPONDENCE_UID)
      INTO   V_DEL_COUNT
      FROM   CORRESPONDENCES
      WHERE  CONTRACT_UID = V_CONTRACT_UID
             AND TRUNC(CORRESPONDENCE_CREATION_DATE) = TRUNC(P_EFFT_DATE);

    IF V_DEL_COUNT > 0 THEN
      DELETE FROM CORRESPONDENCES
        WHERE  CORRESPONDENCE_UID IN
                  (SELECT CORRESPONDENCE_UID
                     FROM   CORRESPONDENCES
               WHERE  CONTRACT_UID = V_CONTRACT_UID
                 AND TRUNC(CORRESPONDENCE_CREATION_DATE) = TRUNC(P_EFFT_DATE));
    END IF;

    -- *** Create Correspondence Row and New File Name ***
    -- *** Create new file name ***
    V_CORRESPONDENCE_UID := CORRESPONDENCES_SEQ.NEXTVAL;
    P_FILENAME_OUT       := RTRIM(LTRIM(TO_CHAR(V_CORRESPONDENCE_UID) || '.pdf'));
    V_NEW_FILE_URL       := 'http://armstorage.integritycompanies.com' || P_DIRECTORY || P_FILENAME_OUT;

    INSERT INTO CORRESPONDENCES
        (CORRESPONDENCE_UID,
         CORRESPONDENCE_TYPE,
         CORRESPONDENCE_CREATION_DATE,
         CORRESPONDENCE_CONTENT_TYPE,
         CORRESPONDENCE_IMAGE_FILE_NAME,
         CORRESPONDENCE_IMAGE_FILE_EXT,
         CORRESPONDENCE_UPDATED,
         CORRESPONDENCE_URL,
         CORRESPONDENCE_DESC,
         CONTRACT_UID)
    VALUES
        (V_CORRESPONDENCE_UID,
         'ST',
         P_EFFT_DATE,
         'application/pdf',
         P_FILENAME_OUT,
         '.pdf',
         SYSDATE,
         V_NEW_FILE_URL,
         'Contract Statement',
         V_CONTRACT_UID);

    COMMIT;

EXCEPTION
    WHEN OTHERS THEN
        DBMS_OUTPUT.PUT_LINE(SQLERRM);
        DBMS_OUTPUT.PUT_LINE(DBMS_UTILITY.FORMAT_ERROR_BACKTRACE);
        ROLLBACK;

END;

何か提案やリクエストはありますか?

4

1 に答える 1