深入出来的Node.js操作MySQL
`本文是一篇使用mysql这个npm模块操作MySQL数据库的基础教程。 不涉及MySQL的安装和配置,如果电脑中还未安装MySQL, 推荐安装WAMP、XAMPP等集成环境。
转载:https://segmentfault.com/a/1190000016835736
初始化项目
创建项目目录,并使用npm init初始化项目后,执行下面操作:
安装依赖
npm install mysql koa koa-router
创建index.js
// index.js
const 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数据库连接成功。
深入出来的Node.js操作MySQL打开浏览器, 访问localhost:3000,当看到屏幕显示Visit index时,表名项目初始化成功。
深入出来的Node.js操作MySQL数据库操作
创建数据库
当访问/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
深入出来的Node.js操作MySQL创建数据表
为了方便,我们直接在连接时使用刚才创建的数据库,需要在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
深入出来的Node.js操作MySQL插入数据
插入单条数据
当访问/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
深入出来的Node.js操作MySQL插入多条数据
当访问/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
深入出来的Node.js操作MySQL使用phpMyAdmin访问,可以看到此时mysqlkoa表如下
深入出来的Node.js操作MySQL删除数据
当访问/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
深入出来的Node.js操作MySQL查找数据
当访问/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给大家推荐一个免费的学习群,里面概括移动应用网站开发,css,html,webpack,vue node angular以及面试资源等。
对web开发技术感兴趣的同学,欢迎加入Q群:864305860,不管你是小白还是大牛我都欢迎,还有大牛整理的一套高效率学习路线和教程与您免费分享,同时每天更新视频资料。
最后,祝大家早日学有所成,拿到满意offer,快速升职加薪,走上人生巅峰。