swift – 是否可以在独立脚本中使用Vapor 3 Postgres Fluent？

我正在尝试使用Vapor和Fluent查询Postgres数据库的独立脚本.在普通的Vapor API应用程序中,这可以通过以下方式完成：

router.get("products") { request in
    return Product.query(on: request).all()
}

但是,在独立脚本中,由于没有“请求”,因此我无法替换“request”或DatabaseConnectable.这是我被困在的地方：

import Fluent
import FluentPostgresql

let databaseConfig = PostgresqlDatabaseConfig(hostname: "localhost",username: "test",database: "test",password: nil)

let database = PostgresqlDatabase(config: databaseConfig)

let foo = Product.query(on: <??WhatDoIPutHere??>)

我尝试创建一个符合DatabaseConnectable的对象,但无法弄清楚如何正确地使该对象符合要求.

解决方法

您需要创建一个事件循环组才能发出数据库请求. SwiftNIO的MultiThreadedEventLoopGroup对此非常有用：

let worker = MultiThreadedEventLoopGroup(numberOfThreads: 2)

您可以根据需要更改使用的线程数.

现在,您可以使用该worker创建与数据库的连接：

let conn = try database.newConnection(on: worker)

该连接是将来的,因此您可以映射它并在查询中传递连接：

conn.flatMap { connection in
    return Product.query(on: connection)...
}

确保在使用shutdownGracefully(queue:_:)完成工作后关闭工作人员