前言
馬上服務外包決賽了贸街，好久沒有寫東西了，大作業(yè)太多了，全是扯淡棘街。
上一個創(chuàng)新創(chuàng)業(yè)管理項目交付了，昨天突然看見Criteria類如下
Criteria是一種比hql更面向對象的查詢方式承边。
然后想到之前項目里自己采用的方法遭殉，慘不忍睹，今天重構一下連接數據庫的想法博助。
實現思路
希望實現的目標：
// 新建與數據庫表對應的實體類對象
let award = new AwardPojo()
// add方法添加需要篩選的條件
award.add({
award_name: '服務外包大賽'
})
// search方法根據add方法中的篩選條件查詢數據险污，以Promise方式返回
award.search().then(res => {
console.log(res)
award.order()
})
- 構建父類
const isEmptyObj = require('./utils').isEmptyObj
const db = require('mysql')
const config = require('./config')
let pools = db.createPool({
user: config.db.user,
port: config.db.port,
password: config.db.password,
database: config.db.db,
host: config.db.host,
connectionLimit: 20
})
function DBInit(tb, _columns) {
if (tb) this.tableName = tb
if (_columns) this.columns = JSON.parse(JSON.stringify(_columns))
this.filter = {}
}
/**
*
* @param {添加篩選條件} _filter
*/
DBInit.prototype.add = function (_filter) {
for (let k in _filter) {
let v = _filter[k]
this.filter[k] = v
}
}
/**
* 查詢數據庫表
* @param {開始行數} start
* @param {結束函數} end
*/
DBInit.prototype.search = function (start, end) {
let sql = `select * from ${this.tableName}`
if (!isEmptyObj(this.filter)) {
let fq = `where `
for (let k in this.filter) {
let v = this.filter[k]
fq += `${k}='${v}' and `
}
fq = fq.slice(0, fq.length - 4)
sql += ` ${fq}`
}
if (start && end) {
sql += `limit ${start}, ${end}`
}
return new Promise((resolve, reject) =>{
pools.getConnection((err, connection) => {
let pojos = null
if (err) {
console.log(err)
reject(pojos)
}
connection.query(sql, (err, results) => {
connection.release()
if (err) {
console.log(err)
reject(pojos)
}
else {
resolve(results)
}
})
})
})
}
module.exports = DBInit
- 對于每張表構建不同的實體類繼承自父類即可
const DBInit = require('../DBHelper')
function AwardPojo() {
let awardPOJO = {
award_id: '',
award_time: '',
award_name: '',
award_identity: '',
award_level: ''
}
DBInit.call(this, 'award', awardPOJO)
}
AwardPojo.prototype = new DBInit()
AwardPojo.prototype.constructor = AwardPojo
AwardPojo.prototype.order = function() {
console.log('order')
}
let award = new AwardPojo()
award.add({
award_name: '服務外包大賽'
})
award.search().then(res => {
console.log(res)
award.order()
})
結束
主要用到的知識點只有一個組合繼承了，參考js原型鏈和面向對象的繼承富岳。
用mysql庫的時候一定要調用release方法關閉鏈接蛔糯！
