spring对JDBC的整合支持
2016-06-07 19:47
447 查看
1、Spring对jdbc等数据库技术编写Dao提供了重要支持。
a、Spring对DAO异常提供了统一处理
b、Spring对DAO编写提供了支持的抽象类
c、提高编程效率,减少jdbc编码量
DataAccessException继承于RuntimeException,属于非检查异常,不会因为没有处理异常而出现编译错误。可以使用拦截器统一处理异常,或者在界面层统一处理(异常必须处理)。
1、JdbcTemplate抽象类封装了常用的JDBC方法
封装了连接获取和释放等工作,大大简化了我们对JDBC的使用,可以有效的避免忘记关闭资源链接等错误。
2、JdbcDaoSupport抽象类是jdbc数据访问对象的基类
利用JDBC技术编写的DAO的父类,类中有获取Connection和JdbcTemple等对象信息;使用的时候需要注入一个datasource对象;对代码有一定的侵入性。
3、HibernateTemplate抽象类封装了hibernate方法
4、HibernateDaoSupport是hibernate数据访问的基类
模式2(推荐使用):不继承JdbcDaoSupport,在spring容器中配置一个JdbcTemplate的实例化对象bean,注入给DAO实现类。
A、模式1实例:
创建表:
创建实体类和实体映射类
编写DAO接口和DAO接口实现类
配置文件applicationContext.xml
编写一个测试类
测试结果:
B、模式2实例(推荐使用)
在applicationContext.xml文件中添加配置信息
编写Dao接口实现类
添加测试方法
结果一样的。
a、Spring对DAO异常提供了统一处理
b、Spring对DAO编写提供了支持的抽象类
c、提高编程效率,减少jdbc编码量
spring对DAO异常支持
spring把特定某种技术的异常,比如SQLException,统一转化为自己的异常类型,这些异常以DataAccessException为父类。封装了原始异常对象,不会丢失原始错误信息。DataAccessException继承于RuntimeException,属于非检查异常,不会因为没有处理异常而出现编译错误。可以使用拦截器统一处理异常,或者在界面层统一处理(异常必须处理)。
spring对DAO编写支持
spring提供了一套抽象的DAO类,便于以一种一致的方式使用各种数据库访问技术,jdbc和hibernate等。抽象类提供了一些方法,通过此方法可以获取到jdbc相关数据访问的数据源和配置信息。1、JdbcTemplate抽象类封装了常用的JDBC方法
封装了连接获取和释放等工作,大大简化了我们对JDBC的使用,可以有效的避免忘记关闭资源链接等错误。
2、JdbcDaoSupport抽象类是jdbc数据访问对象的基类
利用JDBC技术编写的DAO的父类,类中有获取Connection和JdbcTemple等对象信息;使用的时候需要注入一个datasource对象;对代码有一定的侵入性。
3、HibernateTemplate抽象类封装了hibernate方法
4、HibernateDaoSupport是hibernate数据访问的基类
编写DAO组件
模式1:DAO继承JdbcDaoSupport,getJdbcTemplate()方法获取JdbcTemplate对象。模式2(推荐使用):不继承JdbcDaoSupport,在spring容器中配置一个JdbcTemplate的实例化对象bean,注入给DAO实现类。
A、模式1实例:
创建表:
create table CREATE TABLE `emp` ( `id` int(10) NOT NULL, `name` varchar(20) DEFAULT NULL, `age` int(3) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=latin1 INSERT INTO `test`.`emp`(`id`,`name`,`age`) VALUES ( '1','xsx','24'); INSERT INTO `test`.`emp`(`id`,`name`,`age`) VALUES ( '2','mpt','23');
创建实体类和实体映射类
package com.xsx.entity; public class Emp { private Integer id; private String name; private Integer age; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public Integer getAge() { return age; } public void setAge(Integer age) { this.age = age; } } package com.xsx.entity; import java.sql.ResultSet; import java.sql.SQLException; import org.springframework.jdbc.core.RowMapper; public class EmpMapper implements RowMapper<Emp> { @Override public Emp mapRow(ResultSet rs, int rowIndex) throws SQLException { Emp emp = new Emp(); emp.setId(rs.getInt("id")); emp.setName(rs.getString("name")); emp.setAge(rs.getInt("age")); return emp; } }
编写DAO接口和DAO接口实现类
package com.xsx.dao; import java.util.List; import com.xsx.entity.Emp; public interface EmpDao { public void save(Emp emp); public void update(Emp emp); public void delete(int id); public Emp findById(int id); public List<Emp> findAll(); } package com.xsx.dao; import java.util.List; import org.springframework.jdbc.core.RowMapper; import org.springframework.jdbc.core.support.JdbcDaoSupport; import com.xsx.entity.Emp; import com.xsx.entity.EmpMapper; public class JdbcEmpDao1 extends JdbcDaoSupport implements EmpDao { @Override public void save(Emp emp) { String sql = "insert into emp (id,name,age) "+"values (?,?,?)"; Object[] params = { emp.getId(), emp.getName(), emp.getAge() }; super.getJdbcTemplate().update(sql, params); } @Override public void update(Emp emp) { String sql = "update emp "+"set name=?,age=? "+"where id=?"; Object[] params={ emp.getName(), emp.getAge() }; super.getJdbcTemplate().update(sql, params); } @Override public void delete(int id) { String sql = "delete from emp where id=?"; Object[] params = { id }; super.getJdbcTemplate().update(sql, params); } @Override public Emp findById(int id) { String sql = "select * from emp where id=?"; Object[] params = {id}; RowMapper<Emp> mapper = new EmpMapper(); Emp emp = super.getJdbcTemplate().queryForObject(sql, params,mapper); return emp; } @Override public List<Emp> findAll() { String sql = "select * from emp"; RowMapper<Emp> mapper = new EmpMapper(); List<Emp> list = super.getJdbcTemplate().query(sql, mapper); return list; } }
配置文件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" xmlns:context="http://www.springframework.org/schema/context" xmlns:util="http://www.springframework.org/schema/util" xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:jpa="http://www.springframework.org/schema/data/jpa" xmlns:mvc="http://www.springframework.org/schema/mvc" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.2.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/data/jpa http://www.springframework.org/schema/data/jpa/spring-jpa-1.3.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd"> <bean id="datasource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="com.mysql.jdbc.Driver" /> <property name="url" value="jdbc:mysql://localhost:3306/test" /> <property name="username" value="root" /> <!-- property池启动时的初始值 --> <property name="password" value="root" /> <!-- 连接name="initialSize" value="${initialSize}"/> --> <property name="initialSize" value="1" /> <!-- 连接池的最大值 --> <property name="maxActive" value="500" /> <!-- 最大空闲值.当经过一个高峰时间后,连接池可以慢慢将已经用不到的连接慢慢释放一部分,一直减少到maxIdle为止 --> <property name="maxIdle" value="2" /> <!-- 最小空闲值.当空闲的连接数少于阀值时,连接池就会预申请去一些连接,以免洪峰来时来不及申请 --> <property name="minIdle" value="1" /> </bean> <bean id="jdbcEmpDao1" class="com.xsx.dao.JdbcEmpDao1"> <property name="dataSource" ref="datasource" /> </bean> </beans>
编写一个测试类
package com.xsx.test; import java.util.List; import org.junit.Test; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.xsx.dao.EmpDao; import com.xsx.entity.Emp; public class TestJdbcDao { @Test public void test(){ String conf = "applicationContext.xml"; ApplicationContext ac = new ClassPathXmlApplicationContext(conf); EmpDao dao = ac.getBean("jdbcEmpDao1",EmpDao.class); List<Emp> list = dao.findAll(); for(Emp e:list){ System.out.println(e.getId()+"--"+e.getName()+"--"+e.getAge()); } } }
测试结果:
B、模式2实例(推荐使用)
在applicationContext.xml文件中添加配置信息
<!-- 不继承JdbcDaoSupport父类 --> <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name="dataSource" ref="datasource" /> </bean> <bean id="jdbcEmpDao2" class="com.xsx.dao.JdbcEmpDao2"> <property name="template" ref="jdbcTemplate" /> </bean>
编写Dao接口实现类
package com.xsx.dao; import java.util.List; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.RowMapper; import com.xsx.entity.Emp; import com.xsx.entity.EmpMapper; public class JdbcEmpDao2 implements EmpDao { private JdbcTemplate template; public void setTemplate(JdbcTemplate template) { this.template = template; } @Override public void save(Emp emp) { String sql = "insert into emp (id,name,age) "+"values (?,?,?)"; Object[] params = { emp.getId(), emp.getName(), emp.getAge() }; template.update(sql, params); } @Override public void update(Emp emp) { String sql = "update emp "+"set name=?,age=? "+"where id=?"; Object[] params={ emp.getName(), emp.getAge() }; template.update(sql, params); } @Override public void delete(int id) { String sql = "delete from emp where id=?"; Object[] params = { id }; template.update(sql, params); } @Override public Emp findById(int id) { String sql = "select * from emp where id=?"; Object[] params = {id}; RowMapper<Emp> mapper = new EmpMapper(); Emp emp = template.queryForObject(sql, params,mapper); return emp; } @Override public List<Emp> findAll() { String sql = "select * from emp"; RowMapper<Emp> mapper = new EmpMapper(); List<Emp> list = template.query(sql, mapper); return list; } }
添加测试方法
@Test public void test2(){ String conf = "applicationContext.xml"; ApplicationContext ac = new ClassPathXmlApplicationContext(conf); EmpDao dao = ac.getBean("jdbcEmpDao2",EmpDao.class); List<Emp> list = dao.findAll(); for(Emp e:list){ System.out.println(e.getId()+"--"+e.getName()+"--"+e.getAge()); } }
结果一样的。
相关文章推荐
- jdbc中的Statement和PreparedStatement接口对象
- 一个jar包里的网站
- 一个jar包里的网站之文件上传
- 一个jar包里的网站之返回对媒体类型
- Spring和ThreadLocal
- Spring Boot 开发微服务
- Spring AOP动态代理-切面
- Spring整合Quartz(JobDetailBean方式)
- Spring整合Quartz(JobDetailBean方式)
- JDBC 数据库常用连接 链接字符串
- 模拟Spring的简单实现
- Spring整合WebSocket应用示例(上)
- JDBC连接Access数据库的几种方式介绍
- spring+html5实现安全传输随机数字密码键盘
- Spring中属性注入详解
- 监听器获取Spring配置文件的方法
- springmvc 发送ajax出现中文乱码的解决方法汇总
- JDBC程序更新数据库中记录的方法
- SpringMVC框架下JQuery传递并解析Json格式的数据是如何实现的