Node.js對MySQL數(shù)據(jù)庫的增刪改查實戰(zhàn)記錄

更新時間：2021年10月12日 14:56:30 作者：SunFlower914

這篇文章主要給大家介紹了關(guān)于Node.js對MySQL數(shù)據(jù)庫的增刪改查的相關(guān)資料,文中通過實例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作介紹的非常詳細(xì),需要的朋友可以參考下

在項目中操作數(shù)據(jù)庫的三大步驟

安裝操作 MySQL 數(shù)據(jù)庫的第三方模塊（mysql）
通過 mysql 模塊連接到 MySQL 數(shù)據(jù)庫
通過 mysql 模塊執(zhí)行 SQL 語句

操作數(shù)據(jù)庫的具體步驟

一：安裝MySQL模塊及express模塊

MySQL模塊是托管于npm上的第三方模塊，我們可以運行下方命令安裝MySQL第三方包，通過它來建立node.js項目與MySQL數(shù)據(jù)庫的連接，進(jìn)而操作數(shù)據(jù)庫（以下代碼在終端中運行）

//安裝mysql第三方模塊
npm i mysql
//安裝express第三方模塊
npm i express

二：通過express創(chuàng)建一個服務(wù)器

// 引入express
const express = require('express');
// 創(chuàng)建服務(wù)器
const app = express();
// 啟動服務(wù)器
app.listen(80, () => {
    console.log('http://127.0.0.1');
})

三：配置MySQL模塊

在使用 MySQL 模塊操作 MySQL 數(shù)據(jù)庫之前，必須先對 mysql模塊進(jìn)行必要的配置，主要的配置步驟如下：

// 1.引入mysql
const mysql = require('mysql');
// 2.建立與mysql數(shù)據(jù)庫連接
var db = mysql.createPool({
    host: '127.0.0.1',   // 數(shù)據(jù)庫的 ip 地址
    user: 'root',        // 登錄數(shù)據(jù)庫的賬號
    password: '123456',  // 登錄數(shù)據(jù)庫的密碼
    database: 'web67'    // 指定要操作哪個數(shù)據(jù)庫
});

四：測試 mysql 模塊能否正常工作

調(diào)用 db.query() 函數(shù)，指定要執(zhí)行的 SQL 語句，通過回調(diào)函數(shù)拿到執(zhí)行的結(jié)果

// 測試mysql模塊是否能正常運行，查找所有數(shù)據(jù)并顯示至頁面
    db.query('select * from one', (err, data) => {
        if (err) return console.log(err.message);
        if (data.length === 0) return console.log('數(shù)據(jù)庫無數(shù)據(jù)');
        console.log(data) //data是從數(shù)據(jù)庫中查找到的數(shù)據(jù)
        })
    });

以上代碼全部準(zhǔn)備完畢后開始對MySQL數(shù)據(jù)庫中的數(shù)據(jù)進(jìn)行增刪改查：

SELECT：查詢one數(shù)據(jù)表中所有的數(shù)據(jù):

案例代碼：

// 獲取數(shù)據(jù)庫中的數(shù)據(jù)
app.get('/selectuser', (req, res) => {
    // 查看數(shù)據(jù)庫連接是否成功
    db.query('select * from one', (err, data) => {
        //err不為空則表示錯誤
        if (err) return console.log(err.message);
        if (data.length === 0) return console.log('獲取失敗');
        res.send(data)
    })
});

INSERT INTO:向數(shù)據(jù)庫中添加數(shù)據(jù)：

案例代碼：

這里用到了post請求，需要通過req.body接收客戶端請求的數(shù)據(jù)，并通過app.use(express.urlencoded({extended:false}))代碼行將數(shù)據(jù)進(jìn)行解析（見下方完整代碼）

// 向數(shù)據(jù)庫添加數(shù)據(jù)
app.post('/insertuser', (req, res) => {
    // 接收客戶端請求的數(shù)據(jù)
    const body = req.body;
    // 構(gòu)建sql語句
    const sql = 'insert into one set ?'
        // 將客戶請求的數(shù)據(jù)插入到數(shù)據(jù)庫中
    db.query(sql, body, (err, data) => {
        if (err) return console.log(err.message);
        if (data.affectedRows !== 1) return console.log('添加失敗');
        res.send({
            status: 0,
            msg: '添加數(shù)據(jù)成功'
        })
    })
})

UPADTE:修改數(shù)據(jù)庫中的數(shù)據(jù)：

案例代碼：

// 修改數(shù)據(jù)庫中數(shù)據(jù)
app.post('/updateuser', (req, res) => {
    //接收客戶端請求的數(shù)據(jù)
    const body = req.body;
    //構(gòu)建修改的sql語句
    const sql = 'update one set uname=? where id=?';
    db.query(sql, [body.uname, body.id], (err, data) => {
        if (err) return console.log(err.message);
        if (data.affectedRows !== 1) return console.log('修改失敗');
        res.send({
            status: 0,
            msg: '修改數(shù)據(jù)成功'
        })
    })
})

DELETE:刪除數(shù)據(jù)庫中的數(shù)據(jù)：

案例代碼：

// 刪除數(shù)據(jù)庫中的數(shù)據(jù)
app.get('/deleteuser/:id', (req, res) => {
    // 獲取客戶端提交的數(shù)據(jù),req.params通過:冒號匹配動態(tài)參數(shù)
    const id = req.params.id;
    // 構(gòu)建刪除的sql語句，一般為了防止數(shù)據(jù)被永久性刪除，我們會通過update將該條數(shù)據(jù)對應(yīng)的
       狀態(tài)碼先修改為0
    const sql = 'update one set status=0 where id=?';
    // 執(zhí)行sql
    db.query(sql, id, (err, data) => {
        if (err) return console.log(err.message);
        if (data.affectedRows !== 1) return console.log('刪除失敗');
        res.send({
            status: 0,
            msg: '刪除成功'
        })
    })
})

到這里通過express中間件對MySQL數(shù)據(jù)庫的增刪改查就完成啦，【完整代碼】如下：

// 通過express中間件實現(xiàn)對mysql數(shù)據(jù)庫的增刪改查
const express = require('express');
// 創(chuàng)建一個服務(wù)器
const app = express();
// 解析客戶端請求的數(shù)據(jù)
app.use(express.urlencoded({ extended: false }));
// 引入mysql操作數(shù)據(jù)庫
const mysql = require('mysql');
// 配置數(shù)據(jù)庫
const db = mysql.createPool({
    host: '127.0.0.1', //數(shù)據(jù)庫ip地址
    user: 'root', //數(shù)據(jù)庫賬號
    password: '123456', //數(shù)據(jù)庫密碼
    database: 'web67' //數(shù)據(jù)庫名稱
});
 
// 獲取數(shù)據(jù)庫中的數(shù)據(jù)
app.get('/selectuser', (req, res) => {
    // 查看數(shù)據(jù)庫連接是否成功
    db.query('select * from one', (err, data) => {
        if (err) return console.log(err.message);
        if (data.length === 0) return console.log('獲取失敗');
        res.send(data)
    })
});
 
// 向數(shù)據(jù)庫添加數(shù)據(jù)
app.post('/insertuser', (req, res) => {
    // 接收客戶端請求的數(shù)據(jù)
    const body = req.body;
    // 構(gòu)建sql語句
    const sql = 'insert into one set ?'
        // 將客戶請求的數(shù)據(jù)插入到數(shù)據(jù)庫中
    db.query(sql, body, (err, data) => {
        if (err) return console.log(err.message);
        if (data.affectedRows !== 1) return console.log('添加失敗');
        res.send({
            status: 0,
            msg: '添加數(shù)據(jù)成功'
        })
    })
})
 
// 修改數(shù)據(jù)庫中數(shù)據(jù)
app.post('/updateuser', (req, res) => {
    const body = req.body;
    const sql = 'update one set uname=? where id=?';
    db.query(sql, [body.uname, body.id], (err, data) => {
        if (err) return console.log(err.message);
        if (data.affectedRows !== 1) return console.log('修改失敗');
        res.send({
            status: 0,
            msg: '修改數(shù)據(jù)成功'
        })
    })
})
 
// 刪除數(shù)據(jù)庫中的數(shù)據(jù)(指定id)
app.get('/deleteuser/:id', (req, res) => {
        const id = req.params.id; //id為動態(tài)參數(shù)，所以要通過req.params獲取
        const sql = 'update one set status=0 where id=?'
        db.query(sql, id, (err, data) => {
            if (err) return console.log(err.message);
            if (data.affectedRows !== 1) return console.log('刪除數(shù)據(jù)失敗');
            res.send({
                status: 0,
                msg: '刪除成功'
            })
        })
    })
    // 啟動服務(wù)器
app.listen(80, () => {
    console.log('http://127.0.0.1');
})