nodejs+express最簡易的連接數(shù)據(jù)庫的方法

更新時間：2020年12月23日 08:35:41 作者：shine-lzx

這篇文章主要介紹了nodejs+express 最簡易的連接數(shù)據(jù)庫，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

環(huán)境搭建

1.首先需要自行安裝node環(huán)境

2.然后全局安裝 express

npm install -g express

3.創(chuàng)建express項目文件夾

express創(chuàng)建項目默認為jade模板引擎，若使用其他引擎，使用命令切換

express node_demo -e (選擇ejs模板) // 在項目名稱的后面添加 -e 那么創(chuàng)建出來的模板文件就是.ejs類型，語法是與html相同的

在vscode中打開我們建好的項目，目錄如下：

對于ejs看著不習慣的同學可以將其改為html，如下：

然后還需要將在views新建一個index.html 與error.html 內(nèi)容如下 index.html

error.html

安裝依賴 npm install

啟動項目 npm start

監(jiān)聽bin/www文件，默認端口為3000，可在www文件中更改，打開瀏覽器，輸入localhost:3000

這時我們就可以看到頁面顯示的內(nèi)容是index.html 里面定義的內(nèi)容了

因為每次修改都需要重新啟動，比較麻煩，這里有個插件nodemon，可以自動重啟

npm install nodemon

將package.json文件中的代碼修改為：

"start": "nodemon ./bin/www"

連接MySQL數(shù)據(jù)庫

先安裝mysql

npm install mysql 2.然后封裝數(shù)據(jù)庫連接模塊，我們在根目錄下新建一個conf文件夾, 新建一個db.config.js，與db.js 內(nèi)容如下:

// db.config.js
// 創(chuàng)建mysql連接
module.exports = {
 host: 'localhost', // 服務器地址
 user: '*****', // mysql用戶名稱
 password: '**********', // mysql用戶密碼
 port: '3306', // 端口
 database: 'onepiece', // 數(shù)據(jù)庫名稱
}

// db.js 
var mysql = require('mysql')
var dbConfig = require('./db.config')

module.exports = {
 query: function (sql, params, callback) {
  //每次使用的時候需要創(chuàng)建鏈接，數(shù)據(jù)操作完成之后要關閉連接
  var connection = mysql.createConnection(dbConfig)
  connection.connect(function (err) {
   if (err) {
    throw err
   }
   //開始數(shù)據(jù)操作
   connection.query(sql, params, function (err, results, fields) {
    if (err) {
     throw err
    }
    //將查詢出來的數(shù)據(jù)返回給回調(diào)函數(shù)
    callback &&
     callback(
      JSON.parse(JSON.stringify(results)),
      JSON.parse(JSON.stringify(fields))
     )
    //停止鏈接數(shù)據(jù)庫，必須在查詢語句后，要不然一調(diào)用這個方法，就直接停止鏈接，數(shù)據(jù)操作就會失敗
    connection.end(function (err) {
     if (err) {
      console.log('關閉數(shù)據(jù)庫連接失??！')
      throw err
     }
    })
   })
  })
 },
}

然后我們可以在routes 目錄下的users文件中添加如下代碼：

var db = require('../conf/db')

router.get('/userList', (req, res, next) => {
 // sql查詢user表
 db.query('SELECT * FROM user', [], function (results, fields) {
  // 以json的形式返回
  res.json({ results })
 })
})

打開瀏覽器訪問 http://localhost:3000/users/userList