Spring JdbcTemplate框架搭建及其增删改查使用指南 博客分类: springjava 框架搭建增删改查CRUD使用指南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" |
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&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 |
}
|
运行截图
数据库截图