Spring之数据库操作

本文主要包括以下内容

spring+jdbc数据库操作
spring+jdbc声明事务处理
spring+hibernate声明事务处理

spring+jdbc数据库操作

方法

1、让自己写的一个dao类继承JdbcDaoSupport
2、让自己写的一个dao类继承JdbcTemplate
3、让自己写的一个dao类里有一个属性为JdbcTemplate

总结

1、引入dataSource的方式：
1、在dataSource的设置中直接写值
2、引入properties文件
2、在dao的写法中有很多种，最终只需要把dataSource注入jdbcTemplate中

继承JdbcDaoSupport的方法

package cn.itcast.spring.jdbc;import java.util.List;import org.springframework.jdbc.core.support.JdbcDaoSupport;public class PersonDao extends JdbcDaoSupport{public void update(){this.getJdbcTemplate().execute("update person set pname='a' where pid=3");}public void query(){List<Person> persons = this.getJdbcTemplate().query("select * from person", new PersonRowMapper());for(Person person:persons){System.out.println(person.getPname());}}
}

继承JdbcTemplate的方法

package cn.itcast.spring.jdbc;import javax.sql.DataSource;import org.springframework.jdbc.core.JdbcTemplate;public class PersonDao2 extends JdbcTemplate{public PersonDao2(DataSource dataSource){super(dataSource);}public void update(){this.execute("update person set pname='aa' where pid=2");}
}

属性为JdbcTemplate的方法

package cn.itcast.spring.jdbc;import javax.sql.DataSource;import org.springframework.jdbc.core.JdbcTemplate;public class PersonDao3{private JdbcTemplate jdbcTemplate;public JdbcTemplate getJdbcTemplate() {return jdbcTemplate;}public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {this.jdbcTemplate = jdbcTemplate;}public void update(){this.jdbcTemplate.execute("update person set pname='aaa' where pid=2");}
}

其中查询时的PersonRowMapper为

package cn.itcast.spring.jdbc;import java.sql.ResultSet;
import java.sql.SQLException;import org.springframework.jdbc.core.RowMapper;public class PersonRowMapper implements RowMapper{@Overridepublic Object mapRow(ResultSet rs, int rowNum) throws SQLException {// TODO Auto-generated method stubPerson person = new Person();person.setPid(rs.getLong("pid"));person.setPname(rs.getString("pname"));person.setPsex(rs.getString("psex"));return person;}/*** crud做一下*/}

注入dataSource的方法，在配置文件中配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-2.5.xsd"><bean
        class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"><property name="locations"><value>classpath:jdbc.properties</value></property></bean><bean id="dataSource" destroy-method="close"class="org.apache.commons.dbcp.BasicDataSource"><property name="driverClassName" value="${jdbc.driverClassName}" /><property name="url" value="${jdbc.url}" /><property name="username" value="${jdbc.username}" /><property name="password" value="${jdbc.password}" /></bean><bean id="personDao" class="cn.itcast.spring.jdbc.PersonDao"><property name="dataSource"><ref bean="dataSource"/></property></bean><bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><property name="dataSource"><ref bean="dataSource"/></property></bean><bean id="personDao2" class="cn.itcast.spring.jdbc.PersonDao2"><constructor-arg index="0" ref="dataSource"></constructor-arg></bean><bean id="personDao3" class="cn.itcast.spring.jdbc.PersonDao3"><property name="jdbcTemplate"><ref bean="jdbcTemplate"/></property></bean>
</beans>

jdbc.properties如下，路径在src文件夹下

jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc\:mysql\://localhost\:3306/hibernate
jdbc.username=root
jdbc.password=root

测试

package cn.itcast.spring.jdbc;import javax.sql.DataSource;import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;public class PersonTest {@Testpublic void test(){ApplicationContext context = new ClassPathXmlApplicationContext("cn/itcast/spring/jdbc/applicationContext.xml");PersonDao personDao = (PersonDao)context.getBean("personDao");personDao.update();}@Testpublic void testDataSource(){ApplicationContext context=new ClassPathXmlApplicationContext("cn/itcast/spring/jdbc/applicationContext.xml");DataSource datasource=(DataSource) context.getBean("dataSource");System.out.println(datasource);}
}

spring+jdbc声明事务处理

spring声明式事务处理的步骤：
1、搭建环境
2、把dao层和service层的接口和类写完
3、在spring的配置文件中，先导入dataSource
4、测试
5、导入dao和service层的bean
6、测试
7、进行AOP的配置
1、引入事务管理器
2、进行aop的配置
8、测试service层的类看是否是代理对象

dao

package cn.itcast.spring.jdbc.transaction.sh.dao;import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.support.AbstractPlatformTransactionManager;import cn.itcast.spring.jdbc.transaction.bean.Person;public class PersonDaoImpl extends JdbcDaoSupport implements PersonDao{@Overridepublic List<Person> getPerson() {// TODO Auto-generated method stubreturn this.getJdbcTemplate().query("select * from person", new RowMapper() {@Overridepublic Object mapRow(ResultSet rs, int rowNum) throws SQLException {// TODO Auto-generated method stubPerson person = new Person();person.setPid(rs.getLong("pid"));person.setPname(rs.getString("pname"));person.setPsex(rs.getString("psex"));return person;}});}@Overridepublic void savePerson() {// TODO Auto-generated method stubthis.getJdbcTemplate().update("insert into person values(11,'a','a')");}}

Service

package cn.itcast.spring.jdbc.transaction.sh.service;import java.util.List;import org.springframework.transaction.PlatformTransactionManager;import cn.itcast.spring.jdbc.transaction.bean.Person;
import cn.itcast.spring.jdbc.transaction.sh.dao.PersonDao;public class PersonServiceImpl implements PersonService{private PersonDao personDao;public PersonDao getPersonDao() {return personDao;}public void setPersonDao(PersonDao personDao) {this.personDao = personDao;}@Overridepublic List<Person> getPerson() {// TODO Auto-generated method stubreturn this.personDao.getPerson();}@Overridepublic void savePerson() {// TODO Auto-generated method stubthis.personDao.savePerson();}}

spring配置文件

完成了以下功能
1. 导入dataSource
2. 导入dao和service层的bean
3. 引入事务管理器
4. 进行aop的配置

<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"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsdhttp://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsdhttp://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd"><bean
        class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"><property name="locations"><value>classpath:jdbc.properties</value></property></bean><bean id="dataSource" destroy-method="close"class="org.apache.commons.dbcp.BasicDataSource"><property name="driverClassName" value="${jdbc.driverClassName}" /><property name="url" value="${jdbc.url}" /><property name="username" value="${jdbc.username}" /><property name="password" value="${jdbc.password}" /></bean><bean id="personDao" class="cn.itcast.spring.jdbc.transaction.sh.dao.PersonDaoImpl"><property name="dataSource"><ref bean="dataSource" /></property></bean><bean id="personService"class="cn.itcast.spring.jdbc.transaction.sh.service.PersonServiceImpl"><property name="personDao"><ref bean="personDao" /></property></bean><!-- 异常处理 --><bean id="myException" class="cn.itcast.spring.jdbc.transaction.exception.MyException"></bean><!-- 确定transactionManager的种类 --><bean id="transactionManager"class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource"><ref bean="dataSource" /></property></bean><!--通知 1、告诉spring容器，采用什么样的方法处理事务 2、告诉spring容器，目标方法应该采用什么样的事务处理策略--><tx:advice id="tx" transaction-manager="transactionManager"><tx:attributes><!--name规定方法 isolation(隔离机制) 默认值为DEFAULT propagation(传播机制) REQUIRED--><tx:method name="save*" read-only="false" /></tx:attributes></tx:advice><aop:config><aop:pointcut
            expression="execution(* cn.itcast.spring.jdbc.transaction.sh.service.*.*(..))"id="perform" /><aop:advisor advice-ref="tx" pointcut-ref="perform" /><aop:aspect ref="myException"><aop:after-throwing method="myException"pointcut-ref="perform" throwing="ex" /></aop:aspect></aop:config></beans>

测试

package cn.itcast.spring.jdbc.transaction.test;import javax.sql.DataSource;import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;import cn.itcast.spring.jdbc.transaction.sh.service.PersonService;public class TransactionTest {public static ApplicationContext context;static{context = new ClassPathXmlApplicationContext("cn/itcast/spring/jdbc/transaction/config/applicationContext.xml");}@Testpublic void testDataSource(){DataSource dataSource = (DataSource)context.getBean("dataSource");System.out.println(dataSource);}@Testpublic void testPesonDao(){context.getBean("personDao");}@Testpublic void testPersonService(){PersonService personService = (PersonService)context.getBean("personService");personService.savePerson();}
}

spring+hibernate声明事务处理

主要注意sessionFactory在spring配置文件中的配置

方法一

配置sessionFactory第一种方式<bean id="sessionFactory"class="org.springframework.orm.hibernate3.LocalSessionFactoryBean"><property name="dataSource" ref="dataSource"></property><property name="mappingResources"><list><value>cn/itcast/spring/hiberante/transaction/domain/Person.hbm.xml</value></list></property><property name="hibernateProperties"><value>hibernate.dialect=org.hibernate.dialect.MySQLDialect</value></property></bean>

方法二

 <!-- 第二种方式，导入hibernate配置文件 --><bean id="sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean"><property name="configLocation"><value>classpath:cn/itcast/spring/hibernate/transaction/config/hibernate.cfg.xml</value></property></bean>

详细代码如下

dao

package cn.itcast.spring.hibernate.transaction.dao.impl;import org.springframework.orm.hibernate3.support.HibernateDaoSupport;import cn.itcast.spring.hiberante.transaction.domain.Person;
import cn.itcast.spring.hibernate.transaction.dao.PersonDao;public class PersonDaoImpl extends HibernateDaoSupport implements PersonDao{@Overridepublic void savePerson(Person person) {// TODO Auto-generated method stubthis.getHibernateTemplate().save(person);}}

service

package cn.itcast.spring.hibernate.transaction.service.impl;import org.hibernate.impl.SessionFactoryImpl;
import org.springframework.orm.jdo.JdoTemplate;
import org.springframework.orm.toplink.TopLinkTemplate;import cn.itcast.spring.hiberante.transaction.domain.Person;
import cn.itcast.spring.hibernate.transaction.dao.PersonDao;
import cn.itcast.spring.hibernate.transaction.service.PersonService;public class PersonServiceImpl implements PersonService{private PersonDao personDao;public PersonDao getPersonDao() {return personDao;}public void setPersonDao(PersonDao personDao) {this.personDao = personDao;}@Overridepublic void savePerson(Person person) {// TODO Auto-generated method stubthis.personDao.savePerson(person);}
}

配置文件

<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"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsdhttp://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsdhttp://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd"><bean
        class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"><property name="locations"><value>classpath:jdbc.properties</value></property></bean><bean id="dataSource" destroy-method="close"class="org.apache.commons.dbcp.BasicDataSource"><property name="driverClassName" value="${jdbc.driverClassName}" /><property name="url" value="${jdbc.url}" /><property name="username" value="${jdbc.username}" /><property name="password" value="${jdbc.password}" /></bean><!--sessionFactory 1、sessionFactoryImpl 2、利用spring的IOC和DI的特征--><!-- 配置sessionFactory第一种方式<bean id="sessionFactory"class="org.springframework.orm.hibernate3.LocalSessionFactoryBean"><property name="dataSource" ref="dataSource"></property><property name="mappingResources"><list><value>cn/itcast/spring/hiberante/transaction/domain/Person.hbm.xml</value></list></property><property name="hibernateProperties"><value>hibernate.dialect=org.hibernate.dialect.MySQLDialect</value></property></bean>--><!-- 第二种方式，导入hibernate配置文件 --><bean id="sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean"><property name="configLocation"><value>classpath:cn/itcast/spring/hibernate/transaction/config/hibernate.cfg.xml</value></property></bean><bean id="personDao"class="cn.itcast.spring.hibernate.transaction.dao.impl.PersonDaoImpl"><property name="sessionFactory"><ref bean="sessionFactory"/></property></bean><bean id="personService" class="cn.itcast.spring.hibernate.transaction.service.impl.PersonServiceImpl"><property name="personDao"><ref bean="personDao"/></property></bean><bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager"><property name="sessionFactory"><ref bean="sessionFactory"/></property></bean><tx:advice id="tx" transaction-manager="transactionManager"><tx:attributes><tx:method name="save*" read-only="false"/></tx:attributes></tx:advice><aop:config><aop:pointcut expression="execution(* cn.itcast.spring.hibernate.transaction.service.impl.PersonServiceImpl.*(..))" id="perform"/><aop:advisor advice-ref="tx" pointcut-ref="perform"/></aop:config>
</beans>

测试

package cn.itcast.spring.hibernate.transaction.test;import javax.sql.DataSource;import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;import cn.itcast.spring.hiberante.transaction.domain.Person;
import cn.itcast.spring.hibernate.transaction.service.PersonService;public class PersonTest {@Testpublic void testDataSource(){ApplicationContext context =  new ClassPathXmlApplicationContext("cn/itcast/spring/hibernate/transaction/config/applicationContext.xml");DataSource dataSource=(DataSource) context.getBean("dataSource");}@Testpublic void test(){ApplicationContext context =  new ClassPathXmlApplicationContext("cn/itcast/spring/hibernate/transaction/config/applicationContext.xml");PersonService personService = (PersonService)context.getBean("personService");Person person = new Person();person.setPname("a");personService.savePerson(person);}
}

完成

转载于:https://www.cnblogs.com/jjx2013/p/6223676.html

Spring之数据库操作相关推荐

spring boot数据库操作汇总
1 关于orm orm即object relational mapping,对象关系映射,即将数据库中的表映射成对象. 常用的orm有以下: mybatis spring jdbc template ...
Spring Boot数据库操作之基本的JDBC访问和JDBCTemplate使用
作者:谭东我们先看下最基础的JDBC的使用方式吧.我们这里使用MySQL.电脑里可以安装个mysql,便于本地测试使用. Mysql下载地址:https://dev.mysql.com/downlo ...
p6spy监测mysql_P6Spy监控你的Spring boot数据库操作
一.简介: p6Spy通过劫持JDBC驱动,在调用实际`JDBC`驱动前拦截调用的目标语,达到`SQL`语句日志记录的目的. 它包括`P6Log`和`P6Outage`两个模块. P6Log 用来拦截 ...
[转载] Spring的数据库操作---- Spring框架对JDBC的整合---- spring集成jdbc概述
参考链接: Spring-JDBC框架概述 222 转载于:https://www.cnblogs.com/1020182600HENG/p/6175646.html
Spring中使用JdbcTemplate和HibernateTemplate的数据库操作
目前我接触到的Spring的数据库操作主要包括两种,主要使用JdbcTemplate和HibernateTemplate.后者用于结合Hibernate操作. 两者都提供了持久层访问模板化,只需要获得 ...
spring boot 入门_SpringBoot入门建站全系列（三十）Mybatis多数据源进行数据库操作
SpringBoot入门建站全系列(三十)Mybatis多数据源进行数据库操作一.概述多数据源,就是有多个数据库的配置. 多数据源配置并不麻烦,使用起来和单数据源基本相同,但是,重要的是事务的控制 ...
Spring ： JdbcTemplate操作数据库（详细）
前言什么是 JdbcTemplate? Spring 框架对 JDBC 进行封装,使用 JdbcTemplate 方便实现对数据库操作. 本文将对<水浒传>英雄人物表进行数据操作示例,先 ...
listener不能交给spring进行管理，需要自己new，不能注入其他对象，不能实现数据库操作
listener不能交给spring进行管理,需要自己new,不能注入其他对象,不能实现数据库操作. mybatis原生 QueryWrapper<EduSubject> wrapperT ...
Spring Boot：使用p6spy监控数据库操作
最近因为换工作的原因导致博客停更好久,感觉再不写点什么就要废掉了_(:з」∠*)_ 首先p6spy是一个开源的数据库监控插件,我们能通过使用p6spy打印数据库操作或者保存操作日志. 首先放上p6sp ...