node+express框架中連接使用mysql(經(jīng)驗(yàn)總結(jié))

最近在學(xué)習(xí)node.js，做了一個(gè)練手項(xiàng)目，使用node.js+express框架，配合MySQL數(shù)據(jù)庫和前端vue框架開發(fā)一個(gè)多人文檔編輯系統(tǒng)。

創(chuàng)新互聯(lián)專注于中大型企業(yè)的成都網(wǎng)站設(shè)計(jì)、網(wǎng)站制作和網(wǎng)站改版、網(wǎng)站營(yíng)銷服務(wù)，追求商業(yè)策劃與數(shù)據(jù)分析、創(chuàng)意藝術(shù)與技術(shù)開發(fā)的融合，累計(jì)客戶數(shù)千家，服務(wù)滿意度達(dá)97%。幫助廣大客戶順利對(duì)接上互聯(lián)網(wǎng)浪潮，準(zhǔn)確優(yōu)選出符合自己需要的互聯(lián)網(wǎng)運(yùn)用，我們將一直專注成都品牌網(wǎng)站建設(shè)和互聯(lián)網(wǎng)程序開發(fā)，在前進(jìn)的路上，與客戶一起成長(zhǎng)！

node.js環(huán)境下express+mysql的服務(wù)端項(xiàng)目示例

首先是環(huán)境搭建：

node環(huán)境下

$ npm install -g express-generator
$ express -e project

進(jìn)入項(xiàng)目文件根目錄安裝依賴模塊

$ npm install
$ DEBUG=node-blog:* npm start

看看項(xiàng)目目錄都有什么

node+express框架中連接使用mysql(經(jīng)驗(yàn)總結(jié))

看看生成的工程目錄里面都有什么，

bin：存放可執(zhí)行文件

node_modules：存放 package.json 中安裝的模塊，當(dāng)你在 package.json 添加依賴的模塊并安裝后，存放在這個(gè)文件夾下

public：存放 image、css、js 等前端資源文件

routes：存放路由文件

views：存放視圖文件或者說模版文件

app.js：?jiǎn)?dòng)文件，或者說入口文件

package.json：存儲(chǔ)著工程的信息及模塊依賴，當(dāng)在 dependencies 中添加依賴的模塊時(shí)，運(yùn)行npm install ，npm 會(huì)檢查當(dāng)前目錄下的 package.json，并自動(dòng)安裝所有指定的模塊

下面開始安裝數(shù)據(jù)庫，這里我選擇的是mysql。

npm install mysql --save-dev

安裝完畢之后，開始配置數(shù)據(jù)庫。

//mysql配置文件
mysql = {

    host: "xx.xxx.xx.xxx", //這是數(shù)據(jù)庫的地址

    user: "xxx", //需要用戶的名字

    password: "xxx", //用戶密碼 ，如果你沒有密碼，直接雙引號(hào)就是

    database: "xxx" //數(shù)據(jù)庫名字

  } //好了，這樣我們就能連接數(shù)據(jù)庫了

  module.exports = mysql; //用module.exports暴露出這個(gè)接口，
mysql連接池配置：

//mysql連接池配置文件
var mysql = require('mysql');
var $dbConfig = require('../config/mysql');//注意改成自己項(xiàng)目中mysql配置文件的路徑

// 使用連接池，避免開太多的線程，提升性能
var pool = mysql.createPool($dbConfig);

/**
 * 對(duì)query執(zhí)行的結(jié)果自定義返回JSON結(jié)果
 */
function responseDoReturn(res, result, resultJSON) {
  if (typeof result === 'undefined') {
    res.json({
      code: '201',
      msg: 'failed to do'
    });
  } else {
    res.json(result);
  }
};

/**
 * 封裝query之sql帶不占位符func
 */
function query(sql, callback) {
  pool.getConnection(function(err, connection) {
    connection.query(sql, function(err, rows) {
      callback(err, rows);
      //釋放鏈接
      connection.release();
    });
  });
}

/**
 * 封裝query之sql帶占位符func
 */
function queryArgs(sql, args, callback) {
  pool.getConnection(function(err, connection) {
    connection.query(sql, args, function(err, rows) {
      callback(err, rows);
      //釋放鏈接
      connection.release();
    });
  });
}

//exports
module.exports = {
  query: query,
  queryArgs: queryArgs,
  doReturn: responseDoReturn
}

操作數(shù)據(jù)庫的過程比較靈活，我是使用模塊化的思想，將一張數(shù)據(jù)表封裝成一個(gè)模塊暴露出去，通過該模塊獲取這張表的增刪改查SQL語句。下面貼上示例代碼：

let express = require('express');
let mysql = require('../common/basicConnection');

let qibu_task = {
  index: '',
  value: '',
  list: `SELECT * from qibu_task;`, //列表查詢
  insert(args) {
    qibu_task.index = '';
    qibu_task.value = '';
    args = filter(['id', 'task', 'name', 'created_at'], args)
    for (let key in args) {
      qibu_task.index = `${qibu_task.index}${key},`
      let re = /^[0-9]+.?[0-9]*/;
      if (re.test(args[key])) {
        qibu_task.value = `${qibu_task.value}${args[key]},`
      } else {
        qibu_task.value = `${qibu_task.value}'${args[key]}',`
      }
    }
    qibu_task.index = qibu_task.index.substr(0, qibu_task.index.length - 1);
    qibu_task.value = qibu_task.value.substr(0, qibu_task.value.length - 1);

    return `INSERT INTO qibu_task (${qibu_task.index}) VALUES(${qibu_task.value})`;
  }, //按需增加
  select(index, value) {
    return `SELECT * from qibu_task where ${index}=${value};` //按需查詢
  },
  delete(index, value) {
    return `DELETE from qibu_task where ${index}=${value};` //按需刪除
  },
  update(index, args) { //提交修改
    if (index in args) {
      qibu_task.value = '';
      args = filter(['id', 'task', 'name', 'created_at'], args)
      for (let key in args) {
        let re = /^[0-9]+.?[0-9]*/;
        if (re.test(args[key])) {
          qibu_task.value = `${qibu_task.value}${key}=${args[key]},`
        } else {
          qibu_task.value = `${qibu_task.value}${key}='${args[key]}',`
        }
      }
      qibu_task.value = qibu_task.value.substr(0, qibu_task.value.length - 1)
      return `UPDATE qibu_task SET ${qibu_task.value} WHERE ${index}=${args[index]};`
    }
  },
};
//參數(shù)過濾
function filter(arguments, obj) {
  let newObj = {}
  arguments.forEach(every => {
    if (every in obj) {
      newObj[every] = obj[every]
    }
  });
  return newObj;
};
module.exports = qibu_task;

然后就可以在路由返回時(shí)進(jìn)行數(shù)據(jù)庫操作啦。具體代碼就不貼啦。路由可以識(shí)別get、post方法，修改和刪除通過傳遞參數(shù)模擬。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)。

分享名稱：node+express框架中連接使用mysql(經(jīng)驗(yàn)總結(jié))
文章源于：http://m.rwnh.cn/article2/ipjjic.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供企業(yè)網(wǎng)站制作、做網(wǎng)站、網(wǎng)站內(nèi)鏈、App設(shè)計(jì)、電子商務(wù)、外貿(mào)建站

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容

内射老阿姨1区2区3区4区_久久精品人人做人人爽电影蜜月_久久国产精品亚洲77777_99精品又大又爽又粗少妇毛片

node+express框架中連接使用mysql(經(jīng)驗(yàn)總結(jié))