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();
复制代码

客户端发送删除数据的参数，客户端拿到参数，根据条件，操做数据库删除相应数据，响应客户端：删除成功。删除后的数据表：

总结

接触后端的内容后，从后端的角度从新理解了前端数据的传输和操做。