连接未关闭。连接的当前状态已打开。 C＃错误

Question

从gridview保存2个或更多值时出现此错误：

连接未关闭。连接的当前状态是开放的

但是该过程经过并保存并更新数据。我怎样才能消除这个错误？

这里是我的代码：

for(int i = 0; i < gvModal.Rows.Count; i++) 
{ 
    string dateA = DateTime.Now.ToString("yyyy-MM-dd"); 

    Utility u = new Utility(); 
    string conn = u.connect(); 

    Label type = (Label)gvModal.Rows[i].Cells[1].FindControl("lbltype"); 
    Label model = (Label)gvModal.Rows[i].Cells[2].FindControl("lblModel"); 
    Label quantity = (Label)gvModal.Rows[i].Cells[3].FindControl("lblQuan"); 
    Label unit = (Label)gvModal.Rows[i].Cells[4].FindControl("lblUnit"); 
    int bal = Convert.ToInt32(gvModal.Rows[i].Cells[4].Text); 
    int forIssue = 0; 
    int forPO = 0; 

    if (bal != 0) 
    { 
     forIssue = 1; 
     forPO = 0; 
    } 
    else 
    { 
     forIssue = 0; 
     forPO = 1; 
    } 

    SqlConnection connUser = new SqlConnection(conn); 
    SqlCommand read = connUser.CreateCommand(); 

    string query = "INSERT INTO Mosef_Alert values (@Mosef_No, @Branch, @BU, @Dept, @Section, @Requisitioner, @Accepted, @Date_Accepted, @Reason, @MOSEF_Date, @type, @model, @quantity, @unit)"; 

    connUser.Open(); 
    read.CommandText = query; 

    read.Parameters.Add(new SqlParameter("@Mosef_No", transIDs)); 
    read.Parameters.Add(new SqlParameter("@Branch", branch)); 
    read.Parameters.Add(new SqlParameter("@BU", bu)); 
    read.Parameters.Add(new SqlParameter("@Dept", dept)); 
    read.Parameters.Add(new SqlParameter("@Section", sec)); 
    read.Parameters.Add(new SqlParameter("@Requisitioner", requisitioner)); 
    read.Parameters.Add(new SqlParameter("@Accepted", accept)); 
    read.Parameters.Add(new SqlParameter("@Date_Accepted", dateA)); 
    read.Parameters.Add(new SqlParameter("@Reason", reason)); 
    read.Parameters.Add(new SqlParameter("@MOSEF_Date", lblDateFiled.Text)); 
    read.Parameters.Add(new SqlParameter("@type", type.Text)); 
    read.Parameters.Add(new SqlParameter("@model", model.Text)); 
    read.Parameters.Add(new SqlParameter("@quantity", quantity.Text)); 
    read.Parameters.Add(new SqlParameter("@unit", unit.Text)); 
    read.Parameters.Add(new SqlParameter("@For_PO", forPO)); 
    read.Parameters.Add(new SqlParameter("@For_Issuance", forIssue)); 

    read.ExecuteNonQuery(); 

    read.Parameters.Clear(); 
} 

ExecuteUpdate(accept); 
UpdateStatus(); 

System.Text.StringBuilder sb = new System.Text.StringBuilder(); 
sb.Append(@"<script type ='text/javascript'>"); 
sb.Append("alert('Records Updated');"); 
sb.Append("$('#editModal').modal('hide');"); 
sb.Append(@"</script>"); 
ScriptManager.RegisterClientScriptBlock(this, this.GetType(), "EditHideModalScript", sb.ToString(), false); 
} 

public void UpdateStatus() 
{ 
     Utility u = new Utility(); 
     string conn = u.connect(); 
     SqlConnection connUser = new SqlConnection(conn); 
     SqlCommand read = connUser.CreateCommand(); 

     for(int i = 0; i < gvModal.Rows.Count; i++) 
     { 
      Label ItemID = (Label)gvModal.Rows[i].Cells[1].FindControl("lblID"); 
      Label stat = (Label)gvModal.Rows[i].Cells[8].FindControl("ItemStatus"); 
      int balance = Convert.ToInt32(gvModal.Rows[i].Cells[4].Text); 
      string status; 

      if(balance != 0) 
      { 
       status = "For Issuance"; 
      } 
      else 
      { 
       status = "For PO"; 
      } 

      string upd = "UPDATE ItemTransaction SET ItemStatus = '" + status +"' WHERE ID = '"+ ItemID.Text +"'"; 

      connUser.Open(); 
      read.CommandText = upd; 

      read.Parameters.Clear(); 
      read.ExecuteNonQuery(); 
     } 
    } 
    public void ExecuteUpdate(int stat) 
    { 
     string upStat = null; 
     if (stat == 1) 
     { 
      upStat = "Accepted"; 
     } 
     else 
     { 
      upStat = "Denied"; 
     } 
     string id = transID.Text; 
     Utility u = new Utility(); 
     string conn = u.connect(); 
     SqlConnection connUser = new SqlConnection(conn); 
     string up = "UPDATE MosefTransaction SET TransStatus = '"+ upStat +"' WHERE TransactionID = '"+ id +"'"; 
     connUser.Open(); 
     SqlCommand cm = new SqlCommand(up, connUser); 
     //cm.Parameters.AddWithValue("@ID", id); 
     //cm.Parameters.AddWithValue("@TransStatus", upStat); 
     cm.Parameters.Clear(); 
     cm.ExecuteNonQuery(); 

     connUser.Close(); 
    } 

Answer 1

你必须注意到的第一件事情，你的纯文本查询打开一个宽门SqlInjection。所以使用参数化查询。现在让我来看看你的代码， 问题出在UpdateStatus方法，在这种方法中，你在迭代过程中打开了连接，并且不关闭它，所以当你在下一次迭代中再次打开连接时，它会抛出错误。您可以通过多种方式避免这种情况：

1. 使用connUser.Close()
2. 您可以使用ConnectionState枚举检查打开一个新的连接前的连接状态关闭在每次迭代的连接。并仅在状态未打开时才打开它。

这可以通过使用下面的代码来完成：

if (connUser.State != ConnectionState.Open) 
    connUser.Open(); 

3.打开循环外部连接，并使用相同通过时的循环。执行查询后清除每次迭代中的参数。

例如考虑代码：

using (SqlConnection connUser = new SqlConnection(conn)) 
{ 
    string upd = "UPDATE ItemTransaction SET ItemStatus = @status WHERE ID = @id"; 
    connUser.Open(); 
    SqlCommand commandSQL = connUser.CreateCommand(); 
    for (int i = 0; i < gvModal.Rows.Count; i++) 
    { 
     // Get values here using your code 
     commandSQL.Parameters.Add("@status", SqlDbType.VarChar).Value = status; 
     commandSQL.Parameters.Add("@id", SqlDbType.VarChar).Value = ItemID.Text; 
     commandSQL.ExecuteNonQuery(); 
     commandSQL.Parameters.Clear();     
    } 
} 

注：最好的办法是第三个，我喜欢你遵循，其余的音符你的知识，这将有助于你在其他情况;