一、queryforlist概述
queryforlist是Spring框架中最常用的JdbcTemplate查詢方法之一,它可以將查詢結果集封裝為List集合,每個元素是一條記錄對應的JavaBean對象。
這個方法的核心是SQL語句的編寫和結果集到JavaBean的映射轉換,通過這個方法可以進行非常複雜的查詢操作,應用場景非常廣泛。
二、queryforlist參數詳解
queryforlist方法定義如下:
public List<T> queryForList(String sql, Object[] args, RowMapper<T> rowMapper) throws DataAccessException;
它有三個參數:
sql:要執行的SQL查詢語句,可以是任何合法的SQL語句,包括存儲過程和函數。
args:查詢語句的參數,是一個數組類型,它會按照數組的順序替換SQL語句中的佔位符”?”,如果沒有佔位符,可以傳入一個空的數組。
rowMapper:結果集到JavaBean的映射轉換器,它將結果集中的每一條記錄映射成一個JavaBean對象,可以使用Lambda表達式或者匿名內部類的方式完成。
三、queryforlist使用示例
下面是一個基本的使用示例,查詢t_user表中的所有數據並映射成User對象:
//定義sql語句 String sql = "select id, name, age from t_user"; //執行查詢操作 List<User> userList = jdbcTemplate.queryForList(sql, new Object[]{}, (resultSet, i) -> { User user = new User(); user.setId(resultSet.getLong("id")); user.setName(resultSet.getString("name")); user.setAge(resultSet.getInt("age")); return user; });
在這個示例中:
第一行定義了要查詢的SQL語句,包括字段名和表名。
第二行調用了JdbcTemplate的queryForList方法,傳入了三個參數:SQL語句、查詢參數數組和結果集映射轉換器。
第三個參數是一個Lambda表達式,它接收了兩個參數:ResultSet和i,其中ResultSet是查詢結果集對象,i是當前記錄行的編號。
Lambda表達式內部創建了一個User對象,將查詢結果集映射成User對象,並返回這個對象,最後將User對象添加到一個List<User>中。
四、queryforlist的更多使用場景和技巧
除了基本的查詢操作,queryforlist還有許多高級的用法和技巧。
1、帶參數的查詢操作
帶參數的查詢操作可以通過使用佔位符”?”和參數數組args來實現。例如:
String sql = "select * from t_user where name = ?"; List<User> userList = jdbcTemplate.queryForList(sql, new Object[]{"張三"}, (resultSet, i) -> { User user = new User(); user.setId(resultSet.getLong("id")); user.setName(resultSet.getString("name")); user.setAge(resultSet.getInt("age")); return user; });
在這個示例中,使用了一個佔位符”?”來表示參數,它對應的值是一個數組{“張三”},這個數組會按照順序依次替換佔位符。
佔位符”?”也可以表示多個參數,例如:
String sql = "select * from t_user where name = ? and age = ?"; List<User> userList = jdbcTemplate.queryForList(sql, new Object[]{"張三", 30}, (resultSet, i) -> { User user = new User(); user.setId(resultSet.getLong("id")); user.setName(resultSet.getString("name")); user.setAge(resultSet.getInt("age")); return user; });
在這個示例中,使用了兩個佔位符”?”來表示兩個參數,它們分別是”張三”和30。
2、分頁查詢操作
分頁查詢是應用中經常使用的一種查詢方式,通過設置查詢語句中的limit子句和查詢參數中的分頁參數值來實現。例如:
String sql = "select * from t_user limit ?, ?"; List<User> userList = jdbcTemplate.queryForList(sql, new Object[]{0, 10}, (resultSet, i) -> { User user = new User(); user.setId(resultSet.getLong("id")); user.setName(resultSet.getString("name")); user.setAge(resultSet.getInt("age")); return user; });
在這個示例中,使用了limit子句來表示返回結果的起始位置和返回的記錄數,它們分別是0和10。
3、返回指定類型的結果集
除了返回List<T>類型之外,queryforlist還可以返回其他類型的結果集,包括數組、集合和Map等。例如:
String sql = "select id, name from t_user"; List<Map<String, Object>> resultList = jdbcTemplate.queryForList(sql);
在這個示例中,使用了默認的結果集映射轉換器,它將每條查詢記錄映射為一個Map<String, Object>類型的對象,並將這些Map對象添加到一個List<Map<String, Object>>中。
4、批量操作
queryforlist還支持批量操作,它可以使用BatchPreparedStatementSetter接口來實現。例如:
String sql = "insert into t_user (id, name, age) values (?, ?, ?)"; List<User> userList = new ArrayList<>(); //添加一些User對象到userList中 jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() { @Override public void setValues(PreparedStatement preparedStatement, int i) throws SQLException { preparedStatement.setLong(1, userList.get(i).getId()); preparedStatement.setString(2, userList.get(i).getName()); preparedStatement.setInt(3, userList.get(i).getAge()); } @Override public int getBatchSize() { return userList.size(); } });
在這個示例中,使用了batchUpdate方法來批量執行SQL語句,它需要兩個參數:SQL語句和BatchPreparedStatementSetter對象。BatchPreparedStatementSetter是一個接口,它有兩個方法:setValues和getBatchSize。setValues會被調用多次,每次傳入PreparedStatement對象和當前操作的索引,我們可以在這個方法中設置PreparedStatement對象的參數;getBatchSize方法則返回要執行的操作數量。
5、更多技巧
最後,我們介紹一些queryforlist的更多技巧:
使用BeanPropertyRowMapper實現結果集到JavaBean的自動映射轉換。例如:
String sql = "select * from t_user"; List<User> userList = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(User.class));
使用JpaResultMapper實現結果集到Jpa實體類的自動映射轉換。例如:
String sql = "select id, name from t_user"; List<User> userList = (List<User>)jdbcTemplate.query(sql, new JpaResultMapper(User.class));
使用ResultSetExtractor實現更複雜的結果集映射轉換。例如:
String sql = "select * from t_user where id = ?"; User user = jdbcTemplate.query(sql, new Object[]{1}, new ResultSetExtractor<User>() { @Override public User extractData(ResultSet resultSet) throws SQLException, DataAccessException { User user = new User(); if(resultSet.next()) { user.setId(resultSet.getLong("id")); user.setName(resultSet.getString("name")); user.setAge(resultSet.getInt("age")); } return user; } });
原創文章,作者:小藍,如若轉載,請註明出處:https://www.506064.com/zh-hk/n/303710.html