Node.jsを使用したwebsocketサーバからPostgreSQLのDBにアクセスしたい。

Question

環境：
Windows10
Node.js(v6.10.3)

タイトルの通りです。
Node.js + WebSocket + node-postgres
を使用しています。

クライアントからメッセージを受信したらPostgresのDB
にserect文を発行し結果を返すプログラムを作成しています。
色々なサイトを参考にさせていただき、
上記処理は動くようになったのですが、２回目のメッセージ受信時、
connectのタイミングで"Client has already connected"のエラーが発生してしまいます。

そこで、質問として
・pgClient.endをコールしたタイミングで接続は切れないのでしょうか？
・接続を切るにはどうすればよいでしょうか？
・都度connectするのではなくサーバアプリ起動時にconnectし、
ずっと繋ぎっぱなしにするのが正しいのでしょうか？(endは呼ばない)
(その場合、アプリ終了時にendをコール？)

大変初的な質問で申し訳ありませんが、宜しくお願い致します。

var server = require('ws').Server;
var s = new server({ port:8080 });

var pg = require('pg');
var pgClinat = new pg.Client({
    user: 'postgres',
    host: 'localhost',
    database: 'sample',
    password: 'password',
    port: '5432',
})

s.on('connection',function(ws){
    console.log("connect a cliant");

    ws.on('message',function(message){
        console.log("received: "+message);

        pgClinat.connect(function(err){
            if(err){
                return console.error('connect error : ',err);
            }
            pgClinat.query('SELECT * FROM TESTTABLE2',(err,res)=>{
                if(err){
                    return console.error('query error : ',err);
                }

                var resTxt = JSON.stringify(res.rows[0]);
                s.clients.forEach(function(client) {
                    client.send(resTxt);
                });
    
                pgClinat.end(function(){
                    console.log('connection end ');
                });
            })
        });
    })

    ws.on('close',function(){
        console.log("lost a cliant");
    })
})

Answer 1

以下のように変更し、pgClientを毎回生成すれば行けると思います。
てかteratailってdiffの色付け表示してくれないんですね。

 var server = require('ws').Server;
 var s = new server({ port:8080 });
 
 var pg = require('pg');
-var pgClinat = new pg.Client({
+var CLIENT_CONFIG = {
     user: 'postgres',
     host: 'localhost',
     database: 'sample',
     password: 'password',
     port: '5432',
-})
+};
 
 s.on('connection',function(ws){
     console.log("connect a cliant");
 
     ws.on('message',function(message){
         console.log("received: "+message);
 
+        var pgClinat = new pg.Client(CLIENT_CONFIG);
         pgClinat.connect(function(err){
             if(err){
                 return console.error('connect error : ',err);
             }
             pgClinat.query('SELECT * FROM TESTTABLE2',(err,res)=>{
                 if(err){
                     return console.error('query error : ',err);
                 }
 
                 var resTxt = JSON.stringify(res.rows[0]);
                 s.clients.forEach(function(client) {
                     client.send(resTxt);
                 });
 
                 pgClinat.end(function(){
                     console.log('connection end ');
                 });
             })
         });
     })
 
     ws.on('close',function(){
         console.log("lost a cliant");
     })
 })

Comments

[tomo117722]

回答頂き、ありがとうございます。
返信が遅くなりすみませんでした・・

出来ました！