1.安装Mysql数据库

这里略，自己在网上查安装，有问题，随时留言。

安装后，连接参数如下

2.Mysql库和表结构

3.编写nodejs代码，实现增删改查

const express = require("express");
const app = express();
const mysql = require("mysql");
var md5 = require('md5-node');

// 创建连接
const db = mysql.createConnection({
    host:"192.168.1.3",
    user:"nodejs",
    password:"nodejs",
    database:"nodejs"
})
db.connect( (err) => {
    if(err) throw err;
    console.log('连接成功');
})

//  创建表
app.get("/create",(req,res) => {
    //  创建表 表名为user
    let sql = "CREATE TABLE `user` ("+
				  "`id` int(11) NOT NULL AUTO_INCREMENT,"+
				  "`loginName` varchar(50) DEFAULT NULL,"+
				  "`loginPwd` varchar(50) DEFAULT NULL,"+
				  "PRIMARY KEY (`id`)"+
				") ENGINE=InnoDB DEFAULT CHARSET=utf8mb4";
    db.query(sql,(err,result) => {
        if(err){
            console.log(err);
        }else{
			console.log(result);
            res.send("user表创建成功....")
        }
    })
	
})

// 插入数据
app.get("/insert",(req,res) => {
    let post = {loginName:"user1",loginPwd:md5("pwd1")};
    let sql = "INSERT INTO user SET ?";
    db.query(sql,post,(err,result) => {
        if(err){
            console.log(err);
        }else{
            console.log(result);
            res.send("user insert....")
        }
    })
})
// 查询内容
app.get("/gets",(req,res) => {
    let sql = "SELECT * FROM user";
	db.query(sql,(err,result) => {
        if(err){
            console.log(err);
        }else{
			console.log(result);
            res.json(result);
        }
    })
})

// 查询单条内容
app.get("/get/:id",(req,res) => {
    let sql = `SELECT * FROM user WHERE id = ${req.params.id}`;
	db.query(sql,(err,result) => {
        if(err){
            console.log(err);
        }else{
			console.log(result);
            res.json(result);
        }
    })
})
// 更新内容
app.get("/update/:id",(req,res) => {
    let sql = `UPDATE user SET loginPwd = '${md5(req.query.loginPwd)}' WHERE id = ${req.params.id}`;
    db.query(sql,(err,result) => {
        if(err){
            console.log(err);
        }else{
			console.log(result);
            res.send(`update ${req.params.id} success....`)
        }
    })
	
})

// 删除内容
app.get("/del/:id",(req,res) => {
    let sql = `DELETE FROM user WHERE id = ${req.params.id}`;
    db.query(sql,(err,result) => {
        if(err){
            console.log(err);
        }else{
			console.log(result);
            res.send("删除成功.....")
        }
    })
	
})


app.listen(8080, () => {
    console.log("web服务器,访问地址http://localhost:8080-------------");
})