如何在单个Node.js应用中同时接入HBase与PostgreSQL两个不同数据库

前置准备 #

你已完成两个数据库客户端的安装，若还未安装PostgreSQL官方Node.js驱动，执行以下命令：
npm install pg

原有HBase代码优化 #

你现有HBase封装代码存在两处可优化的点：

• 重复初始化conn实例：类属性声明和构造函数中两次创建hbase.Client实例，保留构造函数内的初始化逻辑即可
• 方法名拼写错误：conection建议修正为connection

完整整合实现 #

两个数据库的客户端实例相互独立，直接在原有Db类中新增PostgreSQL连接逻辑即可，不会出现冲突：

import { error } from "console";
const hbase = require('hbase');
// 引入PostgreSQL驱动
const { Pool } = require('pg');

export class Db {
    // HBase相关配置与实例
    private hbaseConn;
    private hbaseConfig = { host: '0.0.0.0', port: 8080 };
    public hbaseClient = new hbase.Client(this.hbaseConfig);

    // PostgreSQL相关配置与实例
    private pgPool;
    private pgConfig = {
        host: '你的PostgreSQL主机地址',
        port: 5432, // 默认端口
        user: '你的数据库用户名',
        password: '你的数据库密码',
        database: '要连接的库名',
        max: 20, // 连接池最大连接数，可根据需求调整
        idleTimeoutMillis: 30000
    };

    constructor() {
        // 初始化HBase连接
        this.hbaseConn = new hbase.Client(this.hbaseConfig);
        // 初始化PostgreSQL连接池
        this.pgPool = new Pool(this.pgConfig);
        // 可选：启动时测试两个数据库连接
        this.initAllDb();
    }

    // 初始化所有数据库连接
    private initAllDb() {
        // HBase连接测试
        this.hbaseConn.table('messages').exists((error: string, success: boolean) => {
            if (error) {
                console.error('HBase连接失败：', error);
                return;
            }
            if (!success) {
                this.createHbaseTable('messages', 'message_data');
            }
            console.log('HBase连接成功');
        });

        // PostgreSQL连接测试
        this.pgPool.connect((err, client, release) => {
            if (err) {
                console.error('PostgreSQL连接失败：', err);
                return;
            }
            release();
            console.log('PostgreSQL连接成功');
        });
    }

    // 原有HBase建表方法
    private createHbaseTable(TblName: string, CF: string) {
        this.hbaseConn.table(TblName).create(CF, function (error: string, success: string) {
            console.log('HBase表创建结果：', success);
            return success
        });
    }

    // 封装PostgreSQL查询方法，方便调用
    public async pgQuery(sql: string, params?: any[]) {
        const res = await this.pgPool.query(sql, params);
        return res.rows;
    }
}

使用示例 #

实例化Db类后可分别调用两个数据库的操作方法：

const db = new Db();

// 操作HBase示例：获取messages表前10条数据
db.hbaseClient.table('messages').scan({
  limit: 10
}, (err, rows) => {
  console.log('HBase查询结果：', rows);
});

// 操作PostgreSQL示例：查询users表指定id的数据
db.pgQuery('SELECT * FROM users WHERE id = $1', [1])
  .then(res => console.log('PostgreSQL查询结果：', res))
  .catch(err => console.error('查询失败：', err));

注意事项 #

• 两个数据库的配置项分开维护，避免混用，生产环境建议将配置存入环境变量读取，不要硬编码在代码中
• PostgreSQL建议使用连接池Pool而非单实例Client，高并发场景下性能更优
• 两个数据库的操作异常要分别捕获处理，避免单库异常影响另一个库的正常使用
• 应用进程退出时，建议主动调用两个客户端的销毁方法关闭连接，避免连接泄漏

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