MySQL多个表的关联字段实现同步更新的解决方案

 更新时间:2024年11月19日 11:50:42   作者:离开地球表面_99  
在对数据库表结构进行设计时,为了提高查询效率,会进行一些反规范化设计,如:设计一些冗余字段,但这样可能会存在数据同步问题,故本文给大家介绍了MySQL多个表的关联字段实现同步更新的解决方案,需要的朋友可以参考下

1. 背景

在对数据库表结构进行设计时,为了提高查询效率,会进行一些反规范化设计,如:设计一些冗余字段。但这样可能会存在数据同步问题,当源表字段值更新时,冗余字段值也需要同步更新。

现有产品表 product ,移动端版本 mobile_version ,授权绑定产品表auth_server_product 三个表,这三个表有一个共同字段 productName,期望当 product 表中的 productName 字段的值改变时,将该字段修改后的值同步更新到 mobile_version,auth_server_product 两个表中。

1.1 表结构定义

1.1.1 product 表

CREATE TABLE `product`  (
  `id` int(0) NOT NULL AUTO_INCREMENT,
  `productName` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;

INSERT INTO `product` VALUES (1, '产品A');
INSERT INTO `product` VALUES (2, '产品B');
INSERT INTO `product` VALUES (3, '产品C');

1.1.2 auth_server_product 表

CREATE TABLE `auth_server_product`  (
  `id` int(0) NOT NULL,
  `authId` int(0) NULL DEFAULT NULL,
  `productId` int(0) NULL DEFAULT NULL,
  `productName` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;

INSERT INTO `auth_server_product` VALUES (1, 1, 1, '产品A');
INSERT INTO `auth_server_product` VALUES (2, 1, 2, '产品B');
INSERT INTO `auth_server_product` VALUES (3, 1, 3, '产品C');

1.1.3 mobile_version 表

CREATE TABLE `mobile_version`  (
  `id` int(0) NOT NULL,
  `mobile_version` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
  `productId` int(0) NULL DEFAULT NULL,
  `productName` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;


INSERT INTO `mobile_version` VALUES (1, 'V1.0.0', 1, '产品A');
INSERT INTO `mobile_version` VALUES (2, 'V1.0.1', 1, '产品A');

2. 解决方案

2.1 应用层代码中更新

代码层实现数据同步逻辑,在更新 product 表中的 productName 字段时,同步更新auth_server_product 与 mobile_version 两表中的字段值。大致逻辑如下:

@Transactional
public void updateProductName(String oldProductName, String newProductName) {
    // 更新 product 表中的 productName
    productRepository.updateProductName(oldProductName, newProductName);
    
    // 同步更新 mobile_version 表
    mobileVersionRepository.updateProductName(oldProductName, newProductName);

    // 同步更新 auth_server_product 表
    authServerProductRepository.updateProductName(oldProductName, newProductName);
}

该种方案的劣势

  • 代码复杂,耦合性强;
  • 数据不一致:如果同步逻辑没有被正确实现或处理,可能会导致数据不一致。

2.2 利用MySQL提供的触发器功能

MySQL 提供了触发器功能,在随某个表进行记录的新增(INSERT)、修改(UPDATE) 或是删除( DELETE) 操作时,会自动触发相应的操作。

针对上述场景中的这个问题,可以在 product 表设置触发器,在 UPDATE 操作时,通过触发器来同步更新 mobile_versionauth_server_product 表中的 productName 字段。

2.2.1 具体实现

Navicat 为例进行演示

Step 1 : 创建触发器

设计 procut 表,点击触发器,定义触发器的名称,类型选择AFTER UPDATE,表示在product 表中的 productName 更新后 同步更新其他表。

Step 2 : SQL 定义触发器行为

编写具体的SQL语句定义触发器行为,在这个例子中,期望在 productName 更新时,自动更新 mobile_versionauth_server_product 表中的 productName。SQL 下:

BEGIN
    -- 如果 productName 发生变化
    IF OLD.productName <> NEW.productName THEN
        -- 更新 mobile_version 表中的 productName
        UPDATE mobile_version
        SET productName = NEW.productName
        WHERE productName = OLD.productName;
        
        -- 更新 auth_server_product 表中的 productName
        UPDATE auth_server_product
        SET productName = NEW.productName
        WHERE productName = OLD.productName;
    END IF;
END 

Step 3 : 验证

  • show triggers,可查看当前数据库中的触发器,验证触发器是否创建成功。

  • 执行更新语句,验证触发器的定义能否达到期望的效果。
update product set productName = '产品AA' where id = '1'

可以看到,当 product 表中的 productName 值更新后,mobile_version 与 auth_server_product 对应的 productName 值同步更新。

2.2.2 关于触发器

  • 触发事件:触发器会在某个特定事件发生时被触发。常见的触发事件包括:

    • INSERT:在插入数据时触发。
    • UPDATE:在更新数据时触发。
    • DELETE:在删除数据时触发。
  • 触发时机:触发器可以定义在数据事件发生的 BEFORE)或 AFTER)执行。

    • BEFORE:触发器在数据变更之前执行。
    • AFTER:触发器在数据变更之后执行。
  • 触发器的作用域:触发器通常绑定到某个表上,并且只能在该表的数据操作时触发。它不能跨表执行,也不能直接返回数据。

以上就是MySQL多个表的关联字段实现同步更新的解决方案的详细内容,更多关于MySQL关联字段同步更新的资料请关注脚本之家其它相关文章!

相关文章

  • MySQL服务器线程数的查看方法详解

    MySQL服务器线程数的查看方法详解

    这篇文章主要介绍了MySQL服务器线程数的查看方法,结合实例形式分析了mysql线程数查看的相关命令、配置、参数及相关使用技巧,需要的朋友可以参考下
    2018-03-03
  • MySQL中关于临时表的一些基本使用方法

    MySQL中关于临时表的一些基本使用方法

    这篇文章主要介绍了MySQL中关于临时表的一些基本使用方法,是MySQL入门学习中的基础知识,需要的朋友可以参考下
    2015-05-05
  • MySql5.7.18字符集配置图文详解

    MySql5.7.18字符集配置图文详解

    本文通过图文并茂的形式给大家介绍了mysql5.7.18字符集配置教程,非常不错,具有参考借鉴价值,需要的朋友参考下吧
    2017-06-06
  • linux下mysql 5.1 和 5.7的安装教程

    linux下mysql 5.1 和 5.7的安装教程

    下面小编就为大家分享一篇linux下mysql 5.1 和 5.7的安装教程,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2017-12-12
  • MySql command line client命令操作大全

    MySql command line client命令操作大全

    这篇文章主要介绍了MySql command line client命令操作大全,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧
    2024-01-01
  • 全面解析MySQL Explain如何优化SQL查询性能

    全面解析MySQL Explain如何优化SQL查询性能

    在 MySQL 中,EXPLAIN 关键字可以帮助我们分析查询执行计划,从而优化查询性能,所以本文就来和大家详细讲讲Explain是如何优化SQL查询性能的
    2023-05-05
  • mysql高效查询left join和group by(加索引)

    mysql高效查询left join和group by(加索引)

    这篇文章主要给大家介绍了关于mysql高效查询left join和group by,这个的前提是加了索引,以及如何在MySQL高效的join3个表 的相关资料,需要的朋友可以参考下
    2021-06-06
  • mysql Out of memory (Needed 16777224 bytes)的错误解决

    mysql Out of memory (Needed 16777224 bytes)的错误解决

    至于我改的这几个值是不是正确的解决方法,目前还不知道。先贴出来
    2012-07-07
  • MySQL查询优化之查询慢原因和解决技巧

    MySQL查询优化之查询慢原因和解决技巧

    这篇文章主要介绍了MySQL查询优化之查询慢原因和解决技巧,内容讲解的很详细,有对于这方面不太懂的同学可以研究一下。
    2021-02-02
  • mysql表的内连和外连实战记录

    mysql表的内连和外连实战记录

    在开发中我们的业务需求有时候是复杂的,多张表联合查询的时候是有多种方式的,面对不同的需求,灵活使用不同的表连接方式,这篇文章主要给大家介绍了关于mysql表内连和外连的相关资料,需要的朋友可以参考下
    2024-01-01

最新评论