Spring集成的JDBC编码和事务管理

àì夳堔傛蜴生んèń 2022-07-12 07:45 157阅读 0赞

代码：

1.配置文件

beans.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:aop="http://www.springframework.org/schema/aop"
    	xmlns:tx="http://www.springframework.org/schema/tx"
    	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
    	http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd 
    	http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd">
    
    	
    	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
    		
    		<property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
    		
    		<property name="url" value="jdbc:mysql://localhost:3306/bookshop"></property>
    		
    		<property name="username" value="root"></property>
    		
    		<property name="password" value="1234"></property>
    		
    		<property name="initialSize" value="1"></property>
    		
    		<property name="maxActive" value="500"></property>
    		
    		<property name="maxIdle" value="2"></property>
    		
    		<property name="minIdle" value="1"></property>
    	</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="cn.itcast.service.impl.PersonServiceBean">
    	   <property name="datasource" ref="datasource"></property>
    	</bean>
    </beans>

2.源代码

Person.java

package cn.itcast.bean;
    
    public class Person {
      private Integer id;
      private String name;
    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 Person(String name) {
    	this.name = name;
    }
    
    }

PersonService.java

package cn.itcast.service;
    
    import java.util.List;
    
    import cn.itcast.bean.Person;
    
    public interface PersonService {
      /*
       * 保存Person
       */
       public void save(Person person);
       /*
        * 更新Person
        */
       public void update(Person person);
       /*
        * 获取Person
        */
       public Person getPerson(Integer personid);
       
       /*
        * 获取所有Person集合的记录
        */
       public List<Person> getPersons();
       
       /*
        * 删除制定ID的person
        */
       public void delete(Integer personid);
    }

PersonRowMapper.java

package cn.itcast.service.impl;
    
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    import org.springframework.jdbc.core.RowMapper;
    
    import cn.itcast.bean.Person;
    
    public class PersonRowMapper implements RowMapper {
    
    	@Override
    	public Object mapRow(ResultSet rs, int index) throws SQLException {
    		// TODO Auto-generated method stub
    		Person person=new Person(rs.getString("name"));
    		person.setId(rs.getInt("id"));
    		return person;
    	}
    
    }

PersonServiceBean.java

package cn.itcast.service.impl;
    
    import java.util.List;
    
    import javax.sql.DataSource;
    
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.transaction.annotation.Transactional;
    
    import cn.itcast.bean.Person;
    import cn.itcast.service.PersonService;
    @Transactional
    public class PersonServiceBean implements PersonService {
        private DataSource datasource;
        private JdbcTemplate jdbcTemplate;
    	public void setDatasource(DataSource datasource) {
    		this.jdbcTemplate=new JdbcTemplate(datasource);
    	}
    
    	public void save(Person person) {
    		// TODO Auto-generated method stub
          jdbcTemplate.update("insert into person(name) values(?)", new Object[]{person.getName()}, new int[]{java.sql.Types.VARCHAR});
    	}
    
    	@Override
    	public void update(Person person) {
    		// TODO Auto-generated method stub
    		jdbcTemplate.update("update person set name=? where id=?", new Object[]{person.getName(),person.getId()}, new int[]{java.sql.Types.VARCHAR,java.sql.Types.INTEGER});
    	}
    
    	@Override
    	public Person getPerson(Integer personid) {
    		// TODO Auto-generated method stub 
    		return (Person) jdbcTemplate.queryForObject("select * from person where id=?", new Object[]{personid}, new int []{java.sql.Types.INTEGER},new PersonRowMapper());
    	} 
    
    	@Override
    	public List<Person> getPersons() {
    		// TODO Auto-generated method stub
    		return (List<Person>) jdbcTemplate.query("select * from person",new PersonRowMapper());
    	}
    
    	@Override
    	public void delete(Integer personid) {
    		// TODO Auto-generated method stub
    		jdbcTemplate.update("delete from person where id=?", new Object[]{personid}, new int[]{java.sql.Types.INTEGER});
    	}
    
    }

3.单元测试类

PersonServiceTest.java

package junit.test;
    
    import static org.junit.Assert.*;
    
    import org.junit.BeforeClass;
    import org.junit.Test;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import cn.itcast.bean.Person;
    import cn.itcast.service.PersonService;
    
    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) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    	
    	@Test public void save(){
    		for(int i=0;i<5;i++){
    			personService.save(new Person("海哥"+i));
    		}
    	}
       
    	@Test public void getPerson(){
    		Person person=personService.getPerson(1);
    		System.out.println(person.getName());
    	}
    	
    	@Test public void update(){
    		Person person=personService.getPerson(1);
    		person.setName("张xx");
    		personService.update(person);
    	}
        
    	@Test public void delete(){
    		personService.delete(1);;
    	}
    	
    	@Test public void getBeans(){
    		for(Person person : personService.getPersons()){
    			System.out.println(person.getName());
    		}
    	}
    }