0

执行代码时出错，我使用的是 C# & SQL Server 7 / 2000。

我正在做的步骤是：

  • 拿到所有的票
  • 然后我读了每张票
  • 传递给 Web 服务方法进行验证
  • 如果返回为真，我需要更新表格。

请查看我的代码，感谢有关如何修复它的反馈.. 因为它让我疯狂了几天！谢谢！

    public void Execute()
    {
        SqlConnection conn = null;
        SqlConnection conn2 = null; 
        SqlDataReader rdr = null;

        try
        {
            Helper helper = new Helper();
            using (conn = new SqlConnection(helper.MISDBConnectionString))
            {
                conn.Open();

                string ticketid = null;
                bool bTerm = false;
                int rowsAffected = 0;

                if (rdr != null) { rdr.Close(); }
                SqlCommand selectCommand = new SqlCommand();
                selectCommand.CommandText = "SELECT ...";
                selectCommand.Connection = conn;
                rdr = selectCommand.ExecuteReader();

                while (rdr.Read())
                {
                    ticketid = rdr["ticketid"].ToString();
                    bTerm = calling webserver for validation

                    if (bTerm)
                    {                           
                        using (conn2 = new SqlConnection(helper.MISDBConnectionString))
                        {
                            conn2.Open();
                            SqlCommand updateCommand = new SqlCommand();

                            updateCommand.CommandText = "UPDATE ticket  SET code = @code WHERE ticketid = @ticketid";
                            updateCommand.CommandType = CommandType.Text;
                            updateCommand.CommandTimeout = 120;
                            updateCommand.Parameters.AddWithValue("@code", 8);
                            updateCommand.Parameters.AddWithValue("@ticketid", ticketid);
                            updateCommand.Connection = conn2;

                            rowsAffected = updateCommand.ExecuteNonQuery(); //fails here
                        }
                    }
                }
            }
        }
        catch (Exception ex)
        {
            logger.Error(ex.ToString());
        }
        finally
        {
            if (conn != null) { conn.Close(); }
            if (conn2 != null) { conn2.Close(); }
            if (rdr != null) { rdr.Close(); }
        }
    }

我需要使用两个连接，因为如果我使用一个需要在更新之前关闭 dataReader 的连接，它会给我一个错误

我目前得到的错误：

System.Data.SqlClient.SqlException (0x80131904)：超时已过期。在操作完成之前超时时间已过或服务器没有响应。在 System.Data.SqlClient.SqlConnection.OnError(SqlException 异常，Boolean breakConnection) 在 System.Data.SqlClient.SqlInternalConnection.OnError(SqlException 异常，Boolean breakConnection) 在 System.Data.SqlClient.TdsParser.ThrowExceptionAndWarning() 在 System.Data System.Data.SqlClient.SqlCommand.FinishExecuteReader(SqlDataReader ds, RunBehavior runBehavior, String resetOptionsString) 在 System.Data.SqlClient.SqlCommand.SqlClient.TdsParser.Run(RunBehavior runBehavior, SqlCommand cmdHandler, SqlDataReader dataStream, BulkCopySimpleResultSet bulkCopyHandler, TdsParserStateObject stateObj) 在 System.Data.SqlClient.SqlCommand .

4

2 回答 2

1

很难说是什么导致了你的超时，很可能你正在创建一个死锁。但是，这是我认为您应该首先更改的内容：

不要使用第二个连接，首先读取所有数据，关闭阅读器，然后使用相同或另一个连接处理它。如果数据太多 - 在页面中执行。

我的意思是这样的

List<string> ids = new List<string>

while (rdr.Read())
{
  ids.add(rdr["ticketid"].ToString())
}

rdr.Close();

foreach(id in ids)
{
 // ...

此外，您不需要这样做

if (conn != null) { conn.Close(); }
if (conn2 != null) { conn2.Close(); }

using(conn=new ...)声明为您做到这一点。

于 2014-02-10T21:11:16.507 回答
0

我同意 Anri 的观点，这很可能是由于锁定问题。您是否尝试WITH (NOLOCK)在您的SELECT声明中使用以查看是否可以解决问题？这应该允许您在迭代结果时更新表，而SELECT语句不会持有阻止UPDATE执行的读锁。

于 2014-02-10T21:22:24.130 回答