spring——使用xml声明式事务整合jdbc—

准备阶段：

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion>
<groupId>com.henu</groupId><artifactId>springJDBCplus</artifactId><version>1.0-SNAPSHOT</version>
<dependencies><!-- spring4.3.20 --><!-- spring-context --><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>4.3.20.RELEASE</version></dependency><!-- spring-core --><dependency><groupId>org.springframework</groupId><artifactId>spring-core</artifactId><version>4.3.20.RELEASE</version></dependency><!-- spring-beans --><dependency><groupId>org.springframework</groupId><artifactId>spring-beans</artifactId><version>4.3.20.RELEASE</version></dependency><!-- https://mvnrepository.com/artifact/org.springframework/spring-expression --><dependency><groupId>org.springframework</groupId><artifactId>spring-expression</artifactId><version>4.3.20.RELEASE</version></dependency><!-- https://mvnrepository.com/artifact/org.springframework/spring-aop --><dependency><groupId>org.springframework</groupId><artifactId>spring-aop</artifactId><version>4.3.20.RELEASE</version></dependency><!-- https://mvnrepository.com/artifact/org.springframework/spring-aspects --><dependency><groupId>org.springframework</groupId><artifactId>spring-aspects</artifactId><version>4.3.20.RELEASE</version></dependency><!--使用AspectJ方式注解需要相应的包 --><dependency><groupId>org.aspectj</groupId><artifactId>aspectjrt</artifactId><version>1.9.1</version></dependency>
<!--使用AspectJ方式注解需要相应的包 --><dependency><groupId>org.aspectj</groupId><artifactId>aspectjweaver</artifactId><version>1.9.2</version></dependency>
<!-- https://mvnrepository.com/artifact/commons-logging/commons-logging --><dependency><groupId>commons-logging</groupId><artifactId>commons-logging</artifactId><version>1.2</version></dependency>
<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.38</version></dependency>
<!-- https://mvnrepository.com/artifact/com.alibaba/druid --><dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.1.10</version></dependency>
<!-- https://mvnrepository.com/artifact/org.springframework/spring-jdbc --><dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>5.1.3.RELEASE</version></dependency>
<!-- https://mvnrepository.com/artifact/org.springframework/spring-tx --><dependency><groupId>org.springframework</groupId><artifactId>spring-tx</artifactId><version>5.1.3.RELEASE</version></dependency>
<!-- https://mvnrepository.com/artifact/org.projectlombok/lombok --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.16.20</version><scope>provided</scope></dependency>
<!-- https://mvnrepository.com/artifact/junit/junit --><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version></dependency>
</dependencies>

</project>

数据库：

项目架构：

一、实体类User

package com.henu.bean;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

/*** @author George* @description**/
@NoArgsConstructor
@AllArgsConstructor
@Data
public class User {private int id;private String name;private String pwd;
}

二、dao层

package com.henu.dao;

import com.henu.bean.User;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

/*** @author George* @description**/
public class UserDaoImpl implements UserDao {
private JdbcTemplate jdbcTemplate;
public int insertUser(User user) {String sql = "insert into user values(0,?,?)";return jdbcTemplate.update(sql,user.getName(),user.getPwd());}
public int deleteUser(int id) {String sql = "delete from user where id = ?";return jdbcTemplate.update(sql,id);}
public int updateUser(User user) {String sql = "update user set name=?,pwd=? where id=?";return jdbcTemplate.update(sql,user.getName(),user.getPwd(),user.getId());}
public User queryUserById(int id) {String sql = "select * from user where id = ?";//使用内部类class UserMapper implements RowMapper<User>{
public User mapRow(ResultSet resultSet, int i) throws SQLException {User user = new User();user.setId(resultSet.getInt("id"));user.setName(resultSet.getString("name"));user.setPwd(resultSet.getString("pwd"));return user;}}//这里需要注意的是使用的是queryForObject（）方法。如果使用query会报出ClassCastExceptionreturn (User) jdbcTemplate.queryForObject(sql,new UserMapper(),id);}
public List<User> queryAll() {String sql = "select * from user";//使用匿名内部类return jdbcTemplate.query(sql, new RowMapper<User>() {public User mapRow(ResultSet resultSet, int i) throws SQLException {User user = new User();user.setId(resultSet.getInt("id"));user.setName(resultSet.getString("name"));user.setPwd(resultSet.getString("pwd"));return user;}});}
public JdbcTemplate getJdbcTemplate() {return jdbcTemplate;}
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {this.jdbcTemplate = jdbcTemplate;}
}

三、service层

package com.henu.service;

import com.henu.bean.User;
import com.henu.dao.UserDao;

import java.util.List;

/*** @author George* @description**/
public class UserServiceImpl implements UserService {
private UserDao userDao;
public int insertUser(User user) {return userDao.insertUser(user);}
public int deleteUser(int id) {return userDao.deleteUser(id);}
public int updateUser(User user) {return userDao.updateUser(user);}
public User queryUserById(int id) {return userDao.queryUserById(id);}
public List<User> queryAll() {return userDao.queryAll();}
public UserDao getUserDao() {return userDao;}
public void setUserDao(UserDao userDao) {this.userDao = userDao;}
}

四、resources

db.properties

#db config
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://127.0.0.1:3306/ooxx
jdbc.username=root
jdbc.password=123456
initialSize=5
minIdle=2
maxActive=10
maxWait=10000
timeBetweenEvictionRunsMillis=60000
minEvictableIdleTimeMillis=300000
testWhileIdle=true
testOnBorrow=true
testOnReturn=false
poolPreparedStatements=true
maxPoolPreparedStatementPerConnectionSize=20
defaultAutoCommit=true
validationQuery=select 1

applicationContext_db.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:p="http://www.springframework.org/schema/p"xmlns:aop="http://www.springframework.org/schema/aop"xmlns:context="http://www.springframework.org/schema/context"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/aop
http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd"><!--导入属性文件--><context:property-placeholder location="classpath:db.properties"></context:property-placeholder><!--配置数据源--><bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"><property name="driverClassName" value="${jdbc.driverClassName}"/><property name="url" value="${jdbc.url}"/><property name="username" value="${jdbc.username}"/><property name="password" value="${jdbc.password}"/><!-- ******配置数据库连接池相关信息******* --><!-- 配置初始化大小、最小、最大 --><property name="initialSize" value="${initialSize}"/><property name="minIdle" value="${minIdle}"/><property name="maxActive" value="${maxActive}"/><!-- 配置获取连接等待超时的时间 --><property name="maxWait" value="${maxWait}"/><!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 --><property name="timeBetweenEvictionRunsMillis" value="${timeBetweenEvictionRunsMillis}"/><!-- 配置一个连接在池中最小生存的时间，单位是毫秒 --><property name="minEvictableIdleTimeMillis" value="${minEvictableIdleTimeMillis}"/><property name="testWhileIdle" value="${testWhileIdle}"/><!-- 这里建议配置为TRUE，防止取到的连接不可用 --><property name="testOnBorrow" value="${testOnBorrow}"/><property name="testOnReturn" value="${testOnReturn}"/><!-- 打开PSCache，并且指定每个连接上PSCache的大小 --><property name="poolPreparedStatements" value="${poolPreparedStatements}"/><property name="maxPoolPreparedStatementPerConnectionSize"value="${maxPoolPreparedStatementPerConnectionSize}"/><!-- 这里配置提交方式，默认就是TRUE，可以不用配置 --><property name="defaultAutoCommit" value="${defaultAutoCommit}"/><!-- 验证连接有效与否的SQL，不同的数据配置不同 --><property name="validationQuery" value="${validationQuery}"/></bean><!--JDBCTemplate--><bean name="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><property name="dataSource" ref="dataSource"/></bean><!--配置dao层--><bean name="userDao" class="com.henu.dao.UserDaoImpl"><property name="jdbcTemplate" ref="jdbcTemplate"/></bean><!--配置service层--><bean name="userService" class="com.henu.service.UserServiceImpl"><property name="userDao" ref="userDao"></property></bean><!--************************************************************--><!--配置事务管理器--><bean name="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/></bean><!--配置切入点表达式（业务层）--><aop:config><aop:advisor advice-ref="userAdvice" pointcut="execution(* com.henu.service.UserServiceImpl.*(..))"></aop:advisor></aop:config><tx:advice id="userAdvice" transaction-manager="txManager"><!--配置事务属性--><tx:attributes><!--配置具体方法使用具体事务属性--><tx:method name="insert*" propagation="REQUIRED" isolation="READ_COMMITTED" read-only="false" rollback-for="java.lang.Exception" timeout="-1"/><tx:method name="update*" propagation="REQUIRED" isolation="READ_COMMITTED" read-only="false" rollback-for="java.lang.Exception" timeout="-1"/><tx:method name="delete*" propagation="REQUIRED" isolation="READ_COMMITTED" read-only="false" rollback-for="java.lang.Exception" timeout="-1"/><tx:method name="query*" propagation="REQUIRED" isolation="READ_COMMITTED" read-only="false" rollback-for="java.lang.Exception" timeout="-1"/></tx:attributes></tx:advice></beans>

五、测试类

package com.henu;

import com.henu.bean.User;
import com.henu.service.UserService;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.List;

/*** @author George* @description* 测试类中的方法，无返回值，无参数**/
public class JdbcTest {
private ClassPathXmlApplicationContext context = null;private UserService userService;@Beforepublic void init(){context = new ClassPathXmlApplicationContext("applicationContext_db.xml");userService = (UserService) context.getBean(UserService.class);}
@Testpublic void insert(){User user = new User(0,"乔治大哥","123456");userService.insertUser(user);}
@Testpublic void deleteUser(){userService.deleteUser(1);}
@Testpublic void updateUser(){User user = new User(1,"康康","56345");userService.updateUser(user);System.out.println("success");}
@Testpublic void queryUserById(){System.out.println(userService.queryUserById(2));}
@Testpublic void queryAll(){List<User> users = userService.queryAll();for (User user : users) {System.out.println(user);}}
@Afterpublic void destory(){context.close();}

}

spring——使用xml声明式事务整合jdbc——GRUD相关推荐

spring——使用注解声明式事务整合jdbc——GRUD
准备阶段: pom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns=&qu ...
spring 注解开启声明式事务
spring开启声明式事务: 导入依赖: pom.xml <dependencies><!-- https://mvnrepository.com/artifact/org.spri ...
Spring AOP实现声明式事务代码分析
众所周知,Spring的声明式事务是利用AOP手段实现的,所谓"深入一点,你会更快乐",本文试图给出相关代码分析. AOP联盟为增强定义了org.aopalliance.aop.A ...
Spring源码——声明式事务流程
前言最近回顾了一下Spring源码,准备用思维导图的方式简单的将整个源码内容的流程展示出来,思维导图.图片等文件更新在https://github.com/MrSorrow/spring-frame ...
spring+mybatis之声明式事务管理初识(小实例)
前几篇的文章都只是初步学习spring和mybatis框架,所写的实例也都非常简单,所进行的数据访问控制也都很简单,没有加入事务管理.这篇文章将初步接触事务管理. 1.事务管理理解事务管理之前,先通 ...
Spring如何用“声明式事务”保护亿万数据安全？【万字解决并发冲突】
Hello,你好呀,我是灰小猿,一个超会写bug的程序猿
spring控制事务:声明式事务（XML）事务的传播行为
声明式事务(XML) 使用spring提供的专用于mybatis的事务管理器在xml中声明式事务声明式事务需要使用到的标签 tx配置进行<tx 标签的使用需要在xml头部导入命名空间 xml ...
spring声明式事务
11.声明式事务 11.1 事务回顾把一组业务当做一个业务来坐,要么都成功,要么都失败! 事物在项目开发中的重要性不言而喻,关系到数据的一致性文件确保完整性和一致性事务的ACID原则原子性(A ...
全面分析 Spring 的编程式事务管理及声明式事务管理(转)
摘要 Spring 的事务管理是 Spring 框架中一个比较重要的知识点,该知识点本身并不复杂,只是由于其比较灵活,导致初学者很难把握.本教程从基础知识开始,详细分析了 Spring 事务管理的使用 ...

spring——使用xml声明式事务整合jdbc——GRUD

spring——使用xml声明式事务整合jdbc——GRUD相关推荐

最新文章

热门文章