update to sql protocols 2.0

Author: tanner0101

Package.swift

@@ -12,13 +12,13 @@ let package = Package(
         .package(url: "https://github.com/vapor/core.git", from: "3.0.0"),
 
         // Swift ORM framework (queries, models, and relations) for building NoSQL and SQL database integrations.
-        .package(url: "https://github.com/vapor/fluent.git", from: "3.0.0-rc"),
+        .package(url: "https://github.com/vapor/fluent.git", .branch("sql")),
 
         // 🐘 Non-blocking, event-driven Swift client for PostgreSQL.
-        .package(url: "https://github.com/vapor/postgresql.git", from: "1.0.0-rc"),
+        .package(url: "https://github.com/vapor/postgresql.git", .branch("sql")),
     ],
     targets: [
-        .target(name: "FluentPostgreSQL", dependencies: ["Async", "Fluent", "PostgreSQL"]),
+        .target(name: "FluentPostgreSQL", dependencies: ["Async", "FluentSQL", "PostgreSQL"]),
         .testTarget(name: "FluentPostgreSQLTests", dependencies: ["FluentBenchmark", "FluentPostgreSQL"]),
     ]
 )

Sources/FluentPostgreSQL/Deprecated.swift

@@ -18,10 +18,10 @@ public protocol PostgreSQLEnumType { }
 public protocol PostgreSQLType { }
 
 
-extension QueryBuilder where Database == PostgreSQLDatabase {
-    /// - warning: Deprecated.
-    @available(*, deprecated, renamed: "groupBy(_:)")
-    public func group<T>(by field: KeyPath<Result, T>) -> Self {
-        return groupBy(field)
-    }
-}
+//extension QueryBuilder where Database == PostgreSQLDatabase {
+//    /// - warning: Deprecated.
+//    @available(*, deprecated, renamed: "groupBy(_:)")
+//    public func group<T>(by field: KeyPath<Result, T>) -> Self {
+//        return groupBy(field)
+//    }
+//}

Sources/FluentPostgreSQL/Exports.swift

@@ -1,2 +1,31 @@
-@_exported import Fluent
+@_exported import FluentSQL
 @_exported import PostgreSQL
+
+//extension QueryBuilder where Database == PostgreSQLDatabase {
+//    public func keys(_ keys: PostgreSQLQuery.Key...) -> Self {
+//        query.keys = keys
+//        return self
+//    }
+//
+//    // MARK: Group By
+//
+//    /// Adds a group by to the query builder.
+//    ///
+//    ///     query.groupBy(\.name)
+//    ///
+//    /// - parameters:
+//    ///     - field: Swift `KeyPath` to field on model to group by.
+//    /// - returns: Query builder for chaining.
+//    public func groupBy<T>(_ field: KeyPath<Result, T>) -> Self {
+//        return groupBy(.expression(.column(PostgreSQLDatabase.queryField(.keyPath(field))), alias: nil))
+//    }
+//
+//    /// Adds a manually created group by to the query builder.
+//    /// - parameters:
+//    ///     - groupBy: New `Query.GroupBy` to add.
+//    /// - returns: Query builder for chaining.
+//    public func groupBy(_ groupBy: PostgreSQLQuery.Key) -> Self {
+//        query.groupBy.append(groupBy)
+//        return self
+//    }
+//}

Sources/FluentPostgreSQL/FluentPostgreSQLProvider.swift

@@ -23,7 +23,7 @@ public final class FluentPostgreSQLProvider: Provider {
         }
 
         return worker.withPooledConnection(to: .psql) { conn in
-            return conn.simpleQuery("SELECT current_setting('server_version') as version", decoding: Setting.self).map { rows in
+            return conn.select().column(.function("current_setting", [.expression(.literal(.string("server_version")))], as: .identifier("version"))).all(decoding: Setting.self).map { rows in
                 _serverVersion = rows[0].version
                 if let versionString = _serverVersion {
                     let pointIndex = versionString.index(of: ".") ?? versionString.endIndex

Sources/FluentPostgreSQL/FluentPostgreSQLQuery.swift

@@ -0,0 +1,53 @@
+public enum FluentPostgreSQLQueryStatement: FluentSQLQueryStatement {
+    public static var insert: FluentPostgreSQLQueryStatement { return ._insert }
+    public static var select: FluentPostgreSQLQueryStatement { return ._select }
+    public static var update: FluentPostgreSQLQueryStatement { return ._update }
+    public static var delete: FluentPostgreSQLQueryStatement { return ._delete }
+    
+    public var isInsert: Bool {
+        switch self {
+        case ._insert: return true
+        default: return false
+        }
+    }
+    
+    case _insert
+    case _select
+    case _update
+    case _delete
+}
+
+public struct FluentPostgreSQLQuery: FluentSQLQuery {
+    public typealias Statement = FluentPostgreSQLQueryStatement
+    public typealias TableIdentifier = PostgreSQLTableIdentifier
+    public typealias Expression = PostgreSQLExpression
+    public typealias SelectExpression = PostgreSQLSelectExpression
+    public typealias Join = PostgreSQLJoin
+    public typealias OrderBy = PostgreSQLOrderBy
+    
+    public var statement: Statement
+    public var table: TableIdentifier
+    public var keys: [SelectExpression]
+    public var values: [String : Expression]
+    public var joins: [Join]
+    public var predicate: Expression?
+    public var orderBy: [OrderBy]
+    public var limit: Int?
+    public var offset: Int?
+    public var defaultBinaryOperator: GenericSQLBinaryOperator
+    
+    public static func query(_ statement: Statement, _ table: TableIdentifier) -> FluentPostgreSQLQuery {
+        return .init(
+            statement: statement,
+            table: table,
+            keys: [],
+            values: [:],
+            joins: [],
+            predicate: nil,
+            orderBy: [],
+            limit: nil,
+            offset: nil,
+            defaultBinaryOperator: .and
+        )
+    }
+}

Sources/FluentPostgreSQL/FluentPostgreSQLSchema.swift

@@ -0,0 +1,34 @@
+public enum FluentPostgreSQLSchemaStatement: FluentSQLSchemaStatement {
+    public static var createTable: FluentPostgreSQLSchemaStatement { return ._createTable }
+    public static var alterTable: FluentPostgreSQLSchemaStatement { return ._alterTable }
+    public static var dropTable: FluentPostgreSQLSchemaStatement { return ._dropTable }
+    
+    case _createTable
+    case _alterTable
+    case _dropTable
+}
+
+public struct FluentPostgreSQLSchema: FluentSQLSchema {
+    public typealias Statement = FluentPostgreSQLSchemaStatement
+    public typealias TableIdentifier = PostgreSQLTableIdentifier
+    public typealias ColumnDefinition = PostgreSQLColumnDefinition
+    public typealias TableConstraint = PostgreSQLTableConstraint
+    
+    public var statement: Statement
+    public var table: TableIdentifier
+    public var columns: [PostgreSQLColumnDefinition]
+    public var deleteColumns: [PostgreSQLColumnIdentifier]
+    public var constraints: [PostgreSQLTableConstraint]
+    public var deleteConstraints: [PostgreSQLTableConstraint]
+    
+    public static func schema(_ statement: Statement, _ table: TableIdentifier) -> FluentPostgreSQLSchema {
+        return .init(
+            statement: statement,
+            table: table,
+            columns: [],
+            deleteColumns: [],
+            constraints: [],
+            deleteConstraints: []
+        )
+    }
+}