Используйте соединение Postgresql на NodeJS (экспресс) - PullRequest
Новая
       9

Используйте соединение Postgresql на NodeJS (экспресс)

0 голосов
/ 26 октября 2018

Я новичок в NodeJS и Express, я следовал руководству по созданию CRUD с подключением к Mysql, где используется «express-myconnection», это подключение записывается как промежуточное ПО и используется из модели или контроллера.Но мне нужно работать с postgresql, мне удалось установить соединение, моя проблема в том, что я не могу вызвать его из модели или контроллера 

const express = require('express');
const path = require('path');
const morgan = require('morgan');
const app = express();
const { Client } = require('pg');
const connectionData = {
    user: 'postgres',
    host: 'localhost',
    database: 'bex',
    password: 'postgres',
    port: 5432,
}
const client = new Client(connectionData);
client.connect()
client.query('SELECT * FROM bex_usuario')
    .then(response => {
        console.log(response.rows)
        client.end()
    })
    .catch(err => {
        client.end()
    })

Как бы вы создали промежуточное ПО, похожее на "express-myconnection ", или как бы вы создали экземпляр из моей модели или контроллера без необходимости определять его в каждой модели или контроллере?

1 Ответ

0 голосов
/ 26 октября 2018 
const { Pool } = require('pg');

function connectionMiddleware(connectionData) {
    const pool = new Pool(connectionData);
    return (req, res, next) => {
        req.pool = pool;
        next();
    }
}

app.use(connectionMiddleware({
    user: 'postgres',
    host: 'localhost',
    database: 'bex',
    password: 'postgres',
    port: 5432,
}));

app.use((req, res, next) => {
    req.pool.connect((err, client, release) => {
        client.query('SELECT NOW()', (err, result) => {
             release();
             if (err) return next(err);
             console.log(result.rows);
             res.send(200);
         });   
    });
});
...