spring——使用注解声明式事务整合jdbc——GRUD
生活随笔
收集整理的這篇文章主要介紹了
spring——使用注解声明式事务整合jdbc——GRUD
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
準備階段：
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.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.RowMapper; import org.springframework.stereotype.Repository; ? import java.sql.ResultSet; import java.sql.SQLException; import java.util.List; ? /*** @author George* @description**/ @Repository public class UserDaoImpl implements UserDao {//注入jdbcTemplate@Autowiredprivate 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 org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; ? import java.util.List; ? /*** @author George* @description**/ @Service public class UserServiceImpl implements UserService {//注入userDao@Autowiredprivate UserDao userDao;@Transactionalpublic int insertUser(User user) {return userDao.insertUser(user);}@Transactionalpublic int deleteUser(int id) {return userDao.deleteUser(id);}@Transactionalpublic 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 1applicationContext_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><!--使用注解進行注入--><context:component-scan base-package="com.henu"></context:component-scan><!--************************************************************--><!--配置事務管理器--><bean name="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/></bean><!--啟動事務注解--><tx:annotation-driven transaction-manager="txManager"></tx:annotation-driven></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();} ? }【補充】
@Transactional的寫法應為：
@Transactional(propagation= Propagation.REQUIRED,isolation= Isolation.READ_COMMITTED,timeout = -1,readOnly = false,rollbackFor = Exception.class)
不過在他的默認屬性值中已經定義，以下是源碼
?
所以我們可以在需要事務管理的方法或類上直接寫直接寫@Transactional
當寫在類上時，本類中所有方法，均被事務管理。
?
?
<!--啟動事務注解-->
<tx:annotation-driven transaction-manager="txManager"></tx:annotation-driven>
總結
以上是生活随笔為你收集整理的spring——使用注解声明式事务整合jdbc——GRUD的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： spring——使用xml声明式事务整合
- 下一篇： Hadoop MapReduce V2—