仅用Node.js内置功能实现Postgres数据库交互是否可行？

Node.js核心模块确实没有自带PostgreSQL驱动，但可以通过内置的net（TCP套接字）和crypto模块，手动实现PostgreSQL的协议交互——因为Postgres基于TCP通信，所有客户端与服务端的交互都遵循标准报文格式。以下是具体实现步骤：

1. 用net模块建立TCP连接 #

Postgres默认监听5432端口，先通过net.createConnection建立基础连接：

const net = require('net');

const client = net.createConnection({ port: 5432, host: 'localhost' }, () => {
  console.log('已连接PostgreSQL服务端');
  // 后续发送启动报文
});

client.on('data', (data) => {
  // 处理服务端返回的各类报文
});

client.on('end', () => {
  console.log('与服务端断开连接');
});

2. 构建并发送启动报文 #

连接建立后，需要发送包含用户名、数据库名的启动报文（类型为\x00），格式需严格遵循Postgres协议：

function buildStartupMessage(user, database) {
  // 构造参数字符串：key\0value\0的格式，最后以空字节结尾
  const params = [
    `user\0${user}\0`,
    `database\0${database}\0`,
    '\0'
  ].join('');
  // 报文长度为参数字节数 + 4字节（长度字段自身）
  const length = Buffer.byteLength(params) + 4;
  const buffer = Buffer.alloc(length);
  buffer.writeInt32BE(length, 0); // 大端序写入长度
  buffer.write(params, 4);
  return buffer;
}

// 连接成功后发送启动报文
client.write(buildStartupMessage('postgres', 'test_db'));

3. 处理认证流程 #

服务端返回的认证报文类型为R（\x52），常见的是MD5密码认证（类型码5），需用crypto模块生成符合要求的哈希值：

const crypto = require('crypto');

function buildPasswordMessage(password, username, salt) {
  // Postgres MD5认证规则：md5(md5(密码+用户名)+随机盐)
  const preHash = crypto.createHash('md5')
    .update(`${password}${username}`)
    .digest('hex');
  const finalHash = crypto.createHash('md5')
    .update(`${preHash}${salt.toString('hex')}`)
    .digest('hex');
  const passwordStr = `md5${finalHash}`;
  
  const length = Buffer.byteLength(passwordStr) + 5; // 4字节长度 + 1字节类型
  const buffer = Buffer.alloc(length);
  buffer.writeInt32BE(length, 0);
  buffer.writeUInt8(0x70, 4); // 'p'的ASCII码，代表密码报文
  buffer.write(passwordStr, 5);
  return buffer;
}

// 监听服务端数据，处理认证请求
client.on('data', (data) => {
  const msgType = data.readUInt8(4);
  if (msgType === 0x52) { // 认证报文
    const authType = data.readInt32BE(8);
    if (authType === 5) { // MD5认证
      const salt = data.slice(12, 16); // 提取服务端返回的4字节随机盐
      client.write(buildPasswordMessage('your_password', 'postgres', salt));
    }
  }
});

4. 发送SQL查询并解析结果 #

认证通过后，发送类型为Q（\x51）的查询报文，格式为SQL语句加空字节：

function buildQueryMessage(sql) {
  const sqlWithNull = `${sql}\0`;
  const length = Buffer.byteLength(sqlWithNull) + 5;
  const buffer = Buffer.alloc(length);
  buffer.writeInt32BE(length, 0);
  buffer.writeUInt8(0x51, 4); // 'Q'代表查询报文
  buffer.write(sqlWithNull, 5);
  return buffer;
}

// 认证通过后执行查询（可在data事件中判断认证成功的报文后发送）
client.write(buildQueryMessage('SELECT id, name FROM users LIMIT 10'));

服务端返回的结果包含多种报文类型：

• T：列定义报文，提取列名、数据类型
• D：数据行报文，解析每行的二进制数据
• C：命令完成报文，提示查询执行状态
• Z：空闲状态报文，代表交互结束

需要根据报文类型逐一解析格式，提取有效数据。

关键提示 #

• 需完全参考PostgreSQL官方协议文档处理报文格式，包括字节序、数据类型转换等细节
• 先从简单查询（如SELECT 1）开始测试，逐步完善复杂逻辑
• 雇主要求无第三方库实现，核心考察你对网络协议、底层交互的理解能力

内容的提问来源于stack exchange，提问作者Georgii Galechyan