REST API with MySQL

---
title:"REST API trong NodeJS với MySQL"
author:DucPV
---
## Database ?
Trong bài viết này chúng ta dùng MySQL, cú pháp của MySQL tương tự như SQL Server. Đầu tiên cần cài đặt MySQL [link Download](https://www.mysql.com/downloads/). Hoặc làm theo hướng dẫn [Video](https://www.youtube.com/watch?v=Ddx13KlW8yQ).
#### Tạo database

>Có thể tạo database bằng lệnh trong _MySQL Command Line client_ hoặc trong _MySQL Workbench_. Chúng ta sẽ dùng lệnh:

* Mở _MySQL Command Line client_ để kiểm tra các databse(DB) đã tồn tại, tránh việc trùng lặp tên khi tạo mới DB:

![](https://www.javaguicodexample.com/snortiisphpbaseperladodb_files/snortmysqlphperliisoinkmasterwinxp128.png)
* Tạo mới một DB có tên Blog: paste lệnh dưới vào command line.
```
CREATE DATABASE BlogDB;
```

* Tạo bảng có tên blog:
```
CREATE TABLE Blog(
   id int PRIMARY KEY AUTO_INCREMENT,
   title_name varchar(50) NOT NULL,
   author_name varchar(50) NOT NULL,
   content varchar(250) NOT NULL
);
```

## Application
> Chúng ta bắt đầu khởi tạo project. Tạo một folder chứa source code. Bạn chắc chăn là máy tính của mình đã cài Node. Nếu chưa cài đặt tham khảo phần **Cài đặt Node và package.json** trong bài viết dưới đây của mình [link](https://note.coralo.ooo/blog/2018-09-22-express-less-co-ban-trong-node-server/).
#### 1.Setup app.js
> Ứng dụng sẽ được chạy từ đây
* Tạo file app.js
* Cài đặt **express module**:
```
npm install --save express
```
* Copy đoạn code dưới đây vào app.js:
```
const express = require('express');
const app = express();
const morgan = require('morgan');
const port = process.env.port || 3000;

// test Understanding req.params.id
app.get("/blog/:id", (req,res)=>{
    console.log("Website is fetching data from id: " + req.params.id);
    res.end();
})
app.listen(port, ()=>{
    console.log('Serner is listenning on port ' + port);
});
```
Ở đây mình có sử dụng thêm **module morgan** để có thể in ra console thông tin mỗi response.
Như trong phương thức get "/blog/:id", khi viết **:id** thì phía sau blog sẽ là một param với tên param là _id_. Để lấy được param được gửi đi trên URL ta dùng "-req.params.id-"
Kiểm tra: Chạy ứng dụng, mở trình duyệt mà nhập vào đường dẫn: localhost:3000/blog/3
=> console sẽ in ra "Website is fetching data from id:3"

#### 2.Kết nối với MySQL
> Đầu tiên chúng ta cần sử dụng **mudule mysql** của npm. Trong bài viết trên mình cũng có hướng dẫn cách cài đặt một module của npm. Để cài đặt module mysql cũng tương tự vậy.
```
npm install --save "mysql"
```

Tạo một folder có tên config, folder này chưa file kết nối với DB. Bên trong folder tạo file _dbContext.js_, copy đoạn code dưới đây:
```
const mysql = require('mysql');
const connection = mysql.createPool({
        host : "localhost",
        user : "root",
        password : "your_pasword",
        database : "database_name"
});
module.exports = connection;
```
Mỗi khi chúng ta cần sử dụng kết nối chỉ cần require đến file này.
#### 3. Setup Route
> Việc chúng ta tương tác với một trang web chính là việc thao tác trên URL. Trong mô hình REST API chúng ta sẽ làm quen với CRUD(create,read,update,delete), với mỗi hành động sẽ do một **route** đảm nhiệm. Trong **Express JS**, route được tích hợp bên trong và rất dễ sử dụng.

* Tạo một folder tên routers, Folder này sẽ quản lý các route
* Tạo file blog.js, dùng để quản lý các route của blog
###### 3.1.Read Blog

Copy đoạn code dưới đây và dán vào file blog.js:

```
const express = require('express');
const router = express.Router();
const connection = require('../config/dbContext.js'); // kết nối MySQL

// get all Blogs
router.get("/blog", (req,res)=>{
    // stringQuery : các câu truy vấn lấy dữ liệu từ DB
    let stringQuery = "select * from blog";
    connection.query(stringQuery, (err,rows)=>{
        if(err){
            res.sendStatus(500);
            console.log("Error: "+ err);
            return;
        }
        return res.send({error:false,data:rows,message:"Blog list"});
    });
});
module.exports = router;
```
Để kiểm tra mở trình duyệt nhập đường dẫn: localhost:3000/blog
Kết quả sẽ trả về một mản chứa đối tượng JSON
###### 3.2.Read Blog by Id
Sử lại file blog.js:
```
const express = require('express');
const router = express.Router();
const connection = require('../config/dbContext.js'); // kết nối MySQL

// get blog by Id
router.get("/blog/:id",(req,res)=>{
    const blogID = req.params.id; // lấy Id client gửi lên
    let queryString = "select * from blog where id = ?";
    // [blogID] : blogID tương ứng với ? thứ nhất
    connection.query(queryString,[blogID], (err,rows)=>{
        if(err){
            res.sendStatus(500);
            console.log("Error: " + err);
            return;
        }
        return res.send({error:false,data:rows[0],message:"Data"});
    });
});
module.exports = router;
```
localhost:3000/blog/3
###### 3.3.Create Blog
Cài đặt **module body-parser**
```
npm install --save body-parser
```
Sử lại file blog.js:
```
const express = require('express');
const bodyParser = require('body-parser');

const router = express.Router();
const connection = require('../config/dbContext.js'); // kết nối MySQL
router.use(bodyParser.urlencoded({extended:false}));
// create Blog
router.post("/blog/create",(req,res)=>{
    let titleName = req.body.title_name;
    let authorName = req.body.author_name;
    let content = req.body.content;
    let stringQuery = "insert into blog(title_name,author_name,content) values(?,?,?)";
    connection.query(stringQuery,[titleName,authorName,content],(error,result)=>{
        if(error){
            console.log("Error: " + err);
        }
        return res.send({error:false,data:result,message:"Insert successfull"});
    });
});
module.exports = router;
```
###### 3.4.Delete Blog
Sửa lại file blog.js:
```
const express = require('express');
const bodyParser = require('body-parser');
const router = express.Router();
const connection = require('../config/dbContext.js'); // kết nối MySQL
router.use(bodyParser.urlencoded({extended:false}));

// Delete Blogby Id
router.delete("/blog/delete/:id", (req,res)=>{
    let blogID = req.params.id;
    let stringQuery = "Delete from blog where id = ?";
    connection.query(stringQuery,[blogID], (err,result)=>{
        if(err){
            console.log("Error: " + err);
        }
        return res.send({error:false,data:result,message:"Delete successfull"});
    })
});
module.exports = router;
```
###### 3.5.Update Blog
Sửa lại file blog.js:
```
const express = require('express');
const bodyParser = require('body-parser');
const router = express.Router();
const connection = require('../config/dbContext.js'); // kết nối MySQL
router.use(bodyParser.urlencoded({extended:false}));

// update Blog
router.put("/blog/update/:id", (req,res)=>{
    let blogID = req.params.id;
    let titleName = req.body.title_name;
    let authorName = req.body.author_name;
    let content = req.body.content;
    let stringQuery = "update blog set title_name = ?, author_name = ?, content = ? where id = ?";
    connection.query(stringQuery,[titleName,authorName,content,blogID],(error,result)=>{
        if(error){
            console.log("Error: " + err);
        }
        return res.send({error:false,data:result,message:"Update successfull"});
    });
})
module.exports = router;
```
## Sử dụng Postman
> Khi chúng ta update, create blog thì có câu hỏi đặt ra là dữ liệu để thêm/sửa sẽ được lấy từ đâu. Thực tế thì những dữ liệu đó sẽ được lấy từ form, tuy nhiên việc tạo ra form để kiểm tra xem dữ liệu thay đổi như thế nào là không tối ưu. Do vậy, chúng ra sẽ sử dụng Postman

Chúng ta có thể tải Postman về hoặc sử dụng extention có sắn của Google Chrome.
![](https://lh3.googleusercontent.com/he6FhqnwdRBJAaULacb1d2i3gakZk1aEB6Yh7--TibEiIsd4iT3-lsm0_5i-z9YGCx4Cvw5vY7M=w640-h400-e365)
* Với việc kiểm tra read,delete thì chỉ cần nhập vào đường dẫn rồi chọn phương thức Get,Delete tương ứng.
* Ứng dụng rõ nhất của Postman có thể thấy được là kiểm tra phương thức Post(create) và Put(update).
![](https://s3.amazonaws.com/postman-static-getpostman-com/postman-docs/requestBuilderUrlEncoded.png)
Như đã đề cập ở phần trên về việc truyền dữ liệu như thế nào,Postman cung cấp cho chúng ta cách để truyền dữ liệu vào. Click vào **Body** , có 2 cột **key** và **value** tương ứng với **tên cột** và **dữ liệu của cột**