05 MyBatis之表关系的声明+事务+SqlSession三件套的作用域

  • MyBatis 支持一对一,一对多,多对多查询。
  • XML 文件和注解都能实现关系的操作。
  • 多对多实质就是一对多

1. 表关系的维护

1.1 @One一对一

一对一查询和多表(两表)查询很相似, 都能查询两表的全部属性
区别是一对一可以在对象中嵌套对象, 呈现包含关系; 多表呈现的是平级关系

每个Article对应一个ArticleDetail:
在这里插入图片描述
实体类代码:

@Data
public class ArticleDetail {
private Integer id;
private Integer articleId;
private String content;
}
@Data
public class Article {
private Integer id;
private Integer userId;
private String title;
private String summary;
private Integer readCount;
private LocalDateTime createTime;
private LocalDateTime updateTime;
//每个Article都包含一个ArticleDetail
private ArticleDetail articleDetail;
}

1.1.1 创建ArticleOneToOneMapper查询接口:

	public interface ArticleOneToOneMapper {//查询文章详情表/**该方法名为queryContent,传入参数id执行SQL,并返回一个ArticleDetail对象*/@Select("""select id,article_id,content from article_detailwhere article_id = #{articleId}""")@Results({@Result(id = true, column = "id", property = "id"),@Result(column = "article_id", property = "articleId"),@Result(column = "content", property = "content")})ArticleDetail queryContent(Integer articleId);//查询文章属性+文章详情@Select("""select id,user_id,title,summary,read_count,create_time,update_timefrom articlewhere id = #{id}""")@Results({@Result(id = true, column = "id", property = "id"),@Result(column = "user_id", property = "userId"),@Result(column = "read_count", property = "readCount"),@Result(column = "create_time", property = "createTime"),@Result(column = "update_time", property = "updateTime"),/**根据@One注解调用指定的SQL方法queryContent,*调用queryContent需要一个参数articleId, 由column="id"提供*queryContent执行完毕后返回一个ArticleDetail类型的对象*该对象注入到property="articleDetail"这个字段中*/@Result(column = "id", property = "articleDetail",one = @One(select ="com.sunsplanter.mapper.ArticleOneToOneMapper.queryContent",fetchType = FetchType.LAZY))})Article queryAllArticle(Integer id);}
}

1.1.2 单元测试:

@SpringBootTest
public class OneToOneTest {@Autowired
private ArticleOneToOneMapper articleOneToOneMapper;@Test
void testOne() {
Article article = articleOneToOneMapper.queryAllArticle(1);
System.out.println("article = " + article);}
}

1.1.3 执行结果

第一步先查询第一层Article

第二步查询嵌套的ArticleDetail

1.2 @Many一对多

每个Article 对应多个 comment :

1.2.1 编写实体类:

@Data
public class Comment {
private Integer id;
private Integer articleId;
private String content;
}
@Data
public class Article {
private Integer id;
private Integer userId;
private String title;
private String summary;
private Integer readCount;
private LocalDateTime createTime;
private LocalDateTime updateTime;
//一个文章对应多个评论,多个评论用类型为comment 的对象装载
private List<CommentPO> comments; 
}

1.2.2 ArticleOneToManyMapper接口

	public interface ArticleOneToManyMapper {@Select("""select id,article_id,content from commentwhere article_id = #{articleId}""")@Results(id="CommentMapper",value = {@Result(id = true, column = "id", property = "id"),@Result(column = "article_id", property = "articleId"),@Result(column = "content", property = "content")})List<Comment> queryComments(Integer articleId);@Select("""select id, user_id,title,summary,read_count,create_time,update_timefrom articlewhere id = #{id}""")@Results(id="ArticleBaseMapper",value={@Result(id = true, column = "id", property = "id"),@Result(column = "user_id", property = "userId"),@Result(column = "read_count", property = "readCount"),@Result(column = "create_time", property = "createTime"),@Result(column = "update_time", property = "updateTime"),@Result(column = "id", property = "comments",many = @Many(select =
"com.mapper.ArticleOneToManyMapper.queryComments", fetchType =
FetchType.LAZY))})ArticleEntity queryArticleAndComments(Integer id);
}

1.2.3 单元测试

@SpringBootTest
public class OneToManyTest {@Autowired
private ArticleOneToManyMapper articleOneToManyMapper;@Test
void testOnetoMany() {Article article = articleOneToManyMapper.queryArticleAndComments(1);System.out.println("ArticleEntity = " + article);}
}

2 事务

  • 事务分为全局事务与本地事务

  • 本地事务是特定于资源的,例如与 JDBC 连接关联的事务。本地事务更容易使用,但有一个显著的缺点:它们不能跨多个事务资源工作。比如在方法中处理连接多个数据库的事务,本地事务是无效的。

  • Spring 解决了全局和本地事务的缺点。它允许应用程序开发人员在任何环境中使用一致的编程模型。只需编写一次代码,就可以从不同环境中的不同事务管理策略中获益。

  • Spring 框架同时提供声明式和编程式事务管理。

  • 推荐声明式事务管理。

  • Spring Framework 的声明式事务管理通过 **Spring AOP 的环绕通知(TransactionInterceptor)**实现.

  • 事务控制的属性:
    Propagation : 传播行为。代码可以继续在现有事务中运行(常见情况),也可以暂停现有事务并创建新事务
    Isolation: 隔离级别。此事务与其他事务的工作隔离的程度。例如,这个事务能看到其他事务未提交的写吗?
    Timeout 超时时间:该事务在超时和被底层事务基础结构自动回滚之前运行的时间。
    Read-only 只读状态:当代码读取但不修改数据时,可以使用只读事务。

  • 声明式事务的方式
    a. XML 配置文件:全局配置
    b. @Transactional 注解驱动 :和代码一起提供,比较直观。和代码的耦合比较高。【建议只使用@Transactional 注释具体类(以及具体类的方法),而不是注释接口。当然,可以将@Transactional 注解放在接口(或接口方法)上,但这只有在使用基于接口的代理时才能正常工作】

  • @Transaction注解的生效范围:
    @Transactional注解 仅生效于public方法.
    在受保护的、私有的或包可见的方法上使用该注解,虽然不会引发错误,但事务不生效。
    如果需要受保护的、私有的方法具有事务考虑使用 AspectJ。而不是基于代理的机制。

2.1 准备事务的演示环境

目标: 两张表:文章表和文章详情表, 使用事务, 仅当两表都被插入成功时才提交事务.

在这里插入图片描述

2.1.1

Spring Initializr 新建一个模块, 3.0.3版本,依赖如下:
在这里插入图片描述

2.1.2 建表及实体类

在这里插入图片描述
本次只是简单演示插入事务, 无需一对一关系, 故Article中不嵌套ArticleDetail对象

import lombok.Data;import java.time.LocalDateTime;@Data
public class Article {private Integer id;private Integer userId;private String title;private String summary;private Integer readCount;private LocalDateTime createTime;private LocalDateTime updateTime;
}
import lombok.Data;@Data
public class ArticleDetail {private Integer id;private Integer articleId;private String content;
}

2.1.3 创建ArticleMapper接口(@Option注解)

import com.sunsplanter.trans.pojo.Article;
import com.sunsplanter.trans.pojo.ArticleDetail;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Options;public interface ArticleMapper {//添加文章的属性 Article/**调用 insertArticle 方法并传入一个 Article 对象时,MyBatis 会执行插入操作。*插入完成后,如果表有自动生成的主键,该主键的值会被设置回传入的 Article 对象的 id 属性中。*/@Insert("""insert intoarticle(user_id,title,summary,read_count,create_time,update_time) \values(#{userId},#{title},#{summary},#{readCount},#{createTime},#{updateTime})""")/**useGeneratedKeys = true 表示 MyBatis 将会使用 JDBC 的 getGeneratedKeys 方法来获取数据库自动生成的主键。*keyProperty指定了 MyBatis 应该将获取到的主键值设置回哪个属性上,在这里是 article 对象的 id 属性。*keyColumn = "id" 表明主键在数据库表中的列名是 id。*/@Options(useGeneratedKeys = true, keyColumn = "id", keyProperty = "id")int insertArticle(Article article);//添加文章的内容 ArticleDetail@Insert("""insert into article_detail(article_id,content)values(#{articleId},#{content})""")int insertArticleContent(ArticleDetail detail);
}

2.1.3 创建 ArticleService 接口,声明发布文章的方法, 并实现其

import com.sunsplanter.trans.pojo.Article;public interface ArticleService {boolean postNewArticle(Article article, String content);
}
import com.sunsplanter.trans.mapper.ArticleMapper;
import com.sunsplanter.trans.pojo.Article;
import com.sunsplanter.trans.pojo.ArticleDetail;
import com.sunsplanter.trans.service.ArticleService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class ArticleServiceImpl implements ArticleService {@Autowiredprivate ArticleMapper articleMapper;@Overridepublic boolean postNewArticle(Article article, String content) {//新增文章,无需前置操作articleMapper.insertArticle(article);//新增文章内容, 必须先知道往哪个文章(id)插入内容ArticleDetail detail = new ArticleDetail();detail.setArticleId(article.getId());detail.setContent(content);articleMapper.insertArticleContent(detail);return true;}
}

2.14 配置文件及启动类

spring:datasource:type: com.zaxxer.hikari.HikariDataSourcedriver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/studyusername: rootpassword: ???hikari:auto-commit: truemaximum-pool-size: 10connection-test-query: select 1mybatis:configuration:log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@MapperScan(basePackages = "com.sunsplanter.trans.mapper")
@SpringBootApplication
public class TransApplication {public static void main(String[] args) {SpringApplication.run(TransApplication.class, args);}
}

2.1.5 单元测试

   @Autowiredprivate ArticleService articleService;@Testvoid testAddArticle() {Article article = new Article();article.setTitle("Spring 事务管理");article.setSummary("Spring 事务属性,事务实现");article.setUserId(2001);article.setReadCount(0);article.setCreateTime(LocalDateTime.now());article.setUpdateTime(LocalDateTime.now());boolean add = articleService.postNewArticle(article, "Spring 统一事务管理。事务管理器管理本地事务");System.out.println("add = " + add);}

尽管两张表都插入成功了, 但不是用事务机制插入的, 有失败(例如只插入了一张表)的风险, 从控制台输出也可以看出提示未开启同步事务:
在这里插入图片描述

2.2 增加事务注解

  • 前述提到, 最好在具体的类或具体的方法上使用@Transactional注解
  • Transactional内有rollback属性, 声明抛出何种异常时回滚事务,默认值是运行时异常
  • .

2.2.1 事务回滚规则

  • 默认情况下,抛出RuntimeException时实例或子类时回滚事务

  • 也可以在属性中指定何时回滚

  • Error 也会回滚事务

  • 已检查异常不会回滚。默认提交事务

  • @Transactional 注解的属性控制回滚
     rollbackFor
     noRollbackFor
     rollbackForClassName
     noRollbackForClassName

2.2.2 开启事务所需注解

我们在 ArticleserviceImpl 上增加@Transaction注解(默认运行时异常回滚)
并且在其内定义各种应该抛出的异常, 例如阅读量的异常:

if( article.getReadCount() < 1) {//Spring发现抛出的是运行时异常, 会执行回滚throw new RuntimeException("已读数量不能 < 1 ");
}
  1. 启动类上增加@EnableTransactionManagement (该注解默认存在, 即使不加也可以)

2.3 无效的事务声明

2.3.1 方法调方法

  • 首先, 仅当public修饰的类或方法才能令事务生效

  • 然而,并不是所有的public修饰的类或方法都能令事务生效

    在 Spring 中,事务是通过代理(Proxy)来实现的。在一个 Spring 管理的 bean 中调用另一个方法时,这种调用的性质(内部调用 vs 外部调用)会影响事务的行为。

外部调用 vs 内部调用
外部调用:

当一个方法从外部类(比如另一个 Spring Bean)被调用时,Spring 的代理机制可以拦截这个调用,确保事务相关的切面(例如 @Transactional 注解)被应用。这是事务正常工作的场景。
内部调用:

当一个方法在同一个类中直接调用另一个方法时,这被称为内部调用。在这种情况下,由于调用发生在代理之内,Spring 的代理机制并不会介入,因此不会处理事务相关的切面。即一个方法内部调用另一个带有 @Transactional 注解的方法,事务注解不会生效。

在上述例子中, ArticleService接口中增加方法 managerArticles, 并在impl中实现其:

//接口中增加方法
boolean managerArticle(String action,ArticlePO article,String content);
//实现类方法:
@Override
public boolean managerArticle(String action, ArticlePO article, String content) {return postNewArticle(article,content);
}

其后, 在测试方法中:

//原本:boolean add = articleService.postNewArticle("add",article, "222 Spring 统一事务管理。事务管理器管理本地事务")
boolean add = articleService.managerArticle("add",article, "222 Spring 统一事务管理。事务管理器管理本地事务")

这样不会执行事务.
通过方法调方法的方式, 事务不会执行.

2.3.1 不同线程之间不会同步事务

在 Spring 中,事务管理通常是通过线程本地存储(Thread Local)来实现的,这意味着事务信息是与执行它的线程绑定的。当在一个新的线程中运行代码时,这个新线程不会自动继承原始线程的事务上下文。

  • 同一线程中的事务
    在同一个线程中,事务的边界被定义为方法调用的开始和结束。在这个边界内,所有的数据库操作都是在同一个事务上下文中执行的。
  • 新线程中的事务
    当在一个新的线程中执行代码时,这个线程将不会有访问原始线程事务上下文的能力。
    任何在新线程中创建的事务将是全新的,与原始线程的事务完全隔离。
    这意味着在新线程中执行的操作要么自己管理事务,要么不在事务的控制之下。

3 SqlSession三件套的生命周期及作用域

  • SqlSessionFactoryBuilder

SqlSessionFactory一旦被创建,就不再需要它了。 因此 SqlSessionFactoryBuilder 实例的最佳作用域是方法作用域(也就是局部方法变量)。 你可以重用 SqlSessionFactoryBuilder 来创建多个 SqlSessionFactory 实例,但最好还是不要一直保留着它,以保证所有的 XML 解析资源可以被释放给更重要的事情。

  • SqlSessionFactory

SqlSessionFactory 一旦被创建就应该在应用的运行期间一直存在,没有任何理由丢弃它或重新创建另一个实例。 使用 SqlSessionFactory 的最佳实践是在应用运行期间不要重复创建多次。因此 SqlSessionFactory 的最佳作用域是应用作用域。 有很多方法可以做到,最简单的就是使用单例模式或者静态单例模式。

  • SqlSession

每个线程都应该有它自己的 SqlSession 实例。SqlSession 的实例不是线程安全的,因此是不能被共享的,所以它的最佳的作用域是请求或方法作用域。 绝对不能将 SqlSession 实例的引用放在一个类的静态域,甚至一个类的实例变量也不行。 也绝不能将 SqlSession 实例的引用放在任何类型的托管作用域中,比如 Servlet 框架中的 HttpSession。 如果你现在正在使用一种 Web 框架,考虑将 SqlSession 放在一个和 HTTP 请求相似的作用域中。 换句话说,每次收到 HTTP 请求,就可以打开一个 SqlSession,返回一个响应后,就关闭它。 这个关闭操作很重要,为了确保每次都能执行关闭操作,你应该把这个关闭操作放到 finally 块中。 下面的示例就是一个确保 SqlSession 关闭的标准模式

mybatis中的dao层一般也叫做mapper层,即UserDao类也可以叫做UserMapper类

以后只要专注于接口和mapper.xml文件,实现类和方法都可以动态生成

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/659003.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

行为型设计模式—迭代器模式

迭代器模式&#xff1a;也叫作游标模式&#xff0c;能在不暴露复杂数据结构内部细节的情况下遍历其中所有的元素。在迭代器的帮助下&#xff0c; 客户端可以用一个迭代器接口以相似的方式遍历不同集合中的元素。 当集合背后为复杂的数据结构&#xff0c;且希望对客户端隐藏其复…

Qt扩展-muParser数学公式解析

muParser数学公式解析 一、概述1. 针对速度进行了优化2. 支持的运算符3. 支持的函数4. 用户定义的常量5. 用户定义的变量6. 自定义值识别回调7. 其他功能 二、内置函数三、内置二元运算符四、三元运算符五、内置常量六、源码引入1. 源码文件2. 编译器开关1. MUP_BASETYPE2.MUP_…

【中关村开源生态论坛暨大模型智能应用技术大会】—— 探索AI和开源在未来的应用

&#x1f308;个人主页: Aileen_0v0 &#x1f525;热门专栏: 华为鸿蒙系统学习|计算机网络|数据结构与算法 ​&#x1f4ab;个人格言:“没有罗马,那就自己创造罗马~” #mermaid-svg-9ttR7rpX3BzyF2C4 {font-family:"trebuchet ms",verdana,arial,sans-serif;font-siz…

阿赵UE学习笔记——13、贴花

阿赵UE学习笔记目录 大家好&#xff0c;我是阿赵。   继续学习虚幻引擎的使用。这次介绍一种特殊的材质类型&#xff0c;贴花。 一、获取贴花资源 在没有分析贴花的原理之前&#xff0c;可以先去获得一些免费的贴花资源来使用&#xff0c;比如在Quixel上面就有专门的一个资源…

初识C语言·文件操作

目录 1 关于文件 i)文件的基本知识 ii)数据文件的分类 2 文件打开和关闭 i)流和标准流 ii)文件指针 iii)文件打开和关闭 3 文件的顺序读写 i) fgetc fputc ii) fgets fputs iii) fscanf fprintf iv) fwrite fread 4 对比一组函数 scanf/fscanf/sscanf/printf/fpri…

VMware虚拟机安装macOS

VMware虚拟机安装macOS 文章目录 VMware虚拟机安装macOS先看效果一、准备工作①&#xff1a;镜像资源下载②&#xff1a;虚拟机③&#xff1a;安装macOS所必要的插件 二、开始安装①&#xff1a;创建新的虚拟机②&#xff1a;自定义硬件③&#xff1a;开启虚拟机 先看效果 一、…

新东方财报解读:新一轮增长逻辑或蕴于电商业务?

从财报表现来看&#xff0c;教育市场的元气在持续提升。 近日&#xff0c;新东方、好未来等上市公司陆续公布了2023年9-11月的业绩表现。其中&#xff0c;好未来实现营收3.7亿美元&#xff0c;同比增长60.5%&#xff1b;归母净亏损2394.6万美元&#xff0c;亏幅同比收窄53.6%。…

Redis常见数据类型[上]

目录 前言&#xff1a; 基本全局命令 KEYS EXISTS DEL EXPIRE TTL TYPE 数据结构和内部编码 内部编码&#xff1a; 单线程架构 引出单线程模型&#xff1a; 为什么单线程还这么快&#xff1f; String字符串 字符串数据类型&#xff1a; 常见命令&#xff1a; S…

嵌入式学习第十五天!(内存管理、链表)

1. 内存管理&#xff1a; 1. malloc void *malloc(size_t size); 功能&#xff1a;申请堆区空间 参数&#xff1a;size&#xff1a;申请堆区空间的大小 返回值&#xff1a;返回获得的空间的首地址&#xff0c;失败返回NULL 2. free void free(void *ptr); 功能&#xff1a;释…

信效度检验2(SPSS

目录 1.效度介绍&#xff1a;2.效度检验&#xff1a;小结&#xff1a; 1.效度介绍&#xff1a; 用于研究题项设计是否合适 2.效度检验&#xff1a; 点击 降维->因子 把涉及到因变量的问题放入即可&#xff1a; 勾选&#xff1a; 得到输出结果&#xff1a; KMO值 0.7…

如何使用wireshark解析二进制文件

目录 目录 1.将已有的packet raw data按照下面格式写入文本文件中 a. Raw IP packet b. Ethernet packet 2.用wiershark导入hex文件 3.设置对应的packet类型 a. Raw IP packet b. Ethernet packet 1.将已有的packet raw data按照下面格式写入文本文件中 a. Raw IP pac…

汽车燃油泵数据分析:全球市场的年复合增长率将达到10%左右

燃油泵是汽车配件行业的专业术语。是电喷汽车燃油喷射系统的基本组成之一&#xff0c;位于车辆油箱内部&#xff0c;燃油泵在启动和发动机运转时工作&#xff0c;如果发动机停止而点火开关仍处于ON时&#xff0c;HFM-SFI控制模块关闭燃油泵的电源&#xff0c;以避免意外点火。 …

OpenCV与机器学习:使用opencv实现KNN

使用opencv实现KNN 前言OpenCV实现KNN生成随机数据使用matplotlib绘制数据OpenCV用于KNN训练生成新数据并观察预测 前言 KNN算法&#xff0c;即K-Nearest Neighbor&#xff0c;是一种简单的机器学习算法。它的基本思想是&#xff1a;如果一个样本在特征空间中的K个最相似&…

标注数据集 --labelimg

前言&#xff1a;我们想要训练自己的数据集时&#xff0c;通常需要自己标注数据集。无论是标注成yolo可识别的txt格式还是voc数据集的xml格式。使用labelimg标注都是一个不错的选择。 下面我们就从创建环境&#xff0c;使用labelimg进行标注两个方面来说明。 1.创建labelimg环境…

ADI 配合 USRP 使用的相控阵天线 cn0566

相控阵天线 在这里插入图片描述

Python实战:爬取微博,获取南京地铁每日客流数据

在这篇文章中&#xff0c;我们将使用 Python 进行网络爬虫&#xff0c;爬取微博上的南京地铁每日客流数据。 一、分析网页 在“南京地铁”微博主页搜索“昨日客流”关键词&#xff0c;搜索到每天发布的昨日客流数据。 “南京地铁”微博主页地址https://weibo.com/u/26382762…

基于视觉的移载协作机器人机床上下料末端纠偏算法

摘 要 针对复合机器人在机床上下料中的定位方法,本文主要关注识别机床卡盘和末端作业面的定位。首先分 析了复合机器人在机床上下料过程中的工作原理及其基本结构,包括 AGV (自动导引车)和协作机器人 的功能及特点。然后,详细阐述了如何使用视觉系统和纠偏算法来…

京东采销急眼,隔空喊话“针对”拼多多,焦虑之下为哪般?

农历新年将至&#xff0c;无论是线下各大商超还是线上电商平台&#xff0c;皆为年终大促而“忙的不亦乐乎”&#xff0c;尤其是近期发生的京东采销人员在直播间向拼多多喊话&#xff0c;“恳请拼多多停止屏蔽&#xff0c;恳请拼多多直接比价”&#xff0c;更是将年底这场朴实无…

flink cdc,standalone模式下,任务运行一段时间taskmanager挂掉

在使用flink cdc&#xff0c;配置任务运行&#xff0c;过了几天后&#xff0c;任务无故取消&#xff0c;超时&#xff0c;导致taskmanager挂掉&#xff0c;相关异常如下&#xff1a; 异常1&#xff1a; did not react to cancelling signal interrupting; it is stuck for 30 s…

ElasticSearch基础用法

什么是ElasticSearch? Elasticsearch是一个开源的、分布式的、实时的搜索和分析引擎。它允许用户近乎实时地存储、检索大量数据&#xff0c;并能够高效地对其进行全文搜索、聚合和分析。 部署ES和Kibana 通常采用docker-compose部署ES&#xff08;ElasticSearch&#xff09;服…