71

我有这个遗留代码：

 private void conecta()
 {  
     if (conexao.State == ConnectionState.Closed)
         conexao.Open();
 }

 public List<string[]> get_dados_historico_verificacao_email_WEB(string email)
 {
     List<string[]> historicos = new List<string[]>();
     conecta();

     sql = 
         @"SELECT * 
         FROM historico_verificacao_email 
         WHERE nm_email = '" + email + @"' 
         ORDER BY dt_verificacao_email DESC, hr_verificacao_email DESC";

     com = new SqlCommand(sql, conexao);
     SqlDataReader dr = com.ExecuteReader();

     if (dr.HasRows)
     {
         while (dr.Read())
         {
             string[] dados_historico = new string[6];
             dados_historico[0] = dr["nm_email"].ToString();
             dados_historico[1] = dr["dt_verificacao_email"].ToString();
             dados_historico[1] = dados_historico[1].Substring(0, 10);
             dados_historico[2] = dr["hr_verificacao_email"].ToString();
             dados_historico[3] = dr["ds_tipo_verificacao"].ToString();

             sql = 
                 @"SELECT COUNT(e.cd_historico_verificacao_email) QT 
                 FROM emails_lidos e 
                 WHERE e.cd_historico_verificacao_email = 
                     '" + dr["cd_historico_verificacao_email"].ToString() + "'";

             tipo_sql = "seleção";
             conecta();
             com2 = new SqlCommand(sql, conexao);

             SqlDataReader dr3 = com2.ExecuteReader();
             while (dr3.Read())
             {
                 //quantidade de emails lidos naquela verificação
                 dados_historico[4] = dr3["QT"].ToString(); 
             }
             dr3.Close();
             conexao.Close();

             //login
             dados_historico[5] = dr["cd_login_usuario"].ToString();
             historicos.Add(dados_historico);
         }
         dr.Close();
     }
     else
     { 
         dr.Close();
     }

     conexao.Close();
     return historicos;
 }


我创建了两个单独的命令来纠正问题，但它仍然继续：“已经有一个打开的 DataReader 与此命令关联，必须先关闭”。

附加信息：相同的代码正在另一个应用程序中工作。

4

7 回答 7

211

只需在连接字符串中添加以下内容：

MultipleActiveResultSets=True;
于 2014-01-15T07:38:36.373 回答
21
  1. 最佳解决方案可能是尝试将您的解决方案转换为您不需要同时打开两个阅读器的形式。理想情况下，它可以是单个查询。我现在没有时间这样做。

  2. 如果您的问题非常特殊以至于您确实需要同时打开更多阅读器，并且您的要求允许不早于 SQL Server 2005 DB 后端，那么神奇的词就是MARS (Multiple Active Result Sets)。http://msdn.microsoft.com/en-us/library/ms345109%28v=SQL.90%29.aspx。Bob Vale 的链接主题的解决方案显示了如何启用它：MultipleActiveResultSets=true在您的连接字符串中指定。我只是说这是一个有趣的可能性，但你应该改变你的解决方案。

    • 为了避免上述 SQL 注入的可能性，请将参数设置为 SQLCommand 本身，而不是将它们嵌入到查询字符串中。查询字符串应该只包含对传递给 SqlCommand 的参数的引用。
于 2013-08-27T21:08:45.107 回答
13

当您two different commands在同一连接上时，您可能会遇到这样的问题 - 特别是在loop. 那就是为从第一个命令返回的每条记录调用第二个命令。如果第一个命令返回大约 10,000 条记录，则此问题的可能性更大。

我曾经通过将其作为单个命令来避免这种情况。第一个命令返回所有必需的数据并将其加载到 DataTable 中。

注意：MARS可能是一个解决方案 - 但它可能有风险，许多人不喜欢它。

参考

  1. 什么是“当前命令发生严重错误。结果（如果有）应丢弃。” SQL Azure 错误是什么意思？
  2. Linq-To-Sql 和 MARS 问题 - 当前命令出现严重错误。结果，如果有的话，应该被丢弃
  3. DataTable 上的复杂 GROUP BY
于 2013-12-12T04:48:11.010 回答
8

我建议为第二个命令创建一个额外的连接，可以解决它。尝试将两个查询合并到一个查询中。为计数创建一个子查询。

while (dr3.Read())
{
    dados_historico[4] = dr3["QT"].ToString(); //quantidade de emails lidos naquela verificação
}

为什么一次又一次地覆盖相同的值？

if (dr3.Read())
{
    dados_historico[4] = dr3["QT"].ToString(); //quantidade de emails lidos naquela verificação
}

就够了。

于 2013-08-27T20:52:26.943 回答
8

我敢打赌问题正在这一行中显示

SqlDataReader dr3 = com2.ExecuteReader();

我建议您执行第一个阅读器并执行 adr.Close();和 iterate historicos，并使用另一个循环执行com2.ExecuteReader().

public List<string[]> get_dados_historico_verificacao_email_WEB(string email)
    {

        List<string[]> historicos = new List<string[]>();
        conecta();
        sql = "SELECT * FROM historico_verificacao_email WHERE nm_email = '" + email + "' ORDER BY  dt_verificacao_email DESC, hr_verificacao_email DESC"; 
        com = new SqlCommand(sql, conexao);
        SqlDataReader dr = com.ExecuteReader();

        if (dr.HasRows)
        {
            while (dr.Read())
            {
                string[] dados_historico = new string[6];
                dados_historico[0] = dr["nm_email"].ToString();
                dados_historico[1] = dr["dt_verificacao_email"].ToString();
                dados_historico[1] = dados_historico[1].Substring(0, 10);
                //System.Windows.Forms.MessageBox.Show(dados_historico[1]);
                dados_historico[2] = dr["hr_verificacao_email"].ToString();
                dados_historico[3] = dr["ds_tipo_verificacao"].ToString();
                dados_historico[5] = dr["cd_login_usuario"].ToString();
                historicos.Add(dados_historico);
            }

            dr.Close();

            sql = "SELECT COUNT(e.cd_historico_verificacao_email) QT FROM emails_lidos e WHERE e.cd_historico_verificacao_email = '" + dr["cd_historico_verificacao_email"].ToString() + "'";
            tipo_sql = "seleção";
            com2 = new SqlCommand(sql, conexao);

            for(int i = 0 ; i < historicos.Count() ; i++)
            {
                SqlDataReader dr3 = com2.ExecuteReader();
                while (dr3.Read())
                {
                    historicos[i][4] = dr3["QT"].ToString(); //quantidade de emails lidos naquela verificação
                }
                dr3.Close();
            }

        }

        return historicos;
于 2013-08-27T20:53:02.807 回答
3

尝试组合查询，它将比每行执行一个附加查询快得多。我不喜欢你正在使用的字符串 []，我会创建一个类来保存信息。

    public List<string[]> get_dados_historico_verificacao_email_WEB(string email)
    {
        List<string[]> historicos = new List<string[]>();

        using (SqlConnection conexao = new SqlConnection("ConnectionString"))
        {
            string sql =
                @"SELECT    *, 
                            (   SELECT      COUNT(e.cd_historico_verificacao_email) 
                                FROM        emails_lidos e 
                                WHERE       e.cd_historico_verificacao_email = a.nm_email ) QT
                  FROM      historico_verificacao_email a
                  WHERE     nm_email = @email
                  ORDER BY  dt_verificacao_email DESC, 
                            hr_verificacao_email DESC";

            using (SqlCommand com = new SqlCommand(sql, conexao))
            {
                com.Parameters.Add("email", SqlDbType.VarChar).Value = email;

                SqlDataReader dr = com.ExecuteReader();

                while (dr.Read())
                {
                    string[] dados_historico = new string[6];
                    dados_historico[0] = dr["nm_email"].ToString();
                    dados_historico[1] = dr["dt_verificacao_email"].ToString();
                    dados_historico[1] = dados_historico[1].Substring(0, 10);
                    //System.Windows.Forms.MessageBox.Show(dados_historico[1]);
                    dados_historico[2] = dr["hr_verificacao_email"].ToString();
                    dados_historico[3] = dr["ds_tipo_verificacao"].ToString();
                    dados_historico[4] = dr["QT"].ToString();
                    dados_historico[5] = dr["cd_login_usuario"].ToString();

                    historicos.Add(dados_historico);
                }
            }
        }
        return historicos;
    }

未经测试，但也许有一些想法。

于 2013-08-28T07:01:27.637 回答
3

添加MultipleActiveResultSets=true到连接字符串的提供者部分。请参见下面的示例：

<add name="DbContext" connectionString="Data Source=(LocalDb)\v11.0;Initial Catalog=dbName;Persist Security Info=True;User ID=userName;Password=password;MultipleActiveResultSets=True" providerName="System.Data.SqlClient" />
于 2017-09-12T10:30:04.483 回答