第 3 章：GO 的接口和抽象拓展篇

第 3 章：GO 的接口和抽象拓展篇 - CRUD 接口实现示例

在前面的第3章中，我们用简单的代码展示了GO的接口和抽象方法，但是代码的示例较少，部分同学可能会觉得理解起来比较抽象。因此在本章中，我们将通过一个具体的例子来演示如何使用 GO 语言的接口来实现抽象化的设计。我们将定义一个 CrudInterface 接口，该接口将提供 CRUD（创建、读取、更新、删除）操作的通用方法。然后，我们将为两种不同的存储系统（MySQL 和 Redis）提供该接口的具体实现。此外，我们还将展示如何根据传入参数中的 URI 协议来动态选择使用哪种存储实现。

3.1 定义 `CrudInterface` 接口

首先，我们定义 CrudInterface 接口，它包含 CRUD 操作的方法：

package main

import (
	"context"
	"errors"
)

// CrudInterface 定义了CRUD操作的方法
type CrudInterface interface {
	Create(ctx context.Context, key string, value interface{}) error
	Read(ctx context.Context, key string) (interface{}, error)
	Update(ctx context.Context, key string, value interface{}) error
	Delete(ctx context.Context, key string) error
}

3.2 实现 MySQL 存储

我们将创建一个 MySQLStore 结构体，它实现了 CrudInterface 接口：

type MySQLStore struct {
	// 此处包含连接数据库所需的字段
}

func (m *MySQLStore) Create(ctx context.Context, key string, value interface{}) error {
	// 实现创建逻辑
	return nil
}

func (m *MySQLStore) Read(ctx context.Context, key string) (interface{}, error) {
	// 实现读取逻辑
	return nil, nil
}

func (m *MySQLStore) Update(ctx context.Context, key string, value interface{}) error {
	// 实现更新逻辑
	return nil
}

func (m *MySQLStore) Delete(ctx context.Context, key string) error {
	// 实现删除逻辑
	return nil
}

3.3 实现 Redis 存储

同样地，我们将创建一个 RedisStore 结构体，它也实现了 CrudInterface 接口：

type RedisStore struct {
	// 此处包含连接Redis所需的字段
}

func (r *RedisStore) Create(ctx context.Context, key string, value interface{}) error {
	// 实现创建逻辑
	return nil
}

func (r *RedisStore) Read(ctx context.Context, key string) (interface{}, error) {
	// 实现读取逻辑
	return nil, nil
}

func (r *RedisStore) Update(ctx context.Context, key string, value interface{}) error {
	// 实现更新逻辑
	return nil
}

func (r *RedisStore) Delete(ctx context.Context, key string) error {
	// 实现删除逻辑
	return nil
}

3.4 创建存储的工厂函数

我们将编写一个工厂函数 NewCrudStore，它根据 URI 协议来创建和返回相应的 CrudInterface 实现：

func NewCrudStore(uri string) (CrudInterface, error) {
	switch uri {
	case "mysql://default":
		return &MySQLStore{}, nil
	case "redis://default":
		return &RedisStore{}, nil
	default:
		return nil, errors.New("unsupported URI scheme")
	}
}

3.5 主程序中的动态选择

在主程序中，我们将使用传入的 URI 参数来动态选择和创建存储实现：

func main() {
	uri := "mysql://default" // 这可以是命令行参数或其他配置来源
	store, err := NewCrudStore(uri)
	if err != nil {
		log.Fatalf("Failed to create CRUD store: %v", err)
	}

	// 现在可以使用store进行CRUD操作
	// 例如: store.Create(ctx, "key", "value")
}