我是Vapor的新手,我想尝试连接我的MySQL数据库。我在官方文档中找到了如何执行此操作,但当我尝试发送查询时,它会抛出一个错误:

No services are available for 'DatabaseConnectionPoolCache'. (Container.swift:112)

我只是复制粘贴文档中的代码,但它不起作用。有人能帮我找出原因吗?

我有

MySQL @ 5.7

在

莫哈韦

. 实际上,简单的请求工作得很好,例如:

router.get("hey") { req in

return "Stas, hey"

}

configure.swift中的代码:

import FluentSQLite

import MySQL

import Vapor

/// Called before your application initializes.

public func configure(_ config: inout Config, _ env: inout Environment, _ services: inout Services) throws {

/// Register providers first

try services.register(FluentSQLiteProvider())

try services.register(MySQLProvider())

/// Register routes to the router

let router = EngineRouter.default()

try routes(router)

services.register(router, as: Router.self)

/// Register middleware

var middlewares = MiddlewareConfig() // Create _empty_ middleware config

/// middlewares.use(FileMiddleware.self) // Serves files from `Public/` directory

middlewares.use(ErrorMiddleware.self) // Catches errors and converts to HTTP response

services.register(middlewares)

// Configure a SQLite database

let sqlite = try SQLiteDatabase(storage: .memory)

/// Register the configured SQLite database to the database config.

var databases = DatabasesConfig()

databases.add(database: sqlite, as: .sqlite)

services.register(databases)

/// Configure migrations

var migrations = MigrationConfig()

migrations.add(model: Todo.self, database: .sqlite)

services.register(migrations)

//Configure a MySQL database

let mysql = try MySQLDatabase(config: MySQLDatabaseConfig(

hostname: "127.0.0.1",

port: 3306,

username: "root",

password: "7374",

database: "WORK_TIME"))

///Register to the congig

var mysqlDatabases = DatabasesConfig()

mysqlDatabases.add(database: mysql, as: .mysql)

services.register(mysqlDatabases)

}

我在main.swift中的查询:

public struct MySQLVersion: Codable {

let version: String

}

router.get("sql") { req in

return req.withPooledConnection(to: .mysql) {conn in

return conn.raw("SELECT @@version as version")

.all(decoding: MySQLVersion.self)

}.map { rows in

return rows[0].version

}

}

它应该返回我的MySQL版本,但它抛出了一个奇怪的错误。