这篇文章主要介绍了PostgreSQL Node.js怎么实现函数计算方法，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。
兴海ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为创新互联建站的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：028-86922220（备注：SSL证书合作）期待与您的合作！
1、能够嵌入动态文本于HTML页面。2、对浏览器事件做出响应。3、读写HTML元素。4、在数据被提交到服务器之前验证数据。5、检测访客的浏览器信息。6、控制cookies，包括创建和修改等。7、基于Node.js技术进行服务器端编程。
技术栈
node.js
postgresql
nodemailer
controller + services
编写postgresql lib
不管异常还是正常都返回resolve，在resolve中处理结果，通过success字段去处理
const { Pool } = require('pg');
const config = require('../config/default.js');
const {
database: {
HOST,
PORT,
DATABASE,
USERNAME,
PASSWORD,
},
} = config;
const pool = new Pool({
port: PORT,
host: HOST,
user: USERNAME,
password: PASSWORD,
database: DATABASE,
});
/**
*
* @param sql 接收的sql语句
* @param {Array} values sql语句参数
* @return { Object } { success: boolean, err || data }
*/
const query = async function( sql = 'select NOW()', values = []) {
return new Promise(resolve => {
pool.connect((err, client, release) => {
if (err) {
return console.error('Error acquiring client', err.stack)
}
const params = Array.isArray(values) ? [...values] : [values];
client.query(sql, params, (error, result) => {
release();
if (error) {
console.error('Error executing query', error.stack);
resolve({
success: false,
error,
});
}
resolve({
success: true,
data: result.rows,
});
});
});
});
}
module.exports = {
query,
}config配置文件如下
const config = {
// 数据库配置
database: {
DATABASE: 'databasename',
USERNAME: 'root',
PASSWORD: '123456',
PORT: '3433',
HOST: 'localhost',
},
};
module.exports = config;Controller
BaseController
首先编写一个基类，用于封装一些通用的方法
const pool = require('../lib/postgre'); // 导入封装好的MySQL库
const { query } = pool; // 导入query方法
class BaseController {
constructor() {
}
// 查询表内所有数据（非删除）
async list() {
const sql = `select * from ${this.table}`;
return await query(sql);
}
async excute(sql, vals = []) {
// 执行方法
return await query(sql, vals);
}
// log 方法
log({func, err}) {
console.log(`excute function[${func}] occured error : ${err.message || err}`);
}
}
module.exports = BaseController;InqueryController
具体的业务逻辑Controller类
const BaseController = require('./BaseController'); // 获得基类
// 继承基类
class InqueryController extends BaseController {
constructor() {
super();
this.table = 'data_table'; // 赋值table
}
// 可以重写基类的方法，如果有业务需要
async list() {
const sql = `select * from ${this.table} ORDER BY created_at DESC `;
return await this.excute(sql);
}
async getUnsendCustomer(vals) {
const sql = `select * from ${this.table} where created_at > $1 ORDER BY created_at DESC`;
// 统一在基类调用sql参数
return await this.excute(sql, vals);
}
}
module.exports = InqueryController;Service
BaseService
统一封装的方法，基类
// 需要绑定this的方法
const funcs = [
'list',
]
class BaseService {
constructor() {
this.controller = null;
// 循环遍历绑定this, 在koa绑定route的时可用到
funcs.forEach(item => {
this[item] = this[item].bind(this)
});
}
// 查询方法
async list(ctx) {
if (!ctx) {
return await this.controller.list();
}
// controller返回的是一个对象，success(成功为true， 失败为false), data(成功则有此数据), err(失败则有此对象)
const { success: flag, data, error } = await this.controller.list();
if (flag) {
// success
ctx.body = {
data,
code: 200,
}
} else {
// failed
ctx.body = {
code: 500,
error,
};
}
}
}
module.exports = BaseServiceInqueryService
具体的业务逻辑
// 导入基类
const BaseService = require('./BaseService');
// 导入对应的controller
const Controller = require('../controller/InqueryController');
// 获取MailSender Service
const MailService = require('./MailSender');
const Helper = require('../util/Helper');
const funcs = [
'unsendUser',
];
// 生成一次controller
const controller = new Controller();
class InqueryService extends BaseService {
constructor() {
super()
// 绑定对应的controller
this.controller = controller;
funcs.forEach(item => {
this[item] = this[item].bind(this);
});
}
getMailOpts(i) {
// you can use the data from database to combine the message
const message = 'Hello world!';
return return {
message,
// 可以从配置文件读取或者oss
to: 'xxxx@gmail.com',
subject: 'Hello World',
};
}
async unsendUser() {
const list = await this.controller.list();
if (list.length > 0) {
const mailer = new MailService();
const errorList = [];
iterateList.forEach(async i => {
const mailerOption = this.getMailOpts(i);
const { success, ...rest } = await mailer.sendToAuitAdmin(mailerOption);
if (!success) {
errorList.push(rest);
}
});
const lastestTime = iterateList[0].created_at;
if (errorList.length === 0) {
return {
code: 200,
message: 'Success',
};
}
} else {
return {
code: 204,
message: 'No user found',
};
}
}
}
module.exports = new InqueryService();index.js
函数计算的逻辑
const inqueryService = require('./services/InqueryService');
exports.handler = async function(event, context, callback) {
const result = await inqueryService.unsendUser();
callback(null, result);
};感谢你能够认真阅读完这篇文章，希望小编分享的“PostgreSQL Node.js怎么实现函数计算方法”这篇文章对大家有帮助，同时也希望大家多多支持创新互联，关注创新互联行业资讯频道，更多相关知识等着你来学习!
