add updated timeout

HicServices · Aug 8, 2024 · ca932a1 · ca932a1
1 parent 9a5636a
commit ca932a1
Showing 1 changed file with 14 additions and 1 deletion.
diff --git a/Rdmp.Core/Logging/TableLoadInfo.cs b/Rdmp.Core/Logging/TableLoadInfo.cs
@@ -12,6 +12,7 @@
 using FAnsi.Connections;
 using FAnsi.Discovery;
 using Rdmp.Core.ReusableLibraryCode.Settings;
+using System.Diagnostics;
 
 namespace Rdmp.Core.Logging;
 
@@ -182,6 +183,7 @@ public string Notes
 
     public void CloseAndArchive()
     {
+        DatabaseSettings.Builder.Add("Command Timeout", 86400);//wait up to 1 day to perform the command
         using var con = DatabaseSettings.BeginNewTransactedConnection();
         using var cmdCloseRecord = DatabaseSettings.GetCommand(
             "UPDATE TableLoadRun SET endTime=@endTime,inserts=@inserts,updates=@updates,deletes=@deletes,errorRows=@errorRows,duplicates=@duplicates, notes=@notes WHERE ID=@ID",
@@ -198,7 +200,18 @@ public void CloseAndArchive()
                 string.IsNullOrWhiteSpace(Notes) ? DBNull.Value : Notes);
             DatabaseSettings.AddParameterWithValueToCommand("@ID", cmdCloseRecord, ID);
 
-            var affectedRows = cmdCloseRecord.ExecuteNonQuery();
+            int affectedRows = 0;
+            var timer = Stopwatch.StartNew();
+            try
+            {
+                affectedRows = cmdCloseRecord.ExecuteNonQuery();
+            }
+            catch (Exception e)
+            {
+                timer.Stop();
+                throw new Exception($"Guneet Logging Test: Waited - {timer.ElapsedMilliseconds}ms.{e.Message}");
+            }
+            timer.Stop();
 
             if (affectedRows != 1)
                 throw new Exception(