类中存在多个 SqlDataReader 和 SqlCommand 的问题

Question

我在使用 C# 时遇到问题，我有一个类，其中包含 SqlDataReader 的函数和 SqlCommand 的另一个函数（第一个类仅用于从数据库读取值，第二个类用于同一数据库中的 INSERT、UPDATE、DELETE ... ）。

问题是，对于代码的第一部分（登录），我必须从 Active Directory 中搜索值（它有效），然后我必须查看用户在我自己的数据库中是否有用户名和密码（它有效） ，然后，如果用户不在数据库中，那么我必须创建它并获取 ID，如果它已经创建，那么我只需要获取 ID。

问题是我收到此消息：

InvalidOperationException 是 用户代码未处理

已经存在一个 Open DataReader 与此命令相关的，谁作为 先关闭。

有代码：

Class.cs：

    private static string MyConnectionString = "THIS IS MY CONNECTION";
    private SqlConnection MyConnection = new SqlConnection(MyConnectionString);
    public SqlCommand MyCommand = new SqlCommand();
    public SqlDataReader MyReader = null;

    public void DBMyReader(String SqlQuery)
    {
        if (MyConnection.State != ConnectionState.Open)
            MyConnection.Open();

        MyCommand.Connection = MyConnection;
        MyCommand.CommandText = SqlQuery;
        MyReader = MyCommand.ExecuteReader(CommandBehavior.CloseConnection);
    }

    public void DBMyUpdate(String SqlQuery)
    {
        if (MyConnection.State != ConnectionState.Open)
            MyConnection.Open();

        var cmdTest = new SqlCommand();

        cmdTest.Connection = MyConnection;
        cmdTest.CommandText = SqlQuery;
        cmdTest.ExecuteNonQuery();
    }

    public void DBMyInsert(String SqlQuery)
    {
        DBMyUpdate(SqlQuery);
    }

** Login.aspx.cs：**

                    MyClass.DBMyReader("SELECT util_codi,util_logi,util_nome FROM Tgep_util WHERE util_logi='"
                            + Session["username"].ToString() + "'");
            MyClass.MyReader.Read();

            if (!MyClass.MyReader.HasRows)
            {
                MyClass.MyReader.Close();
                MyClass.DBMyInsert("INSERT INTO Tgep_util(util_logi,util_nome) "
                            + "VALUES ('" + Session["username"].ToString() + "','" + Session["nome"].ToString() + "')");
            }

            MyClass.DBMyReader("SELECT util_codi,util_logi,util_nome FROM Tgep_util WHERE util_logi='"
            + Session["username"].ToString() + "'");

            MyClass.MyReader.Read();

            Session["user_id"] = MyClass.MyReader["util_codi"].ToString();

            Response.Redirect("FRM_Principal.aspx");

编辑：更新代码（目前有效）

Answer 1

该错误的含义正如其所言。您已加载 SQLCommand 并开始读取行，现在正尝试执行插入。您需要先关闭该读取器，或使用新命令。

在 DBMyUpdate 函数中，您可以创建一个新命令：

public void DBMyUpdate(String SqlQuery)
{
    if (MyConnection.State != ConnectionState.Open)
        MyConnection.Open();
    var cmdUpdate = new SqlCommand();

    cmdUpdate.Connection = MyConnection;
    cmdUpdate.CommandText = SqlQuery;
    cmdUpdate.ExecuteNonQuery(CommandBehavior.CloseConnection);
}

编辑：根据对此答案的注释，它需要使用单独的连接，这似乎很奇怪/不正确。

Answer 2

您不能将用于插入的相同 DataReader 用于 insert/update。在将其他命令与 DataReader 关联之前，您必须先关闭 DataReader。