zoukankan html css js c++ java

四、spring的JDBC模板和事务管理

Spring的JDBC模板

Spring是JavaEE开发的一站式框架，对各种持久化技术都提供了简单的模板

ORM持久化技术	模板类
JDBC	org.springframework.jdbc.core.JdbcTemplate
Hibernate5.0	org.springframework.orm.hibernate5.HibernateTemplate
IBatis(MyBatis)	org.springframework.orm.ibatis.SqlMapClientTemplate
JPA	org.springfrmaework.orm.jpa.JpaTemplate

JDBC模板的基本使用

引入jar
- Spring项目的6个基础开发包
- 数据库驱动包
- Spring的JDBC模板的jar包

测试

编写测试类

public class TestDemo {

	@Test
	public void demo() {
		//创建连接池
		DriverManagerDataSource dataSource = new DriverManagerDataSource();
		dataSource.setDriverClassName("com.mysql.jdbc.Driver");
		dataSource.setUrl("jdbc:mysql:///test");
		dataSource.setUsername("root");
		dataSource.setPassword("root");
		
		//创建jdbc模板
		JdbcTemplate template = new JdbcTemplate(dataSource);
		List<Map<String,Object>> list = template.queryForList("select * from user");
		for (Map<String, Object> map : list) {
			Set<String> keySet = map.keySet();
			Iterator<String> iterator = keySet.iterator();
			while (iterator.hasNext()) {
				String key = iterator.next();
				System.out.println(key+" : "+map.get(key));
			}
		}
	}
}

测试结果

id : 1
name : test
password : 0
id : 2
name : wxf
password : 1
id : 3
name : admin
password : 123

Spring管理模板和连接池

配置文件配置Spring管理

<?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" 
        xsi:schemaLocation="
        http://www.springframework.org/schema/beans
		http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/tx 
        http://www.springframework.org/schema/tx/spring-tx.xsd"> 
        <!-- 管理数据库连接池 -->    
	<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
		<property name="url" value="jdbc:mysql:///test"></property>
		<property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
		<property name="username" value="root"></property>
		<property name="password" value="root"></property>
	</bean>        
        
	<!-- 管理JDBC模板 -->
	<bean id="template" class="org.springframework.jdbc.core.JdbcTemplate">
		<property name="dataSource" ref="dataSource"/>
	</bean>
</beans>

测试方法

@Test
public void demo2() {
	
	ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
	JdbcTemplate template = (JdbcTemplate) context.getBean("template");
	
	List<Map<String,Object>> list = template.queryForList("select * from user");
	for (Map<String, Object> map : list) {
		Set<String> keySet = map.keySet();
		Iterator<String> iterator = keySet.iterator();
		while (iterator.hasNext()) {
			String key = iterator.next();
			System.out.println(key+" : "+map.get(key));
		}
	}
}

Spring中使用开源数据库连接池

DBCP的使用

引入jar包
- com.springsource.org.apache.commons.pool-1.5.3.jar
- com.springsource.org.apache.commons.dbcp-1.2.2.osgi.jar

Spring配置连接池

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
	<property name="url" value="jdbc:mysql:///test"></property>
	<property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
	<property name="username" value="root"></property>
	<property name="password" value="root"></property>
</bean>

C3P0的使用

引入jar包
- com.springsource.com.mchange.v2.c3p0-0.9.1.2.jar

Spring配置连接池

<!-- 管理c3p0数据库连接池 --> 
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
	<property name="jdbcUrl" value="jdbc:mysql:///test"></property>
	<property name="driverClass" value="com.mysql.jdbc.Driver"></property>
	<property name="user" value="root"></property>
	<property name="password" value="root"></property>
</bean>

抽取连接池属性配置值到Properties文件　

定义一个properties文件：jdbc.properties

jdbc.url=jdbc:mysql:///test
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.username=root
jdbc.password=root

Spring引入jdbc.properties文件

第一种：使用<bean>标签

<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
	<property name="location" value="classpath:jdbc.properties"/>
</bean>

第二种：使用<context:property-placeholder>标签

<context:property-placeholder location="classpath:jdbc.properties" />

Spring配置文件使用jdbc.properties的属性值

<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
	<property name="url" value="${jdbc.url}"></property>
	<property name="driverClassName" value="${jdbc.driverClassName}"></property>
	<property name="username" value="${jdbc.username}"></property>
	<property name="password" value="${jdbc.password}"></property>
</bean>

Spring的事务管理

常用API

PlatformTransactionManager

Spring的事务基础结构的中心接口，常用实现类

DataSourceTransactionManager：使用JDBC管理事务

HibernateTransactionManager：使用Hibernate管理事务　　　　

TransactionDefinition

Spring的事务定义，用于定义事务相关的信息。例如，隔离级别、传播行为、是否只读、超时信息等　　

TransactionStatus

用于记录事务管理的过程中，事务的状态信息　　

Spring进行事务管理时，PlatformTransactionManager根据TransactionDefinition进行事务的管理，这个过程中会产生各种状态，将这些状态记录到TransactionStatus中

传播行为

基本认识

事务传播行为用来描述由某一个事务传播行为修饰的方法被嵌套进另一个方法的时事务如何传播

主要用来解决业务层方法（每个业务层方法有自己的事务）相互调用的问题

7种传播行为

class TestServiceImpl01 {
	...
	public void A() {
		testDao1.test1();
		testDao2.test2();
	}
}

class TestServiceImpl02 {
	...
	public void B() {
		new TestServiceImpl01().A();//A操作
		testDao3.test3();//B操作
		testDao4.test4();//B操作
	}
}

分类	传播行为类型	说明
多个操作在同一个事务中 (A、B操作在一个事务中)	PROPAGATION_REQUIRED	默认值，如果A中有事务，使用A中的事务；如果A中没有事务，创建一个新的事务，将操作（A、B）包含进来
	PROPAGATION_SUPPORTS	如果A中有事务，使用A中的事务；如果A中没有事务，就不使用事务
	PROPAGATION_MANDATORY	如果A中有事务，使用A中的事务；如果A中没有事务，就抛出异常
多个操作不在同一个事务中 (A、B操作不在一个事务中)	PROPAGATION_REQUIRES_NEW	如果A中有事务，将A的事务挂起，新建一个事务，只将自身操作（B）包含进来
	PROPAGATION_NOT_SUPPORTED	如果A中有事务，将A的事务挂起，不使用事务
	PROPAGATION_NEVER	如果A中有事务，抛出异常
嵌套式事务	PROPAGATION_NESTED	如果A中有事务，执行A事务，执行完成后设置一个保存点；再执行B中的操作，如果没有异常，执行通过；如果有异常可以回滚到最初始位置（A操作前），也可以回滚到A操作后设置的保存点位置

基本使用

案例要求：

　　账户之间相互转账，一方转出的同时另一方必须转入才行

实现一：不使用事务管理

创建service层、dao层的接口和实现类

dao层

接口

package com.qf.tx.demo;

public interface AccountDao {
	
	void addMoney(Long toId,Double money);
	void subMoney(Long fromId,Double money);
}

实现类

package com.qf.tx.demo;

import org.springframework.jdbc.core.support.JdbcDaoSupport;
import org.springframework.stereotype.Repository;

@Repository("accountDao")
public class AccountDaoImpl extends JdbcDaoSupport implements AccountDao {
	
	@Override
	public void addMoney(Long toId, Double money) {
		this.getJdbcTemplate().update("update account set amount=amount+? where id=?", money, toId);
	}

	@Override
	public void subMoney(Long fromId, Double money) {
		this.getJdbcTemplate().update("update account set amount=amount-? where id=?", money, fromId);
	}

}

service层　

接口

package com.qf.tx.demo;

public interface AccountService {

	void transerTo(Long fromId,Long toId,Double money);
}

实现类

package com.qf.tx.demo;

import javax.annotation.Resource;

import org.springframework.stereotype.Service;

@Service("accountService")
public class AccountServiceImpl implements AccountService{
	@Resource(name="accountDao")
	private AccountDao accountDao;

	public void setAccountDao(AccountDao accountDao) {
		this.accountDao = accountDao;
	}

	@Override
	public void transerTo(Long fromId, Long toId, Double money) {
		accountDao.subMoney(fromId, money);
		//int a = 1/0;
		accountDao.addMoney(toId, money);
	}

}

Spring管理service和dao的实现类

<!-- 配置数据源连接池 --> 
<context:property-placeholder location="classpath:jdbc.properties" />
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
	<property name="url" value="${jdbc.url}"></property>
	<property name="driverClassName" value="${jdbc.driverClassName}"></property>
	<property name="username" value="${jdbc.username}"></property>
	<property name="password" value="${jdbc.password}"></property>
</bean>

<!-- Spring管理dao -->
<bean id="accountDao" class="com.qf.tx.demo.AccountDaoImpl">
	<property name="dataSource" ref="dataSource"></property>
</bean>

<!-- Spring管理service -->
<bean id="accountService" class="com.qf.tx.demo.AccountServiceImpl">
	<property name="accountDao" ref="accountDao"></property>
</bean>

测试

package com.qf.tx.demo;

import javax.annotation.Resource;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext_tx.xml")
public class TestDemo {
	
	@Resource(name="accountService")
	private AccountService accountService;

	@Test
	public void test() {
		accountService.transerTo(1L, 2L, 100d);
	}
}

实现二：编程式事务管理

配置事务平台管理器

<!-- 配置事务平台管理器 -->
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
	<property name="dataSource" ref="dataSource"></property>
</bean>

配置事务管理模板
- 事务管理模板
  - 使用TransactionTemplate 不需要显式地开始事务，甚至不需要显式地提交事务。这些步骤都由模板完成。
  - 出现异常时，应通过TransactionStatus 的setRollbackOnly 显式回滚事务。
  - TransactionTemplate 的execute 方法接收一个TransactionCallback 实例。Callback 也是Spring 的经典设计，用于简化用户操作　　
- 配置
```

<bean id="txTemplate" class="org.springframework.transaction.support.TransactionTemplate">
	<property name="transactionManager" ref="txManager"/>
</bean>
```

service层注入事务管理模板，用于管理事务

<!-- Spring管理service,在service层注入事务管理的模板 -->
<bean id="accountService" class="com.qf.tx.demo.AccountServiceImpl">
	<property name="accountDao" ref="accountDao"/>
	<property name="txTemplate" ref="txTemplate"/>
</bean>

修改service的实现类

package com.qf.tx.demo;

import javax.annotation.Resource;

import org.springframework.stereotype.Service;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallback;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;

@Service("accountService")
public class AccountServiceImpl implements AccountService{
	@Resource(name="accountDao")
	private AccountDao accountDao;

	public void setAccountDao(AccountDao accountDao) {
		this.accountDao = accountDao;
	}
	
	@Resource(name="txTemplate")
	private TransactionTemplate txTemplate;

	public void setTxTemplate(TransactionTemplate txTemplate) {
		this.txTemplate = txTemplate;
	}

	@Override
	public void transerTo(final Long fromId, final Long toId, final Double money) {
		txTemplate.execute(new TransactionCallbackWithoutResult() {
			
			@Override
			protected void doInTransactionWithoutResult(TransactionStatus status) {
				accountDao.subMoney(fromId, money);
				int a = 1/0;
				accountDao.addMoney(toId, money);
			}
		});
	}
}

实现三：声明式事务管理

声明式事务管理

不需要修改代码就可以实现事务管理

采用AOP实现，所以可以使用XML和注解两种方式来实现

XML方式

使用实现一的接口和实现类即可，不需要修改代码
引入AOP开发需要的jar包
- spring-aop-4.2.4.RELEASE.jar
- spring-aspects-4.2.4.RELEASE.jar
- com.springsource.org.aspectj.weaver-1.6.8.RELEASE.jar
- com.springsource.org.aopalliance-1.0.0.jar

配置事务平台管理器

<!-- 配置事务平台管理器 -->
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
	<property name="dataSource" ref="dataSource"></property>
</bean>

AOP配置

配置切面

<!-- 配置事务的增强 -->
<tx:advice id="txAdvice" transaction-manager="txManager">
	<tx:attributes>
		<tx:method name="trans*" propagation="REQUIRED" />
	</tx:attributes>
</tx:advice>

将切面应用到目标类

<!-- 配置AOP -->
<aop:config>
	<aop:pointcut expression="execution(* com.qf.tx.demo.AccountServiceImpl.*(..))" id="pointcut"/>
	<aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut"/>
</aop:config>

注解方式

引入AOP开发需要的jar包
- spring-aop-4.2.4.RELEASE.jar
- spring-aspects-4.2.4.RELEASE.jar
- com.springsource.org.aspectj.weaver-1.6.8.RELEASE.jar
- com.springsource.org.aopalliance-1.0.0.jar

配置事务平台管理器

<!-- 配置事务平台管理器 -->
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
	<property name="dataSource" ref="dataSource"></property>
</bean>

开启注解事务

<!-- 开启注解事务 -->
<tx:annotation-driven transaction-manager="txManager"/>

service层添加注解

@Transactional
@Service("accountService")
public class AccountServiceImpl implements AccountService

查看全文

相关阅读:
解决项目迁移至Kubernetes集群中的代理问题
 gorm系列-简单入门
 py操作mongodb总结
 zabbix添加监控项以及常用的键值
 监控服务器cpu、磁盘、模板以及自定义key
Zabbix+Grafana打造高逼格监控系统
 基于Docker的Mysql主从复制搭建
 rbac权限管理
 Django的认证系统
 Django 中间件

原文地址：https://www.cnblogs.com/qf123/p/10268139.html