Nodejs でデータベース データを追加およびクエリする方法

nodejs でデータベース データを追加およびクエリするにはどうすればよいですか?次の記事では、node.js に基づいてデータベースにデータの追加とクエリ関数を実装する方法を説明します。

#node.js に基づいてデータベースに追加してクエリを実行する

#アイデア

• プロジェクト サーバー API の作成

• プロジェクト フォルダーの初期化

npm init --y

インストール パッケージ

npm i express mysql

• restful style

• Postman ソフトウェアを使用してテスト

[推奨学習: "

nodejs チュートリアル"]

プロジェクト構造図

##実装

sql.js

ファイルのコードは次のとおりです:<div class="code" style="position:relative; padding:0px; margin:0px;"><pre class='brush:php;toolbar:false;'>// 1. 加载msyql var mysql = require(&amp;#39;mysql&amp;#39;); // 2. 创建连接 var connection = mysql.createConnection({ host : &amp;#39;localhost&amp;#39;, // 你要连接的数据库服务器的地址 port : 3306,// 端口号 user : &amp;#39;root&amp;#39;, // 连接数据库服务器需要的用户名 password : &amp;#39;root&amp;#39;, // 连接数据库服务器需要的密码 database : &amp;#39;yanyan&amp;#39; //你要连接的数据库的名字 }); // 3. 连接数据库 connection.connect((err) =&gt; { // 如果有错误对象，表示连接失败 if (err) return console.log(&amp;#39;数据库连接失败&amp;#39;) // 没有错误对象提示连接成功 console.log(&amp;#39;mysql数据库连接成功&amp;#39;) }); module.exports = connection</pre><div class="contentsignin">ログイン後にコピー</div></div>

server.js

ファイル参照コード<div class="code" style="position:relative; padding:0px; margin:0px;"><pre class='brush:php;toolbar:false;'>const express = require(&quot;express&quot;); const app = express(); const connection = require(&quot;./utils/sql&quot;); app.use(express.urlencoded()); // 添加数据接口 app.post(&quot;/api/student&quot;, (req, res) =&gt; { console.log(req.body); // 接收普通键值对参数 const { name, sex, age } = req.body; // 添加到数据库中 const sql = `insert into Students(name,sex,age) value(&amp;#39;${name}&amp;#39;,&amp;#39;${sex}&amp;#39;,${age})`; //console.log(&quot;要执行的sql&quot;, sql); // result 接受的数据 connection.query(sql, (err, result) =&gt; { if (err) { console.log(err); res.json({ msg: &quot;添加失败&quot;, code: 0 }); } else { console.log(result); res.json({ msg: &quot;添加成功&quot;, code: 1 }); } }); }); // 获取数据接口 app.get(&quot;/api/student&quot;, (req, res) =&gt; { const sql = `select * from Students `; connection.query(sql, (err, result) =&gt; { if (err) { console.log(err); res.json({ msg: &quot;获取失败&quot;, code: 0 }); } else { console.log(result); res.json({ msg: &quot;获取成功&quot;, code: 0, data: result }); } }); }); app.listen(3000, () =&gt; { console.log(&quot;接口服务器启动，端口号为3000&quot;); });</pre><div class="contentsignin">ログイン後にコピー</div></div>実行結果

SQLデータベース

postman テスト

コンソール出力結果

ルーティング ミドルウェア最適化ソリューションの使用

#アイデア

##プロジェクトの作成

• ##プロジェクト フォルダーを初期化します

  ##

  npm init --y

  #インストール パッケージ
##

npm i express mysql

• ##休息スタイル
  #Postman ソフトウェア テストの使用

プロジェクト構造図

• 実装

sql.jsfile

// 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.jsfile

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 中国語 Web サイトの他の関連記事を参照してください。