Spring中jdbcTemplate的用法实例

迈不过友情╰ 2022-08-07 15:00 141阅读 0赞

一、首先配置JdbcTemplate；

要使用Jdbctemplate 对象来完成jdbc 操作。通常情况下，有三种种方式得到JdbcTemplate 对象。  
      第一种方式：我们可以在自己定义的DAO 实现类中注入一个DataSource 引用来完 成JdbcTemplate 的实例化。也就是它是从外部“注入” DataSource 到DAO 中，然后 自己实例化JdbcTemplate，然后将DataSource 设置到JdbcTemplate 对象中。  
      第二种方式： 在 Spring 的 IoC 容器中配置一个 JdbcTemplate 的 bean，将 DataSource 注入进来，然后再把JdbcTemplate 注入到自定义DAO 中。  
     第三种方式: Spring 提供了 org.springframework.jdbc.core.support.JdbcDaoSupport 类 ， 这 个 类 中 定 义 了 JdbcTemplate 属性，也定义了DataSource 属性，当设置DataSource 属性的时候，会创 建jdbcTemplate 的实例，所以我们自己编写的DAO 只需要继承JdbcDaoSupport 类， 然后注入DataSource 即可。提倡采用第三种方法。虽然下面的用法中采用了前两种方法

配置方法有3种：

1、

Java代码  [ ![收藏代码][icon_star.png]][_icon_star.png]

1.  **public** **class** UserServiceImpl **implements** UserService \{  
2.    
3.       **private** JdbcTemplate jdbcTemplate;  
4.        
5.       **public** JdbcTemplate getJdbcTemplate() \{  
6.           **return** jdbcTemplate;  
7.      \}  
8.    
9.                   //注入方法1     
10.      **public** **void** setJdbcTemplate(JdbcTemplate jdbcTemplate) \{  
11.          **this**.jdbcTemplate = jdbcTemplate;  
12.     \}  
13.   
14.                 //其它方法这里省略……  
15. \}

spring配置文件为：

Xml代码  [ ![收藏代码][icon_star.png]][_icon_star.png]

1.  **<****bean** id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"**>**  
2.           **<****property** name =  "dataSource" ref="dataSource"**>**  
3.  **</****bean****>**  
4.  **<****bean** id="userService" class="com.hxzy.account.jdbcTemplate.UserServiceImpl"**>**  
5.        **<****property** name="jdbcTemplate" ref="jdbcTemplate"**/>**  
6.  **</****bean****>**

方法2、

Java代码  [ ![收藏代码][icon_star.png]][_icon_star.png]

1.  **public** **class** UserServiceImpl **implements** UserService \{  
2.    
3.           **private** JdbcTemplate jdbcTemplate;  
4.            
5.           //注入方法2  
6.           **public** **void** setDataSource(DataSource dataSource) \{  
7.                      **this**.jdbcTemplate =  **new** JdbcTemplate(dataSource);  
8.          \}  
9.         
10.         //其它方法省略……  
11. \}

spring配置文件为：

Xml代码  [ ![收藏代码][icon_star.png]][_icon_star.png]

1.  **<****bean** id="userService" class="com.hxzy.account.jdbcTemplate.UserServiceImpl"**>**  
2.          **<****property** name="dataSource" ref="dataSource"**/>**  
3.  **</****bean****>**

方法3：继承JdbcDaoSupport，其内部有个JdbcTemplate ，需要注入DataSource 属性来实例化。

Java代码  [ ![收藏代码][icon_star.png]][_icon_star.png]

1.  **public** **class** UserDaoImpl **extends** JdbcDaoSupport **implements** UserDao \{  
2.    
3.      @Override  
4.       **public** **void** save(User user) \{  
5.          String sql =  **null**;  
6.           **this**.getJdbcTemplate().update(sql);  
7.      \}  
8.           //其它方法省略……  
9.  \}

spring配置文件：

Xml代码  [ ![收藏代码][icon_star.png]][_icon_star.png]

1.  **<****bean** id="userDao" class="com.hxzy.account.jdbcTemplate.UserDaoImpl"**>**  
2.              **<****property** name="dataSource" ref="dataSource"**/>**  
3.  **</****bean****>**

二、常用方法使用

【注意：】jdbcTemplate 中的sql均是用“?”做占位符的

domain User：

Java代码  [ ![收藏代码][icon_star.png]][_icon_star.png]

1.  **public** **class** User \{  
2.       **private** **int** id;  
3.       **private** String username;  
4.       **private** String password;  
5.       **private** String sex;  
6.                
7.                  //setter和getter方法省略……  
8.  \}

UserServiceImpl ：

如果采用第三种方式，则下面的用法中将方法中的 jdbcTemplate 换成 this.getJdbcTemplate()即可。

Java代码  [ ![收藏代码][icon_star.png]][_icon_star.png]

1.        /\*\*  
2.       \* 创建表 
3.       \*/   
4.       **public** **void** create(String tableName)\{  //tb\_test1  
5.          jdbcTemplate.execute("create table "\+tableName +" (id integer,user\_name varchar2(40),password varchar2(40))");  
6.      \}  
7.        
8.       //jdbcTemplate.update适合于insert 、update和delete操作；  
9.       /\*\*  
10.      \* 第一个参数为执行sql  
11.      \* 第二个参数为参数数据  
12.      \*/   
13.      **public** **void** save3(User user) \{  
14.         Assert.isNull(user,  "user is not null");  
15.         jdbcTemplate.update("insert into tb\_test1(name,password) values(?,?)",   
16.                  **new** Object\[\]\{user.getUsername(),user.getPassword()\});  
17.     \}  
18.       
19.      /\*\*  
20.      \* 第一个参数为执行sql  
21.      \* 第二个参数为参数数据  
22.      \* 第三个参数为参数类型  
23.      \*/   
24.     @Override  
25.      **public** **void** save(User user) \{  
26.         Assert.isNull(user,  "user is not null");  
27.         jdbcTemplate.update(  
28.                  "insert into tb\_test1(name,password) values(?,?)",   
29.                  **new** Object\[\]\{user.getUsername(),user.getPassword()\},   
30.                  **new** **int**\[\]\{java.sql.Types.VARCHAR,java.sql.Types.VARCHAR\}  
31.                 );  
32.     \}  
33.   
34.      //避免sql注入  
35.      **public** **void** save2(**final** User user) \{  
36.         Assert.isNull(user,  "user is not null");  
37.           
38.         jdbcTemplate.update("insert into tb\_test1(name,password) values(?,?)",   
39.                  **new** PreparedStatementSetter()\{  
40.               
41.                      @Override  
42.                      **public** **void** setValues(PreparedStatement ps) **throws** SQLException \{  
43.                         ps.setString(1, user.getUsername());  
44.                         ps.setString(2, user.getPassword());  
45.                     \}  
46.         \});  
47.           
48.     \}  
49.       
50.      **public** **void** save4(User user) \{  
51.         Assert.isNull(user,  "user is not null");  
52.         jdbcTemplate.update("insert into tb\_test1(name,password) values(?,?)",   
53.                               **new** Object\[\]\{user.getUsername(),user.getPassword()\});  
54.     \}  
55.       
56.      //返回插入的主键  
57.      **public** List save5(**final** User user) \{  
58.           
59.         KeyHolder keyHolder =  **new** GeneratedKeyHolder();  
60.   
61.         jdbcTemplate.update(**new** PreparedStatementCreator() \{  
62.                       
63.                                  @Override  
64.                                  **public** PreparedStatement createPreparedStatement(Connection connection)  **throws** SQLException \{  
65.                                     PreparedStatement ps = connection.prepareStatement("insert into tb\_test1(name,password) values(?,?)", **new** String\[\] \{ "id"\});  
66.                                     ps.setString(1, user.getUsername());  
67.                                     ps.setString(2, user.getPassword());  
68.                                      **return** ps;  
69.                                 \}  
70.                             \},  
71.                 keyHolder);  
72.           
73.          **return** keyHolder.getKeyList();  
74.     \}  
75.       
76.     @Override  
77.      **public** **void** update(**final** User user) \{  
78.         jdbcTemplate.update(  
79.                  "update tb\_test1 set name=？,password=？ where id = ?",   
80.                  **new** PreparedStatementSetter()\{  
81.                      @Override  
82.                      **public** **void** setValues(PreparedStatement ps) **throws** SQLException \{  
83.                         ps.setString(1, user.getUsername());  
84.                         ps.setString(2, user.getPassword());  
85.                         ps.setInt(3, user.getId());  
86.                     \}  
87.                 \}  
88.         );  
89.     \}  
90.   
91.     @Override  
92.      **public** **void** delete(User user) \{  
93.         Assert.isNull(user,  "user is not null");  
94.         jdbcTemplate.update(  
95.                  "delete from tb\_test1 where id = ?",   
96.                  **new** Object\[\]\{user.getId()\},   
97.                  **new** **int**\[\]\{java.sql.Types.INTEGER\});  
98.     \}  
99.   
100.     @Deprecated  //因为没有查询条件，所以用处不大  
101.      **public** **int** queryForInt1()\{  
102.          **return** jdbcTemplate.queryForInt("select count(0) from tb\_test1");  
103.     \}  
104.       
105.      **public** **int** queryForInt2(User user)\{  
106.          **return** jdbcTemplate.queryForInt("select count(0) from tb\_test1 where username = ?" ,  
107.                  **new** Object\[\]\{user.getUsername()\});  
108.     \}  
109.       
110.      //最全的参数3个  
111.      **public** **int** queryForInt3(User user)\{  
112.          **return** jdbcTemplate.queryForInt("select count(0) from tb\_test1 where username = ?" ,  
113.                  **new** Object\[\]\{user.getUsername()\},  
114.                  **new** **int**\[\]\{java.sql.Types.VARCHAR\});  
115.     \}  
116.       
117.      //可以返回是一个基本类型的值  
118.     @Deprecated   //因为没有查询条件，所以用处不大  
119.      **public** String queryForObject1(User user) \{  
120.          **return** (String) jdbcTemplate.queryForObject("select username from tb\_test1 where id = 100",  
121.                                                     String.**class**);  
122.     \}  
123.       
124.      //可以返回值是一个对象  
125.     @Deprecated  //因为没有查询条件，所以用处不大  
126.      **public** User queryForObject2(User user) \{  
127.          **return** (User) jdbcTemplate.queryForObject("select \* from tb\_test1 where id = 100", User.**class**);  //class是结果数据的java类型  
128.     \}  
129.       
130.     @Deprecated  //因为没有查询条件，所以用处不大  
131.      **public** User queryForObject3(User user) \{  
132.          **return** (User) jdbcTemplate.queryForObject("select \* from tb\_test1 where id = 100",   
133.                      **new** RowMapper()\{  
134.       
135.                          @Override  
136.                          **public** Object mapRow(ResultSet rs,  **int** rowNum)**throws** SQLException \{  
137.                             User user  =  **new** User();  
138.                             user.setId(rs.getInt("id"));  
139.                             user.setUsername(rs.getString("username"));  
140.                             user.setPassword(rs.getString("password"));  
141.                              **return** user;  
142.                         \}  
143.                     \}  
144.         );   
145.     \}  
146.       
147.      **public** User queryForObject4(User user) \{  
148.          **return** (User) jdbcTemplate.queryForObject("select \* from tb\_test1 where id = ?",   
149.                                                      **new** Object\[\]\{user.getId()\},  
150.                                                     User.**class**);  //class是结果数据的java类型  实际上这里是做反射，将查询的结果和User进行对应复制  
151.     \}  
152.       
153.      **public** User queryForObject5(User user) \{  
154.          **return** (User) jdbcTemplate.queryForObject(  
155.                  "select \* from tb\_test1 where id = ?",   
156.                  **new** Object\[\]\{user.getId()\},  
157.                  **new** RowMapper()\{  
158.   
159.                      @Override  
160.                      **public** Object mapRow(ResultSet rs,**int** rowNum)**throws** SQLException \{  
161.                         User user  =  **new** User();  
162.                         user.setId(rs.getInt("id"));  
163.                         user.setUsername(rs.getString("username"));  
164.                         user.setPassword(rs.getString("password"));  
165.                          **return** user;  
166.                     \}  
167.               
168.         \});  //class是结果数据的java类型  
169.     \}  
170.       
171.     @Override  
172.      **public** User queryForObject(User user) \{  
173.          //方法有返回值  
174.          **return** (User) jdbcTemplate.queryForObject("select \* from tb\_test1 where id = ?",  
175.                  **new** Object\[\]\{user.getId()\},  
176.                  **new** **int**\[\]\{java.sql.Types.INTEGER\},   
177.                  **new** RowMapper() \{  
178.               
179.                      @Override  
180.                      **public** Object mapRow(ResultSet rs,  **int** rowNum) **throws** SQLException \{  
181.                         User user  =  **new** User();  
182.                         user.setId(rs.getInt("id"));  
183.                         user.setUsername(rs.getString("username"));  
184.                         user.setPassword(rs.getString("password"));  
185.                          **return** user;  
186.                     \}  
187.                 \}  
188.         );  
189.     \}  
190.   
191.     @SuppressWarnings("unchecked")  
192.      **public** List<User> queryForList1(User user) \{  
193.          **return** (List<User>) jdbcTemplate.queryForList("select \* from tb\_test1 where username = ?",   
194.                              **new** Object\[\]\{user.getUsername()\},  
195.                             User.**class**);  
196.     \}  
197.   
198.     @SuppressWarnings("unchecked")  
199.      **public** List<String> queryForList2(User user) \{  
200.          **return** (List<String>) jdbcTemplate.queryForList("select username from tb\_test1 where sex = ?",   
201.                              **new** Object\[\]\{user.getSex()\},  
202.                             String.**class**);  
203.     \}  
204.       
205.     @SuppressWarnings("unchecked")  
206.      //最全的参数查询  
207.      **public** List<User> queryForList3(User user) \{  
208.          **return** (List<User>) jdbcTemplate.queryForList("select \* from tb\_test1 where username = ?",  
209.                              **new** Object\[\]\{user.getUsername()\},  
210.                              **new** **int**\[\]\{java.sql.Types.VARCHAR\},  
211.                             User.**class**);  
212.     \}  
213.   
214.      //通过RowCallbackHandler对Select语句得到的每行记录进行解析，并为其创建一个User数据对象。实现了手动的OR映射。  
215.      **public** User queryUserById4(String id)\{  
216.          **final** User user  =  **new** User();  
217.           
218.          //该方法返回值为void  
219.          **this**.jdbcTemplate.query("select \* from tb\_test1 where id = ?",   
220.                  **new** Object\[\] \{ id \},   
221.                  **new** RowCallbackHandler() \{     
222.               
223.                      @Override    
224.                      **public** **void** processRow(ResultSet rs) **throws** SQLException \{     
225.                         User user  =  **new** User();  
226.             user.setId(rs.getInt("id"));  
227.             user.setUsername(rs.getString("username"));  
228.             user.setPassword(rs.getString("password"));    
229.                     \}     
230.         \});   
231.           
232.          **return** user;     
233.     \}  
234.       
235.     @SuppressWarnings("unchecked")  
236.     @Override  
237.      **public** List<User> list(User user) \{  
238.          **return** jdbcTemplate.query("select \* from tb\_test1 where username like '%?%'",   
239.                  **new** Object\[\]\{user.getUsername()\},   
240.                  **new** **int**\[\]\{java.sql.Types.VARCHAR\},   
241.                  **new** RowMapper()\{  
242.               
243.                      @Override  
244.                      **public** Object mapRow(ResultSet rs,  **int** rowNum) **throws** SQLException \{  
245.                         User user  =  **new** User();  
246.                         user.setId(rs.getInt("id"));  
247.                         user.setUsername(rs.getString("username"));  
248.                         user.setPassword(rs.getString("password"));  
249.                          **return** user;  
250.                     \}  
251.         \});  
252.     \}  
253.   
254.      //批量操作    适合于增、删、改操作  
255.      **public** **int**\[\] batchUpdate(**final** List users) \{  
256.           
257.          **int**\[\] updateCounts = jdbcTemplate.batchUpdate(  
258.                  "update tb\_test1 set username = ?, password = ? where id = ?",  
259.                  **new** BatchPreparedStatementSetter() \{  
260.                       
261.                          @Override  
262.                          **public** **void** setValues(PreparedStatement ps, **int** i)  **throws** SQLException \{  
263.                             ps.setString(1, ((User)users.get(i)).getUsername());  
264.                             ps.setString(2, ((User)users.get(i)).getPassword());  
265.                             ps.setLong(3, ((User)users.get(i)).getId());  
266.                         \}  
267.                           
268.                          @Override  
269.                          **public** **int** getBatchSize() \{  
270.                              **return** users.size();  
271.                         \}  
272.                 \}   
273.         );  
274.           
275.          **return** updateCounts;  
276.     \}  
277.       
278.      //调用存储过程  
279.      **public** **void** callProcedure(**int** id)\{  
280.          **this**.jdbcTemplate.update("call SUPPORT.REFRESH\_USERS\_SUMMARY(?)", **new** Object\[\]\{Long.valueOf(id)\});  
281. \}

其中，batchUpdate适合于批量增、删、改操作；

update(…)：使用于增、删、改操作；

execute（）：执行一个独立的sql语句，包括ddl语句；

queryForInt ：查询出一个整数值

摘自：http://lehsyh.iteye.com/blog/1579737

[icon_star.png]: http://lehsyh.iteye.com/images/icon_star.png
[_icon_star.png]: /images/20220805/fa48c2a6595b443cb754ba11034bb24f.png