我正在使用 nodejs 作为我的 REST api 主机。整体功能非常基本。也就是说,进行一个 REST 调用,它应该执行 postgres 数据库查询并返回数据。我遇到的问题是整体代码组织。
我有具有基本初始化功能的 server.js。现在,我应该在哪里放置 postgres 连接并在需要时调用它来查询数据库。当前结构如下。所以我想我应该将 postgres 连接代码移动到 server.js?什么应该是正确的结构
server.js
"use strict";
var express = require('express'),
app = express(),
port = process.env.PORT || 4001,
bodyParser = require('body-parser');
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
app.use(function (req, res, next) {
// Website you wish to allow to connect
res.setHeader('Access-Control-Allow-Origin', '*')
// Request methods you wish to allow
res.setHeader('Access-Control-Allow-Methods', 'GET, POST, OPTIONS, PUT, PATCH, DELETE');
// Request headers you wish to allow
res.setHeader('Access-Control-Allow-Headers', 'X-Requested-With,content-type');
// Set to true if you need the website to include cookies in the requests sent
// to the API (e.g. in case you use sessions)
res.setHeader('Access-Control-Allow-Credentials', true);
// Pass to next layer of middleware
next();
});
var routes = require('./api/routes/pushRoutes');
routes(app);
app.listen(port);
console.log('push notification server started on: ' + port);
pushController.js
'use strict';
exports.send_notification = function(req, res) {
console.log("start of send_notification ");
if (req.method == 'POST') {
var jsonString = '';
req.on('data', function (data) {
jsonString += data;
});
req.on('end', function () {
console.log(JSON.parse(jsonString));
var json = JSON.parse(jsonString);
var timeNow = json.message;
//get device token from db
var deviceToken = '';
var pg = require('pg')
var format = require('pg-format')
var PGUSER = 'deploy'
var PGDATABASE = 'oscpushserver'
var config = {
user: PGUSER, // name of the user account
database: PGDATABASE, // name of the database
max: 10, // max number of clients in the pool
idleTimeoutMillis: 30000
}
var pool = new pg.Pool(config)
var myClient
pool.connect(function (err, client, done) {
if (err) console.log(err)
app.listen(3000, function () {
console.log('listening on 3000')
})
myClient = client
var ageQuery = format('SELECT * from push_table WHERE seq_id = 1')
myClient.query(ageQuery, function (err, result) {
if (err) {
console.log(err)
}
console.log("row data:" + result.rows[0])
console.log("device id from db:" + result.rows[0].device_id)
deviceToken =result.rows[0].device_id;
})
});
res.json(JSON.parse(jsonString));
});
}
};
最佳答案
我假设您想制作一个只从数据库获取数据的 REST api。
server.js
除了您没有正确使用路线外,大部分内容看起来都不错。要使用您定义的路线,请使用 app.use:
app.use('/', routes);
数据库.js 我会创建另一个文件,您可以在其中将数据库凭据放在一个地方并创建一个新池。
var pg = require('pg')
var PGUSER = 'deploy'
var PGDATABASE = 'oscpushserver'
var config = {
user: PGUSER, // name of the user account
database: PGDATABASE, // name of the database
max: 10, // max number of clients in the pool
idleTimeoutMillis: 30000
}
var pool = new pg.Pool(config);
module.exports = pool;
推送 Controller
我假设你想在 server.js 中需要这个文件。因此,请确保路径指向“.../pushController”而不是“./api/routes/pushRoutes”。
const express = require('express');
const router = express.Router();
const format = require('pg-format');
const pool = require('../path/to/database.js');
router.get(function(req, res, next) {
pool.connect(function (err, client, done) {
if (err) throw new Error(err);
var ageQuery = format('SELECT * from push_table WHERE seq_id = 1')
client.query(ageQuery, function (err, result) {
if (err) throw new Error(err);
res.json(result.rows[0]);
})
});
});
module.exports = router;
现在,对您的 API 服务器的 GET 请求应该从您的 postgres 数据库返回一个 json 对象。
网上有大量关于如何使用 node 和 postgres 制作 REST API 的示例。其中之一是:https://github.com/mjhea0/node-postgres-todo .
关于node.js - 将 postgres 与 nodejs 一起用于连接池,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44643652/