1

我正在开发一个应用程序，一开始将连接到 Access 数据库，并计划在不久的将来切换到 MS SQL 或 SQL Express。两种类型的数据库的数据表结构相同，我试图避免重复代码并试图找到最小化代码的方法。

例如，我编写了以下用于从 Access 数据库中检索数据的函数：

public static DataTable GetActiveCalls()
    {
        string select = "SELECT call_id, call_time, msisdn, status FROM call WHERE status = 0 OR status = 1 ORDER by call_id ASC";
        OleDbCommand cmd = new OleDbCommand(select, conn);
        DataTable dt = new DataTable("Active Calls");
        OleDbDataAdapter DA = new OleDbDataAdapter(cmd);
        try
        {
            conn.Open();
            DA.Fill(dt);
        }
        catch (Exception ex)
        {
            string sDummy = ex.ToString();
        }
        finally
        {
            conn.Close();
        }
        return dt;
    }

以下代码适用于 SQL Express 数据库：

public static DataTable GetActiveCalls()
    {
        string select = "SELECT call_id, call_time, msisdn, status FROM call WHERE status = 0 OR status = 1 ORDER by call_id ASC";
        SqlCommand cmd = new SqlCommand(select, conn);
        DataTable dt = new DataTable("Active Calls");
        SqlDataAdapter DA = new SqlDataAdapter(cmd);
        try
        {
            conn.Open();
            DA.Fill(dt);
        }
        catch (Exception ex)
        {
            string sDummy = ex.ToString();
        }
        finally
        {
            conn.Close();
        }
        return dt;
    }

这两种方法几乎相同。唯一的区别是 SqlCommand/OleDbCommand 和 SqlDataAdapter/OleDbDataAdapter。还有一些方法可以接受参数，例如：

public static void AddMessage(string callID, string content)
    {
        string select =
            "INSERT INTO message(key, direction, content, read, write_time) VALUES (@callId, 0, @content, 0, @insertTime)";
        OleDbCommand cmd = new OleDbCommand(select, conn);
        cmd.Parameters.AddWithValue("callId", callID.ToString());
        cmd.Parameters.AddWithValue("content", content);
        cmd.Parameters.AddWithValue("insertTime", DateTime.Now.ToString());
        try
        {
            conn.Open();
            cmd.ExecuteScalar();
        }
        catch (Exception ex)
        {
            string sDummy = ex.ToString();
        }
        finally
        {
            conn.Close();
        }
    }

在这种情况下，两个数据库的 SQL 查询字符串也相同，但 cmd 的类型（SqlCommand/OleDbCommand）有所不同。

如果有人能就如何避免重复代码和优化给定问题提出任何建议，我将不胜感激。

4

2 回答 2

1

您可以使用数据库独立接口 IDbDataAdapter 和 IDbCommand，然后使用工厂创建具体实例。这是一个例子。

但是，如果您的应用程序不是很简单，我建议使用像NHibernate这样的 ORM 解决方案，因为 Access 和 SQL Server 之间的 SQL 语言几乎没有差异，这会使您的数据访问代码更加复杂。

于 2008-11-01T20:21:23.677 回答
1

您应该查看Enterprise Library数据访问位。为您抽象了底层数据库提供程序的细节。例如：

string sql = @"UPDATE tblContent 
                        SET Title = @Title, Content = @Content, IsPublic = @IsPublic, ItemOrder = @ItemOrder
                        WHERE ContentItemID = @ContentItemID";

Database db = DatabaseFactory.CreateDatabase();
using(DbCommand cmd = db.GetSqlStringCommand(sql))
{
    db.AddInParameter(cmd, "Title", DbType.String, title);
    db.AddInParameter(cmd, "Content", DbType.String, content);
    db.AddInParameter(cmd, "IsPublic", DbType.Boolean, isPublic);
    db.AddInParameter(cmd, "ItemOrder", DbType.Int32, itemOrder);
    db.AddInParameter(cmd, "ContentItemID", DbType.Int32 , contentItemID);

    db.ExecuteNonQuery(cmd);
}

...或者...

string sql = "SELECT MenuText FROM tblMenuItems WHERE MenuItemID = @MenuItemID";

Database db = DatabaseFactory.CreateDatabase();
using(DbCommand cmd = db.GetSqlStringCommand(sql))
{
    db.AddInParameter(cmd, "MenuItemID", DbType.Int32, menuItemID);

    using(IDataReader dr = db.ExecuteReader(cmd))
    {
        while(dr.Read())
        {
            return dr["MenuText"].ToString();
        }
        return null;
    }
}

上面的两个示例都适用于 Access 和 MS SQL，并且只要您坚持与 Jet 和 MS SQL 兼容的 SQL 语句，您应该不会有任何问题。

当您从 Access 切换到 MS SQL 时，只需更改连接字符串，例如，从：

<connectionStrings>
    <add 
         name="ContentManager" 
         connectionString="Provider=Microsoft.Jet.OLEDB.4.0;Data Source=|DataDirectory|Content.mdb;" 
         providerName="System.Data.OleDb"/>
</connectionStrings>

...到...

<connectionStrings>
    <add
        name="ContentManager"
        connectionString="Data Source=your.sql.server;Initial Catalog=content;Persist Security Info=True;User ID=cmuser;Password=password"
        providerName="System.Data.SqlClient" />
</connectionStrings>

为此，您只需在 EL 发行版中引用以下 DLL：

Microsoft.Practices.EnterpriseLibrary.Common.dll
Microsoft.Practices.EnterpriseLibrary.Data.dll

很值得一看。

干杯
凯夫

于 2008-11-02T05:16:28.027 回答