Node.js学习5~nodejs操作mysql数据库，实现增删改查

Posted 2022-01-06 秋9

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Node.js学习5~nodejs操作mysql数据库，实现增删改查相关的知识，希望对你有一定的参考价值。

1.安装mysql数据库

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

安装后，连接参数如下

host:192.168.1.3
user:nodejs
password:nodejs

2.Mysql库和表结构

CREATE DATABASE `nodejs` /*!40100 DEFAULT CHARACTER SET utf8mb4 */

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;

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-------------");
)

4.运行及查看效果

4.1安装nodejs模块

具体命令如下：

D:\\work\\nodejs\\2mysql>npm install express

added 50 packages in 2s

D:\\work\\nodejs\\2mysql>npm install mysql

added 9 packages in 1s

D:\\work\\nodejs\\2mysql>npm install md5-node

up to date in 1s