Merge pull request #145 from mickednk/use-prepareasync

Use PrepareAsync for asynchronous calls
Zaid-Ajaj · Dec 7, 2024 · deb8887 · deb8887
2 parents 727214f + 1264ab8
commit deb8887
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/Npgsql.FSharp.fs b/src/Npgsql.FSharp.fs
@@ -458,7 +458,8 @@ module Sql =
                 then do! connection.OpenAsync(props.CancellationToken)
                 use command = makeCommand props connection
                 do populateCmd command props
-                if props.NeedPrepare then command.Prepare()
+                if props.NeedPrepare then
+                    do! command.PrepareAsync(props.CancellationToken)
                 use! reader = command.ExecuteReaderAsync props.CancellationToken
                 let postgresReader = unbox<NpgsqlDataReader> reader
                 let rowReader = RowReader(postgresReader)
@@ -482,7 +483,8 @@ module Sql =
                 then do! connection.OpenAsync(props.CancellationToken)
                 use command = makeCommand props connection
                 do populateCmd command props
-                if props.NeedPrepare then command.Prepare()
+                if props.NeedPrepare then
+                    do! command.PrepareAsync(props.CancellationToken)
                 use! reader = command.ExecuteReaderAsync(props.CancellationToken)
                 let postgresReader = unbox<NpgsqlDataReader> reader
                 let rowReader = RowReader(postgresReader)
@@ -504,7 +506,8 @@ module Sql =
                 then do! connection.OpenAsync(props.CancellationToken)
                 use command = makeCommand props connection
                 do populateCmd command props
-                if props.NeedPrepare then command.Prepare()
+                if props.NeedPrepare then
+                    do! command.PrepareAsync(props.CancellationToken)
                 use! reader = command.ExecuteReaderAsync props.CancellationToken
                 let postgresReader = unbox<NpgsqlDataReader> reader
                 let rowReader = RowReader(postgresReader)
@@ -547,7 +550,8 @@ module Sql =
                 then do! connection.OpenAsync props.CancellationToken
                 use command = makeCommand props connection
                 populateCmd command props
-                if props.NeedPrepare then command.Prepare()
+                if props.NeedPrepare then
+                    do! command.PrepareAsync(props.CancellationToken)
                 let! affectedRows = command.ExecuteNonQueryAsync props.CancellationToken
                 return affectedRows
             finally