Merge pull request #7 from sanamhub/fix/timeout

sanamhub · web-flow · commit aeb71456aba9 · 2023-02-05T11:31:33.000+05:45
diff --git a/Services/Service.cs b/Services/Service.cs
@@ -27,9 +27,10 @@ public void Migrate()
     {
         try
         {
+            SpectreConsoleHelper.WriteHeader("postgresql to mssql", Color.Blue);
+
             _validator.ValidateProviders();
 
-            SpectreConsoleHelper.WriteHeader("postgresql to mssql", Color.Blue);
             SpectreConsoleHelper.Log("Initializing...");
             AnsiConsole.Status()
                 .Spinner(Spinner.Known.Arc)
@@ -93,6 +94,7 @@ public void Migrate()
                             ctx.Status($"Transferring data from [blue]{sourceSchema}.{table}[/] to [green]{destinationSchema}.{table}[/]");
                             using var bulkCopy = new SqlBulkCopy(sqlServerConnection);
                             bulkCopy.DestinationTableName = $"{destinationSchema}.{table}";
+                            bulkCopy.BulkCopyTimeout = 300;
                             bulkCopy.WriteToServer(dataTable);
                             SpectreConsoleHelper.Success($"Successfully transferred data from {sourceSchema}.{table} to {destinationSchema}.{table}");
                         }

Original file line number	Diff line number	Diff line change
`@@ -27,9 +27,10 @@ public void Migrate()`
`27`	`27`	`{`
`28`	`28`	`try`
`29`	`29`	`{`
	`30`	`+ SpectreConsoleHelper.WriteHeader("postgresql to mssql", Color.Blue);`
	`31`	`+`
`30`	`32`	`_validator.ValidateProviders();`
`31`	`33`
`32`		`- SpectreConsoleHelper.WriteHeader("postgresql to mssql", Color.Blue);`
`33`	`34`	`SpectreConsoleHelper.Log("Initializing...");`
`34`	`35`	`AnsiConsole.Status()`
`35`	`36`	`.Spinner(Spinner.Known.Arc)`
`@@ -93,6 +94,7 @@ public void Migrate()`
`93`	`94`	`ctx.Status($"Transferring data from [blue]{sourceSchema}.{table}[/] to [green]{destinationSchema}.{table}[/]");`
`94`	`95`	`using var bulkCopy = new SqlBulkCopy(sqlServerConnection);`
`95`	`96`	`bulkCopy.DestinationTableName = $"{destinationSchema}.{table}";`
	`97`	`+ bulkCopy.BulkCopyTimeout = 300;`
`96`	`98`	`bulkCopy.WriteToServer(dataTable);`
`97`	`99`	`SpectreConsoleHelper.Success($"Successfully transferred data from {sourceSchema}.{table} to {destinationSchema}.{table}");`
`98`	`100`	`}`