Nay mình chia sẻ với mọi người cách ta có thể Kết nối(Connect) MongoDB với Node.JS . Vừa qua mình có việc làm lại một dự án nhỏ, có Connect MongoDB + NodeJS+ Vue(kết hợp Vuex) quản lý trạng thái (state) của dữ liệu
Cũng lâu rồi mình không có dùng lại MongoDB , tìm tồi cài đặt nó làm mình rối cả lên kaka. Nhưng không sao, còn hơi thở thì ta sẽ tìm ra thôi mà kaka
# Install MongoDB in Windows 10
Việc đầu tiên là ta cài tìm và cài đặt MongoDB. Các bạn hãy vào đây và download về cài đặt nhé : https://www.mongodb.com/try/download/community
Sao khi bạn cài đặt xong bạn sẽ được giao như trên, bạn sẽ được một chuổi kết nối như thế này mongodb://localhost:27017 , Hãy bấm vào chữ "Connect" để tiếp tục ta tạo database
Việc còn lại là tạo project Nodejs và Connect MongoDB vào thôi
# Setup NodeJS Connect MongoDB
Tạo project Nodejs. Các bạn cần phải cài thư viện Node.js vào máy tính mình nhé
npm init
Okay các bạn có thể copy package,json của mình dùng để cài đặt cho lẹ và nhanh, còn không bạn cài đặt từng thư viện vào
{
"name": "nodejs-react",
"version": "1.0.0",
"description": "nodejs react",
"main": "index.js",
"scripts": {
"start": "node index.js",
"dev": "nodemon index.js",
"test": "echo \"Error: no test specified\" && exit 1"
},
"keywords": [
"nodejs",
"react"
],
"author": "hoanguyenit",
"license": "ISC",
"dependencies": {
"bcryptjs": "^2.4.3",
"body-parser": "^1.19.0",
"cors": "^2.8.5",
"dotenv": "^10.0.0",
"express": "^4.17.1",
"jsonwebtoken": "^8.5.1",
"mongodb": "^6.2.0",
"mongoose": "^6.0.9",
"sqlite3": "^5.0.2",
"uid": "^2.0.0"
},
"devDependencies": {
"nodemon": "^2.0.13"
}
}
Sao đó mở Command Line lên và chạy lệnh npm install
npm installVậy là bạn đã cài đặt toàn bộ thư viện như : jsonwebtoken, cors, mongodb, mongoose,... sao này dùng cái nào thì import vào file thôi
Sau khi đã có project Nodejs rồi, bạn tạo cho mình file index.js cùng cấp với project
const http = require("http");
const app = require("./app");
const server = http.createServer(app);
const { API_PORT } = process.env;
const port = process.env.PORT || API_PORT;
// server listening
server.listen(port, () => {
console.log(`Server running on port ${port}`);
});
Tiếp theo hãy tạo app.js như sau:
require("dotenv").config();
const express = require("express");
const jwt = require("jsonwebtoken");
const { MongoClient } = require('mongodb');
var cors = require('cors');
const router = express.Router();
const app = express();
app.use(cors());
app.use(express.json());
// Connection URL
const url = 'mongodb://127.0.0.1:27017';
const client = new MongoClient(url);
// Database Name
const dbName = 'shopbanhang';
let connectDB;
// Kết nối đến MongoDB
async function connectToMongoDB() {
try {
await client.connect();
console.log('Connected to MongoDB');
// Lưu trữ đối tượng cơ sở dữ liệu để sử dụng toàn cục
connectDB = client.db("shopbanhang");
} catch (error) {
console.error('Error connecting to MongoDB:', error);
}
}
connectToMongoDB().catch(console.dir);
//lấy tất cả danh sách hang hoa
router.get("/getItems", async (req, res) => {
try {
const collection = connectDB.collection("HangHoa");
// Sử dụng phương thức find() để lấy tất cả các documents trong collection
const hanghoas = await collection.find({}).toArray();
// Log tất cả users
res.status(200).json({"success":1,"ListsHangHoa":hanghoas});
} catch (error) {
console.error('Error getting all hanghoas:', error);
}
})
app.use('/', router);
module.exports = app;
Bên trên mình cần import thư viện mongodb
const { MongoClient } = require('mongodb');Tiếp theo là lúc chúng ta gọi connect đến MongoDB
// Connection URL
const url = 'mongodb://127.0.0.1:27017';
const client = new MongoClient(url);
// Database Name
const dbName = 'shopbanhang';
let connectDB;
// Kết nối đến MongoDB
async function connectToMongoDB() {
try {
await client.connect();
console.log('Connected to MongoDB');
// Lưu trữ đối tượng cơ sở dữ liệu để sử dụng toàn cục
connectDB = client.db("shopbanhang");
} catch (error) {
console.error('Error connecting to MongoDB:', error);
}
}
connectToMongoDB().catch(console.dir);Bạn thấy mình dùng địa chỉ 127.0.0.1, thay vì là localhost đúng không. Trường hợp bạn dùng connect chuỗi mongodb://localhost:27017 không được, thì hãy dùng địa chỉ ip nhé : mongodb://127.0.0.1:27017
Vậy là xong, Các bạn viết các câu lệnh thêm, sửa , delete, thử nhé
Okay giờ chúng ta có thể chạy nó bằng câu lệnh sau:
npm run dev
//or
node index.jsDưới đây mã code mình dùng Nodejs+MongoDB. cùng với kết hợp với Json Web Token các bạn có thể xem thêm bài viết này -> : JWT(Json Web Token) In Node.Js
Các bạn có thể tham thao thêm app.js :
require("dotenv").config();
const express = require("express");
const jwt = require("jsonwebtoken");
const { MongoClient } = require('mongodb');
var cors = require('cors');
const router = express.Router();
const app = express();
app.use(cors());
app.use(express.json());
// Connection URL
const url = 'mongodb://127.0.0.1:27017';
const client = new MongoClient(url);
// Database Name
const dbName = 'shopbanhang';
let connectDB;
// Kết nối đến MongoDB
async function connectToMongoDB() {
try {
await client.connect();
console.log('Connected to MongoDB');
// Lưu trữ đối tượng cơ sở dữ liệu để sử dụng toàn cục
connectDB = client.db("shopbanhang");
} catch (error) {
console.error('Error connecting to MongoDB:', error);
}
}
// async function run() {
// try {
// await client.connect();
// const database = client.db(dbName);
// // const collection = database.collection("users");
// // const users = await collection.find({}).toArray();
// // Log tất cả users
// console.log(users);
// } finally {
// // Đảm bảo rằng client sẽ đóng khi kết thúc hoặc có lỗi
// await client.close();
// }
// }
connectToMongoDB().catch(console.dir);
//xây dụng các chức năng lấy dữ liệu
//lấy tất cả danh sách hang hoa
router.get("/getItems", async (req, res) => {
try {
const collection = connectDB.collection("HangHoa");
// Sử dụng phương thức find() để lấy tất cả các documents trong collection
const hanghoas = await collection.find({}).toArray();
// Log tất cả users
res.status(200).json({"success":1,"ListsHangHoa":hanghoas});
} catch (error) {
console.error('Error getting all hanghoas:', error);
}
})
//lấy tất cả danh sách hang hoa theo ID
router.get("/getItems/:id", async (req, res) => {
try {
const collection = connectDB.collection("HangHoa");
let MSHH = {
"MSHH": parseInt(req.params.id)
};
let hanghoa = await collection.findOne(MSHH);
if (hanghoa) {
res.status(200).json({ "success": 1, "hanghoa": hanghoa });
} else {
res.status(200).json({ "success": 0, "messsage": "Sản phẩm không tồn tại", "id": req.params.id });
}
} catch (error) {
console.error('Error getting hanghoa:', error);
res.status(500).json({ "success": 0, "message": "Lỗi server" });
}
})
// Register khách hàng
router.post("/register/khachhang", async (req, res) => {
// Our register logic starts here
try {
// Get user input
const { HoTenKH, Password, SoDienThoai, DiaChi } = req.body;
const collection = connectDB.collection("KhachHang");
// Kiểm tra xem khách hàng đã tồn tại chưa
const existingCustomer = await collection.findOne({ SoDienThoai });
if (existingCustomer) {
return res.status(400).json({ message: 'Khách hàng đã tồn tại.' });
}
const MSKH = `MSKH${Date.now()}`;
// Tạo một bản ghi mới
const newCustomer = {
MSKH,
HoTenKH,
Password,
SoDienThoai,
DiaChi,
};
// Chèn bản ghi mới vào cơ sở dữ liệu
await collection.insertOne(newCustomer);
res.status(201).json({ message: 'Đăng ký thành công.' });
/* save user to databse */
} catch (err) {
console.log(err);
}
});
// Register nhân viên
router.post("/register/nhanvien", async (req, res) => {
// Our register logic starts here
try {
// Get user input
const { HoTenNV, Password, SoDienThoai, DiaChi,ChucVu } = req.body;
const collection = connectDB.collection("NhanVien");
// Kiểm tra xem khách hàng đã tồn tại chưa
const existingCustomer = await collection.findOne({ SoDienThoai });
if (existingCustomer) {
return res.status(400).json({ message: 'Nhân viên đã tồn tại.' });
}
const MSNV = `MSNV${Date.now()}`;
// Tạo một bản ghi mới
const newCustomer = {
MSNV,
HoTenNV,
Password,
SoDienThoai,
ChucVu,
DiaChi,
};
// Chèn bản ghi mới vào cơ sở dữ liệu
await collection.insertOne(newCustomer);
res.status(201).json({ message: 'Đăng ký thành công.' });
/* save user to databse */
} catch (err) {
console.log(err);
}
});
// Login (nhân viên hoặc khách hàng or Nhaan vieen, position:1 -> nhanvien, position:0->khachhang
router.post("/login", async (req, res) => {
const { msnv, password,position } = req.body;
if (!(msnv && password)) {
res.status(400).send("All input is required");
}else{
try {
let collection;
let user;
if(position>0){
collection = connectDB.collection("NhanVien");
user = await collection.findOne({
MSNV: msnv,
Password: password,
});
}
else{
collection = connectDB.collection("KhachHang");
user = await collection.findOne({
MSKH: msnv,
Password: password,
});
}
// Tìm một nhân viên với MSNV và password tương ứng
if (user) {
var data;
if(position>0){
data={
"MSNV":user.MSNV,
"HoTenNV":user.HoTenNV,
"ChucVu":user.ChucVu,
"DiaChi":user.DiaChi,
"SoDienThoai":user.SoDienThoai
}
}
else{
data={
"MSKH":user.MSKH,
"HoTenKH":user.HoTenKH,
"DiaChi":user.DiaChi,
"SoDienThoai":user.SoDienThoai
}
}
var token = jwt.sign({ exp: Math.floor(Date.now() / 1000) + (60*60), user: data }, process.env.ACCESS_TOKEN_SECRET);
var refresh_token = jwt.sign({ exp: Math.floor(Date.now() / 1000) + (24*60*60), user: data }, process.env.REFRESH_TOKEN_SECRET);
try {
let result;
if(position>0){
result = await collection.updateOne(
{ MSNV: msnv },
{ $set: { token: token, refresh_token: refresh_token } }
);
}
else{
result = await collection.updateOne(
{ MSKH: msnv },
{ $set: { token: token, refresh_token: refresh_token } }
);
}
if (result.modifiedCount > 0) {
res.status(200).json({"success":1,"message":"Login successful",user:result,"token":token,"refresh_token":refresh_token});
} else {
res.status(200).json({"success":1,"message":"Không thể update token",user:data,"token":token,"refresh_token":refresh_token});
}
} catch (error) {
console.error('Error during update:', error);
}
} else {
res.status(200).json({"success":-1,"message": "Login failed. Invalid MSNV or password."});
}
} catch (error) {
res.status(200).json({"success":-1,"message": "error table in database"});
}
}
});
/**
* Lấy mã token mới sử dụng Refresh token
* POST /refresh_token
*/
router.post('/refresh_token', async (req, res) => {
try {
const { refreshToken, position } = req.body;
// Kiểm tra refreshToken có tồn tại
if (!refreshToken) {
return res.status(400).json({ success: 0, message: "Refresh token is required" });
}
// Kiểm tra refresh token có hợp lệ
let collection;
if(position>0) {
collection = connectDB.collection("NhanVien");
}else{
collection = connectDB.collection("KhachHang");
}
let result = await collection.findOne({ refresh_token: refreshToken });
if (result && result.refresh_token) {
let row_refresh_token = result.refresh_token;
var decoded = jwt.verify(row_refresh_token, process.env.REFRESH_TOKEN_SECRET);
var token = jwt.sign({ exp: Math.floor(Date.now() / 1000) + (60*60), user: decoded.user }, process.env.ACCESS_TOKEN_SECRET);
res.status(200).json({"success":1,"data":decoded,"token":token,"refresh_token":row_refresh_token});
} else {
res.status(404).json({ success: 0, message: "Refresh token not found" });
}
} catch (error) {
console.error('Error refreshing token:', error);
res.status(500).json({ success: 0, message: "Internal Server Error" });
}
});
/**
* Middleware xác thực người dùng dựa vào mã token
* @param {*} req
* @param {*} res
* @param {*} next
*/
const TokenCheckMiddleware = async (req, res, next) => {
// Lấy thông tin mã token được đính kèm trong request
const token = req.body.token || req.query.token || req.headers['x-access-token'];
// decode token
if (token) {
// Xác thực mã token và kiểm tra thời gian hết hạn của mã
try {
var decoded = jwt.verify(token, process.env.ACCESS_TOKEN_SECRET);
// Lưu thông tin giã mã được vào đối tượng req, dùng cho các xử lý ở sau
req.decoded = decoded;
next();
} catch (err) {
// Giải mã gặp lỗi: Không đúng, hết hạn...
console.error(err);
return res.status(401).json({
message: 'Unauthorized access.',
});
}
} else {
// Không tìm thấy token trong request
return res.status(403).send({
message: 'No token provided.',
});
}
}
router.post("/get-info-nhanvien",TokenCheckMiddleware, (req, res) => {
return res.status(200).json({"token":req.decoded})
});
router.use(TokenCheckMiddleware)
router.post("/welcome", (req, res) => {
const token =
req.body.token || req.query.token || req.headers["x-access-token"];
if (!token) {
return res.status(403).send("A token is required for authentication");
}
try {
var decoded = jwt.verify(token, process.env.ACCESS_TOKEN_SECRET);
res.status(200).send(decoded.user);
} catch (err) {
return res.status(401).send("Invalid Token");
}
});
/* cập nhật khách khàng */
router.post("/update/khachhang", async (req, res) => {
const token =
req.body.token || req.query.token || req.headers["x-access-token"];
if (!token) {
return res.status(403).send("A token is required for authentication");
}
try {
const decoded = jwt.verify(token, process.env.ACCESS_TOKEN_SECRET);
// Kiểm tra thời hạn của token
const currentTime = Math.floor(Date.now() / 1000); // Thời gian hiện tại tính bằng giây
if (decoded.exp && decoded.exp < currentTime) {
// Token đã hết hạn, bạn có thể xử lý refresh token ở đây
return res.status(401).send("Token has expired, please log in again");
// Ví dụ:
// const refreshToken = await RefreshToken.findOne({ userId: decoded.user.id });
/* if (refreshToken) {
// Tạo mới access token và gửi về client
const newAccessToken = jwt.sign({ user: decoded.user }, process.env.ACCESS_TOKEN_SECRET, { expiresIn: '15m' });
res.status(200).json({ accessToken: newAccessToken });
} else {
// Không tìm thấy refresh token, đòi hỏi người dùng đăng nhập lại
res.status(401).send("Token has expired, please log in again");
} */
} else {
// Token còn hạn, tiếp tục xử lý
res.status(200).json(decoded.user);
}
} catch (err) {
// Lỗi xác thực token
return res.status(401).send("Invalid Token");
}
})
//dat don hang
router.post("/dathang/check-out", async (req, res) => {
const token =
req.body.token || req.query.token || req.headers["x-access-token"];
if (!token) {
return res.status(403).send("A token is required for authentication");
}else{
try {
const decoded = jwt.verify(token, process.env.ACCESS_TOKEN_SECRET);
const data = decoded.user
const {HoTenKH, SoDienThoai, DiaChi,MSKH,carts} = req.body;
// Lấy ngày đặt hàng hiện tại
const ngayDatHang = new Date().toISOString().split('T')[0];
// Lấy ngày giao hàng sau 3 ngày
const ngayGiaoHang = new Date();
ngayGiaoHang.setDate(ngayGiaoHang.getDate() + 2);
const ngayGiaoHangFormatted = ngayGiaoHang.toISOString().split('T')[0];
const SoDonHang =`${Date.now()}`;
const newDonhang = {
"SoDonDH": SoDonHang,
"MSKH":data.MSKH,
"MSNV":"1233",
"NgayDH":ngayDatHang,
"NgayGH":ngayGiaoHangFormatted,
"TrangThaiDH":0
}
const collection = connectDB.collection("DatHang");
// Chèn bản ghi mới vào cơ sở dữ liệu
const result = await collection.insertOne(newDonhang);
if(result){
const cartsWithSoDonHang = carts.map(cart => ({
...cart,
MSDH: SoDonHang
}));
//thêm danh sách chi tiết đơn hàng
const collection = connectDB.collection("ChiTietDatHang");
// Chèn nhiều bản ghi mới vào cơ sở dữ liệu
const result = await collection.insertMany(cartsWithSoDonHang);
res.status(200).json({"success":1,"donhang":cartsWithSoDonHang,"message":"Đặt hàng thành công"});
}
} catch (error) {
res.status(200).json({"success":-1,"message":"Token has expired, please log in again"});
}
}
})
//check don hang dat don hang
router.get("/check/dathang/:id", async (req, res) => {
const token =
req.body.token || req.query.token || req.headers["x-access-token"];
if (!token) {
return res.status(403).send("A token is required for authentication");
}else{
try {
//const decoded = jwt.verify(token, process.env.ACCESS_TOKEN_SECRET);
//const data = decoded.user
const collection = connectDB.collection("DatHang");
const result = await collection.findOne({
SoDonDH: req.params.id,
});
if(!result) res.status(200).json({"success":0,"message":"Không tồn tại đơn hàng"});
let TrangThaiDH = result.TrangThaiDH;
if(result.TrangThaiDH == 0){
TrangThaiDH = 1;
}
let kq = await collection.updateOne(
{ SoDonDH: req.params.id },
{ $set: { TrangThaiDH:TrangThaiDH} }
);
res.status(200).json({"success":1,"donhang":kq,"message":"Đã cập nhật đơn hàng"});
} catch (error) {
res.status(200).json({"success":-1,"message":"Token has expired, please log in again"});
}
}
});
//lấy tất cả danh sách nhân viên
router.get("/users", async (req, res) => {
const token =
req.body.token || req.query.token || req.headers["x-access-token"];
if (!token) {
return res.status(403).send("A token is required for authentication");
}else{
try {
const collection = connectDB.collection("NhanVien");
// Sử dụng phương thức find() để lấy tất cả các documents trong collection
const users = await collection.find({}).toArray();
// Log tất cả users
console.log(users);
res.status(200).json({"success":1,"ListNhanVien":users});
} catch (error) {
console.error('Error getting all users:', error);
}
}
})
//lấy tất cả danh sách đơn hàng
router.get("/getdathangs", async (req, res) => {
const token =
req.body.token || req.query.token || req.headers["x-access-token"];
if (!token) {
return res.status(403).send("A token is required for authentication");
}else{
try {
const collection = connectDB.collection("DatHang");
// Sử dụng phương thức find() để lấy tất cả các documents trong collection
const dathangs = await collection.find({}).toArray();
let dsdonhang = [];
for (const item of dathangs){
const collection = connectDB.collection("ChiTietDatHang");
const chitietdathang = await collection.find({
MSDH: item.SoDonDH,
}).toArray();
let chitiet = [];
for(const hang of chitietdathang){
let MSHH = hang.MSHH
const collection = connectDB.collection("HangHoa");
const hanghoa = await collection.findOne({
MSHH: MSHH,
});
hang.TenHH = hanghoa.TenHH;
chitiet.push(hang);
}
dsdonhang.push({
"SoDonDH":item.SoDonDH,
"NgayDH":item.NgayDH,
"NgayGH":item.NgayGH,
"TrangThaiDH":item.TrangThaiDH,
"ChiTietDatHang":chitiet
})
}
res.status(200).json({"success":1,"ListDatHang":dsdonhang});
} catch (error) {
console.error('Error getting all users:', error);
}
}
})
app.use('/', router);
module.exports = app;Hẹn mọi người bài viết sau!