首先附上我封装的nodejs后台框架
github:
国内访问gitee:
nodejs
什么是nodejs？
Nodejs框架是基于V8的引擎，是目前速度最快的Javascript引擎。chrome浏览器就基于V8，同时打开20-30个网页都很流畅。Nodejs标准的web开发框架Express，可以帮助我们迅速建立web站点，比起PHP的开发效率更高，而且学习曲线更低。
业务逻辑：三层架构
1.界面层 view层，封装给前端的数据，接收前端的数据
2.务逻辑层 services层，内部的路径操作，每一个路径内的操作不一样
3.数据访问层 dao层，访问数据库的内容，执行sql语句
首先在数据库里建库建表
![图片[1]-关于nodejs写后台连接数据库，对数据库增删改查接口-JieYingAI捷鹰AI](https://www.jieyingai.com/wp-content/uploads/2024/09/1726078065987_1.png)
然后新建一个文件夹里建一个db的文件夹，和一个service.js文件；db文件夹里建一个poor.js以及user.js文件
![图片[2]-关于nodejs写后台连接数据库，对数据库增删改查接口-JieYingAI捷鹰AI](https://www.jieyingai.com/wp-content/uploads/2024/09/1726078065987_2.png)
![图片[3]-关于nodejs写后台连接数据库，对数据库增删改查接口-JieYingAI捷鹰AI](https://www.jieyingai.com/wp-content/uploads/2024/09/1726078065987_3.png)
node_modules和package-lock.json是在文件夹下下载依赖自动生成的
下载依赖，在文件夹下执行命令
> cnpm install --save mysql
接下来开始写代码
首先写pool.js里的代码
这里的代码是用来建立数据库连接的
const mysql = require('mysql')
let pool = mysql.createPool({
host:'localhost',
port:'3306',
user:'root',
password:'root',
database: 'xk'
})
module.exports = {
pool
}
然后是user.js里的代码
这里是写对数据库进行操作的方法，这里我只写了增删改查
// 封装dao层
const { pool } = require('./pool');
// 查询所有的用户
let findUser = (callback)=>{
pool.getConnection((err,connection)=>{
if(err) {
console.log(err);
} else {
let sql = 'select * from user'
connection.query(sql,(err,result)=>{
if(err) {
console.log(err)
} else {
callback(result)
connection.release()
connection.destroy()
}
})
}
})
}
// 根据id查询用户信息
let findById = (id,callback)=>{
pool.getConnection((err,connection)=>{
if(err) {
console.log(err);
} else {
let sql = 'select * from user where id=?'
connection.query(sql,[id],(err,result)=>{
if(err) {
console.log(err)
} else {
callback(result)
connection.release()
connection.destroy()
}
})
}
})
}
// 新增用户或修改用户
let saveWord = (data,callback)=>{
pool.getConnection((err,connection)=>{
if(err) {
console.log(err);
} else {
if(data.id) {
// 修改
let sql = 'update user set username=?,password=?,gender=? where id=?'
connection.query(sql,[data.username,data.password,data.gender,data.id],(err,result)=>{
if(err) {
console.log(err)
} else {
result.code = 200
result.message = '编辑成功'
callback(result)
connection.release()
connection.destroy()
}
})
} else {
// 保存
let sql = 'insert into user(id,username,password,gender) values(?,?,?,?)'
connection.query(sql,[null,data.username,data.password,data.gender],(err,result)=>{
if(err) {
console.log(err)
} else {
result.code = 200
result.message = '添加成功'
callback(result)
connection.release()
connection.destroy()
}
})
}
}
})
}
// 根据id删除用户
let deleteById = (id,callback)=>{
pool.getConnection((err,connection)=>{
if(err) {
console.log(err);
} else {
let sql = 'delete from user where id = ?'
connection.query(sql,[id],(err,result)=>{
if(err) {
console.log(err)
} else {
callback(result)
connection.release()
connection.destroy()
}
})
}
})
}
module.exports = {
findUser,
findById,
saveUser,
deleteById
}
接下来是service.js的代码
这里进行是处理前端的请求以及返回给前端值的方法，最后那个端口号可以自行更改我这里将它跑在6666端口上
const http = require('http');
const url = require('url');
const querystring = require('querystring');
const { findUser,findById,saveUser,deleteById } = require('./db/user.js')
let server = http.createServer((req,res)=>{
res.writeHead(200, {
'Content-Type': 'text/plain;charset=uft-8;',
'Access-Control-Allow-Origin':'*'
})
if(req.method === 'GET') {
// 请求的地址 path_
var path_ = url.parse(req.url).pathname
// 前端发送给给后端的数据
var params = querystring.parse(url.parse(req.url).query)
switch(path_) {
case '/user/findAll':
findUser((result)=>{
// 将从数据库里面查询出来的数据返回给前端
res.end(JSON.stringify(result))
})
break;
case '/user/findById':
// 将前端传递过来的id作为参数发送给findById
findById(params.id,(result)=>{
// 将从数据库里面查询出来的数据返回给前端
res.end(JSON.stringify(result))
})
break;
case '/user/deleteById':
// 将前端传递过来的id作为参数发送给findById
deleteById(params.id,(result)=>{
// 将从数据库里面查询出来的数据返回给前端
res.end(JSON.stringify(result))
})
break;
default:
break;
}
}
if(req.method === 'POST') {
// 请求的地址 path_
var path_ = url.parse(req.url).pathname
switch(path_) {
case '/user/saveOrUpdate':
let buffer = Buffer.from([])
req.on('data', (data)=>{
buffer += data
saveUser(querystring.parse(buffer.toString()),(result)=>{
res.end(JSON.stringify(result))
})
})
req.on('end', ()=>{})
break;
}
}
})
server.listen(6666,()=>{
console.log('启动成功')
})
代码完成了就可以启动服务了
启动服务器
> node service.js
服务启动了，如何从前端请求数据呢？
查询所有数据
axios.get('http://localhost:8080/user/findAll').then((res)=>{
this.users = res.data
})
根据id查询数据
axios.get('http://localhost:8080/user/findById',{params:{id}}).then((res)=>{
this.user_detail = res.data
})
新增和修改数据
axios({
url:'http://localhost:8080/user/saveOrUpdate',
method:'POST',
data: this.form
})
删除数据
axios.get('http://localhost:8080/user/deleteById?id='+id)
写在最后
以上就是使用nodejs写接口以及前端调用的基本操作，这里附上部署nodejs接口到云服务器方法和MySQL语句收录，看完点个赞再走吧
![图片[4]-关于nodejs写后台连接数据库，对数据库增删改查接口-JieYingAI捷鹰AI](https://www.jieyingai.com/wp-content/uploads/2024/09/1726078065987_4.png)
© 版权声明
THE END
暂无评论内容