nodejs如何添加和查询数据库的数据？下面本篇文章带大家了解一下基于node.js实现数据库中数据添加和查询功能的方法，希望对大家有所帮助！
基于node.js实现数据库中的添加和查询
思路
创建项目 serverAPI
初始化项目文件夹
npm init --y
- 安装包
npm i express mysql
restfulf 风格
使用Postman软件测试
【推荐学习：《nodejs 教程》】
项目结构图
实现
sql.js文件代码如下:
// 1. 加载msyql
var mysql = require('mysql');
// 2. 创建连接
var connection = mysql.createConnection({
host : 'localhost', // 你要连接的数据库服务器的地址
port : 3306,// 端口号
user : 'root', // 连接数据库服务器需要的用户名
password : 'root', // 连接数据库服务器需要的密码
database : 'yanyan' //你要连接的数据库的名字
});
// 3. 连接数据库
connection.connect((err) => {
// 如果有错误对象，表示连接失败
if (err) return console.log('数据库连接失败')
// 没有错误对象提示连接成功
console.log('mysql数据库连接成功')
});
module.exports = connectionserver.js文件 参考代码
const express = require("express");
const app = express();
const connection = require("./utils/sql");
app.use(express.urlencoded());
// 添加数据接口
app.post("/api/student", (req, res) => {
console.log(req.body);
// 接收普通键值对参数
const { name, sex, age } = req.body;
// 添加到数据库中
const sql = `insert into Students(name,sex,age) value('${name}','${sex}',${age})`;
//console.log("要执行的sql", sql);
// result 接受的数据
connection.query(sql, (err, result) => {
if (err) {
console.log(err);
res.json({ msg: "添加失败", code: 0 });
} else {
console.log(result);
res.json({ msg: "添加成功", code: 1 });
}
});
});
// 获取数据接口
app.get("/api/student", (req, res) => {
const sql = `select * from Students `;
connection.query(sql, (err, result) => {
if (err) {
console.log(err);
res.json({ msg: "获取失败", code: 0 });
} else {
console.log(result);
res.json({ msg: "获取成功", code: 0, data: result });
}
});
});
app.listen(3000, () => {
console.log("接口服务器启动，端口号为3000");
});运行结果
- sql数据库
- postman测试
- 控制台输出结果
使用路由中间件优化方案
思路
创建项目
初始化项目文件夹
npm init --y
- 安装包
npm i express mysql
restfulf 风格
使用Postman软件测试
项目结构图
实现
sql.js文件
// 1. 加载mysql
var mysql = require("./node_modules/mysql");
// 2. 创建连接
var connection = mysql.createConnection({
host: "localhost", // 你要连接的数据库服务器的地址
port: 3306, // 端口号
user: "root", // 连接数据库服务器需要的用户名
password: "root", // 连接数据库服务器需要的密码
database: "yanyan", //你要连接的数据库的名字
});
// 3. 连接数据库
connection.connect((err) => {
// 如果有错误对象，表示连接失败
if (err) return console.log("数据库连接失败");
// 没有错误对象提示连接成功
console.log("mysql数据库连接成功");
});
module.exports = connection;get.js文件
const connection = require("./sql");
const express = require("./node_modules/express");
const router = express.Router();
router.use(express.urlencoded());
//获取数据接口
router.get("/api/student", (req, res) => {
const sql = `select * from Students`;
connection.query(sql, (err, result) => {
if (err) {
console.log(err);
res.json({ msg: "获取失败", code: 0 });
} else {
console.log(result);
res.json({ msg: "获取成功", code: 0, data: result });
}
});
});
module.exports = router;post.js文件
const connection = require("./sql");
const express = require("./node_modules/express");
const router = express.Router();
router.use(express.urlencoded());
// 添加数据接口
router.post("/api/student", (req, res) => {
//console.log(req.body);
// 接收普通键值对参数
const { name, sex, age } = req.body;
// 添加到数据库中
const sql = `insert into Students(name,sex,age) values('${name}','${sex}',${age})`;
//console.log("要执行的sql", sql);
// result 接受的数据
connection.query(sql, (err, data) => {
if (err) {
console.log(err);
res.json({ msg: "添加失败", code: 0 });
} else {
console.log(data);
res.json({ msg: "添加成功", code: 1 });
}
});
});
module.exports = router;server-pro.js文件
const get = require("./utils/get");
const post = require("./utils/post");
const express = require("./node_modules/express");
const app = express();
app.use("/utils/get", get);
app.use("/utils/post", post);
app.listen(3000, () => {
console.log("接口服务器启动，端口号为3000");
});原文地址：https://juejin.cn/post/7008779311666692126作者：不怂
更多编程相关知识，请访问：编程视频！！
