fastify-atdatabases-pg

This module provides a way to connect to PostgreSQL database using @databases/pg

Install

``
npm i fastify-atdatabases-pg
`

Usage

Add it to you project with register and you are done!

`js
const fastify = require('fastify')()

fastify.register(require('fastify-atdatabases-pg'), {
connectionString: 'postgres://postgres:postgres@localhost:5432/postgres',
bigIntMode: 'string'
})

fastify.get('/', async (req, reply) => {
const result = await fastify.pg.db.query(fastify.pg.sqlSELECT NOW())
return reply.send(result)
})

fastify.listen({ port: 3000 }, err => {
if (err) throw err
})
`

You can also connect with different databases using namespaces to differentiate each other:
`js
const fastify = require('fastify')()

fastify.register(require('fastify-atdatabases-pg'), {
namespace: 'primary',
connectionString: 'postgres://postgres:postgres@primary:5432/primary',
bigIntMode: 'string'
})

fastify.register(require('fastify-atdatabases-pg'), {
namespace: 'secondary',
connectionString: 'postgres://postgres:postgres@secondary:5432/secondary',
bigIntMode: 'string'
})

fastify.get('/primary', async (req, reply) => {
const result = await fastify.pg.primary.db.query(fastify.pg.primary.sqlSELECT NOW())
return reply.send(result)
})

fastify.get('/secondary', async (req, reply) => {
const result = await fastify.pg.secondary.db.query(fastify.pg.secondary.sqlSELECT NOW())
return reply.send(result)
})

fastify.listen({ port: 3000 }, err => {
if (err) throw err
})
`

Health Checks

Use ensureReady() for health check endpoints or to wake up database:

`js
fastify.get('/health/db', async (req, reply) => {
try {
await fastify.pg.ensureReady()
return { status: 'healthy' }
} catch (err) {
reply.status(503)
return { status: 'unhealthy', error: err.message }
}
})
`

Documentation

More details about @databases/pg` documentation, see @databases/pg

License

MIT License