我遇到了数据读取器的问题

Question

我的这部分代码与 datareader 有问题。

foreach (Giorno iDet in iNom.Gg.Where(x => x.minRegular != 0 | x.minOver != 0 | x.minLate != 0))
{
    bool Importato = false;
    com = new SqlCommand("SELECT id, Lavorato, Straordinario, Assenza, Permesso, Malattia, Infortunio, Ferie, Maternita, Ritardo, Festivita " +
                         "FROM presenze_giorno WHERE data = @data AND reparto = @rep AND nomcod = @nom", TranOP.Connection, TranOP);
    com.Parameters.AddWithValue("data", iDet.Gg);
    com.Parameters.AddWithValue("rep", iNom.Reparto);
    com.Parameters.AddWithValue("nom", iNom.Codice);                                
    SqlDataReader dr = com.ExecuteReader();
    if (dr.HasRows)
        Importato = true;                                                      
    if (!Importato)
    {
        //Inserisco il giorno
        com = new SqlCommand("INSERT INTO presenze_giorno (data, reparto, nomcod, nomdesc, errmarcatura, ingresso, uscita, " +
                             "Lavorato, Ritardo, Straordinario, Assenza) VALUES " +
                             "(@data, @reparto, @nomcod, @nomdesc, @errmarcatura, @ingresso, @uscita, @Lavorato, @Ritardo, " +
                             "@Straordinario, @Assenza); SELECT SCOPE_IDENTITY()", TranOP.Connection, TranOP);
        com.Parameters.AddWithValue("data", iDet.Gg);
        com.Parameters.AddWithValue("reparto", iNom.Reparto);
        com.Parameters.AddWithValue("nomcod", iNom.Codice);
        com.Parameters.AddWithValue("nomdesc", iNom.Descrizione);
        com.Parameters.AddWithValue("errmarcatura", iNom.MarcaturaSbagliata);
        com.Parameters.AddWithValue("ingresso", iDet.Gg.Add(iDet.InT));
        com.Parameters.AddWithValue("uscita", iDet.Gg.Add(iDet.OutT));
        com.Parameters.AddWithValue("Lavorato", iDet.minRegular);
        com.Parameters.AddWithValue("Ritardo", iDet.minLate);
        com.Parameters.AddWithValue("Straordinario", iDet.minOver);
        com.Parameters.AddWithValue("Assenza", iDet.minAssente);
        int wid = Convert.ToInt32(com.ExecuteScalar().ToString());
        //Inserisco le marcature
        Lettura search = Lett.Find(f => f.Data == iDet.Gg & f.Reparto == iNom.Reparto & f.Codice == iNom.Codice);
        if (search != null)
            foreach (IngrUsc item in search.IU)
            {
                com = new SqlCommand("INSERT INTO presenze_marcature (idtesta, ingresso, uscita) VALUES (@idtesta, @ingresso, @uscita)", TranOP.Connection, TranOP);
                com.Parameters.AddWithValue("idtesta", wid);
                com.Parameters.AddWithValue("ingresso", iDet.Gg.Add(item.InT));
                com.Parameters.AddWithValue("uscita", iDet.Gg.Add(item.OutT));
                com.ExecuteNonQuery();
            }
    }                             
    //controllo se tutti gli altri campi sono a 0, se si faccio Update                                                                
    else if (Convert.ToInt32(dr["Lavorato"]) == 0 & Convert.ToInt32(dr["Straordinario"]) == 0 & Convert.ToInt32(dr["Assenza"]) == 0 & Convert.ToInt32(dr["Permesso"]) == 0 
             & Convert.ToInt32(dr["Malattia"]) == 0 & Convert.ToInt32(dr["Infortunio"]) == 0 & Convert.ToInt32(dr["Ferie"]) == 0 & Convert.ToInt32(dr["Maternita"]) == 0 
             & Convert.ToInt32(dr["Ritardo"]) == 0 & Convert.ToInt32(dr["Festivita"]) == 0)
    {
        com = new SqlCommand("UPDATE Presenze_Giorno " +
                             "SET Lavorato = @lav, Straordinario = @stra, Assenza = @ass, Permesso = @perm, Malattia = @mala, Infortunio = @inf,  " +
                             "Ferie = @ferie, Maternita = @mat, Ritardo = @rit, Festivita = @fest" +
                             "WHERE data = @data AND reparto = @rep AND nomcod = @nom", TranOP.Connection, TranOP);
        com.Parameters.AddWithValue("data", iDet.Gg);
        com.Parameters.AddWithValue("rep", iNom.Reparto);
        com.Parameters.AddWithValue("nom", iNom.Codice);
        com.Parameters.AddWithValue("lav", iDet.minRegular);
        com.Parameters.AddWithValue("stra", iDet.minOver);
        com.Parameters.AddWithValue("ass", iDet.minAssente);
        com.Parameters.AddWithValue("perm", iDet.minPermesso);
        com.Parameters.AddWithValue("mala", iDet.minMalattia);
        com.Parameters.AddWithValue("inf", iDet.minInfortunio);
        com.Parameters.AddWithValue("ferie", iDet.minFerie);
        com.Parameters.AddWithValue("mat", iDet.minMaternita);
        com.Parameters.AddWithValue("rit", iDet.minLate);
        com.Parameters.AddWithValue("fest", iDet.minFestivita);
        com.ExecuteNonQuery();
    }
    dr.Close();

当我执行 else if 并尝试转换为 int 32 dr["Lavorato"] ecc 时，ecc 给我一个错误。

"System.InvalidOperationException: 'A Command è già associato un DataReader aperto, che deve essere chiuso."

Answer 1

DataReader，与其他 .NET 数据库类不同，未与数据库断开连接。这意味着它需要开放连接和专用命令。 MSDN 声明：

You can use the ADO.NET DataReader to retrieve a read-only, forward-only stream of data from a database. Results are returned as the query executes, and are stored in the network buffer on the client until you request them using the Read method of the DataReader.

您可以通过两种方式解决您的问题：

在命令的连接字符串中设置 MultipleActiveResultSets=true
有另一个处理数据的命令。因此，与其重用 com 实例，不如创建一个新实例，如下所示：SqlCommand com2 = new SqlCommand("INSERT INTO presenze_giorno ...

此外，还有一些事情：

不要忘记关闭 DataReader 以释放资源并关闭连接。最好的方法是在 using block 中使用它，如下所示：

using (SqlDataReader dr = com.ExecuteReader())
{
    //rest of your code
}

而且，看起来您没有调用 dataReader 的 Read 方法，因此 DataReader 没有前进到第一行并保持在 "before" 第一行。你可以这样：

if (dr.HasRows)
    Importato = true;    
dr.Read();

我遇到了数据读取器的问题

i'm in trouble with datareader

.net

c#

sql

sqlcommand

sqldatareader