学步园

利用spring可以解决事务处理时的许多问题，同spring实现其他的功能相似，spring提供了两种不同的方式实现与jdbc的结合，两种方式是注解和xml配置方式。

1.   spring和jdbc的结合

1）       建立PersonService接口：

public interface PersonService {
    /**
     * 保存Person对象
     *
     * @param person
     */
    public void save(Person person);
 
    /**
     * 得到person对象
     *
     * @param personId
     */
    public Person getPerson(Integer personId);
    /**
     * 得到所有的Person
     * @return
     */
    public List<Person> getPersons();
 
    /**
     * 更新person
     *
     * @param person
     */
    public void update(Person person);
 
    /**
     * 删除person
     */
    public void delete(Integer id);
 
}

2）       编写接口的实现类，并且将该bean纳入到spring的事务管理中（通过注解方式）：

@Transactional
public class PersonServiceBean implements PersonService {
    private JdbcTemplate jdbcTemplate;
 
    public void setDataSource(DataSource dataSource) {
       this.jdbcTemplate = new JdbcTemplate(dataSource);
    }
 
    @Override
    public void delete(Integer id) {
       jdbcTemplate.update("delete fromperson where id=?", new Object[] { id },
              new int[] { java.sql.Types.INTEGER });
       jdbcTemplate.update("delete frompersonsss where id=2", new Object[] { id },
              new int[] { java.sql.Types.INTEGER });
    }
 
    @Override
    public Person getPerson(Integer personId) {
 
       return (Person) jdbcTemplate.queryForObject(
              "select *from person where id=?", new Object[] {personId },
              new PersonRowMapper());
    }
 
    @Transactional(propagation =Propagation.NOT_SUPPORTED)
    @Override
    public List<Person> getPersons() {
 
       return (List<Person>) jdbcTemplate.query("select * from person",
              new PersonRowMapper());
    }
 
    @Override
    public void save(Person person) {
 
       jdbcTemplate.update("insert intoperson(name) values(?)",
              new Object[] { person.getName() },
              new int[] { java.sql.Types.VARCHAR });
    }
 
    @Override
    public void update(Person person) {
       jdbcTemplate.update("updateperson set name=? where id=?",
              new Object[] { person.getName(), person.getId() }, new int[] {
                     java.sql.Types.VARCHAR, java.sql.Types.INTEGER });
 
    }
 
}

3）       注意在bean.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:aop="http://www.springframework.org/schema/aop"xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-2.5.xsd

          http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd

http://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop-2.5.xsd

          http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">
 
    <context:property-placeholder location="classpath:jdbc.properties" />
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
       destroy-method="close">
       <property name="driverClassName"value="${driverClassName}" />
       <property name="url"value="${url}" />
       <property name="username"value="${username}" />
       <property name="password"value="${password}" />
       <!-- 连接池启动时的初始值 -->
       <property name="initialSize"value="${initialSize}" />
       <!-- 连接池的最大值 -->
       <property name="maxActive"value="${maxActive}" />
       <!-- 最大空闲值.当经过一个高峰时间后，连接池可以慢慢将已经用不到的连接慢慢释放一部分，一直减少到maxIdle为止 -->
       <property name="maxIdle"value="${maxIdle}" />
       <!--  最小空闲值.当空闲的连接数少于阀值时，连接池就会预申请去一些连接，以免洪峰来时来不及申请 -->
       <property name="minIdle"value="${minIdle}" />
    </bean>
 
    <bean id="txManager"
       class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
       <property name="dataSource"ref="dataSource" />
    </bean>
 
   
    <tx:annotation-driven transaction-manager="txManager"/>
 
    <bean id="personService" class="com.lcq.service.impl.PersonServiceBean">
       <property name="dataSource"ref="dataSource" />
    </bean>
</beans>

4）       编写测试类：

public class PersonServiceTest {
 
    private static PersonService personService;
 
    @BeforeClass
    public static void setUpBeforeClass() throws Exception {
 
       try {
           ApplicationContext cxt = new ClassPathXmlApplicationContext(
                  "beans.xml");
           personService = (PersonService) cxt.getBean("personService");
       } catch (Exception e) {
           e.printStackTrace();
       }
 
    }
 
    @Test
    public void save() {
       personService.save(new Person("张三"));
 
    }
 
    @Test
    public void getPerson() {
       System.out.println(personService.getPerson(1).getName());
    }
 
    @Test
    public void update() {
       Person person = personService.getPerson(1);
       person.setName("name");
       personService.update(person);
    }
 
    @Test
    public void del(){
       personService.delete(1);
 
    }
    @Test
    public void getPersons(){
       for(Person person:personService.getPersons())
           System.out.println(person.getName());
    }
                        
}
使用xml的配置方式实现spring与jdbc的结合使用，在bean.xml中的关键配置：
<aop:config>
       <aop:pointcut id="transactionPointcut"
           expression="execution(* com.lcq.service..*.*(..))"/>
       <aop:advisor advice-ref="txAdvice"pointcut-ref="transactionPointcut" />
    </aop:config>
    <tx:advice id="txAdvice" transaction-manager="txManager">
       <tx:attributes>
           <tx:method name="get*"read-only="true" propagation="NOT_SUPPORTED"/>
           <tx:method name="*"/>
       </tx:attributes>
</tx:advice>