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

发布时间：2020-12-14 04:32:34 所属栏目：百科来源：网络整理

导读：我正在尝试使用Vapor和Fluent查询Postgres数据库的独立脚本.在普通的Vapor API应用程序中,这可以通过以下方式完成： router.get("products") { request in return Product.query(on: request).all()} 但是,在独立脚本中,由于没有“请求”,因此我无法替换“re

我正在尝试使用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:_:)完成工作后关闭工作人员

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!