如何在Java中运行.sql脚本(从文件)并使用Spring返回ResultSet？

如何在Java中运行.sql脚本(从文件)并使用Spring返回ResultSet？

我有一个程序在返回ResultSet的数据库上运行SQL查询,我稍后处理并使用我的类中的数据.我目前正在使用JDBC与Java程序中的脚本.

StringBuilder query = new StringBuilder("some script on multiple lines");
PreparedStatement statement = connection.prepareStatement(query.toString());
ResultSet resultSet = statement.executeQuery();

我想将Java程序之外的SQL查询移动到.sql文件,但我想保留executeQuery语句中的所有程序逻辑.这意味着我希望查询返回ResultSet.

我查看了几个方法,比如使用ScriptRunner,使用Spring JdbcTestUtils.executesqlScript或使用BufferReader读取.sql文件,然后将字符串传递给我的语句. ScriptRunner和Spring JdbcTestUtils.executesqlScript似乎没有返回ResultSet,或者我找不到正确的实现.我想远离BufferReader方法,因为它需要文本解析和许多异常来处理.

ScriptRunner scriptRunner = new ScriptRunner(connection, true, true);
scriptRunner.runScript(new FileReader("script.sql"));

runScript方法返回void. Spring实现也是如此：

MysqLDataSource ds = new MysqLDataSource();
ds.setServerName("host");
ds.setUser("user");
ds.setPassword("password");

JdbcTemplate jdbcTemplate = new JdbcTemplate(ds);

Resource resource = new ClassPathResource("script.sql");
JdbcTestUtils.executesqlScript(jdbcTemplate, resource, true);

我仔细看了一下Spring api但找不到类似于我想要的东西.
有没有办法从文件加载脚本然后运行它,所以它使用Spring返回一个ResultSet？我更喜欢使用Spring,因为它是积极的.

解决方法:

我找到了一种使用Spring的方法：

MysqLDataSource ds = new MysqLDataSource();
ds.setServerName("host");
ds.setUser("user");
ds.setPassword("password");

JdbcTemplate jdbcTemplate = new JdbcTemplate(ds);

BufferedReader in = new BufferedReader(new FileReader("script.sql"));
LineNumberReader fileReader = new LineNumberReader(in);
String query = JdbcTestUtils.readScript(fileReader);

现在我们将使用jdbcTemplate.query使用我们读取的.sql脚本来查询数据库.需要的ResultSet将作为参数传递给ResultSetExtractor实现的extractData或RowMapper实现的mapRow.所以ResultSet的处理将在extractData或mapRow实现中完成,我们将返回我们需要的Collection / Object

List<YourClass> result = jdbcTemplate.query(query, new RowMapper<YourClass>() {
            @Override
            public YourClass mapRow(ResultSet rs, int i) throws sqlException {
                // processing of the ResultSet
                return result;
            }
        });

要么

YourClass object = jdbcTemplate.query(query, new ResultSetExtractor<YourClass>() {
            @Override
            public YourClass extractData(ResultSet rs) throws sqlException, DataAccessException {
                // processing of the ResultSet
                return result;
            }
        });

当然,使用最后一个实现,您可以返回所需的任何对象,甚至是对象的集合.