Spring学习5-Spring整合JDBC及其事务处理（注解方式）

Posted 2020-06-13

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Spring学习5-Spring整合JDBC及其事务处理（注解方式）相关的知识，希望对你有一定的参考价值。

一、整合的步骤

1、步骤一：首先要获得DataSource连接池（推荐使用B方式）:
要对数据库执行任何的JDBC操作，需要有一个Connection.在Spring中，Connection对象是通过DataSource获得的。

有几种方法可以得到DataSource, 其中一种方法是使用Spring提供的轻量级 org.springframework.jdbc.datasource.DriverManagerDataSource，第二种方法是使用 org.apache.commons.dbcp.BasicDataSource类。

A：使用DriverMangerDataSource获取DataSource，这种方法是轻量级的，方便测试
    public class DataSoureProvider {
     public static DriverManagerDataSource dataSource = new DriverManagerDataSource();

     public static DriverManagerDataSource getInstance() {
         dataSource.setDriverClassName("com.mysql.jdbc.Driver");
         dataSource.setUrl("jdbc:mysql://localhost:3306/book");
         dataSource.setUsername("y****");
         dataSource.setPassword("h*******");
         return dataSource;
     }

     @Test
     public void test() {
         DataSoureProvider.getInstance();
         try {
             dataSource.getConnection();
         }
         catch (SQLException e) {
             e.printStackTrace();
         }
     }
}

B：通过使用BasicDataSouce创建一个连接池获取DataSource。应为BasicDataSource所有属性都是通过setter方法暴露在外面的，我们可以像配置其他Srping Bean那样配置它我将数据库连接信息配置在properties文件中，利用spring的org.springframeword.beans.factory.config.PropertyPlaceholderConfigurer类进行读取装载。
注意：
使用org.apache.commons.dbcp.BasicDataSource需要引入额外的jar包，分别是,commons-dbcp-1.4.jar,commons-pool-1.2.jar （官网下载页面：http://commons.apache.org/）

书写配置文件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:p="http://www.springframework.org/schema/p"
     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">

     <bean id="dbproperty" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
         <property name="location">

              <value>connect.properties</value>
         </property>
     </bean>
     <-- 配置BasicDataSource参数，其中<value>中的参数是在connect.propertices配置文件中拿到的,其实value值也可以直接写上的-->
     <bean id="myDataSource" class="org.apache.commons.dbcp.BasicDataSource">
         <property name="driverClassName">
             <value>${db.driver}</value>
         </property>
         <property name="url">
             <value>${db.url}</value>
         </property>
         <property name="username">
             <value>${db.username}</value>
         </property>
         <property name="password">
             <value>${db.password}</value>
         </property>
     </bean>
</beans>
--------------------------------------------------------------------------------------

2、步骤二：使用JdbcTemplate类操作数据库:
    Spring把JDBC中重复的操作建立成了一个模板类：org.springframework.jdbc.core.JdbcTemplate。
   A：要使用JdbcTemplate,需要为每一个DAO配置一个JdbcTemplate实例：
public class StudentDaoImp implements StudentDao {
     private JdbcTemplate jdbcTemplate;

     @Override
     public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
         this.jdbcTemplate = jdbcTemplate;
     }
}
B：如上，StudentDaoImp内配置了一个JdbcTemplate对象和它对应的setter方法。这样就可以在Spring配置文件中对其进行赋值。
<?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:p="http://www.springframework.org/schema/p"
     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">

     <bean id="dbproperty"
         class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
         <property name="location">
             <value>connect.properties</value>
         </property>
     </bean>

     <bean id="myDataSource" class="org.apache.commons.dbcp.BasicDataSource">
         <property name="driverClassName">
             <value>${db.driver}</value>
         </property>
         <property name="url">
             <value>${db.url}</value>
         </property>
         <property name="username">
             <value>${db.username}</value>
         </property>
         <property name="password">
             <value>${db.password}</value>
         </property>
     </bean>

     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
         <constructor-arg ref="myDataSource"></constructor-arg>
     </bean>

     <bean id="studentDao" class="com.sunflower.dao.StudentDaoImp">
         <property name="jdbcTemplate">
             <ref bean="jdbcTemplate"/>
         </property>
     </bean>
</beans>
C：使用JdbcTemplate插入数据:

   1）插入单条数据：JdbcTemplate为我们提供了update(String sql,Object... args)方法，方便我们进行数据的插入.
   2）批量添加数据：批量插入数据需要用到org.springframework.jdbc.core.BatchPreparedStatementSetter接口。BatchPreparedStatementSetter接口的两个方法，其中getBatchSize()方法是得到需要插入的记录的个数，setValues(PreparedStatement ps, int index)方法是实际进行插入的方法。
3）查询单条记录：执行一条数据的查询，需要使用org.springframework.jdbc.core.RowCallbackHandler接口的实现。
4）查询多条记录：这里需要用到org.springframework.jdbc.core.RowMapper接口的实现。RowMapper接口负责把Result中的一条记录映射成一个对象。
public class StudentDaoImp implements StudentDao {
     private JdbcTemplate jdbcTemplate;

     @Override
     public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
         this.jdbcTemplate = jdbcTemplate;
     }
     //插入单条数据
     public void insert(Student student)
     {
         String sql = "insert into student (cno,name,score) values(?,?,?)";
         //设置传递给通配符的参数
         Object[] params = new Object[]{student.getCno(), student.getName(), student.getScore()};
         jdbcTemplate.update(sql, params);
     }
     //批量插入数据
    public int[] batchInsert(final List<Student> list)
     {
         String sql = "insert into student (cno,name,score) values(?,?,?)";

         BatchPreparedStatementSetter setter = new BatchPreparedStatementSetter() {

             @Override
             public void setValues(PreparedStatement ps, int index) throws SQLException {
                 Student student = (Student) list.get(index);
                 ps.setInt(1, student.getCno());
                 ps.setString(2, student.getName());
                 ps.setDouble(3, student.getScore());
             }

             //有多少条记录要处理
             @Override
             public int getBatchSize() {
                 return list.size();
             }
         };

         return jdbcTemplate.batchUpdate(sql, setter);
     }
     //查询单条记录

     public Student getStudent(final int id) {
         // 装载查询结果
         final Student student = new Student();

         String sql = "select s.cno,s.name,s.score from student s where sno = ?";
         // 设置查询参数
         final Object[] params = new Object[] { new Integer(id) };
         // 进行查询
         jdbcTemplate.query(sql, params, new RowCallbackHandler() {
             @Override
             public void processRow(ResultSet rs) throws SQLException {
                 student.setCno(rs.getInt("cno"));
                 student.setName(rs.getString("name"));
                 student.setScore(rs.getDouble("score"));
             }
         });

         return student;
     }

    //查询多条记录

     public List<Student> getAllStudent() {
         String sql = "select s.cno,s.name,s.score from student s";

         return jdbcTemplate.query(sql, new RowMapper<Student>() {
             @Override
             public Student mapRow(ResultSet rs, int index) throws SQLException {
                 Student student = new Student();
                 student.setCno(rs.getInt("cno"));
                 student.setName(rs.getString("name"));
                 student.setScore(rs.getDouble("score"));

                 return student;
             }
         });
     }

}

另附：也可以使用org.springframework.jdbc.core.RowMapper接口查询一条记录，只要附加查询参数即可：

     public Student getStudent(final int id) {
         // 装载查询结果
         final Student student = new Student();

         String sql = "select s.cno,s.name,s.score from student s where sno = ?";
         // 设置查询参数
         final Object[] params = new Object[] { new Integer(id) };

         List<Student> list = jdbcTemplate.query(sql, params,
                 new RowMapper<Student>() {
                     @Override
                     public Student mapRow(ResultSet rs, int index)
                             throws SQLException {
                         Student student = new Student();
                         student.setCno(rs.getInt("cno"));
                         student.setName(rs.getString("name"));
                         student.setScore(rs.getDouble("score"));

                         return student;
                     }
                 });

         return list.get(0);
     }

二、采用注解方式配置事务处理
   1、在Spring配置文件beans元素中添加子元素：
<!– 声明事务管理器 -->
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"/>
</bean>
<!– 采用@Transactional注解方式使用事务 -->
<tx:annotation-driven transaction-manager="txManager"/>

2、在业务逻辑的试下类中使用注解添加相应的事务
   @Service @Transactional
public class StudentServiceBean implements StudentService {
@Transactional(类型=值)
public void add(Student stu) {
    dao.insert(stu);
}
}

以上是关于Spring学习5-Spring整合JDBC及其事务处理（注解方式）的主要内容，如果未能解决你的问题，请参考以下文章

Spring整合JDBC以及AOP管理事务

SpringMVC-狂神（5.整合SSM框架）学习笔记

Spring 框架系列之 JDBC 整合实例

spring-boot-route整合jdbcTemplate操作数据库+整合mybatis操作数据库