Node.js+Express+Mysql 實現增刪改查

時間  2019-11-06
標籤 node.js+express+mysql node express mysql 實現 增刪 欄目 JavaScript 简体版
原文   原文鏈接

前言

此次選用nodejs+express+mysql 使用http做爲客戶端，express框架搭建服務端，從而實現數據的增刪改查。這篇文章能夠算做上篇文章的升級篇，加入了和數據庫的交互。前端

安裝

node 直接去官網下載選擇下載便可 nodejs.org/en/download…node

cnpm install express //express框架安裝
複製代碼
cnpm install mysql //mysql驅動安裝
複製代碼
brew install mysql //數據庫的安裝，根據命令行提示初始化配置
 mysql.server start//啓動mysql服務
 mysql.server stop//中止mysql服務
 mysql -u用戶名 -p用戶密碼//登陸mysql
複製代碼

nodejs鏈接數據庫時報錯mysql

Error: ER_NOT_SUPPORTED_AUTH_MODE: Client does not support 
authentication protocol requested by server; consider upgrading MySQL client
複製代碼

查到的結論是： MySQL8.0版本的加密方式和MySQL5.0的不同，鏈接會報錯。
解決方法以下： 經過命令行進入解壓的mysql根目錄下。
登錄數據庫
mysql -uroot -p
輸入root的密碼
Enter password: ******
更改加密方式
mysql> ALTER USER 'root'@'localhost' IDENTIFIED BY 'password' PASSWORD EXPIRE NEVER;
更改密碼：該例子中 123456爲新密碼
mysql> ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY '123456';
刷新：
mysql> FLUSH PRIVILEGES;web

數據庫的鏈接

var mysql = require('mysql');//引入數據庫驅動模塊
//console.log(mysql)
// 鏈接數據庫的配置
var connection = mysql.createConnection({
  // 主機名稱，通常是本機
  host: 'localhost',
  // 數據庫的端口號，若是不設置，默認是3306
  port: '3306',
  // 建立數據庫時設置用戶名
  user: 'root',
  // 建立數據庫時設置的密碼
  password: '*******',
  // 建立的數據庫
  database: 'express'
});
// 與數據庫創建鏈接
connection.connect();
// 查詢數據庫
connection.query('select * from userinfo', function (error, results, fields) {
  if (error) throw error;
  console.log(results);
});

// 關閉鏈接
connection.end();
複製代碼

新建一張表格在數據庫中爲：sql

express服務端

Express 是一個基於 Node.js 平臺的極簡、靈活的 web 應用開發框架，這裏沒有搭建express框架的項目，只是簡單搭建一個服務端，實現和數據庫的增刪改查。數據庫

var express = require("express");
var app = express();
var query = require('./db')
//var router =require('router')
var mysql = require('mysql');
var querystring = require("querystring");
//console.log(mysql)
// 鏈接數據庫的配置
var connection = mysql.createConnection({
    // 主機名稱，通常是本機
    host: 'localhost',
    // 數據庫的端口號，若是不設置，默認是3306
    port: '3306',
    // 建立數據庫時設置用戶名
    user: 'root',
    // 建立數據庫時設置的密碼
    password: '1234567',
    // 建立的數據庫
    database: 'express'
});
// 與數據庫創建鏈接
connection.connect();
//根據參數，查詢數據
app.get('/index', function (req, res) {
    // 處理 get 請求，獲取 get 請求參數
    //處理 /:xxx 形式的 get 或 post 請求，獲取請求參數 這裏沒有使用到
    var params = req.query
    //查詢語句
    var sql = 'select * from userinfo where name= ? and age=?'
    var where_value = [params.name, params.age];
    // console.log(sql)
    connection.query(sql, where_value, function (err, result) {
        if (err) {
            console.log('[SELECT ERROR]:', err.message);
        }
        res.send(result) //數據庫查詢結果返回到result中,把查詢數據發送到客戶端
    });

})
//增長數據
app.post('/add', function (req, res) {
    //獲取及處理增長的數據
    var post = '';
    req.on('data', function (chunk) {
        post += chunk;
        console.log(post)
    });
    req.on('end', function () {
        //查詢參數解析
        post = querystring.parse(post);
        var sql = 'insert into userinfo set id=? , name=? , age=?, address=?'
        var add_value = [post.id, post.name, post.age, post.address]
        connection.query(sql, add_value, function (err, result) {
            if (err) {
                console.log('新增數據失敗');
            }
            res.send('增長數據成功') //   響應內容 增長數據成功
        });
    });
})
//修改數據
app.put('/update', function (req, res) {
    //處理請求修改的數據和條件
    var update = '';
    req.on('data', function (chunk) {
        update += chunk;
        console.log(update)
    });
    req.on('end', function () {
        //查詢參數解析
        update = querystring.parse(update);
        var sql = 'update userinfo set name=? , age=?, address=? where id=?'
        var update_value = [update.name, update.age, update.address,update.id]
        connection.query(sql, update_value, function (err, result) {
            if (err) {
                console.log('修改數據失敗', err.message);
            }
            res.send('修改數據成功') //   響應內容 修改數據成功
        });
    });
})
//刪除數據
app.delete('/delete', function (req, res) {
    var params = req.query
    var sql = 'delete from userinfo where name= ?'
    var where_value = [params.name];
    // console.log(sql)
    connection.query(sql, where_value, function (err, result) {
        if (err) {
            console.log('刪除失敗', err.message);
        }
        res.send('刪除成功')
    });
})
//關閉鏈接  
//connection.end();
//監聽8080端口
var server = app.listen(8080, function () {
    console.log('server running at 3000 port')
})
複製代碼

http客戶端

這裏把node http模塊來搭建客戶端，發起請求。express

get請求

const http = require("http");
// 發送請求的配置
let config = {
    host: "localhost",
    port: 8080,
    //get請求參數
    path:'/index?name=bill&age=21',
    method: "GET",
    headers: {
        a: 1
    }
};
// 建立客戶端
let client = http.request(config, function(res) {
    // 接收服務端返回的數據
   let repData='';
    res.on("data", function(data) {
        repData=data.toString()
        console.log(repData)
    });
    res.on("end", function() {
        // console.log(Buffer.concat(arr).toString());
    });
});
// 發送請求
client.end();
複製代碼

客戶端發起參數name=bill&age=21的查詢請求，服務端根據條件操做數據庫，響應數據爲： npm

post請求

var http = require('http');
var querystring = require("querystring");
//查詢參數拼接
//增長的數據
var contents = querystring.stringify({
    id:5,
    age:'23',
    name: "艾利斯提",
    address: "dongbei",
});
var options = {
    host: "localhost",
    port: 8080,
    path:"/add",
    method: "POST",
    headers: {
        "Content-Type": "application/x-www-form-urlencoded",
        "Content-Length": contents.length
    }
};
var req = http.request(options, function (res) {
    res.setEncoding("utf8");
    res.on("data", function (data) {
        console.log(data);
    })
})
//發送數據
req.write(contents);
req.end(); //結束請求，不然服務器將不會收到信息
複製代碼

post請求發送增長數據，服務端根據請求，向數據庫追加一條數據，響應客戶端：增長數據成功。增長後的數據表：後端

put請求

const http = require("http");
var querystring = require("querystring");
//查詢參數拼接
// 發送請求的配置
var contents = querystring.stringify({
    id:1,
    age:'25',
    name: "Sarah",
    address: "qingdao",
});
let config = {
    host: "localhost",
    port: 8080,
    path:'/update',
    method: "PUT",
    headers: {
        a: 1
    }
};
// 建立客戶端
let client = http.request(config, function(res) {
    // 接收服務端返回的數據
   let repData='';
    res.on("data", function(data) {
        repData=data.toString()
        console.log(repData)
    });
  
});
  client.write(contents);
// 發送請求
client.end();
複製代碼

這裏請求和post方法相似，服務端根據sql語句('update userinfo set name=? , age=?, address=? where id=?')修改數據庫的內容，響應客戶端：修改數據成功。修改後的數據表：bash

delete請求

const http = require("http");
// 發送請求的配置
let config = {
    host: "localhost",
    port: 8080,
    //刪除數據的參數
    path:'/delete?name=bill',
    method: "DELETE",
    headers: {
        a: 1
    }
};
// 建立客戶端
let client = http.request(config, function(res) {
    // 接收服務端返回的數據
   let repData='';
    res.on("data", function(data) {
        repData=data.toString()
        console.log(repData)
    });
    res.on("end", function() {
        // console.log(Buffer.concat(arr).toString());
    });
});
// 發送請求
client.end();
複製代碼

客戶端發送刪除數據的參數，客戶端拿到參數，根據條件，操做數據庫刪除相應數據，響應客戶端：刪除成功。刪除後的數據表：

總結

接觸後端的內容後，從後端的角度從新理解了前端數據的傳輸和操做。

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程