深入出来的Node.js操作MySQL-白红宇

本文是一篇使用mysql这个npm模块操作MySQL数据库的基础教程。不涉及MySQL的安装和配置，如果电脑中还未安装MySQL, 推荐安装WAMP、XAMPP等集成环境。转载：

初始化项目

创建项目目录，并使用npm init初始化项目后，执行下面操作：

安装依赖

npm install mysql koa koa-router复制代码

创建index.js

// index.jsconst Koa = require('koa');const Router = require('koa-router');const mysql = require('mysql');const app = new Koa();const router = new Router();const connection = mysql.createConnection({ host: 'localhost', // 填写你的mysql host user: 'root', // 填写你的mysql用户名 password: '123456' // 填写你的mysql密码})connection.connect(err => { if(err) throw err; console.log('mysql connncted success!');})router.get('/', ctx => { ctx.body = 'Visit index';})app.use(router.routes());app.listen(3000);复制代码

在shell中执行node index.js，当看到shell中打印出mysql connected success!，表明MySQL数据库连接成功。

打开浏览器, 访问localhost:3000，当看到屏幕显示Visit index时，表名项目初始化成功。

数据库操作

创建数据库

当访问/createdb时，创建一个mysqlkoa的数据库，代码如下：

router.get('/createdb', ctx => { return new Promise(resolve => { const sql = `CREATE DATABASE mysqlkoa`; connection.query(sql, (err) => { if (err) throw err; ctx.body = { code: 200, msg: `create database mysqlkoa success!` } resolve(); }); })})//欢迎加入全栈开发交流群一起学习交流：864305860复制代码

重新执行node index.js，并使用浏览器访问localhost:3000/createdb

创建数据表

为了方便，我们直接在连接时使用刚才创建的数据库，需要在mysql.createConnection中添加database:mysqlkoa的配置项。

const connection = mysql.createConnection({ host: 'localhost', user: 'root', password: '123456', database: 'mysqlkoa' // 添加该列})复制代码

当访问/createtable时，我们创建一个数据表fe_frame，该表用来保存前端框架的数据：

router.get('/createtable', ctx => { return new Promise(resolve => { const sql = `CREATE TABLE fe_frame( id INT(11) AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), author VARCHAR(255) )`; connection.query(sql, (err ,results, filelds) => { if (err) throw err; ctx.body = { code: 200, msg: `create table of fe_frame success!` } resolve(); }) })})复制代码

重新执行node index.js，并使用浏览器访问localhost:3000/createtable

插入数据

插入单条数据

当访问/insert时，用来插入单条数据：

router.get('/insert', ctx => { return new Promise(resolve => { const sql = `INSERT INTO fe_frame(name, author) VALUES('vue', 'Evan')`; connection.query(sql, (err) => { if (err) throw err; ctx.body = { cde: 200, msg: `insert data to fe_frame success!` } resolve(); }) })})给大家推荐一个免费的学习群，里面概括移动应用网站开发，css，html，webpack，vue node angular以及面试资源等。对web开发技术感兴趣的同学，欢迎加入Q群：864305860，不管你是小白还是大牛我都欢迎，还有大牛整理的一套高效率学习路线和教程与您免费分享，同时每天更新视频资料。最后，祝大家早日学有所成，拿到满意offer，快速升职加薪，走上人生巅峰。复制代码

重新执行node index.js，并使用浏览器访问localhost:3000/insert

插入多条数据

当访问/insertmulti时，用来插入多条数据：

router.get('/insertmulti', ctx => { return new Promise(resolve => { const sql = `INSERT INTO fe_frame(name, author) VALUES ?`; const values = [ ['React', 'Facebook'], ['Angular', 'Google'], ['jQuery', 'John Resig'] ]; connection.query(sql, [values], (err, result) => { if (err) throw err; ctx.body = { code: 200, msg: `insert ${result.affectedRows} data to fe_frame success!`  } resolve(); }) })})复制代码

重新执行node index.js，并使用浏览器访问localhost:3000/insertmulti

使用phpMyAdmin访问，可以看到此时mysqlkoa表如下

删除数据

当访问/delete时，删除相应行。我们使用请求参数name来指定删除哪个框架，在服务器端使用ctx.query.name获取，代码如下：

router.get('/delete', ctx => { return new Promise(resolve => { const name = ctx.query.name; const sql = `DELETE FROM fe_frame WHERE name = '${name}'`; connection.query(sql, (err, result) => { if (err) throw err; ctx.body = { code: 200, msg: `delete ${result.affectedRows} data from fe_frame success!` }; resolve(); }) })})//欢迎加入全栈开发交流群一起学习交流：864305860复制代码

重新执行node index.js，并使用浏览器访问http://localhost:3000/delete?name=jQuery

修改数据

当访问/update时，更新vue框架的作者名为Evan You，代码如下：

router.get('/update', ctx => { return new Promise(resolve => { const sql = `UPDATE fe_frame SET author = 'Evan You' WHERE NAME = 'vue'`; connection.query(sql, (err, result) => { if (err) throw err; ctx.body = { code: 200, msg: `update ${result.affectedRows} data from fe_frame success!` }; resolve(); }) })})//欢迎加入全栈开发交流群一起学习交流：864305860复制代码

重新执行node index.js，并使用浏览器访问http://localhost:3000/update

查找数据

当访问/select时，获取满足请求参数中框架名条件的项，代码如下：

router.get('/select', ctx => { return new Promise(resolve => { let name = ctx.query.name; const sql = `SELECT * FROM fe_frame WHERE name = '${name}'`; connection.query(sql, (err, result) => { if (err) throw err; ctx.body = { code: 200, data: result } resolve(); }) })})复制代码

重新执行node index.js，并使用浏览器访问http://localhost:3000/select?name=vue

给大家推荐一个免费的学习群，里面概括移动应用网站开发，css，html，webpack，vue node angular以及面试资源等。对web开发技术感兴趣的同学，欢迎加入Q群：864305860，不管你是小白还是大牛我都欢迎，还有大牛整理的一套高效率学习路线和教程与您免费分享，同时每天更新视频资料。最后，祝大家早日学有所成，拿到满意offer，快速升职加薪，走上人生巅峰。