spring与jdbc的结合使用

利用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>

转自：http://blog.csdn.net/liuchangqing123/article/details/7294926