Phong cách mã hóa C# tốt để bắt SQLException và thử lại là gì

Question

Tôi có một phương thức gọi một hàm SQLServer để thực hiện tìm kiếm văn bản miễn phí đối với một bảng. Chức năng đó đôi khi sẽ có kết quả cuộc gọi đầu tiên trong một SQLException: "Lời vi phạm thời gian chờ cho chuỗi truy vấn toàn văn". Vì vậy, thông thường tôi muốn thử lại yêu cầu đó bởi vì nó sẽ thành công trên các yêu cầu tiếp theo. Phong cách tốt để cấu trúc logic thử lại là gì. Tại thời điểm này tôi có như sau:

var retryCount = 0; 
var results = new List<UserSummaryDto>(); 
using (var ctx = new UsersDataContext(ConfigurationManager.ConnectionStrings[CONNECTION_STRING_KEY].ConnectionString)) 
{ 
    for (; ;) 
    { 
     try 
     { 
      results = ctx.SearchPhoneList(value, maxRows) 
         .Select(user => user.ToDto()) 
         .ToList(); 
      break; 
     } 
     catch (SqlException) 
     { 
      retryCount++; 
      if (retryCount > MAX_RETRY) throw; 
     } 
    } 
} 

return results; 

Answer 1

Cảm ơn tất cả các phản hồi. Tôi trả lời bản thân mình để tôi có thể kết hợp các yếu tố từ các câu trả lời được đưa ra. Xin vui lòng cho tôi biết nếu tôi đã bỏ lỡ một cái gì đó. Phương pháp của tôi trở thành:

var results = new List<UserSummaryDto>(); 
Retry<UsersDataContext>(ctx => results = ctx.SearchPhoneList(value, maxRows) 
              .Select(user => user.ToDto()) 
              .ToList()); 
return results; 

Và tôi đã tái cấu trúc phương pháp gốc để sử dụng lại. Vẫn còn rất nhiều cấp độ làm tổ. Nó cũng dựa vào việc có một hàm tạo mặc định cho ngữ cảnh dữ liệu có thể quá hạn chế. @ Martin, tôi coi đó PreserveStackTrace phương pháp của bạn, nhưng trong trường hợp này tôi không nghĩ rằng nó thực sự bổ sung đủ giá trị - tốt để biết về tương lai tham khảo thanks:

private const int MAX_RETRY = 2; 
private const double LONG_WAIT_SECONDS = 5; 
private const double SHORT_WAIT_SECONDS = 0.5; 
private static readonly TimeSpan longWait = TimeSpan.FromSeconds(LONG_WAIT_SECONDS); 
private static readonly TimeSpan shortWait = TimeSpan.FromSeconds(SHORT_WAIT_SECONDS); 
private enum RetryableSqlErrors 
{ 
    Timeout = -2, 
    NoLock = 1204, 
    Deadlock = 1205, 
    WordbreakerTimeout = 30053, 
} 

private void Retry<T>(Action<T> retryAction) where T : DataContext, new() 
{ 
    var retryCount = 0; 
    using (var ctx = new T()) 
    { 
     for (;;) 
     { 
      try 
      { 
       retryAction(ctx); 
       break; 
      } 
      catch (SqlException ex) 
       when (ex.Number == (int) RetryableSqlErrors.Timeout && 
         retryCount < MAX_RETRY) 
      { 
       Thread.Sleep(longWait); 
      } 
      catch (SqlException ex) 
       when (Enum.IsDefined(typeof(RetryableSqlErrors), ex.Number) && 
         retryCount < MAX_RETRY) 
      { 
       Thread.Sleep(shortWait); 
      } 
      retryCount++; 
     } 
    } 
} 

Answer 2

Tôi muốn thay đổi ngoại lệ xử lý để chỉ thử trên một số lỗi:

• 1204, 1205 deadlocks
• -2 timeout
• -1 kết nối bị hỏng

Đây là những lỗi cơ bản "có thể thử lại"

catch (SqlException ex) 
{ 
    if !(ex.Number == 1205 || ex.Number == 1204 || ...) 
    { 
     throw 
    } 
    retryCount++; 
    if (retryCount > MAX_RETRY) throw; 
} 

Edit, tôi sạch sẽ quên chờ đợi do đó bạn không búa hộp SQL:

• Thêm 500 ms chờ vào bế tắc
• Thêm một sự chậm trễ 5 giây khi quá hạn

Chỉnh sửa 2:

Tôi là nhà phát triển DBA, không làm được nhiều C#. Câu trả lời của tôi là sửa lỗi xử lý ngoại lệ cho các cuộc gọi ...

Answer 3

Phong cách không tốt, nhưng đôi khi bạn phải làm, bởi vì bạn không thể thay đổi mã hiện tại và phải xử lý nó.

Tôi đang sử dụng phương pháp chung sau đây cho trường hợp này. Lưu ý phương pháp PreserveStackTrace(), đôi khi có thể rất hữu ích trong trường hợp phát lại.

public static void RetryBeforeThrow<T>(Action action, int retries, int timeout) where T : Exception 
{ 
    if (action == null) 
     throw new ArgumentNullException("action", string.Format("Argument '{0}' cannot be null.", "action")); 

    int tries = 1; 

    do 
    { 
     try 
     { 
      action(); 
      return; 
     } 
     catch (T ex) 
     { 
      if (retries <= 0) 
      { 
       PreserveStackTrace(ex); 
       throw; 
      } 

      Thread.Sleep(timeout); 
     } 
    } 
    while (tries++ < retries); 
} 

/// <summary> 
/// Sets a flag on an <see cref="T:System.Exception"/> so that all the stack trace information is preserved 
/// when the exception is re-thrown. 
/// </summary> 
/// <remarks>This is useful because "throw" removes information, such as the original stack frame.</remarks> 
/// <see href="http://weblogs.asp.net/fmarguerie/archive/2008/01/02/rethrowing-exceptions-and-preserving-the-full-call-stack-trace.aspx"/> 
public static void PreserveStackTrace(Exception ex) 
{ 
    MethodInfo preserveStackTrace = typeof(Exception).GetMethod("InternalPreserveStackTrace", BindingFlags.Instance | BindingFlags.NonPublic); 
    preserveStackTrace.Invoke(ex, null); 
} 

Bạn sẽ gọi nó là như thế:

RetryBeforeThrow<SqlException>(() => MethodWhichFails(), 3, 100); 

Answer 4

Không có phong cách tốt để làm một cái gì đó như thế này. Bạn sẽ muốn tìm hiểu rõ hơn về số tại sao yêu cầu không thành công lần đầu tiên nhưng thành công lần thứ hai.

Có vẻ như Sql Server phải biên dịch ban đầu kế hoạch thực hiện và sau đó thực hiện truy vấn. Vì vậy, cuộc gọi đầu tiên không thành công vì thời gian kết hợp vượt quá thời gian chờ của bạn và thành công lần thứ hai vì kế hoạch thực hiện đã được biên dịch và lưu.

Tôi không biết cách UsersDataContext hoạt động, nhưng có thể là trường hợp bạn có tùy chọn truy vấn Prepare trước khi thực sự thực hiện nó.

Bất trả lời: Nếu tôi có để làm điều này, tôi sẽ thử lại chỉ một lần và không một lần nữa, như thế này:

var results = new List<UserSummaryDto>(); 
using (var ctx = new 
    UsersDataContext(ConfigurationManager.ConnectionStrings[CONNECTION_STRING_KEY].ConnectionString)) 
{ 
     try 
     { 
      results = ctx.SearchPhoneList(value, maxRows) 
         .Select(user => user.ToDto()) 
         .ToList(); 
      break; 
     } 
     catch (SqlException) 
     { 
      try 
      { 
       results = ctx.SearchPhoneList(value, maxRows) 
         .Select(user => user.ToDto()) 
         .ToList(); 
       break; 
      } 
      catch (SqlException) 
      { 
       // set return value, or indicate failure to user however 
      } 
     } 
    } 
} 

return results; 

Trong khi tôi có thể tin tưởng bạn để không lạm dụng quá trình thử lại, bạn 'd được hấp dẫn người kế nhiệm của bạn để tăng số lượng thử lại như một sửa chữa nhanh chóng.

Answer 5

Kéo mã có liên quan ra theo phương pháp riêng của nó, sau đó sử dụng đệ quy.

Pseudo-code:

try 
{ 
    doDatabaseCall(); 
} 
catch (exception e) 
{ 
    //Check exception object to confirm its the error you've been experiencing as opposed to the server being offline. 
    doDatabaseCall(); 
} 

Answer 6

enum của tôi về retryables cho sql trông như thế này :

SqlConnectionBroken = -1, 
SqlTimeout = -2, 
SqlOutOfMemory = 701, 
SqlOutOfLocks = 1204, 
SqlDeadlockVictim = 1205, 
SqlLockRequestTimeout = 1222, 
SqlTimeoutWaitingForMemoryResource = 8645, 
SqlLowMemoryCondition = 8651, 
SqlWordbreakerTimeout = 30053 

Answer 7

Bạn có thể chỉ cần sử dụng thuộc tính SqlConnectionStringBuilder để thử lại kết nối sql.

var conBuilder = new SqlConnectionStringBuilder("Server=.;Database=xxxx;Trusted_Connection=True;MultipleActiveResultSets=true"); conBuilder.ConnectTimeout = 90; conBuilder.ConnectRetryInterval = 15; conBuilder.ConnectRetryCount = 6;

Lưu ý: - Bắt buộc .Net 4.5 hoặc mới hơn.