fastify-atdatabase-pg
v0.2.0
Published
This module provides a way to use postgressql database.
Downloads
7
Maintainers
Readme
fastify-atdatabase-pg
This module provides a way to connect to PostgreSQL database using @databases/pg
Install
npm i fastify-atdatabase-pg
Usage
Add it to you project with register
and you are done!
const fastify = require('fastify')()
fastify.register(require('fastify-atdatabase-pg'), {
connectionString: 'postgres://postgres:postgres@localhost:5432/postgres',
bigIntMode: 'string'
})
fastify.get('/', async (req, reply) => {
const result = await fastify.pg.db.query(fastify.pg.sql`SELECT 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:
const fastify = require('fastify')()
fastify.register(require('fastify-atdatabase-pg'), {
namespace: 'primary',
connectionString: 'postgres://postgres:postgres@primary:5432/primary',
bigIntMode: 'string'
})
fastify.register(require('fastify-atdatabase-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.sql`SELECT NOW()`)
return reply.send(result)
})
fastify.get('/secondary', async (req, reply) => {
const result = await fastify.pg.secondary.db.query(fastify.pg.secondary.sql`SELECT NOW()`)
return reply.send(result)
})
fastify.listen({ port: 3000 }, err => {
if (err) throw err
})
Bulk insert is also available:
const fastify = require('fastify')()
fastify.register(require('fastify-atdatabase-pg'), {
connectionString: 'postgres://postgres:postgres@localhost:5432/postgres',
bigIntMode: 'string'
})
fastify.get('/:text', async (req, reply) => {
const {text} = req.params
const options = {
tableName: 'samples',
columnTypes: {
sample_data: fastify.pg.sql`TEXT`
}
}
const columnsToInsert = [
'sample_data'
]
const records = [
{ sample_data: text },
]
await fastify.pg.bulkInsert(options, columnsToInsert, records)
const results = await fastify.pg.db.query(fastify.pg.sql`SELECT * FROM samples`)
return reply.send(results)
})
fastify.listen({ port: 3000 }, err => {
if (err) throw err
})
Documentation
More details about @databases/pg
documentation, see @databases/pg