4

我正在使用 Play framework 1.2.5，我想通过创建存储过程并使用它们来优化我的 SQL 查询，但我不知道该怎么做。

通过Java代码创建存储过程我应该怎么做？另外，我是否应该在 @OnApplicationStart 作业中执行此操作，以确保在应用程序启动时创建和存储过程？

之后，我如何使用我的存储过程？使用哪个功能？如何将参数传递给我的程序？如何检索我的程序的结果？（通常结果将是一个 SELECT 查询）最后，是否可以将我的过程的结果绑定到 play 框架中的模型？

我有很多问题，但我是使用 play framework 和 JPA 的存储过程的新手，我想确保我正确使用它们

感谢您的帮助

4

2 回答 2

4

我不知道你应该如何创建它们。也许 OnApplicationStart 方法是您所需要的。在我的环境中，程序已经到位。我们只是使用 Play 来调用它们。要调用存储过程，您应该看一下Work接口。通过实现这一点，您可以在数据库中执行语句。

我们创建了一个基本的 OracleProcedure 类：

public class CallOracleProcedure implements Work {

    private String anonymousPLSQL;
    private String[] parameters;

    public CallOracleProcedure(String anonymousPLSQL, String[] parameters) {
        this.anonymousPLSQL = anonymousPLSQL;
        this.parameters = parameters.clone();
    }

    /**
     * Create a JDBC PreparedStatement and then execute the anonymous
     * PL/SQL procedure.
     */
    @Override
    public void execute(Connection connection) {
        PreparedStatement statement = null;
        try {
            statement = connection.prepareStatement("begin " + anonymousPLSQL + "; end;");

            if (parameters != null) {
                int i = 1;
                for (String param : parameters) {
                    statement.setString(i++, param);
                }
            }
            statement.executeUpdate();
        } catch (SQLException e) {
            Logger.error("Error performing anonymous pl/sql statement: '%s', with parameters: '%s' - catched error '%s'", anonymousPLSQL, parameters, e);
        } finally {
            if (statement != null) {
                try {
                    statement.close();
                } catch (Exception e) {
                    Logger.error("Error closing statement: %s", e);
                }
            }
        }
    }
}

对于每个特定的存储过程，您可以扩展此类并通过以下方式将名称和参数传递给构造函数super()：

public class StoredProcedureCall extends CallOracleProcedure {
    public StoredProcedureCall(String param) {
        super("package.storedprocedure(?)", new String[] { orgname });
    }
}

在您的代码中，您可以这样调用它：

StoredProcedureCall procedure = new StoredProcedureCall("your parameter");
session.doWork(procedure);

如果需要调用过程并检索返回值，可以CallableStatement在execute()方法中使用 a：

public class ProcedureWithReturnValue implements Work {

    private final String parameter;
    private String returnValue = null;

    public ProcedureWithReturnValue (final String parameter) {
        this.parameter = parameter;
    }

    @Override
    public void execute(Connection connection) {
        CallableStatement statement = null;

        try {   
            statement = connection.prepareCall("begin ? := package.procedure(?); end;");
            statement.registerOutParameter(1, OracleTypes.VARCHAR);
            statement.setString(2, parameter);
            statement.execute();

            returnValue = statement.getString(1);
        } catch (SQLException e) {
            Logger.error("Error getting return value - catched error '%s'",  e);
        }
    }

    public String getReturnValue() {
        return returnValue;
    }
}
于 2013-03-06T11:40:55.173 回答
0

查看用于创建存储过程的演变 ( http://www.playframework.com/documentation/1.2.7/evolutions )。

于 2014-01-21T19:53:42.483 回答