在开始使用Heroku和Node.js时,我一直忠实地遵循这个极好的示例。直到数据库部分。
我有:
heroku pg:psql控制台将数据插入到表中。但是,当我尝试通过index.js中的路由连接和查询数据时,我会遇到连接到DB的错误。
从heroku config生成的连接字符串如下所示,它包含所需的凭据。
=== aqueous-eyrie-10062 Config Vars
DATABASE_URL: postgres://uqeeuludvmhdzx:6181554101xxxxxxxxxxxxxxxxxxxxxxa@ec2-107-21-113-16.compute-1.amazonaws.com:5432/dbpa7e9l3b2k8g
PAPERTRAIL_API_TOKEN: T8Y4ESxxxxxxxx0rexl
TIMES: 7启动本地实例heroku local db2 (或浏览到localhost:5000/db2)后,控制台显示以下输出:(用户'rober‘是当前的windows用户b.t.w.)
错误由pg查询调用以及另一路由中的pg.connect调用( /db )生成。
C:\Users\rober\node-js-getting-started>heroku local
[OKAY] Loaded ENV .env File as KEY=VALUE Format
14:23:52 web.1 | Node app is running on port 5000
14:23:55 web.1 | (node:13876) DeprecationWarning: PG.connect is deprecated - please see the upgrade guide at https://node-postgres.com/guides/upgrading
14:23:55 web.1 | result: undefined
14:23:55 web.1 | rows: undefined
14:23:55 web.1 | err: error: role "rober" does not exist
14:23:55 web.1 | err: {"name":"error","length":90,"severity":"FATAL","code":"28000","file":"miscinit.c","line":"494","routine":"InitializeSessionUserId"}下面是index.js
var cool = require('cool-ascii-faces')
var express = require('express');
var app = express();
var pg = require('pg');
var pool = new pg.Pool();
var query2 = require('pg-query');
app.set('port', (process.env.PORT || 5000));
app.use(express.static(__dirname + '/public'));
// views is directory for all template files
app.set('views', __dirname + '/views');
app.set('view engine', 'ejs');
app.get('/db', function (request, response) {
// ERROR received from below line
pg.connect(process.env.DATABASE_URL, function(err, client, done) {
if (client) {
var date = new Date();
var query = client.query('SELECT * FROM test_table',function(err, result) {
if(!err) {
response.send(JSON.stringify(result.rows));
accounts = JSON.stringify(result.rows);
} else {
response.send('failed');
}
done(); // call done to close the conection
});
} else {
response.send('No Client Error - ' + JSON.stringify(err));
throw(err);
}
});
});
app.get('/db2', function(request, response) {
// ERROR received from below line
query2.connectionParameters = process.env.DATABASE_URL;
//accepts optional array of values as 2nd parameter for parameterized queries
query2('SELECT $1::text as name', ['rob'], function(err, rows, result) {
console.log('result: ' + result);
console.log('rows: ' + rows);
console.log('err: ' + err);
console.log('err: ' + JSON.stringify(err));
});
});我的package.json如下:
{
"name": "node-js-getting-started",
"version": "0.2.6",
"description": "A sample Node.js app using Express 4",
"engines": {
"node": "6.10.2"
},
"main": "index.js",
"scripts": {
"start": "node index.js"
},
"dependencies": {
"cool-ascii-faces": "1.3.4",
"ejs": "2.5.6",
"express": "4.15.2",
"pg": "6.4.0",
"pg-query": "0.11.0"
},
"repository": {
"type": "git",
"url": "https://github.com/heroku/node-js-getting-started"
},
"keywords": [
"node",
"heroku",
"express"
],
"license": "MIT"
}根据我的理解,db用户应该从连接字符串中获得,而不是从当前用户那里获得。我该怎么纠正呢?
发布于 2017-07-12 08:16:02
好的-感谢一位团队成员,我成功地解决了这个问题:
我的假设是,heroku config设置在运行heroku local时是可用的--错误!
要在部署之前进行本地测试,我需要使用set命令将DATABASE_URL设置为windows环境变量。
SET DATABASE_URL=postgres://uqexxxxxxhdzx:6181554xxxxxxxxxxxxxxxxxa@ec2-107-21-113-16.compute-1.amazonaws.com:5432/dbpa7e9l3b2k8g然后,我继续从上面的代码中删除所有附加的连接方法,直到我只使用了
var pg = require('pg');
app.get('/db', function (request, response) {
pg.defaults.ssl = true;
pg.connect(process.env.DATABASE_URL, function(err, client) {
if (err) throw err;
console.log('Connected to postgres! Getting schemas...');
client
.query('SELECT table_schema,table_name FROM information_schema.tables;')
.on('row', function(row) {
console.log(JSON.stringify(row));
});
});
});效果很好。
发布于 2017-09-21 18:46:37
下面的代码对我有效。
app.get('/db', function (request, response) {
pg.defaults.ssl = true;
pg.connect(process.env.DATABASE_URL, function(err, client) {
if (err) throw err;
console.log('Connected to postgres! Getting schemas...');
client
.query('SELECT * FROM test_table;', function(err, result) {
if (err)
{ console.error(err); response.send("Error " + err); }
else
{ response.render('pages/db', {results: result.rows} ); }
});
});});
https://stackoverflow.com/questions/45036016
复制相似问题