// 引入node-postgres库
const { Pool } = require('pg');
// 创建配置对象
const config = {
user: 'your_user', // 替换为你的用户名
database: 'your_database', // 替换为你的数据库名
password: 'your_password', // 替换为你的密码
host: 'localhost', // 或者你的数据库服务器地址
port: 5432 // 或者你的数据库端口号
};
// 创建连接池
const pool = new Pool(config);
// 连接数据库
pool.connect((err, client, done) => {
if (err) {
console.error('数据库连接出错', err.stack);
return;
}
console.log('连接成功');
// 使用完成后释放客户端
client.query('SELECT NOW() AS "currentTime"', (err, result) => {
done();
if (err) {
console.error('查询出错', err.stack);
return;
}
console.log(result.rows[0].currentTime);
});
});
这段代码展示了如何在Node.js项目中使用node-postgres
库连接PostgreSQL数据库,并执行一个简单的查询。它还包括了错误处理,以确保在出现问题时程序不会崩溃,而是输出错误信息并尝试恢复。