1

我有一个名为“ovhidhan_e_word”的数据库，它有一个名为的表Table1，其中包含重复的行。但我想将其复制Table1到另一个名为“ovidhan”的数据库下的另一个表中dic。但这次我不想重复行.我用这个代码：

  string english_w = "";

        SqlConnection mssql_con = new System.Data.SqlClient.SqlConnection(@"Data Source=.\SQLEXPRESS;AttachDbFilename=C:\Users\Imon-Bayazid\Documents\ovhidhan_e_word.mdf;MultipleActiveResultSets=true;Integrated Security=True;Connect Timeout=30;User Instance=True");
        SqlConnection con2 = new System.Data.SqlClient.SqlConnection(@"Data Source=.\SQLEXPRESS;AttachDbFilename=C:\Users\Imon-Bayazid\Documents\ovidhan.mdf;Integrated Security=True;Connect Timeout=30;User Instance=True");

        mssql_con.Open();

        SqlCommand mssql_cmnd = new System.Data.SqlClient.SqlCommand("SELECT * from Table1", mssql_con);

        SqlDataReader rd = mssql_cmnd.ExecuteReader();
        while (rd.Read())
        {
            english_w = rd.GetString(0);

            con2.Open();

            SqlCommand cmnd2 = new System.Data.SqlClient.SqlCommand("select * from dic where english=@h",con2);
            cmnd2.Parameters.AddWithValue("@h",english_w);

            SqlDataReader r = cmnd2.ExecuteReader();
            if (r.Read())
            { }
               else {
                    SqlCommand c = new System.Data.SqlClient.SqlCommand("insert into dic values(@k)", con2); ;
                    c.Parameters.AddWithValue("@k", english_w);
                    c.ExecuteNonQuery();
                 }

            con2.Close();      
        }

        mssql_con.Close();

但它显示异常“已经有一个打开的 DataReader 与此命令关联，必须先关闭。” 在“ c.ExecuteNonQuery(); ”行上

我该如何解决这个问题？？？另一个问题如何从 mssql 中的表中删除重复的行？

4

3 回答 3

0

这是因为 mssql_cmnd 与您用于第一个 SQLReader 的 SQLCommand 相同。您可能想调用 SQLCommand c：

c.Parameters.AddWithValue("@k", english_w);
c.ExecuteNonQuery();

至于重复，您总是可以在读取数据时执行 SELECT DISTINCT。请参阅以下链接中的标题 C：

http://msdn.microsoft.com/en-us/library/ms187731.aspx

于 2013-02-27T18:23:34.340 回答
0

我认为它应该是“c”而不是“mssql_cmnd”，并且还建议在您的连接、命令和数据读取器对象周围使用“使用”语句。

编辑

我没有测试代码，但尝试重构它并用执行标量替换数据读取器。 

        string english_w = string.Empty;
        using (SqlConnection mssql_con = new SqlConnection(@"Data Source=.\SQLEXPRESS;AttachDbFilename=C:\Users\Imon-Bayazid\Documents\ovhidhan_e_word.mdf;MultipleActiveResultSets=true;Integrated Security=True;Connect Timeout=30;User Instance=True"))
        {
            using (SqlCommand mssql_cmnd = new SqlCommand("SELECT * from Table1", mssql_con))
            {
                mssql_con.Open();
                using (SqlDataReader rd = mssql_cmnd.ExecuteReader())
                {
                    while (rd.Read())
                    {
                        english_w = rd.GetString(0);
                        using (SqlConnection con2 = new SqlConnection(@"Data Source=.\SQLEXPRESS;AttachDbFilename=C:\Users\Imon-Bayazid\Documents\ovidhan.mdf;Integrated Security=True;Connect Timeout=30;User Instance=True"))
                        {
                            con2.Open();
                            using (SqlCommand cmnd2 = new SqlCommand("select top 1 * from dic where english=@h", con2))
                            {
                                cmnd2.Parameters.AddWithValue("@h", english_w);
                                object obj = cmnd2.ExecuteScalar();
                                if (obj == null)
                                {
                                    using (SqlCommand c = new SqlCommand("insert into dic values(@k)", con2))
                                    {
                                        c.Parameters.AddWithValue("@k", english_w);
                                        c.ExecuteNonQuery();
                                    }
                                }
                            }
                            con2.Close();
                        }
                    }
                    rd.Close();
                }
            }
            mssql_con.Close();
        }
于 2013-02-27T18:24:04.247 回答
0

你从哪里得到错误？mssql_cmnd没有ExecuteNonQuery()如果是，c请尝试。试试这个删除重复的行c.Dispose()c.ExecuteNonQuery()

select * from table1 h1 where H1.ID in (select max(id) from table1 group by duplicate_row_id);
于 2013-02-27T18:50:56.850 回答