ホームページ > 記事 > ウェブフロントエンド > Nodejs でデータベース データを追加およびクエリする方法
nodejs でデータベース データを追加およびクエリするにはどうすればよいですか?次の記事では、node.js に基づいてデータベースにデータの追加とクエリ関数を実装する方法を説明します。
#アイデア
npm init --y
npm i express mysql
nodejs チュートリアル"]
プロジェクト構造図
##実装sql.js
ファイルのコードは次のとおりです:<pre class="brush:js;toolbar:false;">// 1. 加载msyql
var mysql = require(&#39;mysql&#39;);
// 2. 创建连接
var connection = mysql.createConnection({
host : &#39;localhost&#39;, // 你要连接的数据库服务器的地址
port : 3306,// 端口号
user : &#39;root&#39;, // 连接数据库服务器需要的用户名
password : &#39;root&#39;, // 连接数据库服务器需要的密码
database : &#39;yanyan&#39; //你要连接的数据库的名字
});
// 3. 连接数据库
connection.connect((err) => {
// 如果有错误对象,表示连接失败
if (err) return console.log(&#39;数据库连接失败&#39;)
// 没有错误对象提示连接成功
console.log(&#39;mysql数据库连接成功&#39;)
});
module.exports = connection</pre>
ファイル参照コード<pre class="brush:js;toolbar:false;">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(&#39;${name}&#39;,&#39;${sex}&#39;,${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");
});</pre>
実行結果
SQLデータベース
postman テスト
コンソール出力結果
ルーティング ミドルウェア最適化ソリューションの使用
##プロジェクトの作成
##
npm init --y#インストール パッケージ
npm i express mysql
実装
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");
});
著者: 卑怯ではない
プログラミングビデオにアクセスしてください。 !
以上がNodejs でデータベース データを追加およびクエリする方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。