nodejs如何新增和查詢資料庫的數據

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 = 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資料庫

#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#########作者：不慫##########更多程式設計相關知識，請造訪：###程式設計影片###！ ！ ###

以上是nodejs如何新增和查詢資料庫的數據的詳細內容。更多資訊請關注PHP中文網其他相關文章！