diff --git a/src/DotNetCore.CAP.SqlServer/IStorageInitializer.SqlServer.cs b/src/DotNetCore.CAP.SqlServer/IStorageInitializer.SqlServer.cs
index e1c83e1..66a3bb3 100644
--- a/src/DotNetCore.CAP.SqlServer/IStorageInitializer.SqlServer.cs
+++ b/src/DotNetCore.CAP.SqlServer/IStorageInitializer.SqlServer.cs
@@ -44,7 +44,7 @@ namespace DotNetCore.CAP.SqlServer
             if (cancellationToken.IsCancellationRequested) return;
 
             var sql = CreateDbTablesScript(_options.Value.Schema);
-            using (var connection = new SqlConnection(_options.Value.ConnectionString))
+            await using (var connection = new SqlConnection(_options.Value.ConnectionString))
             {
                 await connection.ExecuteAsync(sql);
             }