node使用MySQL数据库
2024-03-25 05:24:51
内容：
1.node连接数据库
2.数据库常用操作
3.数据库实例 - 用户注册、登陆
1.node连接数据库
(1)下载mysql模块
(2)使用mysql模块连接数据库
let db=mysql.createConnection({host, port, user, password, database});
这样连接也有缺陷：连接会一直占着数据库，别的无法在此连接结束之前连接数据库，对于此我们可以使用连接池：
// 连接池
let db = mysql.createPool(配置)
实例：
const mysql = require('mysql')
// 普通连接
// let db = mysql.createConnection({host: 'localhost', user: 'root', password: 'root', port: 3306, database: 'node'})
// 连接池
let db = mysql.createPool({host: 'localhost', user: 'root', password: 'root', port: 3306, database: 'node'})
2.数据库常用操作
(1)node的mysql数据库操作
db.query(sql, (err, data)=>{});
db.query(`INSERT INTO user_table (ID, name, gender, chinese, math, english) VALUES(0, 'saf', '女', 100, 100, 100);`, function (err, data) {
if(err) {
console.log('错了', err)
}
else {
console.log(data)
}
})
(2)SQL基本使用
SQL：
4大查询
1.增 INSERT
INSERT INTO 表 (字段列表) VALUES(值列表) INSERT INTO user_table (ID, name, gender, chinese, math, english) VALUES(0, 'wyb', '男', 75, 88, 69); 2.删 DELETE
DELETE FROM 表 WHERE 条件 DELETE FROM user_table WHERE ID=3; 3.改 UPDATE
UPDATE 表 SET 字段=值, 字段2=值2, ... WHERE 条件 UPDATE user_table SET chinese=100 WHERE ID=2; 4.查 SELECT
SELECT 字段列表 FROM 表 WHERE 条件 SELECT name, gender FROM user_table WHERE ID=2;
3.数据库实例 - 用户注册、登陆
(1)项目需求
用户注册、登陆：
1.数据库结构（数据字典）
2.接口格式（接口文档） 1.数据库结构
ID username password 2.接口 --》 RESTful
注册：
/reg?user=xxx&pass=xxx
=>{err: 0, msg: '原因'} 登陆：
/login?user=xxx&pass=xxx
=>{err: 0, msg: '原因'}
(2)实现
前端代码存在项目下的www文件夹中，后端代码位于项目根目录下的server.js中
前端代码：
<!-- author: wyb -->
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<title>数据库版登陆注册</title>
<!-- 引入jQuery -->
<script src="https://cdn.bootcss.com/jquery/3.2.1/jquery.min.js"></script>
<style> </style>
</head>
<body> 用户名: <input type="text" id="user"> <br>
密码: <input type="password" id="pass"> <br>
<input type="button" value="注册" id="btn_reg">
<input type="button" value="登陆" id="btn_login"> <script>
/*
// 前后端接口:
用户注册：
/reg?user=xxx&pass=xxx
=>{error: 0, msg: '原因'} 用户登陆：
/login?user=xxx&pass=xxx
=>{error: 0, msg: '原因'}
*/
$(function () {
// 注册
$('#btn_reg').click(function () {
$.ajax({
url: '/reg',
data: {user: $('#user').val(), pass: $('#pass').val()},
dataType: 'json',
success(json){
if(json.err){
alert("error: " + json.msg)
} else {
alert("register success")
}
},
error(){
alert("fail")
}
})
}) // 登陆
$('#btn_login').click(function () {
$.ajax({
url: '/login',
data: {user: $('#user').val(), pass: $('#pass').val()},
dataType: 'json',
success(json){
if(json.err){
alert("error: " + json.msg)
} else {
alert("login success")
}
},
error(){
alert("fail")
}
})
})
})
</script> </body>
</html>
后端代码：
const http = require('http')
const mysql = require('mysql')
const fs = require('fs')
const url = require('url')
const zlib = require('zlib')
const crypto=require('crypto')
const _key='sadfslekrtuew5iutoselgdtjiypoydse4ufhs.edtyo;s8te4arfeliawkfhtsie5tlfia;sefdshroiupeoutwyeli5gurse;ihf';
function md5(str){
let obj=crypto.createHash('md5')
obj.update(str);
return obj.digest('hex')
}
function md5_2(str){
return md5(md5(str)+_key);
}
function log() {
console.log.apply(console, arguments)
}
// 连接池
let db = mysql.createPool({host: 'localhost', user: 'root', password: 'root', port: 3306, database: 'node'})
let server = http.createServer(function (req, res) {
let {pathname, query} = url.parse(req.url, true)
log(pathname, query)
let {user, pass} = query
log(user, pass)
// 接口
switch (pathname){
// 注册:
case '/reg':
// 校验数据
if(!user){
res.write('{"err": 1, "msg": "username can\'t be null!"}')
res.end()
}else if(!pass){
res.write('{"err": 1, "msg": "password can\'t be null!"}')
res.end()
}else if(!/^\w{4,16}$/.test(user)){
res.write('{"err": 1, "msg": "username is invalid!"}')
res.end()
}else if(/['|"]/.test(user)){
res.write('{"err": 1, "msg": "username is invalid!"}')
res.end()
}else if(/['|"]/.test(pass)){
res.write('{"err": 1, "msg": "password is invalid!"}')
res.end()
}else{
db.query(`SELECT * FROM user_table WHERE username='${user}';`, function (err, data) {
if(err) {
res.write('{"err": 1, "msg": "database error!"}')
res.end()
}
else if(data.length>0){
res.write('{"err": 1, "msg": "this username exists!"}')
res.end()
}
else {
db.query(`INSERT INTO user_table (ID, username, password) VALUES(0, '${user}', '${md5_2(pass)}');`, function (err, data) {
if(err) {
res.write('{"err": 1, "msg": "database error!"}')
res.end()
}
else {
res.write('{"err": 0, "msg": "register success!"}')
res.end()
}
})
}
})
}
break
// 登陆:
case '/login':
if(!user){
res.write('{"err": 1, "msg": "username can\'t be null"}');
res.end();
}else if(!pass){
res.write('{"err": 1, "msg": "password can\'t be null"}');
res.end();
}else if(!/^\w{4,16}$/.test(user)){
res.write('{"err": 1, "msg": "username is invaild"}');
res.end();
}else if(/['|"]/.test(pass)){
res.write('{"err": 1, "msg": "password is invaild"}');
res.end();
}else{
db.query(`SELECT * FROM user_table WHERE username='${user}'`, (err, data)=>{
if(err){
res.write('{"err": 1, "msg": "database error"}');
res.end();
}else if(data.length===0){
res.write('{"err": 1, "msg": "no this user"}');
res.end();
}else if(data[0].password!==md5_2(pass)){
res.write('{"err": 1, "msg": "username or password is incorrect"}');
res.end();
}else{
res.write('{"err": 0, "msg": "success"}');
res.end();
}
});
}
break;
default:
//获取文件日期
fs.stat(`www${pathname}`, (err, stat)=>{
if(err){
res.writeHeader(404);
res.write('Not Found');
res.end();
}else{
// 缓存
// 请求头中有if-modified-since -> 不是第一次请求，之前浏览器中缓存了该页面
if(req.headers['if-modified-since']){
let oDate=new Date(req.headers['if-modified-since']);
let time_client=Math.floor(oDate.getTime()/1000);
let time_server=Math.floor(stat.mtime.getTime()/1000);
if(time_server>time_client){ // 服务器的文件时间 > 客户端手里的版本
sendFileToClient();
}else{
res.writeHeader(304);
res.write('Not Modified');
res.end();
}
}
// 请求头中没有if-modified-since -> 第一次请求 -> 直接返回要的文件
else{
sendFileToClient();
}
// 直接返回文件
function sendFileToClient(){
//发送
let rs=fs.createReadStream(`www${pathname}`);
let gz = zlib.createGzip()
res.setHeader('Last-Modified', stat.mtime.toGMTString());
res.setHeader('content-encoding', 'gzip')
//输出
rs.pipe(gz).pipe(res)
rs.on('error', function(err){
res.writeHeader(404);
res.write('Not Found');
res.end();
});
}
}
});
}
})
server.listen(8080)
最新文章
- Entity Framework 6 Recipes 2nd Edition（10-8）译 - >映射插入、修改、删除操作到存储过程
- Android Studio使用教程-菜单(Edit)
- 经典String str = new String("abc")内存分配问题
- AngularJS开发指南3：Angular主要组成部分以及如何协同工作
- Java缓存学习之一：缓存
- spring定时器 @Scheduled
- javascript基础学习（六）
- 【转】UiAutomator简要介绍
- 用Inferno代替React开发高性能响应式WEB应用
- 第十八篇 ANDROID的声音管理系统及服务
- Github把自己的本地项目托管到git上
- 【vue】vue +element 搭建项目，vue-cli 如何打包上线
- HDU 1077
- [leetcode]81. Search in Rotated Sorted Array II旋转过有序数组里找目标值II(有重)
- JAVA框架Struts2 Action类
- var this.value 可在任意地方 声明 类成员变量。如果可以利用在C++ 那该有多好啊
- 这个移动通讯中 DB 、DBm 、瓦的基本知识的问题：
- iOS 性能优化之业务性能监控
- MongoDB复制二：复制集的管理
- axure产品原型图，元件库导入方法