在 pg-promise API 中动态选择 database/tables
Dynamically choosing database/tables in pg-promise API
pg-promise API 推荐初始连接对象,如:
var pgp = require('pg-promise')();
const mysqlcon = `postgres://${process.env.DB_USER}:${process.env.DB_PASSWORD}@${process.env.DB_HOST}:5432/my_database}` //note that 'my_database' is hardcoded here
var db = pgp(mysqlcon);
module.exports = db;
然后我使用这个对象在my_database数据库中查询table_customers:
var db = require('./models/postgres')
db.many('SELECT * from table_customers')
.then(function (data) {
console.log('DATA:', data)
})
.catch(function (error) {
console.log('ERROR:', error)
})
这工作得很好,但是如果我要从另一个数据库 select 另一个 table,我怎么能动态修改连接对象以更改 my_database 到 another_database?
为动态变化创建变量 TABLE 或 DATABASE
var db = require('./models/postgres')
db.many('SELECT * FROM ${YOUR_VAR}')
.then(function (data) {
console.log('DATA:', data)
})
.catch(function (error) {
console.log('ERROR:', error)
})
PostgreSql 中的连接是数据库绑定的,因此您只需使用两个数据库对象:
const mySqlCon1 = `postgres://.../database1`;
const mySqlCon2 = `postgres://.../database2`;
export const db1 = pgp(mySqlCon1);
export const db2 = pgp(mySqlCon2);
pg-promise API 推荐初始连接对象,如:
var pgp = require('pg-promise')();
const mysqlcon = `postgres://${process.env.DB_USER}:${process.env.DB_PASSWORD}@${process.env.DB_HOST}:5432/my_database}` //note that 'my_database' is hardcoded here
var db = pgp(mysqlcon);
module.exports = db;
然后我使用这个对象在my_database数据库中查询table_customers:
var db = require('./models/postgres')
db.many('SELECT * from table_customers')
.then(function (data) {
console.log('DATA:', data)
})
.catch(function (error) {
console.log('ERROR:', error)
})
这工作得很好,但是如果我要从另一个数据库 select 另一个 table,我怎么能动态修改连接对象以更改 my_database 到 another_database?
为动态变化创建变量 TABLE 或 DATABASE
var db = require('./models/postgres')
db.many('SELECT * FROM ${YOUR_VAR}')
.then(function (data) {
console.log('DATA:', data)
})
.catch(function (error) {
console.log('ERROR:', error)
})
PostgreSql 中的连接是数据库绑定的,因此您只需使用两个数据库对象:
const mySqlCon1 = `postgres://.../database1`;
const mySqlCon2 = `postgres://.../database2`;
export const db1 = pgp(mySqlCon1);
export const db2 = pgp(mySqlCon2);