Вызов хранимой процедуры из Java / JPA

Question

Я пишу простое веб-приложение для вызова хранимой процедуры и получения некоторых данных. Это очень простое приложение, которое взаимодействует с базой данных клиента. Мы передаем идентификатор сотрудника и идентификатор компании, и хранимая процедура возвращает данные сотрудника.

Веб-приложение не может обновлять / удалять данные и использует SQL Server.

Я развертываю свое веб-приложение в Jboss AS. Должен ли я использовать JPA для доступа к хранимой процедуре или CallableStatement. Любое преимущество использования JPA в этом случае.

Также, что будет оператором sql для вызова этой хранимой процедуры. Я никогда не использовал хранимые процедуры раньше, и я борюсь с этим. Google не сильно помог.

Вот хранимая процедура:

CREATE procedure getEmployeeDetails (@employeeId int, @companyId int)
as
begin
    select firstName, 
           lastName, 
           gender, 
           address
      from employee et
     where et.employeeId = @employeeId
       and et.companyId = @companyId
end

Обновление:

Для всех, у кого возникли проблемы с вызовом хранимой процедуры с использованием JPA .

Query query = em.createNativeQuery("{call getEmployeeDetails(?,?)}",
                                   EmployeeDetails.class)           
                                   .setParameter(1, employeeId)
                                   .setParameter(2, companyId);

List<EmployeeDetails> result = query.getResultList();

Вещи, которые я заметил:

1. Имена параметров у меня не работают, поэтому попробуйте использовать индекс параметра.
2. Правильный оператор SQL {call sp_name(?,?)} вместо call sp_name(?,?)
3. Если хранимая процедура возвращает набор результатов, даже если вы знаете только одну строку, getSingleResult не будет работать
4. Передайте resultSetMapping имя или данные класса результата

Answer 1

JPA 2.1 теперь поддерживает хранимую процедуру, прочтите документ Java здесь .

Пример:

StoredProcedureQuery storedProcedure = em.createStoredProcedureQuery("sales_tax");
// set parameters
storedProcedure.registerStoredProcedureParameter("subtotal", Double.class, ParameterMode.IN);
storedProcedure.registerStoredProcedureParameter("tax", Double.class, ParameterMode.OUT);
storedProcedure.setParameter("subtotal", 1f);
// execute SP
storedProcedure.execute();
// get result
Double tax = (Double)storedProcedure.getOutputParameterValue("tax");

См. Подробный пример здесь

Answer 2

Я развертываю свое веб-приложение в Jboss AS.Должен ли я использовать JPA для доступа к хранимой процедуре или CallableStatement.Любое преимущество использования JPA в этом случае.

Это на самом деле не поддерживается JPA, но это выполнимо .Тем не менее, я бы не пошел по этому пути:

• с использованием JPA просто для отображения результата вызова хранимой процедуры в некоторых bean-компонентах действительно излишне,
• , особенно учитывая, что JPA не являетсяцелесообразно вызывать хранимую процедуру (синтаксис будет довольно многословным).

Поэтому я бы предпочел использовать поддержку Spring для доступа к данным JDBC или преобразователь данных, такой как MyBatis или, учитывая простоту вашего приложения, необработанный JDBC и CallableStatement.На самом деле, JDBC, вероятно, будет моим выбором.Вот базовый пример запуска:

CallableStatement cstmt = con.prepareCall("{call getEmployeeDetails(?, ?)}");
cstmt.setInt("employeeId", 123);
cstmt.setInt("companyId", 456);
ResultSet rs = cstmt.executeQuery();

Ссылка

• Документация JDBC: Java SE 6

Answer 3

Как получить выходной параметр хранимой процедуры с использованием JPA (2.0 требует импорта EclipseLink, а 2.1 - нет)

Несмотря на то, что в этом ответе подробно описывается возврат набора записей из хранимой процедуры, я публикую здесь, потому что онМне понадобилось много времени, чтобы понять это, и эта ветка помогла мне.

Мое приложение использовало Eclipselink-2.3.1, но я заставлю обновление до Eclipselink-2.5.0, поскольку JPA 2.1 имеет гораздо лучшую поддержкухранимые процедуры.

Использование EclipseLink-2.3.1 / JPA-2.0: зависит от реализации

Этот метод требует импорта классов EclipseLink из "org.eclipse.persistence", поэтому он специфичен дляРеализация Eclipselink.

Я нашел его в "http://www.yenlo.nl/en/calling-oracle-stored-procedures-from-eclipselink-with-multiple-out-parameters".

StoredProcedureCall storedProcedureCall = new StoredProcedureCall();
storedProcedureCall.setProcedureName("mypackage.myprocedure");
storedProcedureCall.addNamedArgument("i_input_1"); // Add input argument name.
storedProcedureCall.addNamedOutputArgument("o_output_1"); // Add output parameter name.
DataReadQuery query = new DataReadQuery();
query.setCall(storedProcedureCall);
query.addArgument("i_input_1"); // Add input argument names (again);
List<Object> argumentValues = new ArrayList<Object>();
argumentValues.add("valueOf_i_input_1"); // Add input argument values.
JpaEntityManager jpaEntityManager = (JpaEntityManager) getEntityManager();
Session session = jpaEntityManager.getActiveSession();
List<?> results = (List<?>) session.executeQuery(query, argumentValues);
DatabaseRecord record = (DatabaseRecord) results.get(0);
String result = String.valueOf(record.get("o_output_1")); // Get output parameter

Использование EclipseLink-2.5.0 / JPA-2.1: не зависит от реализации (задокументировано уже в этой теме)

Этот метод не зависит от реализации (не требуется импорт Eclipslink).

StoredProcedureQuery query = getEntityManager().createStoredProcedureQuery("mypackage.myprocedure");
query.registerStoredProcedureParameter("i_input_1", String.class, ParameterMode.IN);
query.registerStoredProcedureParameter("o_output_1", String.class, ParameterMode.OUT);
query.setParameter("i_input_1", "valueOf_i_input_1");
boolean queryResult = query.execute();
String result = String.valueOf(query.getOutputParameterValue("o_output_1"));

Answer 4

Вам необходимо передать параметры в хранимую процедуру.

Это должно работать следующим образом:

    List result = em
      .createNativeQuery("call getEmployeeDetails(:employeeId,:companyId)")
      .setParameter("emplyoyeeId", 123L)
      .setParameter("companyId", 456L)
      .getResultList();

---

Обновление:

Или, может быть, не следует.

В Книге EJB3 в действии на странице 383 сказано, что JPA не поддерживает хранимые процедуры (страницатолько предварительный просмотр, вы не получите полный текст, вся книга доступна для скачивания в нескольких местах, включая этот , хотя я не знаю, законно ли это).

В любом случае текст таков:

JPA и хранимые процедуры базы данных

Если вы большой поклонник SQL, возможно, вы захотите воспользоватьсямощность базы данных хранимых процедур.К сожалению, JPA не поддерживает хранимые процедуры, и вы должны зависеть от проприетарной функции вашего постоянного поставщика.Однако вы можете использовать простые хранимые функции (без параметров out) с собственным запросом SQL.

Answer 5

Если вы используете EclipseLink, вы можете использовать @NamedStoredProcedureQuery или StoreProcedureCall для выполнения любой хранимой процедуры, в том числе с выходными параметрами или вне курсоров.Также доступна поддержка хранимых функций и типов данных PLSQL.

См., http://en.wikibooks.org/wiki/Java_Persistence/Advanced_Topics#Stored_Procedures

Answer 6

Для меня только следующее работало с Oracle 11g и Glassfish 2.1 (Toplink):

Query query = entityManager.createNativeQuery("BEGIN PROCEDURE_NAME(); END;");
query.executeUpdate();

Вариант с фигурными скобками привел к ORA-00900.

Answer 7

1. Для простой хранимой процедуры, в которой используются такие параметры IN / OUT

   CREATE OR REPLACE PROCEDURE count_comments (  
      postId IN NUMBER,  
      commentCount OUT NUMBER )  
   AS 
   BEGIN 
       SELECT COUNT(*) INTO commentCount  
       FROM post_comment  
       WHERE post_id = postId; 
   END;
   

   Вы можете позвонить из JPA следующим образом:

   StoredProcedureQuery query = entityManager
       .createStoredProcedureQuery("count_comments")
       .registerStoredProcedureParameter(1, Long.class, 
           ParameterMode.IN)
       .registerStoredProcedureParameter(2, Long.class, 
           ParameterMode.OUT)
       .setParameter(1, 1L);
   
   query.execute();
   
   Long commentCount = (Long) query.getOutputParameterValue(2);
   

2. Для хранимой процедуры, в которой используется параметр SYS_REFCURSOR OUT:

   CREATE OR REPLACE PROCEDURE post_comments ( 
      postId IN NUMBER, 
      postComments OUT SYS_REFCURSOR ) 
   AS 
   BEGIN
       OPEN postComments FOR
       SELECT *
       FROM post_comment 
       WHERE post_id = postId; 
   END;
   

   Вы можете назвать это следующим образом:

   StoredProcedureQuery query = entityManager
       .createStoredProcedureQuery("post_comments")
       .registerStoredProcedureParameter(1, Long.class, 
            ParameterMode.IN)
       .registerStoredProcedureParameter(2, Class.class, 
            ParameterMode.REF_CURSOR)
       .setParameter(1, 1L);
   
   query.execute();
   
   List<Object[]> postComments = query.getResultList();
   

3. Для функции SQL, которая выглядит следующим образом:

   CREATE OR REPLACE FUNCTION fn_count_comments ( 
       postId IN NUMBER ) 
       RETURN NUMBER 
   IS
       commentCount NUMBER; 
   BEGIN
       SELECT COUNT(*) INTO commentCount 
       FROM post_comment 
       WHERE post_id = postId; 
       RETURN( commentCount ); 
   END;
   

   Вы можете назвать это так:

   BigDecimal commentCount = (BigDecimal) entityManager
   .createNativeQuery(
       "SELECT fn_count_comments(:postId) FROM DUAL"
   )
   .setParameter("postId", 1L)
   .getSingleResult();
   

   По крайней мере при использовании Hibernate 4.x и 5.x, поскольку JPA StoredProcedureQuery не работает для функций SQL.

Подробнее о том, как вызывать хранимые процедуры и функции при использовании JPA и Hibernate, читайте в следующих статьях

• Как вызывать хранимые процедуры и функции Oracle с помощью JPA и Hibernate
• Как вызывать хранимые процедуры и функции SQL Server с помощью JPA и Hibernate
• Как вызывать функции PostgreSQL (хранимые процедуры) с помощью JPA и Hibernate
• Как вызывать хранимые процедуры и функции MySQL с помощью JPA и Hibernate

Answer 8

У меня работает следующее:

Query query = em.createNativeQuery("BEGIN VALIDACIONES_QPAI.RECALC_COMP_ASSEMBLY('X','X','X',0); END;");
query.executeUpdate();

Answer 9

Может быть, это не то же самое для Sql Srver, но для людей, использующих oracle и eclipslink, это работает для меня

ex: процедура, которая имеет один параметр IN (тип CHAR) и два параметра OUT (NUMBER & VARCHAR)

в файле persistence.xml объявите единицу постоянства:

<persistence-unit name="presistanceNameOfProc" transaction-type="RESOURCE_LOCAL">
    <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
    <jta-data-source>jdbc/DataSourceName</jta-data-source>
    <mapping-file>META-INF/eclipselink-orm.xml</mapping-file>
    <properties>
        <property name="eclipselink.logging.level" value="FINEST"/>
        <property name="eclipselink.logging.logger" value="DefaultLogger"/>
        <property name="eclipselink.weaving" value="static"/>
        <property name="eclipselink.ddl.table-creation-suffix" value="JPA_STORED_PROC" />
    </properties>
</persistence-unit>

и объявите структуру proc в eclipselink-orm.xml

<?xml version="1.0" encoding="UTF-8"?><entity-mappings version="2.0"
xmlns="http://java.sun.com/xml/ns/persistence/orm" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence/orm orm_2_0.xsd">
<named-stored-procedure-query name="PERSIST_PROC_NAME" procedure-name="name_of_proc" returns-result-set="false">
    <parameter direction="IN" name="in_param_char" query-parameter="in_param_char" type="Character"/>
    <parameter direction="OUT" name="out_param_int" query-parameter="out_param_int" type="Integer"/>
    <parameter direction="OUT" name="out_param_varchar" query-parameter="out_param_varchar" type="String"/>
</named-stored-procedure-query>

в коде, который вы просто должны называть своей процедурой так:

try {
        final Query query = this.entityManager
                .createNamedQuery("PERSIST_PROC_NAME");
        query.setParameter("in_param_char", 'V'); 
        resultQuery = (Object[]) query.getSingleResult();

    } catch (final Exception ex) {
        LOGGER.log(ex);
        throw new TechnicalException(ex);
    }

чтобы получить два выходных параметра:

Integer myInt = (Integer) resultQuery[0];
String myStr =  (String) resultQuery[1];

Answer 10

Это сработало для меня.

@Entity
@Table(name="acct")
@NamedNativeQueries({
 @NamedNativeQuery(callable=true, name="Account.findOne", query="call sp_get_acct(?), resultClass=Account.class)})
public class Account{
 // Code 
}

Примечание: в будущем, если вы решите использовать версию findOne по умолчанию, просто прокомментируйте аннотацию NamedNativeQueries и JPA переключится на значение по умолчанию