如何使用Node.js net.Socket与Postgresql数据库通信就像使用终端一样

#create database new database;

创建数据库

上面我在终端输入命令“create database newdatabase;”数据库程序响应“CREATE DATABASE”

我试图做同样的事情,但使用节点net.socket.换句话说,我想向我在localhost：5432上运行的POSTGResql服务器发出命令,并通过套接字获得响应.

我的程序成功建立了与POSTGResql服务器的连接并成功将数据刷新到内核,但我从未得到响应(数据监听器永远不会被触发).新数据库也不会被创建.

我还快速了解了wireshark上发生的事情.看起来套接字得到了设置.我看到我的数据以明文形式发送. POSTGResql服务器然后发送ACK FIN ACK.我确认FIN ACK,然后POSTGResql服务器最后一次确认.所以我知道POSTGResql服务器不会发回任何数据.

我的问题是,为什么POSTGResql服务器会忽略我发送它的命令以及为什么POSTGResql服务器不会向我发回任何数据,即使该数据只是一个错误.

const net = require('net');
const BlueBird = require('bluebird');

BlueBird.coroutIne(function* () {

var host = "127.0.0.1";
var port = "5432";
var idle_timeout = 10000;

var MySocket = new net.socket();
MySocket.setTimeout(idle_timeout);

var data = yield new Promise(

    function resolver(resolve,reject) {

        MySocket.on('connect',function () {
            var flushed = MySocket.write("create database newdatabase;","utf8");
            console.log("Data flushed to kernel: " + flushed);
        });

        MySocket.on('data',function (data) {
            console.log(data);
            resolve(data);
        });

        MySocket.on('error',function (error) {
            reject(error);
        });

        MySocket.connect(port,host);

    }

    );

    return data;

})()
.then(function (data) {

    console.log(data);

    return data;

})
.catch(function (error) {

    console.error(error);

})