Node.jsにて、PostgreSQLのデータを上手くEJSファイルに渡せません。

Question

前提

お世話になります。

node.jsで制作しているメモアプリで、現在MySQLからPostgreSQLへの移行を試みているのですが、そこで発生した問題についてお尋ねさせてください。
viewファイルにはEJSファイルを使用しております（EJSというのは、HTML内にJavascriptを簡単に記述できるJSのテンプレートエンジンです）。

先日投稿いたしました投稿（ https://teratail.com/questions/6zqnuiwft1zlkp ）の続きで、実行時に起こるエラーが変わりましたので、このたび質問を投稿し直すこととなりました。
見ていただかなくても今回の質問に差し障りはないと思いますが、以前発生していたエラーをご覧いただく際は、お手数ですが上記のページをご参照いただけますと幸いです。

メモアプリのルーティングについて簡単に説明しますと、/indexでメモの一覧情報を取得し/trashでゴミ箱に入れたメモの一覧ページを取得、また/newで新規メモの作成、/edit/:idで任意のメモの編集が行えるという感じです。

発生している問題

app.jsにて、PostgreSQLのテーブルデータをdata.rowsという形でEJSファイルに渡しているのですが、実際にアプリを実行すると次のような流れでエラーが発生します。

まず、アプリを実行して最初に'localhost:8001/index'、または'localhost:8001/trash'にアクセスすると、問題なくページを読み込むことができます。
しかし、そこから違うページを取得しようとすると、下記の出力結果における14行目以降のようなエラーが起こり、接続が途絶えてしまいます。

Listeninng on 8001   // 1行目: アプリ実行時にconsole.infoで出力されるテキスト
[   // 2~12行目: アプリを実行後、初めて/indexもしくは/trashにアクセスした際にconsole.logで出力されるdata.rowsの内容（/indexの場合）
  {
    id: 1,
    title: 'hoge',
    content: 'huga',
    created: 2023-12-01T07:16:14.517Z,
    modified: 2023-12-06T07:32:17.110Z,
    is_removed: false,
    is_locked: false,
    modified_stamp: 'Dec 06 23 16:32'
  }
]
C:\Users\Kanon\workspace\memo-app\app.js:79   // 14行目~: 最初にアクセスしたページから別のページに飛ぼうとすると起こるエラー
                        console.log(data.rows);
                                         ^

TypeError: Cannot read properties of undefined (reading 'rows')
    at Query.callback (C:\Users\Kanon\workspace\memo-app\app-new.js:79:21)
    at Query.handleError (C:\Users\Kanon\workspace\memo-app\node_modules\pg\lib\query.js:128:19)
    at C:\Users\Kanon\workspace\memo-app\node_modules\pg\lib\client.js:580:15
    at processTicksAndRejections (node:internal/process/task_queues:78:11)

/indexに最初にアクセスするとそこから/trashにアクセスする際にエラーが起こり、/trashに最初にアクセスすると逆の結果になります。
/newにはいつでもアクセスできるのですが、新規メモのデータを保存しようとするとエラーが起こりました。
/edit/:idに至っては、最初のアクセスからエラーが起こり、常に取得ができない状態です。

なお、どのケースでも発生するエラーメッセージに変わりはありませんでした。

該当のソースコード・テーブル

こちらが該当のテーブル情報です。

memo_app=# \d memos
                                                     テーブル"public.memos"
       列       |           タイプ            | 照合順序 | Null 値を許容 |                      デフォルト
----------------+-----------------------------+----------+---------------+-------------------------------------------------------
 id             | integer                     |          | not null      | nextval('memos_id_seq'::regclass)
 title          | character varying(40)       |          |               | 'Untitled'::character varying
 content        | character varying(10485760) |          |               |
 created        | timestamp without time zone |          | not null      | CURRENT_TIMESTAMP
 modified       | timestamp without time zone |          | not null      | CURRENT_TIMESTAMP
 is_removed     | boolean                     |          | not null      | false
 is_locked      | boolean                     |          | not null      | false
 modified_stamp | character varying(15)       |          |               | generated always as (custom_to_char(modified)) stored
インデックス:
    "memos_pkey" PRIMARY KEY, btree (id)
トリガー:
    update_tri BEFORE UPDATE ON memos FOR EACH ROW EXECUTE FUNCTION set_update_time()

また、該当のJSファイル（app.jsとmodule.js）はこちらです。

const express = require('express');
const mod = require('./module')
const app = express();

app.use(express.static('public'));
app.use(express.urlencoded({extended: false}));

// Memo Listの取得
app.get('/index', (req, res) => {
	const connection = mod.connection;
	connection.query(
		'SELECT * FROM memos WHERE is_removed = false',
		(err, data) => {
			const result = data.rows;
			console.log(result);
			res.render('index.ejs', {memos: result});
			connection.end();
		}
	);
});

// 新規メモの作成ページを表示
app.get('/new', (req, res) => {
	res.render('new.ejs');
});

// 新規メモを保存
app.post('/create', (req, res) => {
	const connection = mod.connection;
	connection.query(
		'INSERT INTO memos (title, content) VALUES (?, ?)',
		[req.body.memoTitle, req.body.memoContent],
		(err, data) => {
			res.redirect('/index');
			connection.end();
		}
	);
});

// メモの編集ページを取得
app.get('/edit/:id', (req, res) => {
	const connection = mod.connection;
	connection.query(
		'SELECT * FROM memos WHERE id = ?',
		[req.params.id],
		(err, data) => {
			const result = data.rows;
			res.render('edit.ejs', {memo: result[0]});
			connection.end();
		}
	);
});

// メモを更新
app.post('/update/:id', (req, res) => {
	const connection = mod.connection;
	connection.query(
		'UPDATE memos SET title = ?, content= ?  WHERE id = ?',
		[req.body.memoTitle, req.body.memoContent, req.params.id],
		(err, data) => {
			res.redirect('/index');
			connection.end();
		}
	);
});

// Trash Listの取得
app.get('/trash', (req, res) => {
	const connection = mod.connection;
	connection.query(
		'SELECT * FROM memos WHERE is_removed = true',
		(err, data) => {
			const result = data.rows;
			console.log(result);
			res.render('trash.ejs', {memos: result});
			connection.end();
		}
	);
});

const { Client } = require('pg');

const connection = new Client({
	user: 'postgres',
	host: 'localhost',
	database: 'hoge',
	password: 'huga',
	port: 5432,
});

connection.connect();

module.exports = {
	connection
}

試したこと

エラー文を検索したところ、'TypeError: Cannot read properties of undefined (reading 'hoge')'というエラーはその値がundefinedの時に起こるという情報が見つかりました。
しかし、rows配列は存在しており、実際に一度目のアクセスでは取得が可能なため、解決に紐付けることはできませんでした。
参照したのは以下のページです。
https://magazine.techacademy.jp/magazine/26836

また、以下のような英語の記事をいくつか参照してみたのですが、今回の問題とは原因が少し異なるようでした（恥ずかしながら英語にあまり強くないため、正しく読み取れていない可能性は大いにあります）。
https://discourse.metabase.com/t/cannot-read-properties-of-undefined-reading-rows/18166
https://github.com/TanStack/table/issues/5098

他に、data.rowsを変数に代入してからEJSファイルに渡したりもしたのですが、特に関係はなかったようです。

追記（2023/12/07）

/edit:idのページの取得時にエラーが出る問題については、取得したテーブルデータを第二引数に指定する際のクエリ記法がMySQLとPostgresで異なっていることが原因でした。
/edit:id以外のルーティングでも使用していた記法ですので、全て以下のように修正することで問題なくデータを取得できるようになりました。

// MySQLの記法
app.get('/edit/:id', (req, res) => {
	pool.query(
		'SELECT * FROM memos WHERE id = $1',   // '?'という書き方はPostgreSQLに対応していない
		[req.params.id],
		(error, results) => {
			res.render('edit.ejs', {memo: results.rows[0]});
		}
	);
});

// PostgreSQLの記法
app.get('/edit/:id', (req, res) => {
	pool.query(
		'SELECT * FROM memos WHERE id = $1',   // '?'の部分をPostgreSQLの記法に合わせ'$1'という書き方に変更
		[req.params.id],
		(error, results) => {
			res.render('edit.ejs', {memo: results.rows[0]});
		}
	);
});

参照したページは以下です。
https://qiita.com/sa9ra4ma/items/765660dfd6936aeaff1b

また、文字数の上限に達したため、今回の問題とは関係がなかったviewsファイルの情報を削除しました。

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

実行環境はWindows11です。

Node: v16.14.2
MySQL: v8.0.3
PostgreSQL: v16.1

他にご入用の情報があれば仰ってくださいませ。
知識が浅くて恐縮ですが、どうぞよろしくお願いいたします。

Comments

[hoshi-takanori]

エラーメッセージを直訳すると data.rows における data が undefined ってことです。connection.query のコールバックには err と data の 2 つの引数がありますが、query でエラーが起きた場合は err にエラー内容が渡され、data は undefined になります。その辺に転がってるサンプルコードではエラー処理は省略されることが多いですが、現実のコードでは必ず err をチェックして、適切なエラーハンドリングを行う必要があります。
で、エラーの原因はたぶん connection.end() で接続を切った後に connection を使おうとしてることかと。そして、Web アプリでは基本的に生の connection ではなく、connection pool を使うべきでしょうね…。

[kanon_2155103]

> hoshi-takanori様
前回に引き続き、ありがとうございます！
connection poolを使用し、'pool.connect()'をスコープ外で宣言したところ、問題なく動作するようになりました！

変更点はこちら主に下記のふたつです。

// app.jsにて以下のコードを追加し、それに伴い不要になったコード（スコープ内のconnect()やend()など）を削除しました。
const port = process.env.PORT || 8001;
pool.connect((err) => {
if (err) {
console.log('error connecting: ' + err.stack);
return;
}
app.listen(port, () => {
console.info(`Listeninng on ${port}`);
});
});

// module.jsの内容を以下のように変更しました。
const { Pool } = require('pg');
const pool = new Pool({
user: 'postgres',
host: 'localhost',
database: 'memo_app',
password: 'Wqttqpe1551krpl',
port: 5432,
});
module.exports = {
pool
}

[kanon_2155103]

また、/editアクセス時のエラーはクエリ内での引数の指定の仕方がMySQLとPostgreSQLで違うことが原因でした。詳しくは質問本文の追記欄に記載いたしますが、こちらについても解決できました。

ところで、ベストアンサーへのご指名についてはどうすればよいでしょうか？
私といたしましては、ぜひ回答の方に何らかの投稿をしていただけましたらと思うのですが、もしお望みでないようでしたらこのまま自己解決として処理いたします。