.NET 对ORA-01000问题的正确处理

第一次使用.NET配合ORACLE进行任务操作,使用的数据驱动为:Oracle Data Provider for .NET, Managed Driver(Release 11.2.0.3.50 Beta)

问题的出现和其他人出现的场景一样,在进行一次循环7万次的流程中使用OracleCommand获取数据时发生。

查询了相关材料，

1.对ORACLE本身进行相应的CURSOR数量设置

SQL> alter system set open_cursors=3000 scope=both;

2.在程序内每次调用完相应的COMMAND后将其关闭（连同关闭连接）。但问题同样发生。

具体代码如下：

[csharp]
Parallel.ForEach(dtMainXM.AsEnumerable(), (pDataRowXMK) =>
{
    DataTable dtDetail = new DataTable();<P>    string ID=pDataRowXMK["ID"].ToString();
    using (var pSConn = GetSourceConnection())
    {
        using (OracleCommand cmdSubXM = new OracleCommand())
        {
            cmdSubXM.Connection = pSConn;
            cmdSubXM.CommandText = "select * from tableXX where ID='"+ ID +"'";
            using (var iReader = cmdSubXM.ExecuteReader(CommandBehavior.CloseConnection))
            {
                dtDetail.Load(iReader);
            }
        }
    }
｝</P>

Parallel.ForEach(dtMainXM.AsEnumerable(), (pDataRowXMK) =>
{
    DataTable dtDetail = new DataTable();    string ID=pDataRowXMK["ID"].ToString();
    using (var pSConn = GetSourceConnection())
    {
        using (OracleCommand cmdSubXM = new OracleCommand())
        {
            cmdSubXM.Connection = pSConn;
            cmdSubXM.CommandText = "select * from tableXX where ID='"+ ID +"'";
            using (var iReader = cmdSubXM.ExecuteReader(CommandBehavior.CloseConnection))
            {
                dtDetail.Load(iReader);
            }
        }
    }
｝上述代码中每个并行处理过程中,都对相应的资源进行了释放，但问题还是出现（数据库也设置成3000的CURSOR数量）。

最终通过尝试，分析问题，对代码进行修改，主要问题还是出在cmdSubXM.CommandText 为字符串拼接的原因。将代码修改为参数模式后，无上述问题出现。

[csharp]
Parallel.ForEach(dtMainXM.AsEnumerable(), (pDataRowXMK) =>
{
    DataTable dtDetail = new DataTable();
    string ID=pDataRowXMK["ID"].ToString();
    using (var pSConn = GetSourceConnection())
    {
        using (OracleCommand cmdSubXM = new OracleCommand())
        {
            cmdSubXM.Connection = pSConn;
            cmdSubXM.CommandText = "select * from tableXX where ID=:ID";
    //修改为参数方式
            cmdSubXM.Parameters.Add("ID", ID);
            using (var iReader = cmdSubXM.ExecuteReader(CommandBehavior.CloseConnection))
            {
                dtDetail.Load(iReader);
            }
        }
    }
｝

Parallel.ForEach(dtMainXM.AsEnumerable(), (pDataRowXMK) =>
{
    DataTable dtDetail = new DataTable();
    string ID=pDataRowXMK["ID"].ToString();
    using (var pSConn = GetSourceConnection())
    {
        using (OracleCommand cmdSubXM = new OracleCommand())
        {
            cmdSubXM.Connection = pSConn;
            cmdSubXM.CommandText = "select * from tableXX where ID=:ID";
    //修改为参数方式
            cmdSubXM.Parameters.Add("ID", ID);
            using (var iReader = cmdSubXM.ExecuteReader(CommandBehavior.CloseConnection))
            {
                dtDetail.Load(iReader);
            }
        }
    }
｝

通过前后SQL语句的处理方式,个人理解还是ORACLE的SQL解析计划引起的问题. 使用SQL参数,将最大程度的利用计划缓存.而前一种方式,没有重用性.

补充：软件开发 , C# ,