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

青灯夜游
リリース: 2021-09-22 10:09:26
転載
5380 人が閲覧しました

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

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

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

#アイデア

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

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

  • npm init --y
    ログイン後にコピー
    ログイン後にコピー
    インストール パッケージ
  • npm i express mysql
    ログイン後にコピー
    ログイン後にコピー
  • restful style

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

[推奨学習: "

nodejs チュートリアル"]

プロジェクト構造図

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

##実装

sql.js

ファイルのコードは次のとおりです:<div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:js;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:js;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データベース

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

Nodejs でデータベース データを追加およびクエリする方法コンソール出力結果

Nodejs でデータベース データを追加およびクエリする方法ルーティング ミドルウェア最適化ソリューションの使用

#アイデア

##プロジェクトの作成

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

    ##

    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;
ログイン後にコピー
Nodejs でデータベース データを追加およびクエリする方法

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(&#39;${name}&#39;,&#39;${sex}&#39;,${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 サイトの他の関連記事を参照してください。

関連ラベル:
ソース:juejin.cn
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
最新の問題
人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート