expressのモジュール化について

Question

前提・実現したいこと

ここに質問の内容を詳しく書いてください。
Postgresとexpressの接続を実装しようとしたところ
モジュール化ができずに困ってます。

発生している問題・エラーメッセージ

connection.query is not a function

該当のソースコード

dbConnection.js

var pg = require('pg');

var pool = new pg.Pool({
    database: 'bulletin_board',
    user: 'tatsuya',
    password: '',
    host: 'localhost',
    port: 5432,
});

var connection = pool.connect()

module.exports = connection;

index.js

var express = require('express');
var router = express.Router();
var moment = require('moment');
var connection = require('../dbConnection');

router.get('/', function (req, res, next) {
  res.render('index', { title: 'Express' });
});

router.post('/', function (req, res, next) {
  var title = req.body.title;
  var createdAt = moment().format('YYYY-MM-DD HH:mm:ss');
  var query = 'INSERT INTO boards (title, created_at) VALUES ("' + title + '", ' + '"' + createdAt + '")';
  connection.query(query, function (err, rows) {
    res.redirect('/');
  });
});

module.exports = router;

試したこと

ここに問題に対して試したことを記載してください。

補足情報（FW/ツールのバージョンなど）

ここにより詳細な情報を記載してください。

Answer 1

node-postgres のドキュメントを見ると、 pool.connect() はcallbackの引数または、Promiseでclientを返すとあります。そのため、dbConnectionモジュールからインポートした connection に query 関数が無いのはある意味期待通りの挙動です。

解決策としては、以下のように dbConnection.js からは、poolを直接exportし、index.js側で、poolからconnectionを取り出す方法が良いかと思います。

var pg = require('pg');

var pool = new pg.Pool({
    database: 'bulletin_board',
    user: 'tatsuya',
    password: '',
    host: 'localhost',
    port: 5432,
});


module.exports = pool;

var express = require('express');
var router = express.Router();
var moment = require('moment');
var pool = require('../dbConnection');

router.get('/', function (req, res, next) {
  res.render('index', { title: 'Express' });
});

router.post('/', function (req, res, next) {
  var title = req.body.title;
  var createdAt = moment().format('YYYY-MM-DD HH:mm:ss');
  var query = 'INSERT INTO boards (title, created_at) VALUES ("' + title + '", ' + '"' + createdAt + '")';
  pool.connect((err, client, done) => {
      client.query(query, function (err, rows) {
      res.redirect('/');
      done();
  });
  });
});

module.exports = router;

要件次第ではありますが、トランザクションが不要の場合次のようにsingle queryとして利用することもできるようです。

const { Pool } = require('pg')
const pool = new Pool()
pool.query('SELECT * FROM users WHERE id = $1', [1], (err, res) => {
  if (err) {
    throw err
  }
  console.log('user:', res.rows[0])
})