❤Nodejs 第三章（Node +Express操作本地数据库增删改查）
以下为 REST 基本架构的四个方法：
- GET - 用于获取数据
- PUT - 用于更新或添加数据
- DELETE - 用于删除数据
- POST - 用于添加数据
注：get和delete是在路径中传递数据，而post和put可以在request body中传递数据
1、查询用户列表 （/api/user--get查询 ）
之前我们采用Node连接数据库并查询数据，现在我们使用本地的axios进行请求数据
本地进行调用
// 获取用户
function getUserList(row) {
axios.get('http://localhost:8888/api/user').then(res => {
console.log(res, '/user/list');
if (res.status == 200) {
console.log(res,'res');
tableData.value = res.data.data;
}
})
}
突然发现报错了：
分析报错我们发现是由于跨域访问引起的，前端设置允许跨域
在app.js之中添加这段代码
app.all('*', function (req, res, next) {
res.header("Access-Control-Allow-Origin", "*");
res.header("Access-Control-Allow-Headers", "X-Requested-With");
res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS");
res.header("X-Powered-By", ' 3.2.1')
res.header("Content-Type", "application/json;charset=utf-8");
next();
});app.js完整过程如下：
const connection = mysql.createPool({
host: 'localhost', // 数据库主机地址，如果是本地数据库则使用localhost
user: 'root', // 数据库用户名
password: '', // 数据库密码
database: 'nexus' // 要连接的数据库名
});
const app = express();
//设置跨域访问
app.all('*', function (req, res, next) {
res.header("Access-Control-Allow-Origin", "*");
res.header("Access-Control-Allow-Headers", "X-Requested-With");
res.header("Access-Control-Allow-Methods", "PUT,POST,GET,DELETE,OPTIONS");
res.header("X-Powered-By", ' 3.2.1')
res.header("Content-Type", "application/json;charset=utf-8");
next();
});
app.get('/', (req, res) => {
res.send('林太白数据库!');
});
// 创建路由
app.get('/api/user/list', (req, res) => {
// 查询数据库并返回数据
connection.query('SELECT * FROM user', (err, results) => {
console.log(err,'err');
console.log(results,'results');
if (err) {
console.error('Error querying database:', err);
res.status(500).json({ error: 'Internal server error' });
return;
}
res.json({
code:'200',
data:results,
});
// res.json(results);
});
});重启服务器：
node app.js
查询成功！
2、增加用户 （/api/user--post新增 ）
Mysql增加用户操作命令为
INSERT INTO user (name,sex) VALUES ('张三',1)执行命令我们已经将数据添加进入数据库之中。
接下来我们在我们的Node里面进行一下添加
Sql的插入语句为：
`INSERT INTO user (name, age) VALUES (?, ?)`那我们手写的POST增加用户请求处理就是
// 新增用户 POST 请求处理程序
app.post('/api/user', (req, res) => {
console.log(req.body);
const { name, age } = req.body; // 从请求体中获取数据
const values = [name, age];
// 准备 SQL 插入语句
const insertSql = `INSERT INTO user (name, age) VALUES (?, ?)`;
connection.query(insertSql, values, (err, results) => {
console.log(err,'err');
console.log(results,'results');
if (err) {
console.error('Error querying database:', err);
res.status(500).json({ error: 'Internal server error' });
return;
}
res.json({
code:'200',
data:results,
});
});
});
增加用户成功！
3、修改用户信息以后提交修改（/api/user--put修改 ）
Mysql更改用户操作命令为
UPDATE user SET name = '可爱', age = 18 WHERE id = 12查看我们的sql数据库，数据库已经更改成功！
使用axios之中的put方法提交更改的数据，用户有ID的时候根据id进行更改
更新用户数据 PUT请求处理程序
// 更新用户数据 PUT请求处理程序
app.put('/api/user', (req, res) => {
console.log(req.body);
const { name, age ,id} = req.body; // 从请求体中获取数据
const values = [name, age, id];
// 准备 SQL 插入语句
const sql = "UPDATE user SET name = ?, age = ? WHERE id = ?";
connection.query(sql, values, (err, results) => {
console.log(err,'err');
console.log(results,'results');
if (err) {
console.error('Error querying database:', err);
res.status(500).json({ error: 'Internal server error' });
return;
}
res.json({
code:'200',
data:results,
});
});
});数据已经更改成功！
到这里我们已经实现了增改查，接下来下一节就是针对我们的删除进行处理。
