oracle-databaseplsqlplsql-package

unable to call main procedure from wrapper procedure asynchronously


I want to call main procedure from the wrapper procedure. Wrapper procedure I'm able to output with dbms output print line but I'm unable to print within the main proc, looks like the main proc is not called from wrapper procedure. Please help me

Below is the table script

CREATE TABLE ASYNC_SAMPLE_TAB
( attribute1 varchar2(50),
  attribute2 varchar2(50)
);

Below is my package specification

CREATE OR REPLACE PACKAGE XX_ASYNC_DEMO_PKG
IS
    PROCEDURE MAIN_PROC( 
        attribute1          IN      VARCHAR2,
        attribute2          IN      VARCHAR2
    );
    
    PROCEDURE WRAPPER_MAIN_PROC( 
        attribute1          IN      VARCHAR2,
        attribute2          IN      VARCHAR2
    );
  
END XX_ASYNC_DEMO_PKG;

Below is my package bofy

CREATE OR REPLACE PACKAGE BODY XX_ASYNC_DEMO_PKG
IS
    PROCEDURE WRAPPER_MAIN_PROC( 
            attribute1          IN      VARCHAR2,
            attribute2          IN      VARCHAR2
        )
    AS
    BEGIN
        DBMS_OUTPUT.PUT_LINE('-- START OF WRAPPER PROC---' || SYSTIMESTAMP);
        dbms_scheduler.create_job(
            job_name   => 'ASYNC_MAIN_PROC' || '_' || attribute1, 
            job_type   => 'PLSQL_BLOCK', 
            job_action => 'BEGIN 
                              MAIN_PROC(''' || attribute1 || ''', ''' || attribute2 || ''');
                           END;', 
            start_date => systimestamp , 
            auto_drop  => true,
            enabled    => true
        );
        DBMS_OUTPUT.PUT_LINE('-- END OF WRAPPER PROC---' || SYSTIMESTAMP);
    END;
    

PROCEDURE MAIN_PROC( 
        attribute1          IN      VARCHAR2,
        attribute2          IN      VARCHAR2
    )
    AS
        sql_stmt    VARCHAR2(200);
    BEGIN
        DBMS_OUTPUT.PUT_LINE('-- START OF MAIN PROC---' || SYSTIMESTAMP);
        DBMS_SESSION.sleep(10);
        sql_stmt := 'INSERT INTO ASYNC_SAMPLE_TAB VALUES (:1, :2)';
        EXECUTE IMMEDIATE sql_stmt USING attribute1, attribute2;
        DBMS_OUTPUT.PUT_LINE('-- END OF MAIN PROC---' || SYSTIMESTAMP);
    END;
END XX_ASYNC_DEMO_PKG;

Below is the command with which I'm trying to test above solution

exec XX_ASYNC_DEMO_PKG.WRAPPER_MAIN_PROC('Test101_1', 'Test101_2');

Solution

  • As described in the documentation, the main purpose of DBMS_OUTPUT is debug messages to trace execution flow. It's also said there that it doesn't immediately return anything to the caller, but text is placed into the buffer and may be retrieved from there by the caller or the program itself (though, you cannot "get into" any other program flow and get anything from the executing code until the called unit is complete).

    Scheduler doesn't retrieve the content of the buffer after it completes the job, so DBMS_OUTPUT.PUT* called inside a background job has no effect and you cannot see any result.

    You may use some logging table (with separate logging procedure executed in autonomous transaction not to have an influence or be influenced by the main transaction) or external file and UTL_FILE to send results here. Or use a general table that should be processed by the job and check results after it finishes.

    UPD: Below is a complete setup to demonstrate how to pass parameters to a callable and see its results.

    create table log_table (
        ts timestamp,
        val number,
        job_name varchar2(30)
    )
    
    create or replace procedure proc_insert(
        p_val in number,
        p_job_name in varchar2
    ) as
    begin
        insert into log_table(ts, val, job_name)
        values (systimestamp, p_val, p_job_name);
        commit;
    end;
    
    create or replace procedure proc_insert_async(
      p_call_id varchar2,
      p_val number,
      r_job_name out varchar2
    ) as
      l_job_prefix constant varchar2(20) := 'LOG_TABLE_';
      l_job_name varchar2(100) := l_job_prefix || p_call_id;
    begin
      dbms_scheduler.create_job(
        job_name => l_job_name,
        job_type => 'STORED_PROCEDURE',
        /*Callable unit - out API procedure*/
        job_action => 'TEST_EAS.PROC_INSERT',
        /*Number of args to be passed to the proc*/
        number_of_arguments => 2,
        /*Run immediately*/
        start_date => sysdate,
        enabled => false,
        auto_drop => true
      );
    
      /*Pass parameters to the callable*/
      dbms_scheduler.set_job_anydata_value (
        job_name => l_job_name,
        argument_position => 1,
        argument_value => sys.anydata.convertNumber(p_val)
      );
      dbms_scheduler.set_job_argument_value(
        job_name => l_job_name,
        argument_position => 2,
        argument_value => l_job_name
      );
    
      /*Start job*/
      dbms_scheduler.enable(
        name => l_job_name
      );
      
      r_job_name := l_job_name;
    end;
    
    declare
        l_job_name varchar2(100);
    begin
        proc_insert_async(
            p_call_id => 'test1',
            p_val => 1,
            r_job_name => l_job_name
        );
    
        dbms_output.put_line(l_job_name);
    
        proc_insert_async(
            p_call_id => 'test2',
            p_val => 10,
            r_job_name => l_job_name
        );
    
        dbms_output.put_line(l_job_name);
        dbms_session.sleep(3);
    end;
    /
    LOG_TABLE_test1
    LOG_TABLE_test2
    
    
    PL/SQL procedure successfully completed.
    
    select *
    from log_table
    
    TS VAL JOB_NAME
    25.11.22 10:52:37,310403000 10 LOG_TABLE_test2
    25.11.22 10:52:37,302992000 1 LOG_TABLE_test1