如何在Golang中使用适配器模式_兼容不同接口的数据操作

// 原有类型
type CSVReader struct {
    file *os.File
    // ...
}
func (c CSVReader) ReadLine() (string, error) { / ... */ }
// 目标接口
type DataReader interface {
Next() map[string]interface{}
Close() error
}
// 适配器：嵌入 + 补方法
type CSVAdapter struct {
*CSVReader
headers []string // 缓存表头
}
func (a *CSVAdapter) Next() map[string]interface{} {
line, err := a.ReadLine()
if err != nil || line == "" {
return nil
}
fields := strings.Split(line, ",")
row := make(map[string]interface{})
for i, v := range fields {
if i < len(a.headers) {
row[a.headers[i]] = strings.TrimSpace(v)
}
}
return row
}
func (a *CSVAdapter) Close() error {
return a.CSVReader.file.Close()
}

type QueryFunc func(ctx context.Context, sql string, args ...interface{}) ([]map[string]interface{}, error)
// 适配 MySQL 驱动（返回 sql.Rows）
func MySQLToQueryFunc(db sql.DB) QueryFunc {
return func(ctx context.Context, sql string, args ...interface{}) ([]map[string]interface{}, error) {
rows, err := db.QueryContext(ctx, sql, args...)
if err != nil {
return nil, err
}
defer rows.Close()
return scanRowsToMap(rows)
}
}
// 适配 Redis 的 HGETALL 结果（返回 []string）
func RedisHashToQueryFunc(client *redis.Client, key string) QueryFunc {
return func(ctx context.Context,  string,  ...interface{}) ([]map[string]interface{}, error) {
vals, err := client.HGetAll(ctx, key).Result()
if err != nil {
return nil, err
}
m := make(map[string]interface{})
for k, v := range vals {
m[k] = v
}
return []map[string]interface{}{m}, nil
}
}