nodejs如何添加和查询数据库的数据

基于node.js实现数据库中的添加和查询

思路

• 创建项目 serverAPI

• 初始化项目文件夹

npm inIT --y

• 安装包

npm i exPress MySQL

• restfulf 风格

• 使用Postman软件测试

【推荐学习：《nodejs 教程》】

项目结构图

实现

SQL.js文件代码如下:

// 1. 加载msyqlVAR 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 = connection

server.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. 加载mysqlvar 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

作者：不怂

更多编程相关知识，请访问：编程视频！！

以上就是nodejs如何添加和查询数据库的数据的详细内容，更多请关注其它相关文章！

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！