準(zhǔn)備階段：

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方式注解需要相應(yīng)的包 --><dependency><groupId>org.aspectj</groupId><artifactId>aspectjrt</artifactId><version>1.9.1</version></dependency> ?<!--使用AspectJ方式注解需要相應(yīng)的包 --><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>

數(shù)據(jù)庫：

?

項目架構(gòu)：

一、實體類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 = ?";//使用內(nèi)部類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";//使用匿名內(nèi)部類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"><!--導(dǎo)入屬性文件--><context:property-placeholder location="classpath:db.properties"></context:property-placeholder><!--配置數(shù)據(jù)源--><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}"/><!-- ******配置數(shù)據(jù)庫連接池相關(guān)信息******* --><!-- 配置初始化大小、最小、最大 --><property name="initialSize" value="${initialSize}"/><property name="minIdle" value="${minIdle}"/><property name="maxActive" value="${maxActive}"/><!-- 配置獲取連接等待超時的時間 --><property name="maxWait" value="${maxWait}"/><!-- 配置間隔多久才進行一次檢測，檢測需要關(guān)閉的空閑連接，單位是毫秒 --><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，不同的數(shù)據(jù)配置不同 --><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><!--************************************************************--><!--配置事務(wù)管理器--><bean name="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/></bean><!--配置切入點表達式（業(yè)務(wù)層）--><aop:config><aop:advisor advice-ref="userAdvice" pointcut="execution(* com.henu.service.UserServiceImpl.*(..))"></aop:advisor></aop:config><tx:advice id="userAdvice" transaction-manager="txManager"><!--配置事務(wù)屬性--><tx:attributes><!--配置具體方法使用具體事務(wù)屬性--><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* 測試類中的方法，無返回值，無參數(shù)**/ 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();} ? }

總結(jié)

以上是生活随笔為你收集整理的spring——使用xml声明式事务整合jdbc——GRUD的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。