本文是一篇使用mysql这个npm模块操作mysql数据库的基础教程。 不涉及mysql的安装和配置，如果电脑中还未安装mysql, 推荐安装wamp、xampp等集成环境。本文中还使用到了轻量级的node.js框架koa搭建web程序，为的是通过前端浏览器请求的方式来模拟项目场景，你无需掌握koa框架的语法也是可以轻松阅读本文的。
初始化项目创建项目目录，并使用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(); }); })})
重新执行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(); }) })})
重新执行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(); }) })})
重新执行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(); }) })})
重新执行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
以上就是node.js中操作mysql数据库的基础教程的详细内容。