Возможно ли использовать Vapor 3 Postgres Fluent в автономном скрипте? - PullRequest
Новая
       10

Возможно ли использовать Vapor 3 Postgres Fluent в автономном скрипте?

0 голосов
/ 15 декабря 2018

Я экспериментирую с автономным скриптом, который будет запрашивать базу данных Postgres, используя Vapor и Fluent.В обычном приложении Vapor API это просто делается: 

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

Однако в автономном скрипте, поскольку нет «запроса», я застреваю на том, что заменить «запрос» или 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, но не мог понять, как правильно заставить этот объект соответствовать.

Ответы [ 2 ]

0 голосов
/ 11 марта 2019

Выше очень хорошо, но просто уточнить, насколько это просто, когда вы получите его, я сделал небольшой тестовый пример для этого.Надеюсь, это поможет вам. 

final class StandAloneTest : XCTestCase{
    var expectation : XCTestExpectation?
    func testDbConnection() -> Void {
        expectation = XCTestExpectation(description: "Wating")
        let databaseConfig = PostgreSQLDatabaseConfig(hostname: "your.hostname.here",
                                                      username: "username",
                                                      database: "databasename",
                                                      password: "topsecretpassword")
        let database = PostgreSQLDatabase(config: databaseConfig)
        let worker = MultiThreadedEventLoopGroup(numberOfThreads: 2)
        let conn = database.newConnection(on: worker)

        let sc = SomeClass( a:1, b:2, c:3  ) //etc

        //get all the tupples for this Class type in the base
        let futureTest = conn.flatMap { connection in
              return SomeClass.query(on: connection).all()
        }
        //or save a new tupple by uncommenting the below
        //let futureTest = conn.flatMap { connection in
        //    return someClassInstantiated.save(on: connection)
        //}

        //lets just wait for the future to test it 
        //(PS: this blocks the thread and should not be used in production)
        do{
            let test = try futureTest.wait()
            expectation?.fulfill()
            worker.syncShutdownGracefully()
            print( test )
        }catch{
            expectation?.fulfill()
            print(error)
        }
    }
}

//Declare the class you want to test here using the Fluent stuff in some extension
0 голосов
/ 17 декабря 2018

Вам нужно будет создать группу цикла событий, чтобы иметь возможность делать запросы к базе данных.SwiftNIO MultiThreadedEventLoopGroup подходит для этого: 

let worker = MultiThreadedEventLoopGroup(numberOfThreads: 2)

Вы можете изменять количество используемых потоков по мере необходимости.

Теперь вы можете создать соединение с базой данных с этим рабочим: 

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

Соединение в будущем, поэтому вы можете map установить его и передать соединение в своем запросе: 

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

Убедитесь, что вы выключили своего работника, когда закончилиэто используя shutdownGracefully(queue:_:)

...