Fix SqlConnection undisponse bug. #477

4eaf7a0b · Savorboard · ba182aec · 4eaf7a0b
Commit 4eaf7a0b authored Jan 08, 2020 by Savorboard
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

IDataStorage.SqlServer.cs src/DotNetCore.CAP.SqlServer/IDataStorage.SqlServer.cs +1 -1

No files found.
--- a/src/DotNetCore.CAP.SqlServer/IDataStorage.SqlServer.cs
+++ b/src/DotNetCore.CAP.SqlServer/IDataStorage.SqlServer.cs
@@ -201,7 +201,7 @@ namespace DotNetCore.CAP.SqlServer

            var result = new List<MediumMessage>();

-            var connection = new SqlConnection(_options.Value.ConnectionString);
+            using var connection = new SqlConnection(_options.Value.ConnectionString);
            var reader = await connection.ExecuteReaderAsync(sql);
            while (reader.Read())
            {