Spring框架 XML配置事务控制的步骤操作

Spring框架 XML配置事务控制的步骤操作

目录基于 XML 的声明式事务控制1.环境搭建2.创建 spring 的配置文件并导入约束3.准备数据库表和实体类4.业务层接口与实现类5.数据访问层接口与实现类6.配置c3p0数据源/业务层/数据访问层7.配置事务管理器8.配置事务的通知9.配置 AOP 切入点表达式10.配置切入点表达式和事务通知的对应关系

基于 XML 的声明式事务控制

1.环境搭建

拷贝必要的 jar 包到工程的 lib 目录

2.创建 spring 的配置文件并导入约束

这里直接给出本次测试的全部XML配置，具体细节在后面依次介绍。

xmlns:context="http://springframework.org/schema/context"

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:aop="http://springframework.org/schema/aop"

xmlns:tx="http://springframework.org/schema/tx"

xsi:schemaLocation="

http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans.xsd

http://springframework.org/schema/context

http://springframework.org/schema/context/spring-context.xsd

http://springframework.org/schema/aop

http://springframework.org/schema/aop/spring-aop.xsd

http://springframework.org/schema/tx

http://springframework.org/schema/tx/spring-tx.xsd ">

xmlns:context="http://springframework.org/schema/context"

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:aop="http://springframework.org/schema/aop"

xmlns:tx="http://springframework.org/schema/tx"

xsi:schemaLocation="

http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans.xsd

http://springframework.org/schema/context

http://springframework.org/schema/context/spring-context.xsd

http://springframework.org/schema/aop

http://springframework.org/schema/aop/spring-aop.xsd

http://springframework.org/schema/tx

http://springframework.org/schema/tx/spring-tx.xsd ">

3.准备数据库表和实体类

user数据库表

create database mybase2;

USE mybase2;

CREATE TABLE `user` (

`id` INT(10) NOT NULL AUTO_INCREMENT COMMENT '主键',

`name` VARCHAR(20) NOT NULL DEFAULT '0',

`age` INT(10) NOT NULL DEFAULT '0',

PRIMARY KEY (`id`)

)

COLLATE='utf8_general_ci'

ENGINE=InnoDB

;

INSERT INTO user values(NULL,'周冬雨',21);

INSERT INTO user values(NULL,'马冬梅',18);

INSERT INTO user values(NULL,'马西梅',19);

User实体类

package com.gql.entity;

import java.io.Serializable;

/**

* 类说明:

* User实体类

* @guoqianliang1998.

*/

public class User implements Serializable {

/**

* 生成序列号

*/

private static final long serialVersionUID = -4492760954899814333L;

private int id;

private String name;

private int age;

public int getId() {

return id;

}

public void setId(int id) {

this.id = id;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

public int getAge() {

return age;

}

public void setAge(int age) {

this.age = age;

}

}

4.业务层接口与实现类

业务层接口

package com.gql.service;

import java.util.List;

import com.gql.entity.User;

/**

* 类说明:

* 业务层接口

* @guoqianliang1998.

*/

public interface UserService {

void save(User user);

void update(int id, User user);

void delete(int id);

User getUser(int id);

List getUserList(int[] ids);

List getUserList();

}

业务层实现类

package com.gql.service;

import java.util.List;

import com.gql.dao.UserDao;

import com.gql.entity.User;

/**

* 类说明:

* 业务层实现类

* @guoqianliang1998.

*/

public class UserServiceImp implements UserService {

private UserDao userDao;

public void setUserDao(UserDao userDao) {

this.userDao = userDao;

}

@Override

public void save(User user) {

userDao.save(user);

int i = 1/0;

}

@Override

public void update(int id, User user) {

userDao.update(id, user);

}

@Override

public void delete(int id) {

userDao.delete(id);

}

@Override

public User getUser(int id) {

User user = userDao.getUser(id);

return user;

}

@Override

public List getUserList(int[] ids) {

List userList = userDao.getUserList(ids);

return userList;

}

@Override

public List getUserList() {

List list = userDao.getUserList();

return list;

}

}

5.数据访问层接口与实现类

数据访问层接口

package com.gql.dao;

import java.util.List;

import com.gql.entity.User;

/**

* 类说明:

* 数据访问层接口

* @guoqianliang1998.

*/

public interface UserDao {

void save(User user);

void update(int id, User user);

void delete(int id);

User getUser(int id);

List getUserList(int[] ids);

List getUserList();

}

数据访问层实现类

package com.gql.dao;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import org.springframework.jdbc.core.JdbcTemplate;

import org.springframework.jdbc.core.RowMapper;

import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;

import com.gql.RowMapper.UserRowMapper;

import com.gql.entity.User;

/**

* 类说明:

* 数据访问层实现类

* @guoqianliang1998.

*/

public class UserDaoImp implements UserDao {

private JdbcTemplate jdbcTemplate;

public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {

this.jdbcTemplate = jdbcTemplate;

}

@Override

public void save(User user) {

String sql = "INSERT INTO user values(NULL,?,?)";

jdbcTemplate.update(sql, user.getName(), user.getAge());

}

@Override

public void update(int id, User user) {

String sql = "update user set name=?,age=? WHERE id = ?";

jdbcTemplate.update(sql, user.getName(), user.getAge(), id);

}

@Override

public void delete(int id) {

String sql = "DELETE FROM user WHERE id = ?;";

jdbcTemplate.update(sql, id);

}

@Override

public User getUser(int id) {

String sql = "select * from user where id = ?";

User user = jdbcTemplate.queryForObject(sql, new RowMapper() {

@Override

public User mapRow(ResultSet rs, int rowNum) throws SQLException {

User userHJtkWFr = new User();

user.setId(rs.getInt(1));

user.setName(rs.getString(2));

user.setAge(rs.getInt(3));

return user;

}

}, id);

return user;

}

@Override

public List getUserList(int[] ids) {

String sql = "select * from user where id in(:ids)";

NamedParameterJdbcTemplate n = new NamedParameterJdbcTemplate(jdbcTemplate.getDataSource());

Map paramMap = new HashMap();

List list = new ArrayList();

for (int i = 0; i < ids.length; i++) {

list.add(ids[i]);

}

paramMap.put("ids", list);

List userList = n.query(sql, paramMap, new RowMapper(){

@Override

public User mapRow(ResultSet rs, int rowNum) throws SQLException {

User user = new User();

user.setId(rs.getInt(1));

user.setName(rs.getString(2));

user.setAge(rs.getInt(3));

return user;

}

});

return userList;

// 第二种写法↓↓↓

// StringBuilder sb = new StringBuilder();

// sb.append("SELECT * FROM user WHERE id = ?");

// for(int i=0;i

// sb.append(" or id = ?");

// }

// Integer[] in = new Integer[ids.length];

// for(int i=0;i

// in[i] = ids[i];

// }

// Object[] args = in;

// List userList = jdbcTemplate.query(sb.toString(),args,new RowMapper() {

//

// @Override

// public Object mapRow(ResultSet rs, int rowNum) throws SQLException {

// User user = new User();

// user.setId(rs.getInt(1));

// user.setName(rs.getString(2));

// user.setAge(rs.getInt(3));

// return user;

// }

// });

// return userList;

}

@Override

public List getUserList() {

String sql = "select * from user";

List list = jdbcTemplate.query(sql, new UserRowMapper());

return list;

}

}

6.配置c3p0数据源/业务层/数据访问层

配置c3p0数据源

业务层

数据访问层

7.配置事务管理器

8.配置事务的通知

事务的通知：

配置事务的通知来引用事务管理器

告诉Spring容器采用哪种事务管理机制.

告诉Spring容器目标方法采用什么样的事务处理策略.

通知内配置事务的属性

属性

说明

read-only

是否是只读事务。默认 false，不只读。

isolation

指定事务的隔离级别。默认值是使用数据库的默认隔离级别。

propagation

指定事务的传播行为。

timeout

指定超时时间。默认值为：-1。永不超时。

rollback-for

用于指定一个异常，当执行产生该异常时，事务回滚。产生其他异常，事务不回滚。没有默认值，任何异常都回滚。

no-rollback-for

用于指定一个异常，当产生该异常时，事务不回滚，产生其他异常时，事务回

滚。没有默认值，任何异常都回滚。

9.配置 AOP 切入点表达式

10.配置切入点表达式和事务通知的对应关系

// sb.append(" or id = ?");

// }

// Integer[] in = new Integer[ids.length];

// for(int i=0;i

// in[i] = ids[i];

// }

// Object[] args = in;

// List userList = jdbcTemplate.query(sb.toString(),args,new RowMapper() {

//

// @Override

// public Object mapRow(ResultSet rs, int rowNum) throws SQLException {

// User user = new User();

// user.setId(rs.getInt(1));

// user.setName(rs.getString(2));

// user.setAge(rs.getInt(3));

// return user;

// }

// });

// return userList;

}

@Override

public List getUserList() {

String sql = "select * from user";

List list = jdbcTemplate.query(sql, new UserRowMapper());

return list;

}

}

6.配置c3p0数据源/业务层/数据访问层

配置c3p0数据源

业务层

数据访问层

7.配置事务管理器

8.配置事务的通知

事务的通知：

配置事务的通知来引用事务管理器

告诉Spring容器采用哪种事务管理机制.

告诉Spring容器目标方法采用什么样的事务处理策略.

通知内配置事务的属性

属性

说明

read-only

是否是只读事务。默认 false，不只读。

isolation

指定事务的隔离级别。默认值是使用数据库的默认隔离级别。

propagation

指定事务的传播行为。

timeout

指定超时时间。默认值为：-1。永不超时。

rollback-for

用于指定一个异常，当执行产生该异常时，事务回滚。产生其他异常，事务不回滚。没有默认值，任何异常都回滚。

no-rollback-for

用于指定一个异常，当产生该异常时，事务不回滚，产生其他异常时，事务回

滚。没有默认值，任何异常都回滚。

9.配置 AOP 切入点表达式

10.配置切入点表达式和事务通知的对应关系

// in[i] = ids[i];

// }

// Object[] args = in;

// List userList = jdbcTemplate.query(sb.toString(),args,new RowMapper() {

//

// @Override

// public Object mapRow(ResultSet rs, int rowNum) throws SQLException {

// User user = new User();

// user.setId(rs.getInt(1));

// user.setName(rs.getString(2));

// user.setAge(rs.getInt(3));

// return user;

// }

// });

// return userList;

}

@Override

public List getUserList() {

String sql = "select * from user";

List list = jdbcTemplate.query(sql, new UserRowMapper());

return list;

}

}

6.配置c3p0数据源/业务层/数据访问层

配置c3p0数据源

业务层

数据访问层

7.配置事务管理器

8.配置事务的通知

事务的通知：

配置事务的通知来引用事务管理器

告诉Spring容器采用哪种事务管理机制.

告诉Spring容器目标方法采用什么样的事务处理策略.

通知内配置事务的属性

属性

说明

read-only

是否是只读事务。默认 false，不只读。

isolation

指定事务的隔离级别。默认值是使用数据库的默认隔离级别。

propagation

指定事务的传播行为。

timeout

指定超时时间。默认值为：-1。永不超时。

rollback-for

用于指定一个异常，当执行产生该异常时，事务回滚。产生其他异常，事务不回滚。没有默认值，任何异常都回滚。

no-rollback-for

用于指定一个异常，当产生该异常时，事务不回滚，产生其他异常时，事务回

滚。没有默认值，任何异常都回滚。

9.配置 AOP 切入点表达式

10.配置切入点表达式和事务通知的对应关系

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。