當(dāng)前位置：首頁(yè) > 编程资源 > 编程问答 >内容正文

编程问答

jdbc template 学习总结

發(fā)布時(shí)間：2025/4/14 编程问答 31 豆豆

生活随笔收集整理的這篇文章主要介紹了 jdbc template 学习总结小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

Spring JdbcTemplate方法詳解

?JdbcTemplate主要提供以下五類(lèi)方法：
execute方法：可以用于執(zhí)行任何SQL語(yǔ)句，一般用于執(zhí)行DDL語(yǔ)句；

update方法及batchUpdate方法：update方法用于執(zhí)行新增、修改、刪除等語(yǔ)句；batchUpdate方法用于

執(zhí)行批處理相關(guān)語(yǔ)句；

query方法及queryForXXX方法：用于執(zhí)行查詢(xún)相關(guān)語(yǔ)句；

call方法：用于執(zhí)行存儲(chǔ)過(guò)程、函數(shù)相關(guān)語(yǔ)句。
?
JdbcTemplate類(lèi)支持的回調(diào)類(lèi)：
預(yù)編譯語(yǔ)句及存儲(chǔ)過(guò)程創(chuàng)建回調(diào)：用于根據(jù)JdbcTemplate提供的連接創(chuàng)建相應(yīng)的語(yǔ)句；

? ? ? ? ?PreparedStatementCreator：通過(guò)回調(diào)獲取JdbcTemplate提供的Connection，由用戶(hù)使用該

Conncetion創(chuàng)建相關(guān)的PreparedStatement；
? ? ? ? ?CallableStatementCreator：通過(guò)回調(diào)獲取JdbcTemplate提供的Connection，由用戶(hù)使用該

Conncetion創(chuàng)建相關(guān)的CallableStatement；
預(yù)編譯語(yǔ)句設(shè)值回調(diào)：用于給預(yù)編譯語(yǔ)句相應(yīng)參數(shù)設(shè)值；

? ? ? ? ?PreparedStatementSetter：通過(guò)回調(diào)獲取JdbcTemplate提供的PreparedStatement，由用戶(hù)來(lái)

對(duì)相應(yīng)的預(yù)編譯語(yǔ)句相應(yīng)參數(shù)設(shè)值；
? ? ? ? ?BatchPreparedStatementSetter：；類(lèi)似于PreparedStatementSetter，但用于批處理，需要

指定批處理大小；
自定義功能回調(diào)：提供給用戶(hù)一個(gè)擴(kuò)展點(diǎn)，用戶(hù)可以在指定類(lèi)型的擴(kuò)展點(diǎn)執(zhí)行任何數(shù)量需要的操作；

? ? ? ? ?ConnectionCallback：通過(guò)回調(diào)獲取JdbcTemplate提供的Connection，用戶(hù)可在該Connection

執(zhí)行任何數(shù)量的操作；
? ? ? ? ?StatementCallback：通過(guò)回調(diào)獲取JdbcTemplate提供的Statement，用戶(hù)可以在該Statement

執(zhí)行任何數(shù)量的操作；
? ? ? ? ?PreparedStatementCallback：通過(guò)回調(diào)獲取JdbcTemplate提供的PreparedStatement，用戶(hù)可

以在該P(yáng)reparedStatement執(zhí)行任何數(shù)量的操作；
? ? ? ? ?CallableStatementCallback：通過(guò)回調(diào)獲取JdbcTemplate提供的CallableStatement，用戶(hù)可

以在該CallableStatement執(zhí)行任何數(shù)量的操作；
結(jié)果集處理回調(diào)：通過(guò)回調(diào)處理ResultSet或?qū)esultSet轉(zhuǎn)換為需要的形式；

? ? ? ? ?RowMapper：用于將結(jié)果集每行數(shù)據(jù)轉(zhuǎn)換為需要的類(lèi)型，用戶(hù)需實(shí)現(xiàn)方法mapRow(ResultSet?

rs, int rowNum)來(lái)完成將每行數(shù)據(jù)轉(zhuǎn)換為相應(yīng)的類(lèi)型。
? ? ? ? ?RowCallbackHandler：用于處理ResultSet的每一行結(jié)果，用戶(hù)需實(shí)現(xiàn)方法processRow

(ResultSet rs)來(lái)完成處理，在該回調(diào)方法中無(wú)需執(zhí)行rs.next()，該操作由JdbcTemplate來(lái)執(zhí)行，用戶(hù)

只需按行獲取數(shù)據(jù)然后處理即可。
? ? ? ? ?ResultSetExtractor：用于結(jié)果集數(shù)據(jù)提取，用戶(hù)需實(shí)現(xiàn)方法extractData(ResultSet rs)來(lái)

處理結(jié)果集，用戶(hù)必須處理整個(gè)結(jié)果集；
?
接下來(lái)讓我們看下具體示例吧，在示例中不可能介紹到JdbcTemplate全部方法及回調(diào)類(lèi)的使用方法，我

們只介紹代表性的，其余的使用都是類(lèi)似的；
?
?1）預(yù)編譯語(yǔ)句及存儲(chǔ)過(guò)程創(chuàng)建回調(diào)、自定義功能回調(diào)使用：
?
java代碼：

Java代碼 ?收藏代碼

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創(chuàng)建一個(gè)預(yù)編譯語(yǔ)句，其次由JdbcTemplate通過(guò)

PreparedStatementCallback回調(diào)傳回，由用戶(hù)決定如何執(zhí)行該P(yáng)reparedStatement。此處我們使用的是

execute方法。
?
2）預(yù)編譯語(yǔ)句設(shè)值回調(diào)使用：
?
java代碼：

Java代碼 ?收藏代碼
? ? ? ?

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); ?

} ?
?
? ? ? 通過(guò)JdbcTemplate的int update(String sql, PreparedStatementSetter pss)執(zhí)行預(yù)編譯sql，

其中sql參數(shù)為“insert into test(name) values (?) ”，該sql有一個(gè)占位符需要在執(zhí)行前設(shè)值，

PreparedStatementSetter實(shí)現(xiàn)就是為了設(shè)值，使用setValues(PreparedStatement pstmt)回調(diào)方法設(shè)值

相應(yīng)的占位符位置的值。JdbcTemplate也提供一種更簡(jiǎn)單的方式“update(String sql, Object...?

args)”來(lái)實(shí)現(xiàn)設(shè)值，所以只要當(dāng)使用該種方式不滿(mǎn)足需求時(shí)才應(yīng)使用PreparedStatementSetter。
?
3）結(jié)果集處理回調(diào)：
?
java代碼：

Java代碼 ?收藏代碼

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)方法將結(jié)果集的每一行轉(zhuǎn)換為一個(gè)Map，當(dāng)然可

以轉(zhuǎn)換為其他類(lèi)，如表的對(duì)象畫(huà)形式。
?
java代碼：

Java代碼 ?收藏代碼

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)，能將結(jié)果集的行轉(zhuǎn)換為需要的形式。
?
java代碼：

Java代碼 ?收藏代碼

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使用回調(diào)方法extractData(ResultSet rs)提供給用戶(hù)整個(gè)結(jié)果集，讓用戶(hù)決定如何

處理該結(jié)果集。
?
當(dāng)然JdbcTemplate提供更簡(jiǎn)單的queryForXXX方法，來(lái)簡(jiǎn)化開(kāi)發(fā)：
?
java代碼：

Java代碼 ?收藏代碼

//1.查詢(xún)一行數(shù)據(jù)并返回int型結(jié)果 ?

jdbcTemplate.queryForInt("select count(*) from test"); ?

//2. 查詢(xún)一行數(shù)據(jù)并將該行數(shù)據(jù)轉(zhuǎn)換為Map返回 ?

jdbcTemplate.queryForMap("select * from test where name='name5'"); ?

//3.查詢(xún)一行任何類(lèi)型的數(shù)據(jù)，最后一個(gè)參數(shù)指定返回結(jié)果類(lèi)型 ?

jdbcTemplate.queryForObject("select count(*) from test", Integer.class); ?

//4.查詢(xún)一批數(shù)據(jù)，默認(rèn)將每行數(shù)據(jù)轉(zhuǎn)換為Map ? ? ??

jdbcTemplate.queryForList("select * from test"); ?

//5.只查詢(xún)一列數(shù)據(jù)列表，列類(lèi)型是String類(lèi)型，列名字是name ?

jdbcTemplate.queryForList(" ?

select name from test where name=?", new Object[]{"name5"}, String.class); ?

//6.查詢(xún)一批數(shù)據(jù)，返回為SqlRowSet，類(lèi)似于ResultSet，但不再綁定到連接上 ?

SqlRowSet rs = jdbcTemplate.queryForRowSet("select * from test"); ?

?
3）存儲(chǔ)過(guò)程及函數(shù)回調(diào)：
首先修改JdbcTemplateTest的setUp方法，修改后如下所示：
?
?
java代碼：

Java代碼 ?收藏代碼

? ? ??

@Before ?

public void setUp() { ?

? ? String createTableSql = "create memory table test" + ?

? ? "(id int GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY, " + ?

? ? "name varchar(100))"; ?

? ? jdbcTemplate.update(createTableSql); ?

? ? ? ? ?

? ? String createHsqldbFunctionSql = ?

? ? ? "CREATE FUNCTION FUNCTION_TEST(str CHAR(100)) " + ?

? ? ? "returns INT begin atomic return length(str);end"; ?

? ? jdbcTemplate.update(createHsqldbFunctionSql); ?

? ? String createHsqldbProcedureSql = ?

? ? ? "CREATE PROCEDURE PROCEDURE_TEST" + ?

? ? ? "(INOUT inOutName VARCHAR(100), OUT outId INT) " + ?

? ? ? "MODIFIES SQL DATA " + ?

? ? ? "BEGIN ATOMIC " + ?

? ? ? " ?insert into test(name) values (inOutName); " + ?

? ? ? " ?SET outId = IDENTITY(); " + ?

? ? ? " ?SET inOutName = 'Hello,' + inOutName; " + ?

? ? "END"; ?

? ? jdbcTemplate.execute(createHsqldbProcedureSql); ?

} ?

?
? ? ? ?其中CREATE FUNCTION FUNCTION_TEST用于創(chuàng)建自定義函數(shù)，CREATE PROCEDURE PROCEDURE_TEST

用于創(chuàng)建存儲(chǔ)過(guò)程，注意這些創(chuàng)建語(yǔ)句是數(shù)據(jù)庫(kù)相關(guān)的，本示例中的語(yǔ)句只適用于HSQLDB數(shù)據(jù)庫(kù)。
?
? ? ? ?其次修改JdbcTemplateTest的tearDown方法，修改后如下所示：
?
java代碼：

Java代碼 ?收藏代碼

public void tearDown() { ?

? ? jdbcTemplate.execute("DROP FUNCTION FUNCTION_TEST"); ?

? ? jdbcTemplate.execute("DROP PROCEDURE PROCEDURE_TEST"); ?

? ? String dropTableSql = "drop table test"; ?

? ? jdbcTemplate.execute(dropTableSql); ?

} ?

?
? ? ? ?其中drop語(yǔ)句用于刪除創(chuàng)建的存儲(chǔ)過(guò)程、自定義函數(shù)及數(shù)據(jù)庫(kù)表。
?
? ? ? ?接下來(lái)看一下hsqldb如何調(diào)用自定義函數(shù)：
?
java代碼：

Java代碼 ?收藏代碼

public void testCallableStatementCreator1() { ?

? ? final String callFunctionSql = "{call FUNCTION_TEST(?)}"; ?

? ? List<SqlParameter> params = new ArrayList<SqlParameter>(); ?

? ? params.add(new SqlParameter(Types.VARCHAR)); ?

? ? params.add(new SqlReturnResultSet("result", ?

? ? ? ?new ResultSetExtractor<Integer>() { ?

? ? ? ? ? ?@Override ?

? ? ? ? ? ?public Integer extractData(ResultSet rs) throws SQLException, ?

? ? ? ? ? ? ? ?DataAccessException { ?

? ? ? ? ? ? ? ?while(rs.next()) { ?

? ? ? ? ? ? ? ? ? ?return rs.getInt(1); ?

? ? ? ? ? ? ? ?} ?

? ? ? ? ? ? ? return 0; ?

? ? ? ?})); ?

? ? Map<String, Object> outValues = jdbcTemplate.call( ?

? ? ? ?new CallableStatementCreator() { ?

? ? ? ? ? ? @Override ?

? ? ? ? ? ? public CallableStatement createCallableStatement(Connection conn) throws?

SQLException { ?

? ? ? ? ? ? ? CallableStatement cstmt = conn.prepareCall(callFunctionSql); ?

? ? ? ? ? ? ? cstmt.setString(1, "test"); ?

? ? ? ? ? ? ? return cstmt; ?

? ? }}, params); ?

? ? Assert.assertEquals(4, outValues.get("result")); ?

} ?

? ?

?
{call FUNCTION_TEST(?)}：定義自定義函數(shù)的sql語(yǔ)句，注意hsqldb {?= call …}和{call …}含義是

一樣的，而比如mysql中兩種含義是不一樣的；

params：用于描述自定義函數(shù)占位符參數(shù)或命名參數(shù)類(lèi)型；SqlParameter用于描述IN類(lèi)型參數(shù)、

SqlOutParameter用于描述OUT類(lèi)型參數(shù)、SqlInOutParameter用于描述INOUT類(lèi)型參數(shù)、

SqlReturnResultSet用于描述調(diào)用存儲(chǔ)過(guò)程或自定義函數(shù)返回的ResultSet類(lèi)型數(shù)據(jù)，其中

SqlReturnResultSet需要提供結(jié)果集處理回調(diào)用于將結(jié)果集轉(zhuǎn)換為相應(yīng)的形式，hsqldb自定義函數(shù)返回

值是ResultSet類(lèi)型。

CallableStatementCreator：提供Connection對(duì)象用于創(chuàng)建CallableStatement對(duì)象

outValues：調(diào)用call方法將返回類(lèi)型為Map<String, Object>對(duì)象；

outValues.get("result")：獲取結(jié)果，即通過(guò)SqlReturnResultSet對(duì)象轉(zhuǎn)換過(guò)的數(shù)據(jù)；其中

SqlOutParameter、SqlInOutParameter、SqlReturnResultSet指定的name用于從call執(zhí)行后返回的Map中

獲取相應(yīng)的結(jié)果，即name是Map的鍵。

注：因?yàn)閔sqldb {?= call …}和{call …}含義是一樣的，因此調(diào)用自定義函數(shù)將返回一個(gè)包含結(jié)果的

ResultSet。
?
最后讓我們示例下mysql如何調(diào)用自定義函數(shù)：
?
java代碼：

Java代碼 ?收藏代碼

public void testCallableStatementCreator2() { ?

? ? JdbcTemplate mysqlJdbcTemplate = new JdbcTemplate(getMysqlDataSource); ?

? ? //2.創(chuàng)建自定義函數(shù) ?

String createFunctionSql = ?

? ? "CREATE FUNCTION FUNCTION_TEST(str VARCHAR(100)) " + ?

? ? ?"returns INT return LENGTH(str)"; ?

String dropFunctionSql = "DROP FUNCTION IF EXISTS FUNCTION_TEST"; ?

mysqlJdbcTemplate.update(dropFunctionSql); ? ? ? ??

mysqlJdbcTemplate.update(createFunctionSql); ?

//3.準(zhǔn)備sql,mysql支持{?= call …} ?

final String callFunctionSql = "{?= call FUNCTION_TEST(?)}"; ?

//4.定義參數(shù) ?

List<SqlParameter> params = new ArrayList<SqlParameter>(); ?

params.add(new SqlOutParameter("result", Types.INTEGER)); ?

params.add(new SqlParameter("str", Types.VARCHAR)); ?

Map<String, Object> outValues = mysqlJdbcTemplate.call( ?

new CallableStatementCreator() { ?

? ? @Override ?

? ? public CallableStatement createCallableStatement(Connection conn) throws SQLException {?

?

? ? ? CallableStatement cstmt = conn.prepareCall(callFunctionSql); ?

? ? ? cstmt.registerOutParameter(1, Types.INTEGER); ?

? ? ? cstmt.setString(2, "test"); ?

? ? ? ? return cstmt; ?

? ? }}, params); ?

? ?Assert.assertEquals(4, outValues.get("result")); ?

} ?

public DataSource getMysqlDataSource() { ?

? ? String url = "jdbc:mysql://localhost:3306/test"; ?

? ? DriverManagerDataSource dataSource = ?

? ? ? ? new DriverManagerDataSource(url, "root", ""); ? ? dataSource.setDriverClassName

("com.mysql.jdbc.Driver"); ?

? ? return dataSource; ?

} ?

? ?

getMysqlDataSource：首先啟動(dòng)mysql（本書(shū)使用5.4.3版本），其次登錄mysql創(chuàng)建test數(shù)據(jù)庫(kù)

（“create database test;”），在進(jìn)行測(cè)試前，請(qǐng)先下載并添加mysql-connector-java-5.1.10.jar

到classpath；

{?= call FUNCTION_TEST(?)}：可以使用{?= call …}形式調(diào)用自定義函數(shù)；

params：無(wú)需使用SqlReturnResultSet提取結(jié)果集數(shù)據(jù)，而是使用SqlOutParameter來(lái)描述自定義函數(shù)返

回值；

CallableStatementCreator：同上個(gè)例子含義一樣；

cstmt.registerOutParameter(1, Types.INTEGER)：將OUT類(lèi)型參數(shù)注冊(cè)為JDBC類(lèi)型Types.INTEGER，此

處即返回值類(lèi)型為T(mén)ypes.INTEGER。

outValues.get("result")：獲取結(jié)果，直接返回Integer類(lèi)型，比hsqldb簡(jiǎn)單多了吧。

?
最后看一下如何如何調(diào)用存儲(chǔ)過(guò)程：
?
java代碼：

Java代碼 ?收藏代碼

public void testCallableStatementCreator3() { ?

? ? final String callProcedureSql = "{call PROCEDURE_TEST(?, ?)}"; ?

? ? List<SqlParameter> params = new ArrayList<SqlParameter>(); ?

? ? params.add(new SqlInOutParameter("inOutName", Types.VARCHAR)); ?

? ? params.add(new SqlOutParameter("outId", Types.INTEGER)); ?

? ? Map<String, Object> outValues = jdbcTemplate.call( ?

? ? ? new CallableStatementCreator() { ?

? ? ? ? @Override ?

? ? ? ? public CallableStatement createCallableStatement(Connection conn) throws?

SQLException { ?

? ? ? ? ? CallableStatement cstmt = conn.prepareCall(callProcedureSql); ?

? ? ? ? ? cstmt.registerOutParameter(1, Types.VARCHAR); ?

? ? ? ? ? cstmt.registerOutParameter(2, Types.INTEGER); ?

? ? ? ? ? cstmt.setString(1, "test"); ?

? ? ? ? ? return cstmt; ?

? ? }}, params); ?

? ? Assert.assertEquals("Hello,test", outValues.get("inOutName")); ?

? ? Assert.assertEquals(0, outValues.get("outId")); ?

} ?

? ?

{call PROCEDURE_TEST(?, ?)}：定義存儲(chǔ)過(guò)程sql；

params：定義存儲(chǔ)過(guò)程參數(shù)；SqlInOutParameter描述INOUT類(lèi)型參數(shù)、SqlOutParameter描述OUT類(lèi)型參

數(shù)；

CallableStatementCreator：用于創(chuàng)建CallableStatement，并設(shè)值及注冊(cè)O(shè)UT參數(shù)類(lèi)型；

outValues：通過(guò)SqlInOutParameter及SqlOutParameter參數(shù)定義的name來(lái)獲取存儲(chǔ)過(guò)程結(jié)果。

?
? ? ? ?JdbcTemplate類(lèi)還提供了很多便利方法，在此就不一一介紹了，但這些方法是由規(guī)律可循的，第

一種就是提供回調(diào)接口讓用戶(hù)決定做什么，第二種可以認(rèn)為是便利方法（如queryForXXX），用于那些比

較簡(jiǎn)單的操作。
========

使用Spring的jdbcTemplate進(jìn)一步簡(jiǎn)化JDBC操作

http://www.cnblogs.com/Fskjb/archive/2009/11/18/1605622.html

先看applicationContext.xml配置文件：
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd"><bean id="springDSN"class="org.springframework.jdbc.datasource.DriverManagerDataSource"><property name="driverClassName"value="com.microsoft.jdbc.sqlserver.SQLServerDriver"></property><property name="url"value="jdbc:microsoft:sqlserver://localhost:1433;databasename=bbs"></property><property name="username" value="sa"></property><property name="password" value="sa"></property></bean><bean id="jdbcTemplate"class="org.springframework.jdbc.core.JdbcTemplate" abstract="false"lazy-init="false" autowire="default" dependency-check="default"><property name="dataSource"><ref bean="springDSN" /></property></bean> </beans>

在看SpringUtil類(lèi)?
package com.r.dao;import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext;public final class SpringUtil {private static ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext.xml");public static Object getBean(String beanName){return ctx.getBean(beanName);} }
?
最后看DAO:
import java.math.BigDecimal; import java.util.ArrayList; import java.util.Iterator; import java.util.List; import java.util.Map;import org.springframework.jdbc.core.JdbcTemplate;import com.r.vo.Book;public class BookDao {private JdbcTemplate jdbcT = (JdbcTemplate) SpringUtil.getBean("jdbcTemplate");public List findALL() {String sql = "select * from BookInfo";return jdbcT.queryForList(sql); }public List<Book> findALLBooks() {List<Book> books = new ArrayList<Book>();;String sql = "select * from BookInfo";List list = jdbcT.queryForList(sql); Iterator iterator = list.iterator();Book book = null;while (iterator.hasNext()) {Map map4book = (Map) iterator.next();book = new Book();book.setBid((Integer) map4book.get("bid"));book.setBookName((String)map4book.get("bookName"));book.setBookType((String)map4book.get("bookType")); book.setBookPic(((BigDecimal)map4book.get("bookPic")).doubleValue() ); book.setCount((Integer) map4book.get("count"));books.add(book);}return books;} public int delete(int bid){String sql = "delete from BookInfo where bid =?";return jdbcT.update(sql, new Object[]{bid});} public static void main(String[] args) { List<Book> books = new BookDao().findALLBooks();;for(Book book:books){System.out.println(book.getBid()+","+book.getBookName()+","+book.getBookType());}} }
?
細(xì)心你，會(huì)發(fā)現(xiàn)JdbcTemplate的實(shí)例中有一系列的方法如：queryForXXX,update,delete大大簡(jiǎn)化了JDBC

操作。

當(dāng)然,還可以再進(jìn)一步的優(yōu)化一下,就是通過(guò)依賴(lài)注入，直接把jdbcTemplate注入到dao類(lèi)的jdbcT字段。

先看新的applicationContext.xml配置文件： ?

復(fù)制代碼
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
? ? xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
? ? xsi:schemaLocation="http://www.springframework.org/schema/beans?

http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">

? ? <bean id="springDSN"
? ? ? ? class="org.springframework.jdbc.datasource.DriverManagerDataSource">
? ? ? ? <property name="driverClassName"
? ? ? ? ? ? value="com.microsoft.jdbc.sqlserver.SQLServerDriver">
? ? ? ? </property>
? ? ? ? <property name="url"
? ? ? ? ? ? value="jdbc:microsoft:sqlserver://localhost:1433;databasename=bbs">
? ? ? ? </property>
? ? ? ? <property name="username" value="sa"></property>
? ? ? ? <property name="password" value="sa"></property>
? ? </bean>

? ? <bean id="jdbcTemplate"
? ? ? ? class="org.springframework.jdbc.core.JdbcTemplate" abstract="false"
? ? ? ? lazy-init="false" autowire="default" dependency-check="default">
? ? ? ? <property name="dataSource">
? ? ? ? ? ? <ref bean="springDSN" />
? ? ? ? </property>
? ? </bean>

? ? <bean id="bookDao" class="com.yy.struts.dao.BookDao">
? ? ? ?<property name="jdbcT">
? ? ? ? ? <ref bean="jdbcTemplate" />
? ? ? ?</property>
? ? </bean>
</beans>
復(fù)制代碼
?那么新的DAO類(lèi)：

復(fù)制代碼
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.springframework.jdbc.core.JdbcTemplate;

import com.r.vo.Book;

public class BookDao {

? ? private JdbcTemplate jdbcT;

? ? public List findALL() {
? ? ? ? String sql = "select * from BookInfo";
? ? ? ? return jdbcT.queryForList(sql); ? ? ? ?
? ? }

? ? public List<Book> findALLBooks() {
? ? ? ? List<Book> books = new ArrayList<Book>();;
? ? ? ? String sql = "select * from BookInfo";
? ? ? ? List list = jdbcT.queryForList(sql);?
? ? ? ? Iterator iterator = list.iterator();
? ? ? ? Book book = null;
? ? ? ? while (iterator.hasNext()) {
? ? ? ? ? ? Map map4book = (Map) iterator.next();
? ? ? ? ? ? book = new Book();
? ? ? ? ? ? book.setBid((Integer) map4book.get("bid"));
? ? ? ? ? ? book.setBookName((String)map4book.get("bookName"));
? ? ? ? ? ? book.setBookType((String)map4book.get("bookType")); ? ? ? ?
? ? ? ? ? ? book.setBookPic(((BigDecimal)map4book.get("bookPic")).doubleValue() ); ? ? ? ? ?

??
? ? ? ? ? ? book.setCount((Integer) map4book.get("count"));
? ? ? ? ? ? books.add(book);
? ? ? ? }
? ? ? ? return books;
? ? } ? ?
? ? public int delete(int bid){
? ? ? ? String sql = "delete from BookInfo where bid =?";
? ? ? ? return jdbcT.update(sql, new Object[]{bid});
? ? } ? ??
? ? public static void main(String[] args) { ? ? ? ?
? ? ? ? List<Book> books = new BookDao().findALLBooks();;
? ? ? ? for(Book book:books){
? ? ? ? ? ? System.out.println(book.getBid()+","+book.getBookName()+","+book.getBookType

());
? ? ? ? }
? ? }
}
復(fù)制代碼
?

?通過(guò)依賴(lài)注入，對(duì)象之間的關(guān)系由SPRING來(lái)維護(hù)，這樣能降低類(lèi)與類(lèi)的耦合度
========

JdbcTemplate學(xué)習(xí)筆記

1、使用JdbcTemplate的execute()方法執(zhí)行SQL語(yǔ)句

Java 代碼
? ??
jdbcTemplate.execute("CREATE TABLE USER (user_id integer, name varchar(100))");
? ??
jdbcTemplate.execute("CREATE TABLE USER (user_id integer, name varchar(100))"); ?
2、如果是UPDATE或INSERT,可以用update()方法。

Java 代碼
? ??
jdbcTemplate.update("INSERT INTO USER VALUES('" ?
? ??
+ user.getId() + "', '" ?
? ??
+ user.getName() + "', '" ?
? ??
+ user.getSex() + "', '" ?
? ??
+ user.getAge() + "')"); ?
? ??
jdbcTemplate.update("INSERT INTO USER VALUES('" ?
? ??
+ user.getId() + "', '" ?
? ??
+ user.getName() + "', '" ?
? ??
+ user.getSex() + "', '" ?
? ??
+ user.getAge() + "')"); ?
3、帶參數(shù)的更新

Java代碼
? ??
jdbcTemplate.update("UPDATE USER SET name = ? WHERE user_id = ?", new Object[] {name, id});?

? ?
? ??
jdbcTemplate.update("UPDATE USER SET name = ? WHERE user_id = ?", new Object[] {name, id});?

?
Java代碼
? ??
jdbcTemplate.update("INSERT INTO USER VALUES(?, ?, ?, ?)", new Object[] {user.getId(),?

user.getName(), user.getSex(), user.getAge()}); ? ?
? ??
jdbcTemplate.update("INSERT INTO USER VALUES(?, ?, ?, ?)", new Object[] {user.getId(),?

user.getName(), user.getSex(), user.getAge()}); ?
4、使用JdbcTemplate進(jìn)行查詢(xún)時(shí)，使用queryForXXX()等方法

Java代碼
? ??
int count = jdbcTemplate.queryForInt("SELECT COUNT(*) FROM USER"); ? ?
? ??
int count = jdbcTemplate.queryForInt("SELECT COUNT(*) FROM USER"); ?
Java代碼
? ??
String name = (String) jdbcTemplate.queryForObject("SELECT name FROM USER WHERE user_id =?

?", new Object[] {id}, java.lang.String.class); ? ?
? ??
String name = (String) jdbcTemplate.queryForObject("SELECT name FROM USER WHERE user_id =?

?", new Object[] {id}, java.lang.String.class); ?
Java代碼
? ??
List rows = jdbcTemplate.queryForList("SELECT * FROM USER"); ? ?
? ??
List rows = jdbcTemplate.queryForList("SELECT * FROM USER"); ?
Java代碼
? ??
List rows = jdbcTemplate.queryForList("SELECT * FROM USER"); ?
? ??
Iterator it = rows.iterator(); ?
? ??
while(it.hasNext()) { ?
? ??
Map userMap = (Map) it.next(); ?
? ??
System.out.print(userMap.get("user_id") + "\t"); ?
? ??
System.out.print(userMap.get("name") + "\t"); ?
? ??
System.out.print(userMap.get("sex") + "\t"); ?
? ??
System.out.println(userMap.get("age") + "\t"); ?
? ??
} ?
? ??
??
? ??
List rows = jdbcTemplate.queryForList("SELECT * FROM USER"); ?
? ??
??
? ??
Iterator it = rows.iterator(); ?
? ??
while(it.hasNext()) { ?
? ??
Map userMap = (Map) it.next(); ?
? ??
System.out.print(userMap.get("user_id") + "\t"); ?
? ??
System.out.print(userMap.get("name") + "\t"); ?
? ??
System.out.print(userMap.get("sex") + "\t"); ?
? ??
System.out.println(userMap.get("age") + "\t");?
? ??
? ??
} ?
JdbcTemplate將我們使用的JDBC的流程封裝起來(lái)，包括了異常的捕捉、SQL的執(zhí)行、查詢(xún)結(jié)果的轉(zhuǎn)換等等

。spring大量使用Template Method模式來(lái)封裝固定流程的動(dòng)作，XXXTemplate等類(lèi)別都是基于這種方式

的實(shí)現(xiàn)。

除了大量使用Template Method來(lái)封裝一些底層的操作細(xì)節(jié)，spring也大量使用callback方式類(lèi)回調(diào)相關(guān)

類(lèi)別的方法以提供JDBC相關(guān)類(lèi)別的功能，使傳統(tǒng)的JDBC的使用者也能清楚了解spring所提供的相關(guān)封裝

類(lèi)別方法的使用。

JDBC的PreparedStatement

Java代碼
? ??
final String id = user.getId(); ? ?
? ??
final String name = user.getName(); ? ?
? ??
final String sex = user.getSex() + ""; ? ?
? ??
final int age = user.getAge(); ?
? ??
??
? ??
jdbcTemplate.update("INSERT INTO USER VALUES(?, ?, ?, ?)", ?
? ??
??
? ??
new PreparedStatementSetter() { ? ?
? ??
public void setValues(PreparedStatement ps) throws SQLException { ? ?
? ??
ps.setString(1, id); ?
? ??
ps.setString(2, name); ?
? ??
ps.setString(3, sex); ?
? ??
ps.setInt(4, age); ?
? ??
} ?
? ??
}); ?
? ??
??
? ??
final String id = user.getId(); ?
? ??
final String name = user.getName(); ?
? ??
final String sex = user.getSex() + ""; ?
? ??
final int age = user.getAge(); ?
? ??
? ??
? ??
jdbcTemplate.update("INSERT INTO USER VALUES(?, ?, ?, ?)", ?
? ??
? ??
? ??
new PreparedStatementSetter() { ? ? ?
? ??
public void setValues(PreparedStatement ps) throws SQLException { ? ?
? ??
ps.setString(1, id); ? ?
? ??
ps.setString(2, name); ? ? ?
? ??
ps.setString(3, sex); ? ?
? ??
ps.setInt(4, age); ? ? ?
? ??
} ? ?
? ??
}); ? ? ? ?
Java代碼
? ??
final User user = new User(); ? ? ?
? ??
jdbcTemplate.query("SELECT * FROM USER WHERE user_id = ?", ? ?
? ??
new Object[] {id}, ? ?
? ??
new RowCallbackHandler() { ? ?
? ??
public void processRow(ResultSet rs) throws SQLException { ? ?
? ??
user.setId(rs.getString("user_id")); ?
? ??
user.setName(rs.getString("name")); ?
? ??
user.setSex(rs.getString("sex").charAt(0)); ? ?
? ??
user.setAge(rs.getInt("age")); ? ?
? ??
} ?
? ??
}); ?
? ??
??
? ??
final User user = new User(); ?
? ??
? ??
? ??
jdbcTemplate.query("SELECT * FROM USER WHERE user_id = ?", ? ?
? ??
new Object[] {id}, ? ? ?
? ??
new RowCallbackHandler() { ?
? ??
??
? ??
??
? ??
public void processRow(ResultSet rs) throws SQLException { ? ?
? ??
user.setId(rs.getString("user_id")); ? ?
? ??
user.setName(rs.getString("name")); ? ?
? ??
user.setSex(rs.getString("sex").charAt(0)); ? ?
? ??
user.setAge(rs.getInt("age")); ? ?
? ??
} ? ?
? ??
}); ?
Java代碼
? ??
class UserRowMapper implements RowMapper { ?
? ??
??
? ??
public Object mapRow(ResultSet rs, int index) throws SQLException { ?
? ??
??
? ??
User user = new User(); ?
? ??
user.setId(rs.getString("user_id")); ? ? ?
? ??
user.setName(rs.getString("name")); ? ?
? ??
user.setSex(rs.getString("sex").charAt(0)); ? ? ?
? ??
user.setAge(rs.getInt("age")); ? ? ?
? ??
return user; ? ? ? ??
? ??
} ? ? ? ??
? ??
} ?
? ??
? ??
? ??
public List findAllByRowMapperResultReader() { ? ? ?
? ??
??
? ??
String sql = "SELECT * FROM USER"; ?
? ??
??
? ??
return jdbcTemplate.query(sql, new RowMapperResultReader(new UserRowMapper())); ?
? ??
??
? ??
} ?
? ??
??
? ??
class UserRowMapper implements RowMapper { ?
? ??
??
? ??
public Object mapRow(ResultSet rs, int index) throws SQLException { ?
? ??
User user = new User(); ? ?
? ??
user.setId(rs.getString("user_id")); ? ?
? ??
user.setName(rs.getString("name")); ? ?
? ??
user.setSex(rs.getString("sex").charAt(0)); ? ?
? ??
user.setAge(rs.getInt("age")); ? ?
? ??
return user; ? ?
? ??
} ? ?
? ??
} ?
? ??
??
? ??
public List findAllByRowMapperResultReader() { ? ? ?
? ??
String sql = "SELECT * FROM USER"; ? ?
? ??
return jdbcTemplate.query(sql, new RowMapperResultReader(new UserRowMapper())); ?
? ??
} ?
在getUser(id)里面使用UserRowMapper

Java代碼
? ??
public User getUser(final String id) throws DataAccessException { ? ?
? ??
String sql = "SELECT * FROM USER WHERE user_id=?"; ? ?
? ??
final Object[] params = new Object[] { id }; ? ?
? ??
List list = jdbcTemplate.query(sql, params, new RowMapperResultReader(new UserRowMapper

())); ? ? ?
? ??
return (User) list.get(0); ? ?
? ??
}
? ??
??
? ??
public User getUser(final String id) throws DataAccessException { ?
? ??
String sql = "SELECT * FROM USER WHERE user_id=?"; ? ? ?
? ??
final Object[] params = new Object[] { id }; ? ? ?
? ??
List list = jdbcTemplate.query(sql, params, new RowMapperResultReader(new UserRowMapper

())); ? ? ?
? ??
return (User) list.get(0); ? ? ?
? ??
}
網(wǎng)上收集

org.springframework.jdbc.core.PreparedStatementCreator 返回預(yù)編譯SQL 不能于Object[]一起用

Java代碼
? ??
public PreparedStatement createPreparedStatement(Connection con) throws SQLException { ? ?
? ??
return con.prepareStatement(sql); ? ?
? ??
} ?
? ??
??
? ??
public PreparedStatement createPreparedStatement(Connection con) throws SQLException { ? ?
? ??
return con.prepareStatement(sql); ? ?
? ??
} ?
1.增刪改

org.springframework.jdbc.core.JdbcTemplate 類(lèi)(必須指定數(shù)據(jù)源dataSource)

Java代碼
? ??
template.update("insert into web_person values(?,?,?)",Object[]); ? ?
? ??
template.update("insert into web_person values(?,?,?)",Object[]); ?
? ??
或

Java代碼
? ??
template.update("insert into web_person values(?,?,?)",new PreparedStatementSetter(){ //匿

名內(nèi)部類(lèi) 只能訪(fǎng)問(wèn)外部最終局部變量 ? ?
? ??
public void setValues(PreparedStatement ps) throws SQLException { ? ?
? ??
ps.setInt(index++,3); ? ?
? ??
}); ?
? ??
??
? ??
template.update("insert into web_person values(?,?,?)",new PreparedStatementSetter(){ //匿

名內(nèi)部類(lèi) 只能訪(fǎng)問(wèn)外部最終局部變量 ?
? ??
??
? ??
public void setValues(PreparedStatement ps) throws SQLException { ? ?
? ??
ps.setInt(index++,3); ? ?
? ??
}); ?
? ??
??
? ??
org.springframework.jdbc.core.PreparedStatementSetter //接口處理預(yù)編譯SQL ? ? ? ?
? ??
public void setValues(PreparedStatement ps) throws SQLException { ? ?
? ??
ps.setInt(index++,3); ? ?
? ??
} ?
? ??
??
? ??
public void setValues(PreparedStatement ps) throws SQLException { ? ?
? ??
ps.setInt(index++,3); ? ?
? ??
} ?
2.查詢(xún)JdbcTemplate.query(String,[Object

[]/PreparedStatementSetter],RowMapper/RowCallbackHandler)

org.springframework.jdbc.core.RowMapper 記錄映射接口處理結(jié)果集

Java代碼
? ??
public Object mapRow(ResultSet rs, int arg1) throws SQLException { //int表當(dāng)前行數(shù) ? ?
? ??
person.setId(rs.getInt("id")); ? ?
? ??
} ? ?
? ??
List template.query("select * from web_person where id=?",Object[],RowMapper); ? ?
? ??
public Object mapRow(ResultSet rs, int arg1) throws SQLException { //int表當(dāng)前行數(shù) ? ?
? ??
person.setId(rs.getInt("id")); ? ?
? ??
} ? ?
? ??
List template.query("select * from web_person where id=?",Object[],RowMapper); ?
org.springframework.jdbc.core.RowCallbackHandler 記錄回調(diào)管理器接口處理結(jié)果集

Java代碼
? ??
template.query("select * from web_person where id=?",Object[],new RowCallbackHandler(){ ? ?
? ??
public void processRow(ResultSet rs) throws SQLException { ? ?
? ??
person.setId(rs.getInt("id")); ? ?
? ??
}); ?
======== 《新程序員》：云原生和全面數(shù)字化實(shí)踐50位技術(shù)專(zhuān)家共同創(chuàng)作，文字、視頻、音頻交互閱讀

總結(jié)

以上是生活随笔為你收集整理的jdbc template 学习总结的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。