jdbcTemplate使用方法詳解
- execute方法:可以用於執行任何SQL語句,一般用於執行DDL語句;
- update方法及batchUpdate方法:update方法用於執行新增、修改、刪除等語句;batchUpdate方法用於執行批處理相關語句;
- query方法及queryForXXX方法:用於執行查詢相關語句;
- call方法:用於執行儲存過程、函式相關語句。
JdbcTemplate類支援的回撥類:
- 預編譯語句及儲存過程建立回撥:用於根據JdbcTemplate提供的連線建立相應的語句;
PreparedStatementCreator:通過回撥獲取JdbcTemplate提供的Connection,由使用者使用該Conncetion建立相關的PreparedStatement;
CallableStatementCreator:通過回撥獲取JdbcTemplate提供的Connection,由使用者使用該Conncetion建立相關的CallableStatement;
- 預編譯語句設值回撥:用於給預編譯語句相應引數設值;
PreparedStatementSetter:通過回撥獲取JdbcTemplate提供的PreparedStatement,由使用者來對相應的預編譯語句相應引數設值;
BatchPreparedStatementSetter:;類似於PreparedStatementSetter,但用於批處理,需要指定批處理大小;
- 自定義功能回撥:提供給使用者一個擴充套件點,使用者可以在指定型別的擴充套件點執行任何數量需要的操作;
ConnectionCallback:通過回撥獲取JdbcTemplate提供的Connection,使用者可在該Connection執行任何數量的操作;
StatementCallback:通過回撥獲取JdbcTemplate提供的Statement,使用者可以在該Statement執行任何數量的操作;
PreparedStatementCallback:通過回撥獲取JdbcTemplate提供的PreparedStatement,使用者可以在該PreparedStatement執行任何數量的操作;
CallableStatementCallback:通過回撥獲取JdbcTemplate提供的CallableStatement,使用者可以在該CallableStatement執行任何數量的操作;
- 結果集處理回撥:通過回撥處理ResultSet或將ResultSet轉換為需要的形式;
RowMapper:用於將結果集每行資料轉換為需要的型別,使用者需實現方法mapRow(ResultSet rs, int rowNum)來完成將每行資料轉換為相應的型別。
RowCallbackHandler:用於處理ResultSet的每一行結果,使用者需實現方法processRow(ResultSet rs)來完成處理,在該回調方法中無需執行rs.next(),該操作由JdbcTemplate來執行,使用者只需按行獲取資料然後處理即可。
ResultSetExtractor:用於結果集資料提取,使用者需實現方法extractData(ResultSet rs)來處理結果集,使用者必須處理整個結果集;
接下來讓我們看下具體示例吧,在示例中不可能介紹到JdbcTemplate全部方法及回撥類的使用方法,我們只介紹代表性的,其餘的使用都是類似的;
1)預編譯語句及儲存過程建立回撥、自定義功能回撥使用:
java程式碼:Java程式碼- @Test
- public void testPpreparedStatement1() {
- int count = jdbcTemplate.execute(new PreparedStatementCreator() {
- @Override
- public PreparedStatement createPreparedStatement(Connection conn)
- throws SQLException {
- return conn.prepareStatement("select count(*) from test");
- }}, new PreparedStatementCallback<Integer>() {
- @Override
- public Integer doInPreparedStatement(PreparedStatement pstmt)
- throws SQLException, DataAccessException {
- pstmt.execute();
- ResultSet rs = pstmt.getResultSet();
- rs.next();
- return rs.getInt(1);
- }});
- Assert.assertEquals(0, count);
- }
首先使用PreparedStatementCreator建立一個預編譯語句,其次由JdbcTemplate通過PreparedStatementCallback回撥傳回,由使用者決定如何執行該PreparedStatement。此處我們使用的是execute方法。
2)預編譯語句設值回撥使用:
java程式碼:Java程式碼- @Test
- public void testPreparedStatement2() {
- String insertSql = "insert into test(name) values (?)";
- int count = jdbcTemplate.update(insertSql, new PreparedStatementSetter() {
- @Override
- public void setValues(PreparedStatement pstmt) throws SQLException {
- pstmt.setObject(1, "name4");
- }});
- Assert.assertEquals(1, count);
- String deleteSql = "delete from test where name=?";
- count = jdbcTemplate.update(deleteSql, new Object[] {"name4"});
- Assert.assertEquals(1, count);
- }
通過JdbcTemplate的int update(String sql, PreparedStatementSetter pss)執行預編譯sql,其中sql引數為“insert into test(name) values (?) ”,該sql有一個佔位符需要在執行前設值,PreparedStatementSetter實現就是為了設值,使用setValues(PreparedStatement pstmt)回撥方法設值相應的佔位符位置的值。JdbcTemplate也提供一種更簡單的方式“update(String sql, Object... args)”來實現設值,所以只要當使用該種方式不滿足需求時才應使用PreparedStatementSetter。
3)結果集處理回撥:
java程式碼:Java程式碼- @Test
- public void testResultSet1() {
- jdbcTemplate.update("insert into test(name) values('name5')");
- String listSql = "select * from test";
- List result = jdbcTemplate.query(listSql, new RowMapper<Map>() {
- @Override
- public Map mapRow(ResultSet rs, int rowNum) throws SQLException {
- Map row = new HashMap();
- row.put(rs.getInt("id"), rs.getString("name"));
- return row;
- }});
- Assert.assertEquals(1, result.size());
- jdbcTemplate.update("delete from test where name='name5'");
- }
RowMapper介面提供mapRow(ResultSet rs, int rowNum)方法將結果集的每一行轉換為一個Map,當然可以轉換為其他類,如表的物件畫形式。
java程式碼:Java程式碼- @Test
- public void testResultSet2() {
- jdbcTemplate.update("insert into test(name) values('name5')");
- String listSql = "select * from test";
- final List result = new ArrayList();
- jdbcTemplate.query(listSql, new RowCallbackHandler() {
- @Override
- public void processRow(ResultSet rs) throws SQLException {
- Map row = new HashMap();
- row.put(rs.getInt("id"), rs.getString("name"));
- result.add(row);
- }});
- Assert.assertEquals(1, result.size());
- jdbcTemplate.update("delete from test where name='name5'");
- }
RowCallbackHandler介面也提供方法processRow(ResultSet rs),能將結果集的行轉換為需要的形式。
java程式碼:Java程式碼- @Test
- public void testResultSet3() {
- jdbcTemplate.update("insert into test(name) values('name5')");
- String listSql = "select * from test";
- List result = jdbcTemplate.query(listSql, new ResultSetExtractor<List>() {
- @Override
- public List extractData(ResultSet rs)
- throws SQLException, DataAccessException {
- List result = new ArrayList();
- while(rs.next()) {
- Map row = new HashMap();
- row.put(rs.getInt("id"), rs.getString("name"));
- result.add(row);
- }
- return result;
- }});
- Assert.assertEquals(0, result.size());
- jdbcTemplate.update("delete from test where name='name5'");
- }
ResultSetExtractor使用回撥方法extractData(ResultSet rs)提供給使用者整個結果集,讓使用者決定如何處理該結果集。
當然JdbcTemplate提供更簡單的queryForXXX方法,來簡化開發:
java程式碼:Java程式碼- //1.查詢一行資料並返回int型結果
- jdbcTemplate.queryForInt("select count(*) from test");
- //2. 查詢一行資料並將該行資料轉換為Map返回
- jdbcTemplate.queryForMap("select * from test where name='name5'");
- //3.查詢一行任何型別的資料,最後一個引數指定返回結果型別
- jdbcTemplate.queryForObject("select count(*) from test", Integer.class);
- //4.查詢一批資料,預設將每行資料轉換為Map
- jdbcTemplate.queryForList("select * from test");
- //5.只查詢一列資料列表,列型別是String型別,列名字是name
- jdbcTemplate.queryForList("
- select name from test where name=?", new Object[]{"name5"}, String.class);
- //6.查詢一批資料,返回為SqlRowSet,類似於ResultSet,但不再繫結到連線上
- SqlRowSet rs = jdbcTemplate.queryForRowSet("select * from test");
3) 儲存過程及函式回撥:
首先修改JdbcTemplateTest的setUp方法,修改後如下所示:
java程式碼:Java程式碼