Add async_execute with SQLStrings.Sql

Author: c42f

src/asyncresults.jl

@@ -236,6 +236,15 @@ function _multi_async_execute(jl_conn::Connection, query::AbstractString; kwargs
     return async_result
 end
 
+function async_execute(
+    jl_conn::Connection,
+    query::SQLStrings.Sql;
+    kwargs...
+)
+    query_str, parameters = SQLStrings.prepare(query)
+    async_execute(jl_conn, query_str, parameters; kwargs...)
+end
+
 function async_execute(
     jl_conn::Connection,
     query::AbstractString,

src/results.jl

@@ -301,12 +301,11 @@ end
 
 function execute(
     jl_conn::Connection,
-    sql::SQLStrings.Sql;
-    throw_error::Bool=true,
+    query::SQLStrings.Sql;
     kwargs...
 )
-    query, parameters = SQLStrings.prepare(sql)
-    execute(jl_conn, query, parameters; throw_error=throw_error, kwargs...)
+    query_str, parameters = SQLStrings.prepare(query)
+    execute(jl_conn, query_str, parameters; kwargs...)
 end
 
 function execute(

test/runtests.jl

@@ -1548,6 +1548,11 @@ end
             bar_id = 3
             result = execute(conn, sql`SELECT * from libpq_test_users where id = $bar_id`)
             @test first(result).name == "Bar"
+
+            # Async with SqlStrings
+            ar = async_execute(conn, sql`SELECT * from libpq_test_users where id = 1`)
+            result = fetch(ar)
+            @test first(result).name == "Foo"
         end
 
         @testset "Query Errors" begin