在 golang 框架中，数据库监听和触发器可用于监控数据库更改并自动触发操作。数据库监听允许应用程序订阅数据库事件并采取相应措施，而触发器是数据库中预定义的代码块，在特定事件发生时自动执行。这些工具可用于监控可疑活动、创建欢迎电子邮件、更新关联表和保持缓存数据同步等任务。

Golang 框架中的数据库监听和触发器应用

在 Golang 框架中，数据库监听和触发器是强大的工具，可用于监控数据库更改并自动触发操作。

数据库监听

立即学习“go语言免费学习笔记（深入）”；

数据库监听允许应用程序订阅数据库中的特定事件，例如插入、更新和删除。当触发事件时，应用程序会收到通知并可以根据需要采取相应措施。

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

import (
    "context"
    "fmt"
    "time"

    "cloud.google.com/go/pubsub"
)

func listenDatabaseEvents(ctx context.Context, projectID, subscriptionID string) error {
    // Creates a Pub/Sub client
    client, err := pubsub.NewClient(ctx, projectID)
    if err != nil {
        return fmt.Errorf("pubsub.NewClient: %v", err)
    }

    // Subscribe to a Pub/Sub topic that receives Cloud SQL database events
    // You must have a Cloud SQL instance with Pub/Sub integration enabled
    sub := client.Subscription(subscriptionID)

    // Listen for database events
    // The context is canceled when the program is terminated
    for {
        ctx, cancel := context.WithTimeout(ctx, time.Second*10)
        msg, err := sub.Receive(ctx)
        if err != nil {
            cancel()
            return fmt.Errorf("sub.Receive: %v", err)
        }

        fmt.Printf("Received event for database: %s\n", msg.Attributes["database"])

        // Acknowledge the message to delete it from the subscription
        msg.Ack()
        cancel()
    }
}

触发器

触发器是数据库中预定义的代码块，在特定事件（如插入、更新或删除）发生时自动执行。当触发事件时，触发器会运行其代码并执行相应的操作，例如发送电子邮件、记录事件或更新关联表。

import (
    "context"
    "fmt"

    "cloud.google.com/go/spanner"
)

func createUserTrigger(ctx context.Context, db string) error {
    stmt := spanner.Statement{
        SQL: `
        CREATE TRIGGER UpdateUserLog
        AFTER INSERT, UPDATE ON Users
        FOR EACH ROW
        WHEN (OLD.Active IS NULL OR NEW.Active IS NULL OR OLD.Active <> NEW.Active)
            INSERT INTO UsersLog (UserId, Message, Timestamp)
            VALUES (NEW.UserId, CONCAT(
                CASE
                    WHEN OLD.Active IS NULL
                    THEN 'User created: '
                    WHEN NEW.Active IS NULL
                    THEN 'User deleted: '
                    ELSE 'User updated: '
                END,
                NEW.Name
            ), CURRENT_TIMESTAMP())
        `,
    }

    _, err := db.ReadWriteTransaction(ctx, func(ctx context.Context, txn *spanner.ReadWriteTransaction) error {
        _, err := txn.Update(ctx, stmt)
        return err
    })

    if err != nil {
        return fmt.Errorf("couldn't create trigger: %v", err)
    }

    return nil
}

实战案例

以下是一些数据库监听和触发器的实际应用示例：

• 监控数据库中的可疑活动，并在检测到异常时发送电子邮件。
• 在新用户注册时自动创建欢迎电子邮件。
• 在记录编辑后自动更新关联表中包含的外键。
• 在发生更改时保持缓存数据和实时信息同步。

通过利用 Go 框架中的数据库监听和触发器，您可以增强应用程序，使其能够有效监控数据库更改并自动执行任务，从而提高效率和响应能力。