-1

为什么我的代码中会出现此异常？我重新启动了服务器，更改了端口等，但没有任何效果。

怎么了？

DataTable dt = new DataTable();

SqlConnection con = new SqlConnection("server=localhost;user=armin;password=root;");
con.Open();

SqlCommand result = new SqlCommand(
    "SELECT userid FROM KDDData.dbo.userprofile order by userid", con);

SqlDataReader reader = result.ExecuteReader();
dt.Load(reader);

List<string> userids = new List<string>(dt.Rows.Count);

foreach (DataRow item in dt.Rows)
{
    userids.Add(item.ItemArray[0].ToString().Trim());
}

con.Close();

con = new SqlConnection("server=localhost;user=armin;password=root;");
con.Open();

foreach (string user in userids)
{
    DataTable temp = new DataTable();
    SqlCommand result1 = new SqlCommand(
    "select itemid from KDDTrain.dbo.train where userid=" + user, con);

    SqlDataReader reader1 = result1.ExecuteReader();

    if (!reader1.HasRows)
    {
        continue;
    }

    temp.Load(reader1);
}

第一个查询工作正常，但第二个没有。正如你所看到的，我什至使用了其他一些SqlConnection，但它仍然不起作用。

注意：我正在使用的数据库至少有 1 亿条记录，我认为这可能是个问题。

4

3 回答 3

3

在您的连接字符串中有些东西看起来不正确
我总是"server=localhost; user=armin;password=root"在 MySql 的连接字符串中看到，而不是在 SqlServer 的连接字符串中，我将使用"Data Source=(LOCAL);Integrated Security=SSPI"或 SqlServer 的实例名称。您确定第一个查询有效吗？

但是我认为您应该使用适当的 using 语句

DataTable dt = new DataTable(); 
using(SqlConnection con = new SqlConnection("server=localhost;user=armin;password=root;"))
{
    using(SqlCommand result = new SqlCommand(
            "SELECT userid FROM KDDData.dbo.userprofile order by userid", con))
    {
        con.Open(); 
        using(SqlDataReader reader = result.ExecuteReader())
        {
           dt.Load(reader); 
           List<string> userids = new List<string>(dt.Rows.Count); 
           foreach (DataRow item in dt.Rows) 
           { 
              userids.Add(item.ItemArray[0].ToString().Trim()); 
           }
        } 
        DataTable temp = new DataTable(); 
        foreach (string user in userids) 
        { 
            using(SqlCommand result1 = new SqlCommand( 
            "select itemid from KDDTrain.dbo.train where userid=" + user, con))
            {
                using(SqlDataReader reader1 = result1.ExecuteReader())
                {
                    if (!reader1.HasRows)   continue; 
                    temp.Load(reader1); 
                }
            } 
        } 
   }
于 2012-04-20T07:22:11.293 回答
1

请插入此行

result1.CommandTimeout = 0;

在第二个查询中的这一行之前

SqlDataReader reader1 = result1.ExecuteReader();
于 2012-06-08T11:51:23.457 回答
0

在以下情况下处置您的阅读器：

foreach (DataRow item in dt.Rows)
{
    userids.Add(item.ItemArray[0].ToString().Trim()); 
}

...并在 temp.Load(reader1) 之后关闭连接。同时关闭 reader1。

而不是所有这些......干净的方法是使用 USING 来初始化阅读器和连接。:)

于 2012-04-20T07:19:45.073 回答