Spring JdbcTemplate框架搭建及其增删改查使用指南

前言：

本文指在介绍Spring框架中的JdbcTemplate类的使用方法，涉及基本的Spring反转控制的使用方法和JDBC的基本概念。目标是使读者能够对JdbcTemplate快速地掌握和使用。

原创不易，转载请注明出处：Spring JdbcTemplate框架搭建及其增删改查使用指南

代码下载地址：http://www.zuidaima.com/share/1724429678644224.htm

准备：

1. Spring的基本概念

       Spring框架核心的思想就是建立一个Java对象的大工厂，用户只要给工厂一个指令，工厂就能将用户需要的对象根据配置文件组装好返还给用户。用户需要做的许多工作则可以写成简单的配置文件。

2. 丑陋的JDBC代码

01	Connection con = null;

02	PreparedStatement pStmt = null;

03	ResultSet rs = null;

04

try {

05	con = ods.getConnection();

06	String sql = "select * from admin";

07	pStmt = con.prepareStatement(sql);

08	rs = pStmt.executeQuery();

09	while (rs.next()) {

10

}

11	} catch (Exception ex) {

12

try {

13	con.rollback();

14	} catch (SQLException sqlex) {

15	sqlex.printStackTrace(System.out);

16

}

17	ex.printStackTrace();

18

19	} finally {

20

try {

21	rs.close();

22	pStmt.close();

23	con.close();

24	} catch (Exception e) {

25	e.printStackTrace();

26

}

27

}

 

以上是常见的JDBC代码，简单的select语句也需要冗长的出错处理，并且每个函数都不断地重复同样的代码。

 

3. JdbcTemplate的作用

       JdbcTemplate正是为了减少上述繁琐的代码而设计出来的。它是对JDBC的一种封装，抽象我们常用的一些方法。Simple and Stupid就是它的目标。下面是完成了刚才JDBC代码同样功能的JdbcTemplate的代码：

1	String sql = "select * from admin";

2

3	jdbcTemplate.query(sql,new RowCallbackHandler() {

4

5	public void processRow(ResultSet rs) throws SQLException {

6

7

}

8

9

} );

 

 

环境搭建：

1. 数据库的配置

      本文使用Mysql数据库，新建表admin：

1	CREATE TABLE `admin` (

2	`ID` bigint(20) unsigned NOT NULL auto_increment,

3	`NAME` varchar(100) NOT NULL,

4	`PASSWORD` varchar(200) NOT NULL,

5	PRIMARY KEY  (`ID`)

6	) ENGINE=InnoDB DEFAULT CHARSET=utf8

 

  2. Spring配置

       JdbcTemplate的使用需要有DataSource的支持，所以在配置文件中，我们首先要配置一个OracleDataSource，然后在将这个DataSource配置到JdbcTemplate里。接着将JdbcTemplate配置进DAO层，最后将DAO配置进Model层。简要的关系如下：

 

 

01	<?xml version="1.0" encoding="UTF-8"?>

02	<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"

03	"http://www.springframework.org/dtd/spring-beans.dtd">

04

<beans>

05	<bean id="dataSource"

06	class="org.springframework.jdbc.datasource.DriverManagerDataSource">

07	<property name="driverClassName" value="com.mysql.jdbc.Driver" />

08	<property name="url" value="jdbc:mysql://localhost:3306/zuidaima_admin?useUnicode=true&amp;characterEncoding=utf-8" />

09	<property name="username" value="root" />

10	<property name="password" value="111111" />

11

</bean>

12

13	<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">

14	<property name="dataSource">

15	<ref bean="dataSource" />

16	</property>

17

</bean>

18

19	<bean id="userDao" class="com.zuidaima.dao.impl.UserDaoImpl">

20	<property name="jdbcTemplate">

21	<ref bean="jdbcTemplate" />

22	</property>

23

</bean>

24

25	<bean id="user" class="com.zuidaima.model.User">

26	<property name="dao">

27	<ref bean="userDao" />

28	</property>

29

</bean>

30

31

</beans>

 

 

3. 项目截图：

      

 

使用方法：

1.查找

多行查询：

01	class UserRowMapper implements RowMapper {

02

03	public Object mapRow(ResultSet rs,int index) throws SQLException

04

05

{

06

07	User u = new User();

08

09	u.setId(rs.getString("ID"));

10

11	u.setName(rs.getString("Name"));

12

13	u.setPassword(rs.getString("Password"));

14

15

return u;

16

17

}

18

19

}

20

21	public List select(String where)

22

23

{

24

25	List list;

26

27	String sql = "select * from admin "+where;

28

29	list = jdbcTemplate.query(sql,new RowMapperResultReader(new UserRowMapper()));

30

31	return list;

32

33

}

 

 

List最终返回的是满足条件的User队列。

 

单行查询：

01	public User selectById(String id){

02

03	String sql = "select * from admin where id=?";

04

05	final User u = new User();

06

07	final Object[] params = new Object[] {id};

08

09	jdbcTemplate.query(sql, params, new RowCallbackHandler(){

10

11	public void processRow(ResultSet rs) throws SQLException {

12

13	u.setId(rs.getString("ID"));

14

15	u.setName(rs.getString("NAME"));

16

17	u.setPassword(rs.getString("PASSWORD"));

18

19

}

20

21

});

22

23

return u;

24

25

}

 

 

2.      插入

01	public void insert(User u)

02

03

{

04

05	String sql = "insert into admin (ID,NAME,PASSWORD) values (admin_id_seq.nextval,?,?)";

06

07	Object[] params = new Object[] {

08

09	u.getName(),

10

11	u.getPassword() };

12

13	jdbcTemplate.update(sql,params);

14

15

}

 

admin_id_seq.nextval为Oracle设置好的序列，问号“?”被params里的数据依次替代，最终执行sql。

 

3.       修改

非常简单：

1	public void update(String how)

2

3

{

4

5	jdbcTemplate.update(how);

6

7

}

 

 

运行截图

数据库截图