《Go 简易速速上手小册》第6章：错误处理和测试（2024 最新版）（上）

type error interface {
    Error() string
}

package main
import (
    "fmt"
    "io/ioutil"
    "os"
)
// readFileEnhanced 从指定的文件中读取数据，并提供详细的错误处理
func readFileEnhanced(filename string) (string, error) {
    // 尝试打开文件
    file, err := os.Open(filename)
    if err != nil {
        // 文件打开失败的错误处理
        if os.IsNotExist(err) {
            return "", fmt.Errorf("文件 '%s' 不存在", filename)
        }
        if os.IsPermission(err) {
            return "", fmt.Errorf("没有权限读取文件 '%s'", filename)
        }
        // 其他类型的错误
        return "", fmt.Errorf("打开文件 '%s' 时发生未知错误: %v", filename, err)
    }
    defer file.Close()
    // 读取文件内容
    data, err := ioutil.ReadAll(file)
    if err != nil {
        return "", fmt.Errorf("读取文件 '%s' 内容时发生错误: %v", filename, err)
    }
    return string(data), nil
}
func main() {
    // 测试文件读取
    filename := "example.txt"
    content, err := readFileEnhanced(filename)
    if err != nil {
        // 错误处理：打印出错信息
        fmt.Println("错误:", err)
        return
    }
    // 文件读取成功，打印文件内容
    fmt.Println("文件内容:", content)
}

package main
import (
    "fmt"
    "io/ioutil"
    "net/http"
)

// fetchURL 发送 HTTP 请求并处理响应
func fetchURL(url string) (string, error) {
    resp, err := http.Get(url)
    if err != nil {
        // 网络请求错误处理
        return "", fmt.Errorf("请求 URL '%s' 时发生网络错误: %v", url, err)
    }
    defer resp.Body.Close()
    // 检查 HTTP 响应状态码
    if resp.StatusCode != http.StatusOK {
        return "", fmt.Errorf("请求 URL '%s' 返回状态码: %d", url, resp.StatusCode)
    }
    // 读取响应体内容
    body, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        return "", fmt.Errorf("读取 URL '%s' 响应体时发生错误: %v", url, err)
    }
    return string(body), nil
}

func main() {
    url := "http://example.com"
    fmt.Printf("正在请求: %s\n", url)
    content, err := fetchURL(url)
    if err != nil {
        // 错误处理
        fmt.Println("错误:", err)
        return
    }
    // 请求成功，打印返回的内容
    fmt.Println("响应内容:", content)
}

package main
import (
    "database/sql"
    "fmt"
    _ "github.com/mattn/go-sqlite3" // 示例使用 SQLite
    "log"
)

// executeQuery 执行数据库查询并返回结果
func executeQuery(db *sql.DB, query string) ([]map[string]interface{}, error) {
    rows, err := db.Query(query)
    if err != nil {
        return nil, fmt.Errorf("执行查询时发生错误: %v", err)
    }
    defer rows.Close()
    // 获取列名
    columns, err := rows.Columns()
    if err != nil {
        return nil, fmt.Errorf("获取列名时发生错误: %v", err)
    }
    // 准备扫描结果
    results := make([]map[string]interface{}, 0)
    values := make([]interface{}, len(columns))
    valuePtrs := make([]interface{}, len(columns))
    for rows.Next() {
        for i := range columns {
            valuePtrs[i] = &values[i]
        }
        rows.Scan(valuePtrs...)
        result := make(map[string]interface{})
        for i, col := range columns {
            var val interface{}
            val = values[i]
            result[col] = val
        }
        results = append(results, result)
    }
    return results, nil
}

func main() {
    db, err := sql.Open("sqlite3", "./example.db")
    if err != nil {
        log.Fatalf("打开数据库时发生错误: %v", err)
    }
    defer db.Close()
    query := "SELECT * FROM example_table"
    results, err := executeQuery(db, query)
    if err != nil {
        log.Fatalf("执行查询时发生错误: %v", err)
    }
    fmt.Println("查询结果:")
    for _, result := range results {
        fmt.Println(result)
    }
}

package main
import (
    "fmt"
)
// Logger 接口定义了日志记录的方法
type Logger interface {
    Log(message string)
}
// Notifier 接口定义了发送通知的方法
type Notifier interface {
    Notify(message string)
}
// OrderProcessor 负责处理订单
type OrderProcessor struct {
    logger   Logger
    notifier Notifier
}
// NewOrderProcessor 创建一个新的OrderProcessor实例
func NewOrderProcessor(l Logger, n Notifier) *OrderProcessor {
    return &OrderProcessor{logger: l, notifier: n}
}
// ProcessOrder 处理订单，记录日志并发送通知
func (op *OrderProcessor) ProcessOrder(orderID string) {
    // 记录订单处理日志
    op.logger.Log("Order processed: " + orderID)
    // 发送订单处理通知
    op.notifier.Notify("Your order " + orderID + " has been processed")
}

// ConsoleLogger 实现 Logger 接口，将日志输出到控制台
type ConsoleLogger struct{}
func (cl ConsoleLogger) Log(message string) {
    fmt.Println("Log:", message)
}
// EmailNotifier 实现 Notifier 接口，模拟发送电子邮件通知
type EmailNotifier struct{}
func (en EmailNotifier) Notify(message string) {
    fmt.Println("Sending email notification:", message)
}

func main() {
    logger := ConsoleLogger{}
    notifier := EmailNotifier{}
    processor := NewOrderProcessor(logger, notifier)
    processor.ProcessOrder("1234")
}