add parameterized encodable test

Author: tanner0101

Sources/PostgreSQL/Client/PostgreSQLClient+ParamaterizedQuery.swift

@@ -74,3 +74,27 @@ extension PostgreSQLClient {
         }
     }
 }
+
+/// MARK: Codable
+
+extension PostgreSQLClient {
+    /// Sends a parameterized PostgreSQL query command, collecting the parsed results.
+    public func parameterizedQuery(
+        _ string: String,
+        encoding parameters: [Encodable]
+    ) throws -> Future<[[String: PostgreSQLData]]> {
+        let parameters = try parameters.map { try PostgreSQLDataEncoder().encode($0) }
+        return try parameterizedQuery(string, parameters)
+    }
+
+    /// Sends a parameterized PostgreSQL query command, returning the parsed results to
+    /// the supplied closure.
+    public func parameterizedQuery(
+        _ string: String,
+        encoding parameters: [Encodable],
+        onRow: @escaping ([String: PostgreSQLData]) -> ()
+    ) throws -> Future<Void> {
+        let parameters = try parameters.map { try PostgreSQLDataEncoder().encode($0) }
+        return try parameterizedQuery(string, parameters, onRow: onRow)
+    }
+}

Tests/PostgreSQLTests/PostgreSQLClientTests.swift

@@ -210,7 +210,7 @@ class PostgreSQLClientTests: XCTestCase {
         ]).await(on: eventLoop)
         XCTAssertEqual(insertResult.count, 0)
 
-        let parameterizedResult = try! client.parameterizedQuery("select * from kitchen_sink").await(on: eventLoop)
+        let parameterizedResult = try client.parameterizedQuery("select * from kitchen_sink").await(on: eventLoop)
         if parameterizedResult.count == 1 {
             let row = parameterizedResult[0]
             XCTAssertEqual(row["smallint"], .int16(1))
@@ -230,12 +230,29 @@ class PostgreSQLClientTests: XCTestCase {
         }
     }
 
+    func testParameterizedEncodable() throws {
+        let (client, eventLoop) = try PostgreSQLClient.makeTest()
+        _ = try client.query("drop table if exists foo;").await(on: eventLoop)
+        let createResult = try client.query("create table foo (fooid integer);").await(on: eventLoop)
+        XCTAssertEqual(createResult.count, 0)
+        let insertResult = try client.parameterizedQuery("insert into foo values ($1);", encoding: [Int(123)]).await(on: eventLoop)
+        XCTAssertEqual(insertResult.count, 0)
+        let parameterizedResult = try client.parameterizedQuery("select * from foo").await(on: eventLoop)
+        if parameterizedResult.count == 1 {
+            let row = parameterizedResult[0]
+            XCTAssertEqual(row["fooid"], .int32(123))
+        } else {
+            XCTFail("parameterized result count is: \(parameterizedResult.count)")
+        }
+    }
+
     static var allTests = [
         ("testVersion", testVersion),
         ("testSelectTypes", testSelectTypes),
         ("testParse", testParse),
         ("testTypes", testTypes),
         ("testParameterizedTypes", testParameterizedTypes),
+        ("testParameterizedEncodable", testParameterizedEncodable),
     ]
 }