爱一个人是一回事，拥有一个人是另外一回事，爱上并拥有一个人，更是另外一回事。 蝴蝶，是什么，是希望，是真正的希望。
上一章简单介绍了Spring的简单AOP开发(六),如果没有看过,请观看上一章。
一.Spring 的数据库模板的使用
Spring 可以与Hibernate,MyBatis 进行整合，进行相应的持久化，但都是Spring 自己也有相应的数据库操作，即JdbcTemplate。
接下来，重点讲解一下JdbcTemplate 的用法。
二.JdbcTemplate 类的使用前准备
二.一 引入jar包
在使用JdbcTemplate 类之前，需要引入相应的jar包。 需要引入jdbc和tx jar包。
Spring 可以与Junit 进行测试，引入spring-test 的jar包。这三个，都需要进行引入。
另外，不要忘记引入mysql数据库驱动的jar包。
二.二 搭建环境
采用上一章所使用的例子。 这里为了方便，进行简化一下。 简化后的为。
UserDao.java 接口
public interface UserDao {
}
UserDaoImpl 实现类
@Repository
public class UserDaoImpl implements UserDao {
}
UserService 接口
public interface UserService {
}
UserServiceImpl 实现类
@Service
public class UserServiceImpl implements UserService{
@Resource
private UserDao userDao;
}
User Pojo 类，有四个简单的属性
private Integer id;
private String name;
private String sex;
private Integer age;
配置文件 applicationContext.xml
<!-- 开启注解扫描 -->
<context:component-scan base-package="com.yjl"></context:component-scan>
采用@Resource 的注解进行相应的注入。
这里采用的是Spring 测试的方式，所以不用Action 类了。
UserTest.java 类
@RunWith(SpringJUnit4ClassRunner.class) // 引入哪个类，固定语法。
@ContextConfiguration("classpath:applicationContext.xml") // 引入配置文件
public class UserTest {
@Resource
private UserService userService;
}
需要手动创建Mysql 数据表 user 表。
三. JdbcTemplate 的常见方法使用
三.一 JdbcTemplate 对象的创建
创建对象，采用的是new JdbcTemplate(dataSource) 的形式， dataSource 指的是数据源。
创建数据源 dataSource
org.springframework.jdbc.datasource.DriverManagerDataSource
DriverManagerDataSource dataSource=new DriverManagerDataSource();
// 构建数据库连接
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://localhost:3306/spring");
dataSource.setUsername("root");
dataSource.setPassword("abc123");
构建JdbcTemplate 对象
JdbcTemplate jdbc=new JdbcTemplate(dataSource);
为了简化后面的开发，将数据源的创建 封装成一个方法。
public DriverManagerDataSource getDataSource(){
DriverManagerDataSource dataSource=new DriverManagerDataSource();
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://localhost:3306/spring");
dataSource.setUsername("root");
dataSource.setPassword("abc123");
return dataSource;
}
三.二 插入数据 update()
public int add() {
//1. 创建数据源
DriverManagerDataSource dataSource=getDataSource();
//2. 实现化jdbcTemplate 对象。
JdbcTemplate jdbc=new JdbcTemplate(dataSource);
//3. sql语句
String sql="insert into user(name,sex,age) values(?,?,?)";
//4. 调用内部方法，进行执行sql语句。
//采用的是可变参数的形式。
//return jdbc.update(sql,"两个蝴蝶飞","男",24);
//也可以采用对象数组的形式,传入的是一个对象参数.
return jdbc.update(sql,new Object[]{"精灵妹","女",24});
}
UserTest 中测试方法为:(以后省略写。)
@Test
public void testAdd(){
int count=userService.add();
System.out.println("变更的数目为:"+count);
}
测试运行后:
三.三 修改语句 update()
@Override
public int update() {
DriverManagerDataSource dataSource=getDataSource();
JdbcTemplate jdbc=new JdbcTemplate(dataSource);
String sql="update user set name=?,age=? where id=?";
return jdbc.update(sql,new Object[]{"老蝴蝶",25,1});
}
三.四 删除语句 update()
传入参数值为1
public int delete(int id) {
DriverManagerDataSource dataSource=getDataSource();
JdbcTemplate jdbc=new JdbcTemplate(dataSource);
String sql="delete from user where id=?";
return jdbc.update(sql,id);
}
三.五 批量更新 batchUpdate()
添加，删除，修改，都是用的update() 方法， 为了便于后面的查询，这里提前讲解一下 批量更新的操作。 batchUpdate()
public int updateBatch() {
DriverManagerDataSource dataSource=getDataSource();
JdbcTemplate jdbc=new JdbcTemplate(dataSource);
// sql 语句必须是同一个sql语句， 只是参数不一样而已。
String sql="insert into user(name,sex,age) values(?,?,?)";
// 单个时，每一个是Object [] 数组，批量时，便是List<Object []> 数组。
List<Object []> param=new ArrayList<Object []> ();
Object [] obj1=new Object[]{"张三","男",24};
Object [] obj2=new Object[]{"李四","男",25};
Object [] obj3=new Object[]{"王二","女",24};
param.add(obj1);
param.add(obj2);
param.add(obj3);
// 更新语句。
return jdbc.batchUpdate(sql,param).length;
}
执行后，结果为: 返回的是 int[] 数组
三.六 根据id 查询单个值 queryForObject
查询时，用queryForObject(), 需要自己手动处理查询后的结果。 实现RowMapper 接口，重写里面的mapRow 方法。
@Override
public User getById(int id) {
DriverManagerDataSource dataSource=getDataSource();
JdbcTemplate jdbc=new JdbcTemplate(dataSource);
String sql="select * from user where id=?";
//User user=jdbc.queryForObject(sql,new MyUserRow(),id);
// 也可以将参数放在前面，但这个时候，参数必须是数组方式
User user=jdbc.queryForObject(sql,new Object[]{id},new MyUserRow());
return user;
}
class MyUserRow implements RowMapper<User>{
@Override
public User mapRow(ResultSet res, int num) throws SQLException {
// 根据res 取出里面的属性。 num 表示索引行
String name=res.getObject("name").toString();
String sex=res.getObject("sex").toString();
int age=Integer.parseInt(res.getObject("age").toString());
int id=Integer.parseInt(res.getObject("id").toString());
// 构建user 对象。
User user=new User();
user.setId(id);
user.setName(name);
user.setSex(sex);
user.setAge(age);
return user;
}
}
查询后的结果为:
三.七 查询多条数据 query()
public List<User> getAll() {
DriverManagerDataSource dataSource=getDataSource();
JdbcTemplate jdbc=new JdbcTemplate(dataSource);
String sql="select * from user";
List<User> userList=jdbc.query(sql,new MyUserRow());
return userList;
}
输出集合
List<User> userList=userService.getAll();
userList.forEach(n->System.out.println(n));
三.八 查询单个值 queryForObject()
public int count() {
DriverManagerDataSource dataSource=getDataSource();
JdbcTemplate jdbc=new JdbcTemplate(dataSource);
String sql="select count(*) as count from user";
// 返回的是Integer 类型。
int count=jdbc.queryForObject(sql,Integer.class);
return count;
}
三.九 查询封装成Map集合 queryForList()
@Override
public int forList(){
DriverManagerDataSource dataSource=getDataSource();
JdbcTemplate jdbc=new JdbcTemplate(dataSource);
String sql="select * from user";
// 查询出的是map 集合， 列名为key,值为value .
List<Map<String,Object>> result =jdbc.queryForList(sql);
Iterator <Map<String,Object>> iterator=result.iterator();
while(iterator.hasNext()){
Map<String,Object> map=iterator.next();
// 里面的编号为 属性名称. //实际上，需要遍历一下map,看key 和value 分别是什么。
System.out.print("编号为:"+map.get("id"));
System.out.print("名称为:"+map.get("name"));
System.out.print("性别为:"+map.get("sex"));
System.out.print("年龄为:"+map.get("age"));
System.out.println();
}
return result.size();
}
queryForList() 时，查询出的是List, 单个值是Map, 里面的key 放置的是列名，value 是数值。 如果sql 语句中 列名不明显或者是不好用的话，最好在sql 语句中设置别名，这样在map 中就可以把别名当成key了。
三.十 封装成单个Map queryForMap()
里面只放置单个Map的值，
可以放置单个值的结果，如 聚集函数 count().
只能放置单个值，不能查询出单条记录。
public int count() {
DriverManagerDataSource dataSource=getDataSource();
JdbcTemplate jdbc=new JdbcTemplate(dataSource);
// 设置别名，好设置key值。
String sql="select count(*) as count from user";
Map<String, Object> map=jdbc.queryForMap(sql);
int count=Integer.parseInt(map.get("count").toString());
return count;
}
不能放置单条记录，这样写是错误的
public User getById(int id) { // 是错误的写法。
DriverManagerDataSource dataSource=getDataSource();
JdbcTemplate jdbc=new JdbcTemplate(dataSource);
String sql="select * from user where id=?";
Map<String, Object> map=jdbc.queryForMap(sql,1);
User user=new User();
user.setId(Integer.parseInt(map.get("id").toString()));
user.setName(map.get("name").toString());
user.setSex(map.get("sex").toString());
user.setAge(Integer.parseInt(map.get("age").toString()));
return user;
}
四. jdbcTemplate 与数据库配置使用
数据库的配置，应该是用配置文件，而不是硬编码到程序里面。
四.一 jdbc.properties 配置文件
放置在src 目录下。
内容是:
## key值，前面最好加上jdbc的前缀。 因为username 与password 可能与其他值重名。
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/spring
jdbc.username=root
jdbc.password=abc123
四.二 在applictionContext.xml 中引入配置文件jdbc.properties
<!-- 引入配置文件 -->
<context:property-placeholder location="jdbc.properties"/>
四.三 UserDaoImpl 类中声明JdbcTemplate对象
@Repository
public class UserDaoImpl implements UserDao {
@Resource
private JdbcTemplate jdbcTemplate;
}
四.四 Spring 内置连接池的配置
bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="${jdbc.driverClassName}"/>
<property name="url" value="${jdbc.url}"/> -->
<property name="user" value="${jdbc.username}"/>
<property name="password" value="${jdbc.password}"/>
</bean>
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"></property>
</bean>
四.五 Spring 配置dbcp 连接池
需要引入关于dbcp 的jar包， 一个是 dbcp.jar ,一个是pool.jar
bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
<property name="driverClassName" value="${jdbc.driverClassName}"/>
<property name="url" value="${jdbc.url}"/> -->
<property name="user" value="${jdbc.username}"/>
<property name="password" value="${jdbc.password}"/>
</bean>
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"></property>
</bean>
四.六 Spring 配置C3p0 连接池
需要引入关于c3p0的jar包。
和:
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<!--注意，这里用的是driverClass和jdbcUrl-->
<property name="driverClass" value="${jdbc.driverClassName}"/>
<property name="jdbcUrl" value="${jdbc.url}"/>
<property name="user" value="${jdbc.username}"/>
<property name="password" value="${jdbc.password}"/>
</bean>
<bean id="jdbc" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"></property>
</bean>
上面的三种方式均可以。
这样，就可以在配置文件中进行配置数据源了。
谢谢!!!
