msb_160006
/
sprint_all
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

spring tx

Browse Source
main
lsrong 2 years ago
parent 633a6cbba8
commit ee6d8a7a2a
13 changed files with 406 additions and 0 deletions
Show Stats Download Patch File Download Diff File

38
spring_tx_01/.gitignore vendored
Unescape View File

@ -0,0 +1,38 @@
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### IntelliJ IDEA ###
.idea/modules.xml
.idea/jarRepositories.xml
.idea/compiler.xml
.idea/libraries/
*.iws
*.iml
*.ipr
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store

102
spring_tx_01/pom.xml
Unescape View File

@ -0,0 +1,102 @@
<?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>org.example</groupId>
<artifactId>spring_tx_01</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!--spring核心容器包-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>6.0.11</version>
</dependency>
<!--spring切面包-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aspects</artifactId>
<version>6.0.11</version>
</dependency>
<!--spring test测试支持包-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>6.0.11</version>
<scope>test</scope>
</dependency>
<!--aop联盟包-->
<dependency>
<groupId>aopalliance</groupId>
<artifactId>aopalliance</artifactId>
<version>1.0</version>
</dependency>
<!--德鲁伊连接池-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.10</version>
</dependency>
<!--mysql驱动-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.28</version>
</dependency>
<!--springJDBC包-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>6.0.11</version>
</dependency>
<!--spring事务控制包-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>6.0.11</version>
</dependency>
<!--spring orm 映射依赖-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-orm</artifactId>
<version>6.0.11</version>
</dependency>
<!--Apache Commons日志包-->
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
<version>1.2</version>
</dependency>
<!--slf4-impl 包含了log4j2 依赖-->
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-slf4j-impl</artifactId>
<version>2.14.0</version>
<scope>test</scope>
</dependency>
<!--Junit单元测试-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.13.2</version>
<scope>test</scope>
</dependency>
<!--lombok -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.12</version>
<scope>provided</scope>
</dependency>
</dependencies>
</project>

85
spring_tx_01/src/main/java/com/msb/config/SpringConfig.java
Unescape View File

@ -0,0 +1,85 @@
package com.msb.config;
import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import javax.sql.DataSource;
//@Configuration // 配置类注解
//@ComponentScan(basePackages = "com.msb") // Spring 包扫描
//@PropertySource("classpath:jdbc.properties") // 读取配置文件
//@EnableTransactionManagement // 开启事务
public class SpringConfig {
@Value("${jdbc_username}")
private String username;
@Value("${jdbc_password}")
private String pwd;
@Value("${jdbc_url}")
private String url;
@Value("${jdbc_driver}")
private String driver;
/**
* 加载特鲁伊数据库连接池
* <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
* <property name="username" value="${jdbc_username}"></property>
* <property name="password" value="${jdbc_password}"></property>
* <property name="url" value="${jdbc_url}"></property>
* <property name="driverClassName" value="${jdbc_driver}"></property>
* </bean>
* @return
*/
@Bean
public DruidDataSource getDruidDataSource(){
DruidDataSource dataSource = new DruidDataSource();
dataSource.setUsername(username);
dataSource.setPassword(pwd);
dataSource.setDriverClassName(driver);
dataSource.setUrl(url);
return dataSource;
}
/**
* 获取jdbcTemplate 对象
* <!--配置JDBCTemplate对象,并向里面注入DataSource-->
* <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
* <!--通过set方法注入连接池-->
* <property name="dataSource" ref="dataSource"></property>
* </bean>
* @param dataSource
* @return
*/
@Bean
public JdbcTemplate getJdbcTemplate(DataSource dataSource){
JdbcTemplate jdbcTemplate = new JdbcTemplate();
jdbcTemplate.setDataSource(dataSource);
return jdbcTemplate;
}
/**
* <!--配置一个事务管理器-->
* <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
* <!--将数据源注入事务管理器-->
* <property name="dataSource" ref="dataSource"/>
* </bean>
*/
@Bean
public PlatformTransactionManager getDataSourceTransactionManager(DataSource dataSource){
DataSourceTransactionManager dataSourceTransactionManager = new DataSourceTransactionManager();
dataSourceTransactionManager.setDataSource(dataSource);
return dataSourceTransactionManager;
}
}

5
spring_tx_01/src/main/java/com/msb/dao/AccountDao.java
Unescape View File

@ -0,0 +1,5 @@
package com.msb.dao;
public interface AccountDao {
int changeMoneyById(int id, int money);
}

21
spring_tx_01/src/main/java/com/msb/dao/impl/AccountDaoImpl.java
Unescape View File

@ -0,0 +1,21 @@
package com.msb.dao.impl;
import com.msb.dao.AccountDao;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
@Repository
public class AccountDaoImpl implements AccountDao {
private final JdbcTemplate jdbcTemplate;
public AccountDaoImpl(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
@Override
public int changeMoneyById(int id, int money) {
String sql = "update account set money=money+? where id = ?";
return jdbcTemplate.update(sql, money, id);
}
}

14
spring_tx_01/src/main/java/com/msb/pojo/Account.java
Unescape View File

@ -0,0 +1,14 @@
package com.msb.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@NoArgsConstructor
@AllArgsConstructor
@Data
public class Account {
private Integer id;
private String name;
private Integer money;
}

5
spring_tx_01/src/main/java/com/msb/service/AccountService.java
Unescape View File

@ -0,0 +1,5 @@
package com.msb.service;
public interface AccountService {
int transMoney(int form, int to, int money);
}

30
spring_tx_01/src/main/java/com/msb/service/impl/AccountServiceImpl.java
Unescape View File

@ -0,0 +1,30 @@
package com.msb.service.impl;
import com.msb.dao.AccountDao;
import com.msb.dao.impl.AccountDaoImpl;
import com.msb.service.AccountService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@Service
//@Transactional // 代表当前类下面的所有类都开启事务
public class AccountServiceImpl implements AccountService {
private final AccountDao accountDao;
public AccountServiceImpl(AccountDao accountDao){
this.accountDao = accountDao;
}
@Override
@Transactional // 开启事务
public int transMoney(int form, int to, int money) {
int rows = 0;
rows += accountDao.changeMoneyById(form, 0-money);
// int i = 1/0; // 手动生产异常，测试事务
rows += accountDao.changeMoneyById(to, money);
return rows;
}
}

40
spring_tx_01/src/main/resources/applicationContext.xml
Unescape View File

@ -0,0 +1,40 @@
<?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: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/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
">
<!--spring 注解扫描-->
<context:component-scan base-package="com.msb"/>
<!--读取jdbc配置文件-->
<context:property-placeholder location="classpath:jdbc.properties"/>
<!--配置德鲁伊连接池-->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
<property name="username" value="${jdbc_username}"></property>
<property name="password" value="${jdbc_password}"></property>
<property name="url" value="${jdbc_url}"></property>
<property name="driverClassName" value="${jdbc_driver}"></property>
</bean>
<!--配置JDBCTemplate对象,并向里面注入DataSource-->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<!--通过set方法注入连接池-->
<property name="dataSource" ref="dataSource"></property>
</bean>
<!--配置一个事务管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<!--将数据源注入事务管理器-->
<property name="dataSource" ref="dataSource"/>
</bean>
<!--开启事务注解-->
<tx:annotation-driven transaction-manager="transactionManager"/>
</beans>

4
spring_tx_01/src/main/resources/jdbc.properties
Unescape View File

@ -0,0 +1,4 @@
jdbc_username=root
jdbc_password=12345678
jdbc_driver=com.mysql.cj.jdbc.Driver
jdbc_url=jdbc:mysql://localhost:3306/learnjdbc?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true

13
spring_tx_01/src/main/resources/log4j2.xml
Unescape View File

@ -0,0 +1,13 @@
<?xml version="1.0" encoding="UTF-8"?>
<Configuration status="INFO">
<Appenders>
<Console name="Console" target="SYSTEM_OUT">
<PatternLayout pattern="%d{YYYY-MM-dd HH:mm:ss} [%t] %-5p %c{1}:%L - %msg%n" />
</Console>
</Appenders>
<Loggers>
<Root level="INFO">
<AppenderRef ref="Console" />
</Root>
</Loggers>
</Configuration>

22
spring_tx_01/src/test/java/com/msb/test/SpringTest.java
Unescape View File

@ -0,0 +1,22 @@
package com.msb.test;
import com.msb.service.AccountService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")
public class SpringTest {
@Autowired
AccountService accountService;
@Test
public void testTranMoney(){
int rows = accountService.transMoney(1,2,100);
System.out.println(rows);
}
}

27
spring_tx_01/src/test/java/com/msb/test/TestTx.java
Unescape View File

@ -0,0 +1,27 @@
package com.msb.test;
import com.msb.config.SpringConfig;
import com.msb.service.AccountService;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class TestTx {
@Test
public void testTranMoney(){
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
AccountService accountService = applicationContext.getBean(AccountService.class);
int rows = accountService.transMoney(1, 2, 100);
System.out.println(rows);
}
@Test
public void testSpringConfig(){
ApplicationContext context = new AnnotationConfigApplicationContext(SpringConfig.class);
AccountService accountService = context.getBean(AccountService.class);
int rows = accountService.transMoney(1, 2, 100);
System.out.println(rows);
}
}
Write Preview
Loading…
Cancel
Save