MongoDB + Vapor integration
A library for building applications with MongoDB + Vapor.
Think you’ve found a bug? Want to see a new feature in mongodb-vapor? Please open a case in our issue management tool, JIRA:
Bug reports in JIRA for all driver projects (i.e. NODE, PYTHON, CSHARP, JAVA) and the
Core Server (i.e. SERVER) project are public.
This library works with Swift 5.2+ , and supports Linux and macOS usage. The minimum macOS version required is 10.15.
Installation is supported via Swift Package Manager.
If you are using macOS, you can skip ahead.
The driver vendors and wraps the MongoDB C driver (libmongoc), which depends on a number of external C libraries when built in Linux environments. As a result, these libraries must be installed on your system in order to build MongoSwift.
To install those libraries, please follow the instructions from libmongoc’s documentation.
To create a new project using the library, the easiest way to get started is by using
Vapor’s command line tool, Vapor Toolbox, along with our application template:
vapor new MyProject --template https://github.com/mongodb/mongodb-vapor-template/
This will create a new project from a template, which you can edit to your liking. See the instructions here or in the generated README for more details on the generated project.
Alternatively, you can integrate this library manually in a SwiftPM project by adding it along with Vapor as dependencies in your project’s Package.swift file:
// swift-tools-version:5.2
import PackageDescription
let package = Package(
name: "VaporExample",
platforms: [
.macOS(.v10_15)
],
dependencies: [
.package(url: "https://github.com/vapor/vapor", .upToNextMajor(from: "4.7.0")),
.package(url: "https://github.com/mongodb/mongodb-vapor", .upToNextMajor(from: "1.1.0"))
],
targets: [
.target(
name: "App",
dependencies: [
.product(name: "Vapor", package: "vapor"),
.product(name: "MongoDBVapor", package: "mongodb-vapor")
]
),
.target(name: "Run", dependencies: [
.target(name: "App"),
.product(name: "MongoDBVapor", package: "mongodb-vapor")
])
]
)
Then run swift build to download, compile, and link all your dependencies.
Note that if you are using this library on Docker with Vapor’s default Docker template file, you’ll need to install the system
dependencies the driver requires on Linux, as mentioned above.
To do this, add the following to your Dockerfile:
RUN apt-get update && apt-get install -y libssl-dev
A user @dotmain has also created a Vapor template that includes Docker configuration here.
To summarize the available features:
In your configure(_:) method in App/configure.swift, add:
// Configure the app for using a MongoDB server at the provided connection string.
try app.mongoDB.configure("mongodb://localhost:27017")
In Run/main.swift, add:
import MongoDBVapor
defer {
// Cleanup the application's MongoDB data.
app.mongoDB.cleanup()
// Clean up the driver's global state. The driver will no longer be usable from this program after this method is
// called.
cleanupMongoSwift()
}
For collections you plan to access frequently, we recommend adding computed properties in an extension to Request
to provide easy access, like:
extension Request {
/// A collection with an associated `Codable` type `Kitten`.
var kittenCollection: MongoCollection<Kitten> {
self.application.mongoDB.client.db("home").collection("kittens", withType: Kitten.self)
}
}
You can then use these in request handlers as follows:
/// Handles a request to load the list of kittens.
app.get("kittens") { req async throws -> [Kitten] in
try await req.kittenCollection.find().toArray()
}
/// Handles a request to add a new kitten.
app.post("kittens") { req async throws -> Response in
let newKitten = try req.content.decode(Kitten.self)
try await req.kittenCollection.insertOne(newKitten)
return Response(status: .created)
}
EventLoopFuture APIsFor collections you plan to access frequently, we recommend adding computed properties in an extension to Request
to provide easy access, like:
extension Request {
/// A collection with an associated `Codable` type `Kitten`.
var kittenCollection: MongoCollection<Kitten> {
self.mongoDB.client.db("home").collection("kittens", withType: Kitten.self)
}
}
Any client, database, or collection object you access via Request.mongoDB will automatically return EventLoopFutures
on the same EventLoop the Request is being handled on, simplifying thread safety concerns and improving performance
by removing the need to hop the returned futures.
You can then use these in request handlers as follows:
/// Handles a request to load the list of kittens.
app.get("kittens") { req -> EventLoopFuture<[Kitten]> in
req.kittenCollection.find().flatMap { cursor in
cursor.toArray()
}
}
/// Handles a request to add a new kitten.
app.post("kittens") { req -> EventLoopFuture<Response> in
let newKitten = try req.content.decode(Kitten.self)
return req.kittenCollection.insertOne(newKitten)
.map { _ in Response(status: .created) }
}
If you have one-time code you’d like to run each time your application starts up, e.g. in Run/main.swift, you can
use the global client, accessible via Application.mongoDB:
// Configure the app for using a MongoDB server at the provided connection string.
try app.mongoDB.configure("mongodb://localhost:27017")
let coll = app.mongoDB.client.db("home").collection("kittens")
// creates a unique index if it doesn't exist already.
_ = try coll.createIndex(["name": 1], indexOptions: IndexOptions(unique: true)).wait()
If you’d like to use ExtendedJSONEncoder and ExtendedJSONDecoder for encoding/decoding JSON requests/responses, in App/configure.swift, add:
// Use `ExtendedJSONEncoder` and `ExtendedJSONDecoder` for encoding/decoding `Content`.
ContentConfiguration.global.use(encoder: ExtendedJSONEncoder(), for: .json)
ContentConfiguration.global.use(decoder: ExtendedJSONDecoder(), for: .json)
Note that this is currently required if you want to use BSONDocument as a Content type and e.g.
directly return BSONDocuments from request handlers, because BSONDocument does not yet support
being encoded/decoded via JSONEncoder and JSONDecoder.
For more information on JSON interoperation in general with the driver, see our
JSON interop guide.