1 使用触发器同步更新数据

前面讲数据同步有3个方式，应用程序同步，触发器同步和批处理同步。

批处理时是在更新主要数据相隔一段时间后，考虑引入批量更新或异步同步的方式来优化性能，同时仍然使用事务管理保证数据一致性。

对于冗余数据可采用应用程序同步或触发器同步，
应用（程序）触发器: 每当一个特定的应用事件发生时触发，
数据库触发器: 每当在一个用户或数据库中一个数据事件（如DML）发生时或系统事件（如登录或关闭系统）发生时触发。

触发器几个组件的具体含义：

tigger_name(触发器名）：唯一地标识一个触发器，在同一个模式中触发器的名字必须唯一。

timing(触发的时机）；指定触发器在什么时候触发（与触发事件相关），其值为BEFORE、AFTER和INSTEAD OF。

event(事件）：标识引起触发器触发的DML操作，其值为INSERT、UPDATE[OF column]和DELETE。

object_name(对象名）：指定与触发器相关的表或视图。

在Golang程序中实现冗余数据的同步更新并保证操作的原子性，可以使用事务管理和触发器来确保供应商信息的更新会自动同步到商品表中。以下是一个方案，结合gorm框架和数据库触发器来处理冗余数据更新：

2. 使用数据库触发器同步冗余数据

可以在数据库中创建触发器，当suppliers表中的supplier_name或supplier_address发生变化时，自动更新products表中的冗余数据。

BEFORE: 在触发一个表上的DML事件之前执行触发器的体

AFTER: 在触发一个表上的DML事件之后执行触发器的体

INSTEAD OF: 代替触发的语句来执行触发器体、它被用于用其它方法不能修改的视图

创建触发器

CREATE TRIGGER update_product_supplier_info
AFTER UPDATE ON suppliers
FOR EACH ROW
BEGIN
    UPDATE products
    SET supplier_name = NEW.supplier_name,
        supplier_address = NEW.supplier_address
    WHERE supplier_id = NEW.supplier_id;
END;

这个触发器会在suppliers表中某个供应商的信息被更新后，自动更新products表中相关的冗余列。

2. 在程序使用事务保证操作的原子性

在Golang应用程序中，可以通过使用gorm框架的事务功能来确保操作的原子性。事务能够确保当供应商信息和商品信息在同一业务逻辑中更新时，要么全部操作成功，要么全部回滚。

示例代码

	package main

	import (
	    "fmt"
	    "gorm.io/driver/mysql"
	    "gorm.io/gorm"
	)

	type Supplier struct {
	    SupplierID      int
	    SupplierName    string
	    ContactInfo     string
	    SupplierAddress string
	}

	type Product struct {
	    ProductID       int
	    ProductName     string
	    ProductModel    string
	    ProductPrice    float64
	    SupplierID      int
	    SupplierName    string
	    SupplierAddress string
	}

	func main() {
	    dsn := "user:password@tcp(127.0.0.1:3306)/dbname?charset=utf8mb4&parseTime=True&loc=Local"
	    db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})
	    if err != nil {
	        fmt.Println("Failed to connect to database:", err)
	        return
	    }

	    // 开始事务
	    tx := db.Begin()

	    // 更新供应商信息
	    err = tx.Model(&Supplier{}).Where("supplier_id = ?", 1).Updates(Supplier{
	        SupplierName:    "New Supplier Name",
	        SupplierAddress: "New Supplier Address",
	    }).Error
	    if err != nil {
	        tx.Rollback() // 如果更新失败，回滚事务
	        fmt.Println("Failed to update supplier:", err)
	        return
	    }

	    // 更新商品表中的冗余数据（触发器会自动更新，所以这里可以省略手动更新）
	    // 提交事务
	    err = tx.Commit().Error
	    if err != nil {
	        fmt.Println("Failed to commit transaction:", err)
	    } else {
	        fmt.Println("Transaction committed successfully")
	    }
	}

4. 原子性保证

通过使用事务和触发器，能够确保当供应商信息发生变化时，商品表中的冗余信息也会同步更新。事务提供了原子性，确保整个操作要么完全成功，要么完全失败，从而避免数据不一致的情况。

这种方案既利用了数据库的自动化机制，也在应用层提供了必要的保障，确保数据的一致性和系统的健壮性。

语句触发器是每一个DML语句触发一次。行触发器是所影响的每一行触发一次。
如果在相同的对象上定义了多个触发器，那么它们触发的次序是随机的。
而且在同一个模式中触发器的名字必须唯一。