PostgreSQL Node.js怎么實(shí)現(xiàn)函數(shù)計(jì)算方法

這篇文章主要介紹了PostgreSQL Node.js怎么實(shí)現(xiàn)函數(shù)計(jì)算方法，具有一定借鑒價(jià)值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

js的作用是什么

1、能夠嵌入動(dòng)態(tài)文本于HTML頁(yè)面。2、對(duì)瀏覽器事件做出響應(yīng)。3、讀寫HTML元素。4、在數(shù)據(jù)被提交到服務(wù)器之前驗(yàn)證數(shù)據(jù)。5、檢測(cè)訪客的瀏覽器信息。6、控制cookies，包括創(chuàng)建和修改等。7、基于Node.js技術(shù)進(jìn)行服務(wù)器端編程。

技術(shù)棧

• node.js

• postgresql

• nodemailer

controller +  services

編寫postgresql lib

不管異常還是正常都返回resolve，在resolve中處理結(jié)果，通過(guò)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語(yǔ)句
 * @param {Array} values sql語(yǔ)句參數(shù)
 * @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 = {
 // 數(shù)據(jù)庫(kù)配置
 database: {
 DATABASE: 'databasename',
 USERNAME: 'root',
 PASSWORD: '123456',
 PORT: '3433',
 HOST: 'localhost',
 },
};

module.exports = config;

Controller

BaseController

首先編寫一個(gè)基類，用于封裝一些通用的方法

const pool = require('../lib/postgre'); // 導(dǎo)入封裝好的mysql庫(kù)
const { query } = pool; // 導(dǎo)入query方法
class BaseController {
 constructor() {
 }
 // 查詢表內(nèi)所有數(shù)據(jù)（非刪除）
 async list() {
 const sql = `select * from ${this.table}`;
 return await query(sql);
 }
 async excute(sql, vals = []) {
 // 執(zhí)行方法
 return await query(sql, vals);
 }
 // log 方法
 log({func, err}) {
 console.log(`excute function[${func}] occured error : ${err.message || err}`);
 }
}

module.exports = BaseController;

InqueryController

具體的業(yè)務(wù)邏輯Controller類

const BaseController = require('./BaseController'); // 獲得基類
// 繼承基類
class InqueryController extends BaseController {
 constructor() {
 super();
 this.table = 'data_table'; // 賦值table
 }
 // 可以重寫基類的方法，如果有業(yè)務(wù)需要
 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`;
 // 統(tǒng)一在基類調(diào)用sql參數(shù)
 return await this.excute(sql, vals);
 }
 
}
module.exports = InqueryController;

Service

BaseService

統(tǒng)一封裝的方法，基類

// 需要綁定this的方法
const funcs = [
 'list',
]
class BaseService {
 constructor() {
 this.controller = null;
 // 循環(huán)遍歷綁定this, 在koa綁定route的時(shí)可用到
 funcs.forEach(item => {
  this[item] = this[item].bind(this)
 });
 }

 // 查詢方法
 async list(ctx) {
 if (!ctx) {
  return await this.controller.list();
 }
 // controller返回的是一個(gè)對(duì)象，success(成功為true， 失敗為false), data(成功則有此數(shù)據(jù)), err(失敗則有此對(duì)象)
 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 = BaseService

InqueryService

具體的業(yè)務(wù)邏輯

// 導(dǎo)入基類
const BaseService = require('./BaseService');
// 導(dǎo)入對(duì)應(yīng)的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()
 // 綁定對(duì)應(yīng)的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

函數(shù)計(jì)算的邏輯

const inqueryService = require('./services/InqueryService'); 
exports.handler = async function(event, context, callback) {
 const result = await inqueryService.unsendUser();
 callback(null, result);
};

感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“PostgreSQL Node.js怎么實(shí)現(xiàn)函數(shù)計(jì)算方法”這篇文章對(duì)大家有幫助，同時(shí)也希望大家多多支持億速云，關(guān)注億速云行業(yè)資訊頻道，更多相關(guān)知識(shí)等著你來(lái)學(xué)習(xí)!