Node连接MySql快速实战(增删改查)

之前所了解的链接数据库都是mongoodb,那如何链接MySql呢？接下来将详细说明。

1. 在链接MySql之前，当前的电脑需要拥有一个集成的环境，所以先要安装 xampp。
2. 安装完成之后，启动MySql服务，当它变成绿色则说明启动成功。
3. 在浏览器中输入localhost进入apache提供的地址，点击右上方导航phpmyadmin进入本地数据库地址。
4. 新建文件夹nodemysql，并初始化项目npm init
5. mysqljs使用教程
6. 安装mysql npm install mysql
7. 安装express npm install express
8. 安装nodemonnpm install nodemon -g 如果之前安装过可以跳过
9. 创建链接

const express = require('express');
const mysql = require('mysql');

const app = express();

//创建链接
const db = mysql.createConnection({
    host     : 'localhost',
    user     : 'root',
    password : '',
    // database : 'my_db'
});

app.listen('3000',() => {
    console.log('服务启动3000');
});

注意：
创建链接中字段对应的参数为步骤3中打开网页的字段对应

QQ截图20190529142002.png

10. 创建数据库

//创建数据库
app.get('/createddb',(req,res) => {
    let sql = 'CREATE DATABASE nodemysql';//'CREATE DATABASE'为sql语句，'nodemysql'为数据库名称
    db.query(sql,(err,result) => {
        if(err) throw err;
        console.log(result);
        res.send('database created...');
    })
})

保存成功后，访问http://localhost:3000/createddb 就已经成功的创建了数据库了，此时刷新phpmyadmin的页面，也可以成功看见创建的数据库列表

QQ截图20190529143459.png
但此时数据库中没有数据表，接下来我们新建一张数据表

11. 先把之前的数据库配置修改一下,打开database配置，并设置成刚刚新建的数据库名称

//创建连接
const db = mysql.createConnection({
    host     : 'localhost',
    user     : 'root',
    password : '',
    database : 'nodemysql'
});

12. 创建表

//创建表
app.get('/createpoststable',(req,res) => {
    let sql = 'CREATE TABLE posts(id int AUTO_INCREMENT,title VARCHAR(255),body  VARCHAR(255),PRIMARY KEY(id))';
    //'CREATE TABLE'创建表，‘posts’为表名称 id为字段，int确定该字段为整型，AUTO_INCREMENT确定该字段自增
    //不同字段间用，隔开
    //VARCHAR(255) 为字符数据，且长度为255
    //'PRIMARY KEY'为主键，一张表中必须有且仅有一个字段为主键

    db.query(sql,(err,result) => {
        if(err) throw err;
        console.log(result);
        res.send('posts created...');
    })

})

访问http://localhost:3000/createpoststable 后，数据表就新建成功了。

新建表

13. 新增数据

//新增数据
app.get('/addpost1',(req,res) => {
    let data = {
        title:'neo',
        body:'sssss'
    }
    let sql = 'INSERT INTO posts SET ?';
    //'INSERT INTO'新增数据，‘posts’为表名称 ？为自定义插入内容，此处定义的内容为data

    db.query(sql,data,(err,result) => {
        if(err) throw err;
        console.log(result);
        res.send('数据添加成功！');
    })
})

注意如果新增数据为中文会出现乱码现象。

乱码
所以需要修改数据库的配置项

//创建数据库
app.get('/createddb',(req,res) => {
    let sql = 'CREATE DATABASE IF NOT EXISTS nodemysql default character set utf8 COLLATE utf8_general_ci;';//'CREATE DATABASE'为sql语句，'nodemysql'为数据库名称
    db.query(sql,(err,result) => {
        if(err) throw err;
        console.log(result);
        res.send('database created...');
    })
})

14. 查询数据

//查询数据（多条）
app.get('/getposts',(req,res) => {
    let sql = 'SELECT * FROM posts';
    db.query(sql,(err,result) => {
        if(err) throw err;
        console.log(result);
        res.json(result);
    })
})

//查询数据（单条）
app.get('/getposts/:id',(req,res) => {
    let sql =  `SELECT * FROM posts WHERE id = ${req.params.id}`;
    db.query(sql,(err,result) => {
        if(err) throw err;
        console.log(result);
        res.json(result);
    })
})

15. 更新数据

//更新内容
app.get('/updatepost/:id',(req,res) => {
    let newTitle = '最新标题';
    let sql =  `UPDATE posts SET title = '${newTitle}' WHERE id = ${req.params.id}`;
    db.query(sql,(err,result) => {
        if(err) throw err;
        console.log(result);
        res.json(result);
    })
})

16. 删除内容

app.get('/deletepost/:id',(req,res) => {
    let sql =  `DELETE FROM posts WHERE id = ${req.params.id}`;
    //如果不给条件，会把整个表的数据全部删除
    db.query(sql,(err,result) => {
        if(err) throw err;
        console.log(result);
        res.send('删除成功！');
    })
})