add TIMESTAMPTZ support, fixes vapor#63

Author: tanner0101

Sources/PostgreSQL/Column/PostgreSQLDataType.swift

@@ -38,6 +38,8 @@ public struct PostgreSQLDataType: Codable, Equatable, ExpressibleByIntegerLitera
     public static let time = PostgreSQLDataType(1083)
     public static let timestamp = PostgreSQLDataType(1114)
     public static let _timestamp = PostgreSQLDataType(1115)
+    public static let timestamptz = PostgreSQLDataType(1184)
+    public static let timetz = PostgreSQLDataType(1266)
     public static let numeric = PostgreSQLDataType(1700)
     public static let void = PostgreSQLDataType(2278)
     public static let uuid = PostgreSQLDataType(2950)

Sources/PostgreSQL/Data/PostgreSQLData+Date.swift

@@ -7,21 +7,22 @@ extension Date: PostgreSQLDataConvertible {
             case .timestamp: return try value.parseDate(format:  "yyyy-MM-dd HH:mm:ss")
             case .date: return try value.parseDate(format:  "yyyy-MM-dd")
             case .time: return try value.parseDate(format:  "HH:mm:ss")
-            default: throw PostgreSQLError(identifier: "date", reason: "Could not parse Date from text data type: \(data.type).")
+            default: throw PostgreSQLError.decode(Date.self, from: data)
             }
         case .binary(let value):
             switch data.type {
-            case .timestamp, .time:
+            case .timestamp, .timestamptz:
                 let microseconds = value.as(Int64.self, default: 0).bigEndian
                 let seconds = Double(microseconds) / Double(_microsecondsPerSecond)
                 return Date(timeInterval: seconds, since: _psqlDateStart)
+            case .time, .timetz: throw PostgreSQLError.decode(Date.self, from: data)
             case .date:
                 let days = value.as(Int32.self, default: 0).bigEndian
                 let seconds = days * _secondsInDay
                 return Date(timeInterval: Double(seconds), since: _psqlDateStart)
-            default: throw PostgreSQLError(identifier: "date", reason: "Could not parse Date from binary data type: \(data.type).")
+            default: throw PostgreSQLError.decode(Date.self, from: data)
             }
-        case .null: throw PostgreSQLError(identifier: "data", reason: "Could not decode String from null.")
+        case .null: throw PostgreSQLError.decode(Date.self, from: data)
         }
     }
 

Tests/PostgreSQLTests/PostgreSQLConnectionTests.swift

@@ -489,21 +489,41 @@ class PostgreSQLConnectionTests: XCTestCase {
         )).wait()
         XCTAssertEqual(save.count, 0)
 
-        let search = try conn.query(.dml(
-            statement: .select,
-            table: "users",
-            keys: [.all],
-            predicates: [.predicate("name", .equal, .bind("vapor"))]
-            )).wait()
+        let search = try conn.query(.select([.all], from: "users", where: [.predicate("name", .equal, .bind("vapor"))]
+        )).wait()
         XCTAssertEqual(search.count, 1)
 
         try conn.query(.select(["id", "name", "pet"], from: "users")) { row in
             print(row)
         }.wait()
     }
+    
+    // https://github.com/vapor/postgresql/issues/63
+    func testTimeTz() throws {
+        let conn = try PostgreSQLConnection.makeTest(transport: .cleartext)
+        _ = try conn.simpleQuery(.create(table: "timetest", columns: [
+            .column("timestamptz", .columnType("TIMESTAMPTZ"))
+        ])).wait()
+        defer { _ = try? conn.simpleQuery(.drop(table: "timetest")).wait() }
+        
+        struct Time: Codable, Equatable {
+            var timestamptz: Date
+        }
+        
+        let time = Time(timestamptz: .init())
+        _ = try conn.query(.insert(into: "timetest", values: SQLRowEncoder().encode(time))).wait()
+        
+        let fetch = try conn.query(.select([.all], from: "timetest"), decoding: Time.self).wait()
+        switch fetch.count {
+        case 1:
+            XCTAssertEqual(fetch[0], time)
+        default: XCTFail("invalid row count")
+        }
+    }
 
     static var allTests = [
         ("testVersion", testVersion),
+        ("testTimeTz", testTimeTz),
     ]
 }