spring与Jdbc的操作
2012-08-12 16:27
253 查看
************************
beans.xml
************************
jdbc.properties
**********************
需要的jar包
**********************
Person.java
**********************
******************
PersonService.java
******************
*********************
PersonServiceBean.java
********************
*******************
PersonRowMap.java
*******************
******************
junittest
******************
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: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 "> <!-- 利用spring提供的占位符的方式引用properties文件的数据 --> <context:property-placeholder location="classpath:jdbc.properties"/> <!-- dbcp数据源配置 --> <bean id="dataSource" class=" org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="${driverClassName}"></property> <property name="url" value="${url}"> </property> <property name="username" value="${username}"></property> <property name="password" value="${password}"></property> <!-- 连接池启动时初始值 --> <property name="initialSize" value="${initialSize}"></property> <!-- 连接池的最大值 --> <property name="maxActive" value="${maxActive}"></property> <!-- 最大空闲值。当经过一个高峰时间后,连接池可以慢慢将已经用不到的连接慢慢释放一部分,一直减少到 maxIdle为止 --> <property name="maxIdle" value="${maxIdle}"></property> <!-- 最小空闲值。当空闲的连接数少于阀值时,连接池就会预申请一些去连接,以免洪峰来时来不及申请 --> <property name="minIdle" value="${minIdle}"></property> </bean> <!-- 采用spring来管理数据源的事务 --> <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"></property> </bean> <!-- 使用@Transactional注解方式使用事务 --> <tx:annotation-driven transaction-manager="txManager"/> <bean id="personService" class="blog.service.impl.PersonServiceBean"> <property name="dataSource" ref="dataSource"></property> </bean> </beans>**********************
jdbc.properties
**********************
url=jdbc\:mysql\://localhost\:3306/springandjdbc?useUnicode\=true&characterEncoding\=utf-8 username=root password=1234 initialSize=1 maxActive=500 maxIdle=2 minIdle=1 driverClassName=org.gjt.mm.mysql.Driver
需要的jar包
**********************
Person.java
**********************
package blog.service.bean; public class Person { private Integer personId; private String name; public Integer getPersonId() { return personId; } public void setPersonId(Integer personId) { this.personId = personId; } public String getName() { return name; } public void setName(String name) { this.name = name; } public Person() { } public Person(String name) { this.name = name; } }
******************
PersonService.java
******************
package blog.service; import java.util.List; import blog.service.bean.Person; public interface PersonService { public void save(Person person); public void delete(Integer personId); public void update(Person person); public List<Person> getPersons(); public Person getPerson(Integer personId); }
*********************
PersonServiceBean.java
********************
package blog.service.impl; import java.util.List; import javax.sql.DataSource; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.transaction.annotation.Transactional; import blog.service.PersonService; import blog.service.bean.Person; @Transactional public class PersonServiceBean implements PersonService { private JdbcTemplate jdbcTemplate; public void setDataSource(DataSource dataSource) { this.jdbcTemplate = new JdbcTemplate(dataSource); } @Override public void delete(Integer personId) { jdbcTemplate.update("delete from person where id = ?", new Object[]{personId},new int[]{java.sql.Types.INTEGER}); } @Override public Person getPerson(Integer personId) { Person person =(Person) jdbcTemplate.queryForObject("select * from person where id = ?", new Object[]{personId},new int[]{java.sql.Types.INTEGER}, new PersonRowMapper()); return person; } @SuppressWarnings("unchecked") @Override public List<Person> getPersons() { List<Person> persons = jdbcTemplate.query("select * from person", new PersonRowMapper()); return persons; } @Override public void save(Person person) { jdbcTemplate.update("insert into person(name) values(?)", new Object[]{person.getName()}, new int[]{java.sql.Types.VARCHAR}); } @Override public void update(Person person) { jdbcTemplate.update("update person set name = ? where id = ?", new Object[]{person.getName(),person.getPersonId()}, new int[]{java.sql.Types.VARCHAR,java.sql.Types.INTEGER}); } }
*******************
PersonRowMap.java
*******************
package blog.service.impl; import java.sql.ResultSet; import java.sql.SQLException; import org.springframework.jdbc.core.RowMapper; import blog.service.bean.Person; public class PersonRowMapper implements RowMapper { @Override//if(rs.next()) public Object mapRow(ResultSet rs, int rowNum) throws SQLException { Person person = new Person(rs.getString("name")); person.setPersonId(rs.getInt("id")); return person; } }
******************
junittest
******************
package junitTest; import java.util.List; import org.junit.BeforeClass; import org.junit.Test; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import blog.service.PersonService; import blog.service.bean.Person; public class SpringAndJdbc { private static PersonService personService; @BeforeClass public static void setUpBeforeClass() throws Exception { try { ApplicationContext ctx = new ClassPathXmlApplicationContext("beans.xml"); personService = (PersonService) ctx.getBean("personService"); } catch (Exception e) { e.printStackTrace(); } } @Test public void getBeans() { List<Person> persons = personService.getPersons(); for (Person person : persons) { System.out.println(person.getName()); } } @Test public void save(){ Person person = new Person("Alice"); person.setPersonId(3); personService.save(person); } @Test public void delete(){ personService.delete(1); } @Test public void getBean(){ Person person = personService.getPerson(1); System.out.println(person.getName()); } @Test public void update(){ Person person = new Person("Judy"); person.setPersonId(2); personService.update(person); } }
相关文章推荐
- spring--jdbc的批量操作
- 详解spring与jdbc整合操作
- 使用Spring的jdbcTemplate进一步简化JDBC操作
- Spring-JDBC连接以及基础数据库操作
- SpringBoot实战之10 整合jdbc进行crud操作
- Spring对jdbc操作的支持
- spring-JDBC模板操作
- Spring 事务操作(银行转账案例),使用spring 对jdbc的支持完成对数据库的操作
- 使用Spring的jdbcTemplate进一步简化JDBC操作
- 详解spring开发_JDBC操作MySQL数据库
- 使用spring jdbc template简化jdbc数据库操作实例代码
- Spring的数据库操作---- Spring框架对JDBC的整合---- spring集成jdbc概述
- 使用Spring的jdbcTemplate进一步简化JDBC操作
- Spring学习心得(22)-- spring声明式事务处理(使用jdbc操作数据库)
- JDBC借助Spring进行增删改查的操作--大大简化了程序
- spring的jdbc操作
- Spring的数据库操作---- Spring框架对JDBC的整合---- Spring的数据库操作
- Spring 对JDBC操作的支持
- 使用Spring的JdbcTemplate简化jdbc操作
- 使用Spring JDBC框架连接并操作数据库