Java开发之Spring连接数据库方法实例分析

package cn.com.service; import java.util.List; import cn.com.bean.PersonBean; public interface PersonService {  //保存  public void save(PersonBean person);  //更新  public void update(PersonBean person);  //获取person  public PersonBean getPerson(int id);  public List<PersonBean> getPersonBean();  //删除记录  public void delete(int personid); }

package cn.com.bean; public class PersonBean {  private int id;  private String name;  public PersonBean(String name) {   this.name=name;  }  public int getId() {   return id;  }  public void setId(int id) {   this.id = id;  }  public String getName() {   return name;  }  public void setName(String name) {   this.name = name;  } }

package cn.com.service.impl; import java.util.List; import javax.sql.DataSource; import org.springframework.jdbc.core.JdbcTemplate; import cn.com.bean.PersonBean; import cn.com.service.PersonService; public class PersonServiceImpl implements PersonService {  private JdbcTemplate jdbcTemplate;  public void setDataSource(DataSource dataSource) {   this.jdbcTemplate = new JdbcTemplate(dataSource);  }  @Override  public void save(PersonBean 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(PersonBean 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 PersonBean getPerson(int id) {   // TODO Auto-generated method stub   return (PersonBean)jdbcTemplate.queryForObject("select * from person where id=?", new Object[]{id},     new int[]{java.sql.Types.INTEGER},new PersonRowMapper() );  }  @SuppressWarnings("unchecked")  @Override  public List<PersonBean> getPersonBean() {   // TODO Auto-generated method stub   return (List<PersonBean>)jdbcTemplate.query("select * from person",     new PersonRowMapper() );  }  @Override  public void delete(int personid) {   // TODO Auto-generated method stub   jdbcTemplate.update("delete from person where id=?", new Object[]{personid},    new int[]{java.sql.Types.INTEGER});  } }

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

<?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/aop http://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="com.mysql.jdbc.Driver"/>     <property name="url" value="jdbc:mysql://localhost:3306/wy"/>     <property name="username" value="root"/>     <!-- property池启动时的初始值 -->      <property name="password" value="123"/>      <!-- 连接name="initialSize" value="${initialSize}"/>-->      <property name="initialSize" value="1"/>      <!-- 连接池的最大值 -->      <property name="maxActive" value="500"/>      <!-- 最大空闲值.当经过一个高峰时间后，连接池可以慢慢将已经用不到的连接慢慢释放一部分，一直减少到maxIdle为止 -->      <property name="maxIdle" value="2"/>      <!-- 最小空闲值.当空闲的连接数少于阀值时，连接池就会预申请去一些连接，以免洪峰来时来不及申请 -->      <property name="minIdle" value="1"/>     </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.com.service.impl.PersonServiceImpl">     <property name="dataSource" ref="dataSource"></property>     </bean> </beans> 

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.com.bean.PersonBean; import cn.com.service.PersonService; public class PersonTest2 {  private static PersonService personService;  @BeforeClass  public static void setUpBeforeClass() throws Exception {  ApplicationContext act=new ClassPathXmlApplicationContext("beans.xml");  personService=(PersonService) act.getBean("personService");  }  @Test  public void save() {  personService.save(new PersonBean("wyy"));  }  @Test  public void update() {  PersonBean person=personService.getPerson(1);  person.setName("wy");  personService.update(person);  }  @Test  public void getPerson() {  PersonBean person=personService.getPerson(1);  System.out.println(person.getName());  }  @Test  public void delete() {  personService.delete(1);  } }

Create Table CREATE TABLE `person` (  `id` int(11) NOT NULL auto_increment,  `name` varchar(10) NOT NULL,  PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8