常规查询方法

Question

我发现我的C#应用程序用大量的样板文件进行大量查询，这些样板文件占用了我的代码空间。我也想避免重复，但我不确定如何编写一个方法来实现这一点。

我正在使用ODP访问Oracle数据库。我不能使用Linq，因为我们的数据仓库人员拒绝指定主键，而对Linq的ODP支持似乎是，嗯。。。他们宁愿你使用他们的平台。

我真的不能返回List，因为每个查询都返回不同类型的不同数字。

string gufcode = String.Empty;
double cost = 0.0;
OracleCommand GUFCommand2 = thisConnection.CreateCommand();
String GUFQuery2 = "SELECT GUF_ID, COST_RATE FROM SIMPLE_TABLE";
GUFCommand2.CommandText = GUFQuery2;
OracleDataReader GUFReader2 = GUFCommand2.ExecuteReader();
while (GUFReader2.Read())
{
    if (GUFReader2[0/**GUF_CODE**/] != DBNull.Value)
    {
        gufcode = Convert.ToString(BUFReader2[0]);
    }
    if (GUFReader2[1/**COST_RATE**/] != DBNull.Value)
    {
        cost = Convert.ToDouble(GUFReader2[1]);
    }
    effortRatioDictionary.Add(bufcode, percentageOfEffort);
}
GUFReader2.Close();

但像这样的术语和查询确实多得多。我想说是15个左右的查询，有些查询返回的字段多达15个左右。

到处复制/粘贴这个样板会导致很多火灾：例如，如果我不更新复制粘贴中的所有内容，我会关闭错误的读取器（或者更糟的是）向数据库发送不同的查询字符串。

我希望能够做这样的事情：

string gufQuery = "SELECT GUF_ID, COST_RATE FROM SIMPLE_TABLE";
List<something> gufResponse = miracleProcedure(gufQuery, thisConnection);

所以大部分样板都消失了。

我在找简单的东西。

Answer 1

我认为不能抽象函数的主要原因是每次返回的数据都会不同。

这意味着每次读取的次数也会有所不同。

你可以只返回GUFReader2，但你将失去在你想要的函数内关闭它的能力。

我会说返回一个对象数组（或列表）。

在过程中，只需通读每一行，并在关闭连接时返回列表。

调用函数总是知道期望的数据将是什么以及按哪个顺序出现。它也必须强制转换对象数据，但无论如何，您都是在这个过程中这样做的。

Answer 2

一些提示：

从IDisposable派生可以使用using语句实现更干净的代码。

IMO你的魔术方法应该看起来更像这样：

List<T> list = doMagic("SIMPLE_TABLE", columns);

列可以是像下面这样的小结构数组：

struct Column
{
    string Name;
    Type   DataType;
}

如果经常使用相同的表/列，则可以使用枚举。

或

您可以从XNA中的VertexDeclaration、VertexElement、VertexElementFormat和VertexElementUsage类型中获得一些灵感：http://msdn.microsoft.com/en-us/library/bb197344.

事实证明，当以随机顺序处理不同数量的"输入"时，这非常有用。

在我的例子中，我已经能够用这样的东西为OpenGL构建一个易于使用的、类似XNA的框架。

关于您名单的退货类型，请参阅我的第二条建议。

Answer 3

Linq是正确的答案。我相信大卫·M，但我不能把它标记为正确的答案，因为他只留下了一条评论。

我能够使用ArrayLists:做一个半广义的方法

    public static ArrayList GeneralQuery(string thisQuery, OracleConnection myConnection)
    {
        ArrayList outerAL = new ArrayList();
        OracleCommand GeneralCommand = myConnection.CreateCommand();
        GeneralCommand.CommandText = thisQuery;
        OracleDataReader GeneralReader = GeneralCommand.ExecuteReader();
        while (GeneralReader.Read())
        {
            for (int i = 0; i < GeneralReader.FieldCount; i++)
            {
                ArrayList innerAL = new ArrayList();
                if (GeneralReader[i] != DBNull.Value)
                {
                    innerAL.Add(GeneralReader[i]);
                }
                else
                {
                    innerAL.Add(0);
                }
                outerAL.Add(innerAL);
            }
        }
        GeneralReader.Close();
        return outerAL;
    }

调用此方法的代码如下所示：

                thisConnection.Open();
                List<ProjectWrapper> liProjectCOs = new List<ProjectWrapper>();
                String ProjectQuery = "SELECT SF_CLIENT_PROJECT.ID, SF_CLIENT_PROJECT.NAMEX, SF_CHANGE_ORDER.ID, SF_CHANGE_ORDER.END_DATE, ";
                ProjectQuery += "SF_CLIENT_PROJECT.CONTRACTED_START_DATE, SF_CHANGE_ORDER.STATUS, SF_CHANGE_ORDER.TYPE, SF_CLIENT_PROJECT.ESTIMATED_END_DATE, SF_CLIENT_PROJECT.CONTRACTED_END_DATE ";
                ProjectQuery += "FROM SF_CLIENT_PROJECT, SF_CHANGE_ORDER ";
                ProjectQuery += "WHERE SF_CHANGE_ORDER.TYPE = 'New' ";
                ProjectQuery += "AND SF_CLIENT_PROJECT.ID = SF_CHANGE_ORDER.PROJECT";
                ArrayList alProjects = GeneralQuery(ProjectQuery, thisConnection);
                foreach( ArrayList proj in alProjects ) {
                    ProjectWrapper pw = new ProjectWrapper();
                    pw.projectId = Convert.ToString( proj[0] );
                    pw.projectId = Convert.ToString(proj[0]);
                    pw.projectName = Convert.ToString(proj[1]);
                    pw.changeOrderId = Convert.ToString(proj[2]);
                    pw.newEndDate = Convert.ToDateTime(proj[3]);
                    pw.startDate = Convert.ToDateTime(proj[4]);
                    pw.status = Convert.ToString(proj[5]);
                    pw.type = Convert.ToString(proj[6]);
                    if ( Convert.ToString(proj[7]) != "0" ) // 0 returned by generalquery if null
                        pw.oldEndDate = Convert.ToDateTime(proj[7]);
                    else
                        pw.oldEndDate = Convert.ToDateTime(proj[8]);
                    liProjectCOs.Add(pw);

这里有很多明显的缺点（尽管它比我之前试图做的要好得多）。这比Linq糟糕得多，我和我们的数据仓库人员重新协商了一下。那里有一个新人，他帮了我很多忙。

Linq将上面的代码行减少了2倍。这与我之前的非封装方式相比是4倍。