先说说为啥要玩 Node.js + 金仓

说实话，金仓在国内企业里挺常见的。

尤其是那种要搞高并发、要严控事务的业务，选它靠谱。

可是 Node.js 本身没有官方驱动。

哈哈，我也是踩坑爬坡后才弄清楚的。

下面咱们一步步聊，从装驱动到事务、再到连接池，统统给你掰开揉碎。

别慌，金仓其实兼容 PostgreSQL 协议。

所以直接把 pg 包当作客户端就行了。

先装：

npm install pg

Ru果想要geng专业点的连接池，还Ke以装 pg-pool，不过 pg Yi经自带池子功Neng。

先抄个Zui简示例：

const { Pool } = require;
const pool = new Pool({
    user: 'SYSTEM',
    host: '127.0.0.1',
    database: 'TESTDB',
    password: process.env.DB_PWD,
    port: 5432,
    max: 20,                 // Zui大连接数
    idleTimeoutMillis: 30000,
    connectionTimeoutMillis: 2000
});

记得密码别硬写进代码，环境变量Zui安全。

async function test {
    const client = await pool.connect;
    try {
        const res = await client.query');
        console.log;
    } finally {
        client.release;   // 一定要还回去
    }
}
test.catch;

这段代码跑通了你就算是成功和金仓打成了一片。

先说个小故事——我公司有个转账功Neng，A 给 B 转钱。

A 扣钱成功了B 加钱却因为网络抖了一下报错，那钱就飞了！

这时候就得上事务：两个操作要么一起成功，要么一起回滚。

async function transfer {
    const client = await pool.connect;
    try {
        await client.query;
        await client.query(
            'UPDATE accounts SET balance = balance - $1 WHERE id = $2',
        );
        await client.query(
            'UPDATE accounts SET balance = balance + $1 WHERE id = $2',
        );
        await client.query;
        console.log;
    } catch  {
        await client.query;
        console.error;
    } finally {
        client.release;
    }
}

记住这里每一步dou必须在同一个 client 上执行，否则事务根本不生效。

我刚开始写完事务直接返回，没有放 .release.

结果第二天监控报警：连接数飙到几百，数据库快挂掉了。

*不对不对*，应该把释放放在 finally, 保证无论成功还是异常douNeng还回去。

A 调用 B 的业务，而 B 又自己开了事务。

B 那边用了 SAVEPOINT? 没有的话会直接报错 “Yi经在事务中”。

Ehh，我Zui后改成把所有子业务合并到同一个外层事务里一次提交。省事儿也省心。

别把太多业务塞进一个事务，比如一次性遍历上万条记录再geng新，每条dou占锁hen久。

C 那边抢不到锁，就一直等下去，整个系统卡住。

SOLUTION：拆成批处理，每批几百条，用游标或者分页来控制锁的持有时间。

每次创建 TCP 连接dou有开销；频繁创建/关闭会拖慢响应速度；

池子Neng复用Yi有连接，提高并发吞吐；

还Neng统一管理Zui大并发数，防止 DB 被打垮。

`max`：一般设为服务器 CPU 核数 * 2 左右；我这台 8 核，用 15 就挺稳。

`idleTimeoutMillis`：`30000`够用了；太短会频繁断线。

`connectionTimeoutMillis`：`2000` 防止请求卡死太久。

class KingbaseDB {
    constructor {
        this.pool = new Pool;
    }
    async query {
        const client = await this.pool.connect;
        try {
            return await client.query;
        } finally {
            client.release;   // 永远不要忘
        }
    }
    async transaction {
        const client = await this.pool.connect;
        try {
            await client.query;
            const result = await callback;   // 把 client 传进去让外部自行 query
            await client.query;
            return result;
        } catch  {
            await client.query;
            throw e;
        } finally {
            client.release;
        }
    }
    async close {
        await this.pool.end;
    }
}
// 用法
const db = new KingbaseDB({
    user: 'SYSTEM',
    host: '127.0.0.1',
    database: 'TESTDB',
    password: process.env.DB_PWD,
    port: 5432,
    max: 15,
});
 => {
   const rows = ).rows;
   console.log;
});

async function bulkInsert {
   const values = ;
   const placeholders = ;
   users.forEach => {
       values.push;
       placeholders.push`);
   });
   const sql = `INSERT INTO users VALUES ${placeholders.join}`;
   return db.query;
}

Ehh，这样一次网络往返就Neng插十几百条，大幅提升性Neng。

async function fetchAllLargeTable {
   const client = await db.pool.connect;
   try {
       await client.query;
       await client.query;
       let hasMore = true;
       while  {
           const res = await client.query;
           if  hasMore = false;
           else {
               for  {
                   // 这里Zuo点业务处理，不要阻塞太久
                   processRow;
               }
           }
       }
       await client.query;
       await client.query;
   } catch {
       await client.query;
       throw e;
   } finally{
       client.release;
   }
}

- 对于上亿行数据，这招真的救命啊！不会一次性把全表拉进内存炸掉。

a) 监控连接数 用 PING / SHOW POOL STATUS; 定时打印池子状态，一旦接近阈值马上扩容或调小并发请求量。

b) 错误统一日志 捕获数据库异常后不要直接抛出给前端，而是记录日志、返回友好错误码。

C) 超时设置 SQL 超时、查询超时dou得配置好，不然某条慢查询会把整个事务卡住几分钟。

D) 安全防护 开启 SSL/TLS 加密链接；同时在 DB 层限制 IP 白名单，只允许 Node 服务所在机器访问。

Ehh，说实话，我现在Yi经把金仓当成微服务里的“数据中心”。配合 GraphQL 或者 gRPC，douNeng跑得飞起。

C 那些老牌 ORM虽然Ke以通过自定义驱动接入，但我geng倾向于手写 SQL，因为金仓特有的一些函数和分区特性，用 ORM 时往往被“抽象”掉，性Neng受影响。

- 对啦，Ru果你想玩geng高级的东西，Ke以试试Pipelining 批处理+流式读取+ Kafka 消费者同步到金仓 。哈哈，我先不扯太远啦～.