C#重用我的接口进行数据库访问

// 定义数据库访问接口
public interface IDatabaseAccess
{
    void Connect();
    void ExecuteQuery(string query);
    void Close();
}

// 实现接口的具体数据库访问类
public class SqlServerDatabaseAccess : IDatabaseAccess
{
    private SqlConnection connection;

    public void Connect()
    {
        // 连接到SQL Server数据库
        connection = new SqlConnection("connectionString");
        connection.Open();
    }

    public void ExecuteQuery(string query)
    {
        // 执行SQL查询
        SqlCommand command = new SqlCommand(query, connection);
        command.ExecuteNonQuery();
    }

    public void Close()
    {
        // 关闭数据库连接
        connection.Close();
    }
}

public class MySqlDatabaseAccess : IDatabaseAccess
{
    private MySqlConnection connection;

    public void Connect()
    {
        // 连接到MySQL数据库
        connection = new MySqlConnection("connectionString");
        connection.Open();
    }

    public void ExecuteQuery(string query)
    {
        // 执行SQL查询
        MySqlCommand command = new MySqlCommand(query, connection);
        command.ExecuteNonQuery();
    }

    public void Close()
    {
        // 关闭数据库连接
        connection.Close();
    }
}

// 使用数据库访问接口进行数据库操作
public class DatabaseManager
{
    private IDatabaseAccess databaseAccess;

    public DatabaseManager(IDatabaseAccess databaseAccess)
    {
        this.databaseAccess = databaseAccess;
    }

    public void PerformDatabaseOperation()
    {
        databaseAccess.Connect();
        databaseAccess.ExecuteQuery("SELECT * FROM table");
        databaseAccess.Close();
    }
}

// 在应用程序中使用数据库访问
public class Program
{
    public static void Main()
    {
        IDatabaseAccess sqlServerDatabaseAccess = new SqlServerDatabaseAccess();
        DatabaseManager databaseManager1 = new DatabaseManager(sqlServerDatabaseAccess);
        databaseManager1.PerformDatabaseOperation();

        IDatabaseAccess mySqlDatabaseAccess = new MySqlDatabaseAccess();
        DatabaseManager databaseManager2 = new DatabaseManager(mySqlDatabaseAccess);
        databaseManager2.PerformDatabaseOperation();
    }
}