An ESM only Fastify plugin for Postgres.js with full TypeScript support.
This plugin has two features:
postgres
module with the supplied options and adds it to the Fastify server instance;sql.end()
in the Fastify onClose
hook to close all database connections.npm install fastify-postgres-dot-js
Import the plugin, pass it to the .register
method on your Fastify instance and optionally pass postgres
module options.
import Fastify from "fastify";
import { fastifyPostgresJs } from "../";
const fastify = Fastify({
logger: true,
});
fastify.register(fastifyPostgresJs, {
host: "localhost",
port: 5431,
database: "postgres",
username: "some_user",
password: "some_password",
});
interface Foo {
foo: string;
}
fastify.get("/:id", async function (request) {
interface Params {
id: string;
}
const { id } = request.params as Params;
const foo = await request.server.sql<Foo[]>`
SELECT "bar" FROM "foo" WHERE id = ${id};
`;
return foo[0];
});
try {
await fastify.listen({
port: 3000,
});
} catch (err) {
fastify.log.error(err);
process.exit(1);
}
If your Postgres connection details are environment variables, you may not need to pass any options.
.env file:
PGUSER=some_user
PGHOST=localhost
PGPASSWORD=some_password
PGDATABASE=postgres
PGPORT=5432
TypeScript file:
import "dotenv/config";
import Fastify from "fastify";
import { fastifyPostgresJs } from "../";
const fastify = Fastify({
logger: true,
});
fastify.register(fastifyPostgresJs);
interface Foo {
foo: string;
}
fastify.get("/:id", async function (request) {
interface Params {
id: string;
}
const { id } = request.params as Params;
const foo = await request.server.sql<Foo[]>`
SELECT "bar" FROM "foo" WHERE id = ${id};
`;
return foo[0];
});
try {
await fastify.listen({
port: 3000,
});
} catch (err) {
fastify.log.error(err);
process.exit(1);
}
First, start postgres with:
npm run postgres
Then run the database migration:
npm run migrate