带有SqlParameters的SqlDataReader

Question

我正在尝试运行依赖于参数的查询。

我之前使用它并且它有效，但在这种情况下似乎有一个问题，我无法理解。

我正在使用SQL Server 2012。

这是我的代码：

 public void getMissingKeys()
 {
        SqlConnection conn = new SqlConnection(_connection);

        conn.Open();

        foreach(DataRow dr in _result.Rows)
        {
            string sqlSearch = "SELECT TOP 1 [Column1], 
             [Column2], [Column3], [Column4], [Column5], 
             [Column6], [Column7], [Column8] 
             FROM KeyValuationActual_destination 
             WHERE [SystemType] = @system 
             AND [DataType] = @data 
             AND [Location] LIKE @location 
             AND [Department] LIKE @department 
             AND [Role] LIKE @role 
             AND [Language] LIKE @language 
             AND [Shift] LIKE @shift
             AND [ResourceID] = @resource
             AND [Activity] LIKE @activity AND
             [Unique ID] IS NOT NULL";
            SqlCommand cmd = new SqlCommand(sqlSearch, conn);

            SqlParameter[] parameters = new SqlParameter[9];
            parameters[0] = new SqlParameter("@system", SqlDbType.Float);
            parameters[0].Value = dr["SystemType"];

            parameters[1] = new SqlParameter("@data", SqlDbType.Float);
            parameters[1].Value = dr["DataType"];

            parameters[2] = new SqlParameter("@location", SqlDbType.VarChar, 255);
            parameters[2].Value = dr["Location"].ToString();

            parameters[3] = new SqlParameter("@department", SqlDbType.VarChar, 255);
            parameters[3].Value = dr["Department"].ToString();

            parameters[4] = new SqlParameter("@role", SqlDbType.VarChar, 255);
            parameters[4].Value = dr["Role"].ToString();

            parameters[5] = new SqlParameter("@language", SqlDbType.VarChar, 255);
            parameters[5].Value = dr["Language"].ToString();

            parameters[6] = new SqlParameter("@shift", SqlDbType.VarChar, 255);
            parameters[6].Value = dr["Shift"].ToString();

            parameters[7] = new SqlParameter("@resource", SqlDbType.Float);
            parameters[7].Value = dr["ResourceID"];

            parameters[8] = new SqlParameter("@activity", SqlDbType.VarChar, 255);
            parameters[8].Value = dr["Activity"].ToString();

            foreach (SqlParameter param in parameters)
            {
                cmd.Parameters.Add(param);
            }


            SqlDataReader reader = cmd.ExecuteReader();

            while (reader.Read())
            {
                //Do something
            }
        }

        conn.Close();
}

Column1..8是虚构的名字。

不知怎的，我看到参数实际上正在被正确查询并返回，但SqlDataReader似乎无法处理变量以在查询命令中“替换”它们。

因此，reader.Read()永远不会返回任何价值。

我想知道它是否是参数类型（我也尝试使用Nullables作为VarChars）。

在调试时，如果我检查cmd并前往“非公共成员”，我看到两个错误：

EventSink ='cmd.EventSink'抛出类型'System.InvalidCastException'的异常

InternalSmiConnection ='cmd.InternalSmiConnection'引发了'System.InvalidCastException'类型的异常

Screeenshot from debug on cmd

我一直在寻找各地，但我对如何继续前进毫无头绪。

有什么想法吗？

UPDATE

我最终成功完成了这项工作。

我已经放弃了ExecuteReader，因为它没有检索行，甚至与DataTable结合使用。似乎如果你想使用其字符串类型的参数，并且由于表使用Float作为类型，这让我很难尝试匹配类型。

我结束了使用和SqlAdapater，DataTable和参数。似乎参数不是强类型的，因为我不需要进行任何强制转换。

所以这是我最终得到的代码：

public void getMissingKeys()
    {
        SqlConnection conn = new SqlConnection(_connection);
        string sqlSearch = "SELECT TOP 1 "+
                    "[Column1], [Column2], [Column3], "+
                    "[Column4], [Column5], [Column6], "+
                    "[Column7], [Column8] "+
                    "FROM KeyValuationActual_destination "+
                    "WHERE [SystemType] = @system "+
                    "AND [DataType] = @data "+
                    "AND [Location] LIKE @location "+
                    "AND [Department] LIKE @department "+
                    "AND [Role] LIKE @role "+
                    "AND [Language] LIKE @language "+
                    "AND [Shift] LIKE @shift "+
                    "AND [Resource Utilisation Ref_ID] = @resource "+
                    "AND [Activity] LIKE @activity "+
                    "AND [Unique ID] IS NOT NULL";

        try {
            foreach (DataRow dr in _result.Rows)
            {
                conn.Open();

                SqlDataAdapter da = new SqlDataAdapter(sqlSearch, conn);
                da.SelectCommand.Parameters.AddWithValue("@location", dr[2]);
                da.SelectCommand.Parameters.AddWithValue("@department", dr[3]);
                da.SelectCommand.Parameters.AddWithValue("@role", dr[4]);
                da.SelectCommand.Parameters.AddWithValue("@language", dr[5]);
                da.SelectCommand.Parameters.AddWithValue("@shift", dr[7]);
                da.SelectCommand.Parameters.AddWithValue("@resource", dr[8]);
                da.SelectCommand.Parameters.AddWithValue("@activity", dr[9]);
                da.SelectCommand.Parameters.AddWithValue("@data", dr[10]);
                da.SelectCommand.Parameters.AddWithValue("@system", dr[11]);

                DataTable dataTable = new DataTable();
                da.Fill(dataTable);

                if(dataTable != null)
                {
                    foreach(DataRow keyRow in dataTable.Rows)
                    {
                        dr[13] = keyRow["Column1"];
                        dr[14] = keyRow["Column2"];
                        dr[15] = keyRow["Column3"];
                        dr[16] = keyRow["Column4"];
                        dr[17] = keyRow["Column5"];
                        dr[18] = keyRow["Column6"];
                        dr[19] = keyRow["Column7"];
                        dr[20] = keyRow["Column8"];
                    }

                }
            conn.Close();
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine("Querying keys exception information! : {0}", ex);
        }

    }

如果您认为可以在此代码中改进某些内容，我愿意接受建议

Answer 1

另一答案

Answer 2

另一答案