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类进行读取装载。

注意：

使用[b]org.apache.commons.dbcp.BasicDataSource需要引入额外的jar包，分别是,commons-dbcp-1.4.jar,commons-pool-1.2.jar
（官网下载页面：[/b]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>/WEB-INF/connect.properties</value>
-->

<!-- 此位置是相对于：部署后的项目的类路径
-->

<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)方法，方便我们进行数据的插入.

[b]
2）批量添加数据：[/b][b]批量插入数据需要用到[b]org.springframework.jdbc.core.BatchPreparedStatementSetter接口。BatchPreparedStatementSette[/b]r接口的两个方法，其中getBatchSize()方法是得到需要插入的记录的个数，setValues(PreparedStatement
ps, int index)方法是实际进行插入的方法。

3）查询单条记录：[/b]执行一条数据的查询，需要使用[b]org.springframework.jdbc.core.RowCallbackHandler接口的实现。

4）查询多条记录：这里需要用到org.springframework.jdbc.core.RowMapper接口的实现。[/b]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元素中添加子元素：
[b]
<!– 声明事务管理器
-->

<bean
id="txManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

<property name="dataSource"
ref="dataSource"/>

</bean>

<!–
采用@Transactional注解方式使用事务 -->

<tx:annotation-driven
transaction-manager="txManager"/>

[/b]
2、在业务逻辑的试下类中使用注解添加相应的事务

@Service @Transactional

public class StudentServiceBean implements StudentService {

@Transactional(类型=值)

public void add(Student stu) {

dao.insert(stu);

}

}