Oracle JDBC Получить SYS_REFCURSOR из процедуры - PullRequest
Новая
       41

Oracle JDBC Получить SYS_REFCURSOR из процедуры

0 голосов
/ 29 ноября 2018

Я использую Oracle 12g и пытаюсь получить ResultSet от SYS_REFCURSOR

У меня есть процедура со следующей подписью: 

CREATE OR REPLACE PROCEDURE proc_search(user IN VARCHAR2, res OUT SYS_REFCURSOR)

Это JavaКод JDBC, который я использую: 

try {
    CallableStatement cstmt = con.prepareCall("exec proc_search(?, ?)");
    cstmt.setString(1, login);
    cstmt.registerOutParameter(2, Types.REF);
    cstmt.execute();
    ResultSet rs = (ResultSet)cstmt.getObject(2);

    while (rs.next()) {
        System.out.println(rs.getString(1));
    }
} catch (Exception e) {
    System.err.println(e);
    e.printStackTrace();
}

Однако я получаю следующую ошибку:

java.sql.SQLException: ORA-03115: неподдерживаемый тип сетевых данных или представление

1 Ответ

0 голосов
/ 29 ноября 2018

Во-первых, метод getCursor должен использоваться для SYS_REFCURSOR вместо getObject

Во-вторых, prepareCall должен иметь BEGIN и END

Фрагмент кода 

try {
    CallableStatement cstmt = con.prepareCall("BEGIN proc_search(?, ?); END;");
    cstmt.setString(1, login);
    cstmt.registerOutParameter(2, OracleTypes.CURSOR); 
    cstmt.execute();
    ResultSet rs = ((OracleCallableStatement)cstmt).getCursor(2);

    while (rs.next()) {
        System.out.println(rs.getString("name"));
    }
} catch (Exception e) {
    System.err.println(e);
    e.printStackTrace();
}

В качестве примечания, необходимо иметь блок finally для закрытия Connection, CallableStatement, ResultSet и т. Д. 

finally {
    try {
        if (con != null)
            con.close();

        if (cstmt!= null)
            cstmt.close();

        if (rs!= null)
            rs.close();

    } catch (SQLException sqlexc) {
        sqlexc.printStackTrace();
    }
}

Обновление 1

Использование CallableStatement 

    Connection conn = null;
    CallableStatement callableStatement = null;
    ResultSet rs = null;

    try {
        conn = getconn();
        callableStatement = conn.prepareCall("{call proc_search(?, ?)}");    
        callableStatement.setString(1, login);
        callableStatement.registerOutParameter(2, OracleTypes.CURSOR);

        callableStatement.executeUpdate();    

        rs = (ResultSet) callableStatement.getObject(2);    
        while (rs.next()) {
            String userid = rs.getString("name");
        }

    } catch (SQLException e) {

        System.out.println(e.getMessage());
        e.printStackTrace();

    } finally {

        if (rs != null) {
            rs.close();
        }

        if (callableStatement != null) {
            callableStatement.close();
        }

        if (conn != null) {
            conn.close();
        }

    }

    }
...