使用Express對mysql進行增改查操作(完全代碼版本)

使用Express對mysql進行增改查操作(完全代碼版本)

今天發的是Express對mysql進行增刪改操作的所有代碼，這個代碼還沒有完善好，都是一些基礎的增刪改查操作，有一些地方也寫上了注釋方便大家查看，還有更方便管理的方法，后續再給大家更新把，

最近要是有時間就會把文章寫出來給大家，希望想要學習的朋友都能學習順利，

server.js檔案夾完整的代碼示例

    // 引入 express 框架
    const express = require('express')
    const mysql = require("mysql");
    const bodyParser = require('body-parser');
?
    // 創建實體
    const app = express();
    // 決議 application/json
    app.use(bodyParser.json());
    // // 決議 application/x-www-form-urlencoded
    // app.use(bodyParser.urlencoded());
?
    app.all('*', function(req, res, next) {
        res.header('Access-Control-Allow-Origin',
            '*'); //*表示可以跨域任何域名都行（包括直接存在本地的html檔案）出于安全考慮最好只設定 你信任的來源也可以填域名表示只接受某個域名
        res.header('Access-Control-Allow-Headers', 'X-Requested-With,Content-Type'); //可以支持的訊息首部串列
        res.header('Access-Control-Allow-Methods', 'PUT,POST,GET,DELETE,OPTIONS'); //可以支持的提交方式
        res.header('Content-Type', 'application/json;charset=utf-8'); //回應頭中定義的型別
        next();
    });
?
    const connection = mysql.createConnection({ //建立一個連接引數方法
        host: 'localhost', //資料庫地址
        port: '3306', //埠號
        user: 'root', //用戶名
        password: 'root', //密碼
        database: 'test' //資料庫名稱
    });
    //用引數與資料庫進行連接
    // connection.connect();
    let str = '';
    connection.connect(); //打開連接
    // connection.end()//關閉連接 如果關閉連接第二次請求資料庫連接會失敗
    const getBanner = (table) => { //查詢資料
        return new Promise(function(resolve, reject) {
            let sql = `SELECT * FROM ${table}`;
            try {
                connection.query(sql, (err, data) => {
                    if (err) {
                        reject(err)
                    } else {
                        resolve(data)
                    }
                })
            } catch (e) {
                console.log(e);
            }
        })
    }
?
    const addBanner = (list) => { //增加資料
        // console.log(Object.values(list));
        list = Object.values(list) //將物件轉成陣列
        return new Promise(function(resolve, reject) {
            // const sql = 'UPDATE `user` SET ? WHERE id = ?'
            //     //若sql陳述句中包含多個?占位符,第二個實參必須傳遞一個陣列,并一一對應
            //     conn.query(sql,[user,user.id],(err,result) => {}
                
            let addSql = `INSERT INTO banner(name,url) VALUES (?,?)`;
            try {
                connection.query(addSql, list, (err, result) => {
                    if (err) {
                        reject(err)
                    } else {
                        result = {
                            code: 200,
                            msg: '增加成功'
                        };
                        resolve(result)
                    }
                })
            } catch (e) {
                console.log(e);
            }
        })
    }
?
?
    const deleteBanner = (list) => { //洗掉資料
        return new Promise(function(resolve, reject) {
            let deleteSql = `delete from banner where name='${list.name}'`;
            try {
                connection.query(deleteSql, (err, result) => {
                    if (err) {
                        reject(err)
                    } else {
                        result = {
                            code: 200,
                            msg: '洗掉成功'
                        };
                        // console.log(result);
                        resolve(result)
                    }
                })
            } catch (e) {
                console.log(e);
            }
        })
    }
?
    const updateBanner = (list) => { //修改資料
        return new Promise(function(resolve, reject) {
            let updateSql = `update  banner set ? where id=${list.id}`;
            try {
                connection.query(updateSql,list.data, (err, result) => {
                    if (err) {
                        reject(err)
                    } else {
                        result = {
                            code: 200,
                            msg: '修改成功'
                        };
                        // console.log(result);
                        resolve(result)
                    }
                })
            } catch (e) {
                console.log(e);
            }
        })
    }
    //2.發送請求(查詢)
    // var insert = `INSERT INTO table_name (name,url )VALUES(${name},${url});`
?
    app.get('/', (req, res) => {
        res.send('express啟動成功埠號3011');
    })
?
    app.post('/addbanner', (req, res) => { //增加
    addBanner(req.body).then(re => {
    console.log(re);
    res.send(re)
    })
    })
    app.post('/deletebanner', (req, res) => { //洗掉
    deleteBanner(req.body).then(re => {
    // console.log(re);
    res.send(re)
    })
    })
?
    app.post('/updatebanner', (req, res) => { //修改
    updateBanner(req.body).then(re => {
    console.log(re);
    res.send(re)
    })
    })
?
    app.post('/select', (req, res) => { //查詢某表資料
    getBanner(req.body.table).then(re => {
    res.send(re);
    })
    })
?
?
    // 監聽埠
    app.listen(3011, () => {
    console.log("服務已經啟動，3011 埠監聽中...");
    })
?

標籤：JavaScript

上一篇：1000粉！使用Three.js制作一個專屬3D獎牌🥇

下一篇：1000粉！使用Three.js制作一個專屬3D獎牌🥇