导语:之前做过一个小我的项目,其中用到了 node 和 mysql,当初就联合这两者做一个应用操作总结。CURD 是数据库技术中的缩写词,代表创立(Create)、更新(Update)、读取(Retrieve)和删除(Delete)操作,用于解决数据等操作。
目录
- 后期筹备
- 实战演练
- 办法总结
后期筹备
装置 php 环境
- 手动装置
倡议浏览本博客另一篇文章《win10 手动配置 php 开发环境教程》
- 集成环境装置
能够应用这几个集成包:
PHPStudy
LNMP
XAMPP
wampserver
appserv
装置 node 环境
在 nodejs 官网下面下载而后装置,一步一步的装置好了以下,查问下那个版本。
实战演练
本大节通过一个商品的增删改查来展现如何应用 node 来连贯 mysql 进行各种操作。
node 筹备
- 装置依赖包
$ mkdir demo
$ cd demo
$ npm init
$ npm install express --save
$ npm install -g express-generator
$ npm install pm2 -g
$ npm install supervisor
- 启动 node 服务
编写启动脚本
// index.js
const express = require('express');
const app = express();
const port = 3000;
const db = require('./mysql');
app.get('/', (req, res) => {res.send('Hello,demo!');
})
app.listen(port, () => {console.log('Server is running on port', port + '!');
})
在 package.json
退出以下命令
"dev": "node index.js"
// package.json
{
"name": "demo",
"version": "1.0.0",
"description": "","main":"index.js","scripts": {"test":"echo \"Error: no test specified\" && exit 1","dev":"node index.js"},"author":"",
"license": "ISC",
"dependencies": {
"express": "^4.17.1",
"mysql": "^2.18.1",
"supervisor": "^0.12.0"
}
}
启动脚本
$ npm run start
# 或者
$ supervisor index.js
mysql 筹备
建设一个名叫 demo
的数据库,而后建一个名称为 goods
的数据表, 接着进行如下构造的配置。
以下是具体的命令行操作方法。
- 连贯数据库
$ mysql -h 127.0.0.1 -P 3306 -u demo -p
# 输出明码后回车确认
Enter password:
连贯胜利后如下所示:
Welcome to the MySQL monitor. Commands end with ; or \g.
Your MySQL connection id is 455
Server version: 5.7.26 MySQL Community Server (GPL)
Copyright (c) 2000, 2021, Oracle and/or its affiliates.
Oracle is a registered trademark of Oracle Corporation and/or its
affiliates. Other names may be trademarks of their respective
owners.
Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.
mysql>
- sql 语句操作
-- 建设 demo 用户
mysql> CREATE USER 'demo'@'127.0.0.1' IDENTIFIED BY 'demo123456.';
-- 建设 demo 数据库
mysql> CREATE DATABASE demo;
-- 赋予用户 demo 操作数据库 demo 的权限
mysql> GRANT ALL PRIVILEGES ON demo.* TO 'demo'@'127.0.0.1';
FLUSH PRIVILEGES;
-- 创立数据表
mysql> CREATE TABLE `goods` (`id` int(11) NOT NULL COMMENT 'id',
`name` varchar(255) COLLATE utf8_unicode_ci NOT NULL COMMENT '名称',
`number` int(11) NOT NULL COMMENT '数量',
`price` int(11) NOT NULL COMMENT '价格',
`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创立工夫',
`update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新工夫'
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='商品表';
node 连贯 mysql
- 装置依赖包
终于到了最要害的一步,首先装置 mysql 依赖包。回到 demo
目录上面,而后关上命令行。
mysql 包地址
$ npm install mysql
- 编写 mysql 文件
// mysql.js
const mysql = require('mysql');
const connection = mysql.createConnection({
host: '127.0.0.1',
user: 'demo',
password: 'demo123456.',
database: 'demo'
});
connection.connect(function (err) {if (err) {console.error(`error connecting: ${err.stack}`);
return;
}
console.log(`Mysql is connected! 连贯 id: ${connection.threadId}`);
});
module.exports = db;
- 导入 mysql
引入 index.js
文件中
// index.js
const db = require('./mysql');
运行胜利后的截图:
curd 操作
以下操作均在 index.js
中操作。
- 查问商品信息
查问须要用到的语句SELECT < 字段 > FROM < 表名 > < 查问条件 >
;
例如:
mysql> SELECT * FROM `goods`;
*
示意全副的字段,如果你只想要查问 id 和名称,只须要写入 SELECT id,name FROM "goods"
即可。
// 查问商品信息
app.get('/goods', (req, res) => {let result = {};
db.query('SELECT * FROM `goods`', function (error, results, fields) {if (error) {
result = {
code: 101,
msg: 'get_fail',
data: {info: "查问失败!"}
}
};
result = {
code: 200,
msg: 'get_succ',
data: {
info: "查问胜利!",
list: results
}
}
res.json(result);
});
})
在地址栏输出http://localhost:3000/goods
,便能够看到查问的信息。
- 增加商品信息
刚刚查问了一下,发现外面的商品空洞无物,当初来增加几条商品信息。
创立须要用到的语句格局大抵为INSERT INTO < 表名 >(< 字段 1, 字段 2,...>) VALUES (值 1,)
;
例如:
mysql> INSERT INTO `goods`(`name`, `number`, `price`) VALUES ('香蕉', 8, 10);
留神 : 增加商品是post
申请, 所以须要提前下载一个 api 接口软件,有利于测试,比拟有名的是postman
。请自行下载安装。
postman 下载地址
接着开始进行商品的程序编写, 因为 mysql 倡议表,字段加反斜线,故本次 mysql 语句不应用模板字符串,而是应用字符串拼接办法。
装置body-parser
, 这个是解析前端 post 申请的 body 内容。
$ npm install body-parser
引入 index.js 文件。
// index.js
// 增加商品
// 引入 body-parser
const bodyParser = require('body-parser');
app.use(bodyParser.urlencoded({ extended: false}))
app.use(bodyParser.json());
app.post('/goods', (req, res) => {let result = {};
let params = req.body;
let names = '',values ='';
for (const key in params) {
names += '`'+ key + '`,';
if (key == 'name') {values += `"${params[key]}",`;
} else {values += `${params[key]},`;
}
}
names = names.slice(0, names.length-1);
values = values.slice(0, values.length-1);
db.query('SELECT id FROM `goods` WHERE name="' + params.name + '"', function (error, results, fields) {if (error) {
result = {
code: 101,
msg: 'get_fail',
data: {info: "查问失败!"}
}
};
if (results && results.length) {
result = {
code: 200,
msg: 'get_succ',
data: {info: "商品已存在!"}
}
return res.json(result);
}
db.query('INSERT INTO `goods`(' + names + ') VALUES (' + values + ')', function (error, results, fields) {if (error) {
result = {
code: 101,
msg: 'save_fail',
data: {info: "增加失败!"}
}
};
result = {
code: 200,
msg: 'save_succ',
data: {
info: "增加胜利!",
des: {id: results[0].insertId
}
}
}
return res.json(result);
});
});
})
关上 postman
,输出以下内容,而后点击send
按钮,发送 post 申请。
以下是后果截图。
增加失败
增加胜利
再次查问商品信息,呈现了刚刚增加的内容。
- 批改商品信息
有时候,增加的商品信息会有稳定,那么当初就批改以下实时变动的商品信息属性。
批改须要用到的语句格局大抵为UPDATE < 表名 > SET 字段 1 = 值 1, 字段 2 = 值 2 < 条件 >
;
例如:
mysql> UPDATE `goods` SET `number` = 15, `price` = 12 WHERE `id` = 1;
上面就批改一下那个苹果的数量为 15,价格为 9.9。
// 批改商品信息
app.put('/goods', (req, res) => {let result = {};
let params = req.body;
if (!params.id) {
return res.json({
code: 101,
msg: 'get_fail',
data: {info: "id 不能为空!"}
})
}
db.query('SELECT id FROM `goods` WHERE `id` =' + params.id, function (error, results, fields) {if (error) {
result = {
code: 101,
msg: 'get_fail',
data: {info: "查问失败!"}
}
};
if (results && results.length == 0) {
result = {
code: 200,
msg: 'get_succ',
data: {info: "商品不存在!"}
}
return res.json(result);
}
db.query('UPDATE `goods` SET `number` =' + params.number + ', `price` =' + params.price + 'WHERE `id` =' + params.id, function (error, results, fields) {if (error) {
result = {
code: 101,
msg: 'save_fail',
data: {info: "批改失败!"}
}
};
result = {
code: 200,
msg: 'save_succ',
data: {info: "批改胜利!"}
}
return res.json(result);
});
});
})
- 删除商品
如果商品卖完了,或者不卖了,能够下架商品,那这里间接删除这个商品的信息。
删除须要用到的语句格局大抵为DELETE FROM < 表名 > < 条件 >
;
例如:
mysql> DELETE FROM `goods` WHERE `id` = 1;
上面就删除一下那个苹果商品。
// 删除商品
app.delete('/goods', (req, res) => {let result = {};
let params = req.body;
if (!params.id) {
return res.json({
code: 101,
msg: 'get_fail',
data: {info: "id 不能为空!"}
})
}
db.query('SELECT id FROM `goods` WHERE `id` =' + params.id, function (error, results, fields) {if (error) {
result = {
code: 101,
msg: 'get_fail',
data: {info: "查问失败!"}
}
};
if (results && results.length == 0) {
result = {
code: 200,
msg: 'get_succ',
data: {info: "商品不存在!"}
}
return res.json(result);
}
db.query('DELETE FROM `goods` WHERE `id` =' + params.id, function (error, results, fields) {if (error) {
result = {
code: 101,
msg: 'get_fail',
data: {info: "删除失败!"}
}
};
result = {
code: 200,
msg: 'get_succ',
data: {info: "删除胜利!"}
}
return res.json(result);
});
});
})
以上就是比较简单的一个商品的 CURD,所列举的例子都是比拟根底的案例。
办法总结
通过方才的实战,置信你对 curd 曾经很相熟了,上面就简略封装一个查问的办法。
// simple.js
const simple = (sql, params = null) => {var connection = mysql.createConnection(dbConfig);
return new Promise(function (resolve, reject) {connection.connect();
console.log('Database is connected!');
connection.query(sql, params, (err, result) => {if (err) {
reject({
code: 102,
msg: 'get_fail',
data: {
info: '查问失败!',
detail: {
errno: err.errno,
sqlMessage: err.sqlMessage,
sql: err.sql
}
}
});
} else {
resolve({
code: 200,
msg: 'get_succ',
data: {
info: '查问胜利!',
data: result
}
});
}
})
connection.end();
console.log('Database is disconnected!');
})
}
应用办法:
app.get('/goods/test', async (req, res) => {let data = await simple('SELECT * FROM `goods`');
return res.json(data);
});
这里举荐一个依赖包,这个能够生成 mysql 语句。
$ npm install xqsql
xqsql npm 地址
具体应用办法,点击地址有文档介绍。
这样就比拟不便点, 也看着直观。
好了,明天的总结就到这里,有什么疑难,请邮箱分割我。