package main

import "fmt"

// 驱动接口
type Driver interface {
	Connect() error
	Query(query string) (string, error)
	Close() error
}

// MySQL驱动实现
type MySQLDriver struct {
	// MySQL连接参数等相关配置
}

func (d *MySQLDriver) Connect() error {
	fmt.Println("Connecting to MySQL...")
	// 实现MySQL连接逻辑
	return nil
}

func (d *MySQLDriver) Query(query string) (string, error) {
	fmt.Println("Querying MySQL:", query)
	// 实现MySQL查询逻辑
	return "MySQL Result", nil
}

func (d *MySQLDriver) Close() error {
	fmt.Println("Closing MySQL connection...")
	// 实现MySQL关闭连接逻辑
	return nil
}

// Redis驱动实现
type RedisDriver struct {
	// Redis连接参数等相关配置
}

func (d *RedisDriver) Connect() error {
	fmt.Println("Connecting to Redis...")
	// 实现Redis连接逻辑
	return nil
}

func (d *RedisDriver) Query(query string) (string, error) {
	fmt.Println("Querying Redis:", query)
	// 实现Redis查询逻辑
	return "Redis Result", nil
}

func (d *RedisDriver) Close() error {
	fmt.Println("Closing Redis connection...")
	// 实现Redis关闭连接逻辑
	return nil
}

func main() {
	// 使用MySQL驱动
	mysqlDriver := &MySQLDriver{}
	useDriver(mysqlDriver)

	fmt.Println("--------")

	// 使用Redis驱动
	redisDriver := &RedisDriver{}
	useDriver(redisDriver)
}

// 使用驱动的通用方法
func useDriver(driver Driver) {
	// 连接
	err := driver.Connect()
	if err != nil {
		fmt.Println("Error connecting:", err)
		return
	}

	// 查询
	result, err := driver.Query("SELECT * FROM table")
	if err != nil {
		fmt.Println("Error querying:", err)
		return
	}
	fmt.Println("Query result:", result)

	// 关闭连接
	err = driver.Close()
	if err != nil {
		fmt.Println("Error closing connection:", err)
	}
}