/*

项目组一般开发成员勿动此文件！

*/
const pg = require('pg');
 
let pgPool = null


/* isOpen */
if (u_config.pgConfig.isOpen) {

    pgPool = new pg.Pool(u_config.pgConfig.poolConfig);
    //系统启动连接自测
    pgPool.connect(function (err, client, release) {
        if (err) {
            console.log('\x1B[31m', '数据库连接测试失败:' + err.message);
            return;
        }

        client.query('select now();', [], function (err, result) {
            release();
            if (err) {
                console.log('\x1B[31m', '数据库测试查询失败:' + err.message)
            } else {
                let date = new Date(result.rows[0].now)
                console.log('\x1B[32m', `项目数据库（${u_config.pgConfig.poolConfig.database}）测试查询成功/测试时间: ` + date)
            }
        })
    });

}



module.exports = pgPool;