Skip to content

Commit 088886f

Browse files
author
Davoud Eshtehari
committed
fix test
1 parent 481b6a0 commit 088886f

File tree

1 file changed

+15
-15
lines changed

1 file changed

+15
-15
lines changed

src/Microsoft.Data.SqlClient/tests/ManualTests/SQL/RetryLogic/SqlConnectionReliabilityTest.cs

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -66,34 +66,34 @@ public void CreateDatabaseWhileTryingToConnect(string cnnString, SqlRetryLogicBa
6666
using (var cnn1 = new SqlConnection(new SqlConnectionStringBuilder(cnnString) { ConnectTimeout = 60, Pooling = false }.ConnectionString))
6767
{
6868
cnn1.Open();
69-
Task createDBTask = null;
70-
try
69+
using (var cmd = cnn1.CreateCommand())
7170
{
72-
provider.Retrying += (s, e) =>
71+
Task createDBTask = null;
72+
try
7373
{
74-
currentRetries = e.RetryCount;
75-
using (var cmd = cnn1.CreateCommand())
74+
provider.Retrying += (s, e) =>
7675
{
76+
currentRetries = e.RetryCount;
7777
// Try to create database just after first faliure.
7878
if (createDBTask == null || createDBTask.Status == TaskStatus.Faulted)
7979
{
8080
cmd.CommandText = $"IF (NOT EXISTS(SELECT 1 FROM sys.databases WHERE name = '{database}')) CREATE DATABASE [{database}];";
8181
createDBTask = cmd.ExecuteNonQueryAsync();
8282
}
83-
}
84-
};
83+
};
8584

86-
using (var cnn2 = new SqlConnection(builder.ConnectionString))
85+
using (var cnn2 = new SqlConnection(builder.ConnectionString))
86+
{
87+
cnn2.RetryLogicProvider = provider;
88+
cnn2.Open();
89+
}
90+
}
91+
finally
8792
{
88-
cnn2.RetryLogicProvider = provider;
89-
cnn2.Open();
93+
createDBTask?.Wait();
94+
DataTestUtility.DropDatabase(cnn1, database);
9095
}
9196
}
92-
finally
93-
{
94-
createDBTask?.Wait();
95-
DataTestUtility.DropDatabase(cnn1, database);
96-
}
9797
}
9898
Assert.True(currentRetries > 0);
9999
}

0 commit comments

Comments
 (0)