DEV Community: Bhurisub Dejpipatpracha

Node.js : การ Upload ไฟล์ด้วยมอดูล multer

Bhurisub Dejpipatpracha — Thu, 24 Oct 2019 04:23:06 +0000

บทความนี้จะแนะนำการเขียนสคริปต์เพื่อ Upload ไฟล์เข้าสู่ Server ด้วยมอดูล multer ซึ่งจะเป็นมอดูลหลักในการช่วยให้เรา Upload ไฟล์ต่างๆ ได้สะดวกมากขึ้น โดยขอเริ่มจากติดตั้งมอดูลที่จำเป็นต้องใช้งาน express, ejs, multer

npm i express
npm i ejs
npm i multer

สร้างโฟลเดอร์ public แล้วใส่ข้อมูลเกี่ยวกับ bootstrap ทั้งหมด และสร้างโฟลเดอร์ uploads เพื่อเก็บข้อมูลไฟล์หรือรูปภาพที่ได้ทำการอัปโหลดจากเครื่องผู้ใช้ จากนั้นสร้างฟอร์มสำหรับ Upload ไฟล์

สคริปต์ views/upload.ejs สร้างฟอร์มสำหรับ Upload ไฟล์ โดยกำหนดชื่อตัวแปร fileupload เพื่อนำไปใช้ในส่วนการ upload ไฟล์

<!DOCTYPE html>
<html>
  <head>
    <title>Upload File </title>
    <meta charset="utf-8">
    <meta http-equiv="X-UA-Compatible" content="IE=edge">
    <meta name="viewport" content="width=device-width, initial-scale=1">
    <link href="./bootstrap/css/bootstrap.min.css" rel="stylesheet">
  </head>
  <body>
      <div class="container">
          <div class="page-header">
              <h1>Upload File</h1>
              <hr>
          </div>
          <div class="row">
            <div class="col">
              <form method="post" action="/upload" enctype="multipart/form-data">
                <div class="form-group">
                  <label for="firstname">Upload</label>
                  <input type="file" class="form-control" name="fileupload" required>
                </div>
                <button type="submit" class="btn btn-primary">Submit</button>
                <button type="reset" class="btn btn-primary">Reset</button>
              </form>
            </div>
          </div>
        </div>
        <script src="./jquery-3.2.1.slim.min.js" ></script>
        <script src="./popper.min.js" ></script>
        <script src="./bootstrap/dist/js/bootstrap.min.js"></script>
  </body>
</html>

จากนั้นสร้างสคริปต์ index.js ซึ่งจะเป็นสคริปต์ในการ Upload ไฟล์

สคริปต์ index.js

const express = require('express')
const app = express()
app.use(express.static(__dirname + '/public'))

app.set('view engine', 'ejs')

const bodyParser = require('body-parser')
app.use(bodyParser.urlencoded({ extended: false }))
app.use(bodyParser.json())

const multer = require('multer')
const storage = multer.diskStorage({
    destination: (req, file, cb) => {
        cb(null, './public/uploads')
    },
    filename: (req, file, cb) => {
        cb(null, 'file-' + Date.now() + '.' +
        file.originalname.split('.')[file.originalname.split('.').length-1])}
})

const upload = multer({ storage: storage })

app.get('/', (req, res) => {
    res.render('upload')
})

app.post('/upload',upload.single('fileupload'),(req,res) => {
    res.render('show',req.file)
})

app.listen(3000, () => {
    console.log('Server Started on localhost:3000...')
})

จากสคริปต์ index.js เราจะต้องเรียกใช้มอดูล multer เก็บไว้ในตัวแปร multer
จากนั้นต้องกำหนดข้อมูลที่เกี่ยวของ destination เป็นการกำหนดโฟลเดอร์สำหรับเก็บไฟล์ที่ผู้ใช้ Upload เข้ามาซึ่งในตัวอย่างนี้จะเก็บไว้ที่ /public/uploads

filename เป็นการกำหนดชื่อไฟล์หลังจาก uploads ในตัวอย่างนี้จะกำหนดชื่อไฟล์เริ่มต้นด้วยข้อความ "file-" ต่อด้วยวันเดือนปีที่ upload และหานามสกุลไฟล์ต้นฉบับ

'file-' + Date.now() + '.' + file.originalname.split('.')[file.originalname.split('.').length-1])

โดยการกำหนดค่าทั้งหมดที่กล่าวมาจะเก็บไว้ในตัวแปร storage แล้วไปใช้กับมอดูล multer เก็บไว้ในตัวแปร upload

const upload = multer({ storage: storage })

จากนั้นเมื่อรันสคริปต์ก็จะแสดงหน้าฟอร์ม โดยสคริปต์จะไปเรียกใช้ไฟล์ upload.ejs ออกมา ดังภาพ

app.get('/', (req, res) => {
    res.render('upload')
})

จากนั้นหากผู้ใช้ upload ไฟล์แล้วกดปุ่ม submit ก็จะส่งมายังหน้า upload method post

app.post('/upload',upload.single('fileupload'),(req,res) => {
    res.render('show',req.file)
})

โดยเราสามารถนำตัวแปรไปใช้งานได้ เช่น filename ชื่อไฟล์ที่เรา Upload เสร็จแล้ว size ขนาดของไฟล์ originalname ชื่อไฟล์ต้นฉบับ ฯลฯ

Key	Description	Note
fieldname	Field name specified in the form
originalname	Name of the file on the user's computer
encoding	Encoding type of the file
mimetype	Mime type of the file
size	Size of the file in bytes
destination	The folder to which the file has been saved	DiskStorage
filename	The name of the file within the destination	DiskStorage
path	The full path to the uploaded file	DiskStorage
buffer	A Buffer of the entire file	MemoryStorage

สคริปต์ views/show.ejs แสดงภาพที่ upload มา

<!DOCTYPE html>
<html>
  <head>
    <title> Upload File </title>
    <meta charset="utf-8">
    <meta http-equiv="X-UA-Compatible" content="IE=edge">
    <meta name="viewport" content="width=device-width, initial-scale=1">
    <link href="./bootstrap/css/bootstrap.min.css" rel="stylesheet">
  </head>
  <body>
      <div class="container">
          <div class="page-header">
              <h1>Upload File</h1>
              <hr>
          </div>
          <div class="row">
            <div class="col">
              <img src="uploads/<%=filename%>" width="250">
            </div>
          </div>
        </div>
    <script src="./jquery.min.js"></script>
    <script src="./bootstrap/js/bootstrap.min.js"></script>
  </body>
</html>

สรุป

การ upload ไฟล์ด้วยใช้มอดูล multer ในตัวอย่างนี้จะ upload ไฟล์ได้ครั้งละ 1 ไฟล์เท่านั้น ซึ่งมอดูล multer สามารถ upload ไฟล์ครั้งละหลายๆ ไฟล์ โดยสามารถเข้าไปดูรายละเอียดเพิ่มเติมได้ที่ https://www.npmjs.com/package/multer

Node.js : ระบบ Authentication ที่ทำงานร่วมกับฐานข้อมูล Mongo

Bhurisub Dejpipatpracha — Sun, 20 Oct 2019 08:49:56 +0000

จากบทความที่แล้ว ได้แนะนำการเขียนสคริปต์ JavaScript เพื่อทำระบบ Authentication แบบพื้นฐาน ด้วยมอดูล Passport สำหรับในบทความนี้จะขอแนะนำการเขียนสคิปต์ทำระบบ Authentication ทำงานร่วมกับฐานข้อมูล Mongo โดยเราจะเก็บข้อมูลสมาชิกไว้ใน Collection users

ซึ่งขอยกตัวอย่างข้อมูล db.users.find()

{ 
   _id:OjectId("5daa74efb50ece2f98643d35"),
   username:"anakin",
   password:"1234",
   fname:"Anakin",
   lname:"Skywalker"
}
{ 
   _id:OjectId("5daa748b1a5fc22f98b6db32"),
   username:"bhurisub",
   password:"1234",
   fname:"Bhurisub",
   lname:"Dejpipatpracha"
}

เราจะนำเอาสคริปต์ในบทความที่ผ่านมาปรับปรุง โดยเริ่มจากติดตั้งมอดูลเพิ่มเติม
npm i mongodb

สคริปต์ views/home.ejs ปรับปรุงหน้าหลักสมาชิก

...
...
      <div class="container">
          <div class="row">
            <h1>:: Home ::</h1>
          </div>
          <div class="row">
             Login Ok.<br/><br/> 
             _id = <%=_id%> <br/>
             Username = <%=username%> <br/>
             Name = <%=fname%> <%=lname%> <br/><br/>
          </div>
          <div class="row">
            <a href='./logout'>Logout</a>
          </div>
      </div>
...
...

สร้างสคริปต์ config.js สำหรับติดต่อฐานข้อมูล Mongo

const MongoClient = require('mongodb').MongoClient  

const url = 'mongodb://localhost:27017' 
const dbName = 'webphuket' 

module.exports = new Promise((resolve, reject)=>{
    MongoClient.connect(url, { useNewUrlParser: true,useUnifiedTopology: true },(err, client) => {
        if (err) throw err
        const mongo = client.db(dbName)
        console.log("Connected successfully to server")
        resolve(mongo)
    })
})

สคริปต์ index.js (ปรับปรุง)

const express = require('express')
const app = express()
app.use(express.static(__dirname + '/public'))
app.set('view engine', 'ejs')

const MongoObjectID = require('mongodb').ObjectID
const mongo = require('./config')

const passport = require('passport')
const LocalStrategy = require('passport-local').Strategy

const bodyParser = require('body-parser')
const cookieParser = require('cookie-parser')
app.use(bodyParser.urlencoded({ extended: false }))
app.use(bodyParser.json())
app.use(cookieParser())

const session = require('express-session')
app.use(session({ secret: 'I am Anakin.', resave: true, saveUninitialized: true }))
app.use(passport.initialize())
app.use(passport.session())

passport.use(new LocalStrategy((username, password, done) => {
    mongo.then((db) => {
        query = { username : username }
        db.collection('users').findOne(query,(err, user) => {
            if (err) return done(err)

            if (!user) {
                console.log('Incorrect username.')
                return done(null, false, { message: 'Incorrect username.' })
            } else if (user.password == password ) {
                console.log('Correct password.')
                return done(null, user)
            } else {
                console.log('Incorrect password.')
                return done(null, false, { message: 'Incorrect password.' })
            }
        })
    })
}))

passport.serializeUser((user, done) => {
    console.log('SerializeUser')
    done(null, user._id) 
})

passport.deserializeUser((id, done) => {
    mongo.then((db) => {
        query = { _id : new MongoObjectID.ObjectID(id) }
        db.collection('users').findOne(query,(err, user) => {
            if (err) return done(err)

            console.log('DeserializeUser')
            done(null, user) 
        })
    })
})

app.get('/', (req, res) =>  {
    res.render('login')
})

app.get('/login', (req, res) =>  {
    res.render('login')
})

app.post('/login', passport.authenticate('local', { 
    successRedirect: '/home',
    failureRedirect: '/' 
}))

function isLoggedIn(req, res, next) {
    if (req.isAuthenticated()) {
        return next()
    } else {
        res.redirect('/')
    }
}

app.get('/home',isLoggedIn,(req,res) => {
    res.render('home',req.user)
})

app.get('/logout',(req,res) => {
    req.logout()
    res.redirect('/')
})

app.listen(3000, () => {
    console.log('Server Started on localhost:3000...')
})

เรียกใช้ ObjectID เก็บไว้ในตัวแปร MongoObjectID และเรียกใช้การติดต่อฐานข้อมูล Mongo เก็บไว้ในตัวแปร mongo

const MongoObjectID = require('mongodb').ObjectID
const mongo = require('./config')

กำหนดการตรวจสอบสมาชิกในฐานข้อมูล Mongo เรียกแสดงข้อมูลใน collection ชื่อ users ที่ username ตามที่ผู้ใช้ป้อนมาจากฟอร์ม หากค้นหาข้อมูลได้แล้วก็จะเก็บไว้ใน user

จากนั้นตรวจสอบ user ว่ามีข้อมูลหรือไม่ หากไม่มีแสดงว่าผู้ใช้ป้อน Username ที่ไม่มีอยู่ใน Collection
และหากรหัสผ่านที่ดึงมาจาก collection ตรงกับรหัสผ่านที่ผู้ใช้ป้อน และหากไม่ถูกตอ้งก็แสดงว่า รหัสผ่านของ Username ดังกล่าวไม่ตรงกับที่อยู่ในฐานข้อมูล

passport.use(new LocalStrategy((username, password, done) => {
    mongo.then((db) => {
        query = { username : username }
        db.collection('users').findOne(query,(err, user) => {
            if (err) return done(err)

            if (!user) {
                console.log('Incorrect username.')
                return done(null, false, { message: 'Incorrect username.' })
            } else if (user.password == password ) {
                console.log('Incorrect password.')
                return done(null, user)
            } else {
                console.log('Incorrect password.')
                return done(null, false, { message: 'Incorrect password.' })
            }
        })
    })
}))

สำหรับในการเก็บข้อมูลใน Session เราจะเก็บเฉพาะ _id ของ Username เท่านั้น

passport.serializeUser((user, done) => {
    console.log('SerializeUser')
    done(null, user._id) 
})

หลังจากนั้นนำ id ที่เก็บไว้ Seesion ไปใช้อ้างอิงเพื่อดึงข้อมูลสมาชิกใน collection users เก็บไว้ในตัวแปร user

passport.deserializeUser((id, done) => {
    mongo.then((db) => {
        query = { _id : new MongoObjectID.ObjectID(id) }
        db.collection('users').findOne(query,(err, user) => {
            if (err) return done(err)

            console.log('DeserializeUser')
            done(null, user) 
        })
    })
})

ขอจบบทความนี้เพียงเท่านี้ ครับ ;)

Node.js : ระบบ Authentication แบบพื้นฐานด้วยมอดูล Passport-local

Bhurisub Dejpipatpracha — Sat, 19 Oct 2019 02:01:33 +0000

บทความนี้จะขอแนะนำการเขียนสคริปต์ JavaScript เพื่อทำระบบ Authenticationแบบพื้นฐาน ด้วยมอดูล Passport จะช่วยให้ระบบสามารถตรวจสอบสมาชิกก่อนที่เข้าใช้งานระบบสมาชิกได้ โดยมอดูล passport จะช่วยตรวจสอบ Username และ Password ได้ทั้งแบบพื้นฐาน ผ่าน Account ของฐานข้อมูลของเรา ผ่าน Account ของ Facebook ผ่าน Account ของ Twitter ฯลฯ

ซึ่งในตัวอย่างนี้จะแนะนำการเขียนสคริปต์ทั้งแบบพื้นฐาน คือ นำชื่อผู้ใช้และรหัสผ่านใส่ไว้ในสคริปต์ เพื่อทำความเข้าใจหลักการใช้งานมอดูล Passport

โดยเริ่มจากติดตั้งมอดูล express, ejs, express, express-session, passport, passport-local

npm i cookie-parser
npm i ejs
npm i express
npm i express-session
npm i passpost
npm i passport-local

สคริปต์ views/login.ejs สร้างฟอร์มรับข้อมูล login ฟอร์ม login

<!DOCTYPE html>
<html>
  <head>
    <title>:: Login ::</title>
    <meta charset="utf-8">
    <meta http-equiv="X-UA-Compatible" content="IE=edge">
    <meta name="viewport" content="width=device-width, initial-scale=1">
    <link href="./bootstrap/css/bootstrap.min.css" rel="stylesheet">
  </head>
  <body>
      <div class="container">
          <div class="page-header">
              <h1>:: Login ::</h1>
              <hr>
          </div>
          <div class="row">
            <div class="col">
              <form method="post" action="login">
                <div class="form-group">
                  <label for="user">Username</label>
                  <input type="text" class="form-control" name="username" 
                    placeholder="Username" required>
                </div>
                <div class="form-group">
                  <label for="pass">Password</label>
                  <input type="text" class="form-control"name="password" 
  placeholder="Password" required>
                </div> 
                <button type="submit" class="btn btn-primary">Login</button>
                <button type="reset" class="btn btn-primary">Reset</button>
              </form>
            </div>
          </div>
        </div>
    <script src="./jquery.min.js"></script>
    <script src="./bootstrap/js/bootstrap.min.js"></script>
  </body>
</html>

สคริปต์ views/home.ejs หน้าหลักหลังจากผ่านการ login เข้ามาแล้ว

<!DOCTYPE html>
<html>
  <head>
    <title>:: Home ::</title>
    <meta charset="utf-8">
    <meta http-equiv="X-UA-Compatible" content="IE=edge">
    <meta name="viewport" content="width=device-width, initial-scale=1">
    <link href="./bootstrap/css/bootstrap.min.css" rel="stylesheet">
  </head>
  <body>
      <div class="container">
          <div class="row">
            <h1>:: Home ::</h1>
          </div>
          <div class="row">
             Login Ok.<br/><br/> 
             Users -> <%=_id%> <%=fname%> <%=lname%> <br/><br/>
          </div>
          <div class="row">
            <a href='./logout'>Logout</a>
          </div>
        </div>
    <script src="./jquery.min.js"></script>
    <script src="./bootstrap/js/bootstrap.min.js"></script>
  </body>
</html>

สคริปต์ index.js เป็นสคริปต์หลักของงานนี้

const express = require('express')
const app = express()
app.use(express.static(__dirname + '/public'))
app.set('view engine', 'ejs')

const passport = require('passport')
const LocalStrategy = require('passport-local').Strategy

const bodyParser = require('body-parser')
const cookieParser = require('cookie-parser')
app.use(bodyParser.urlencoded({ extended: false }))
app.use(bodyParser.json())
app.use(cookieParser())

const session = require('express-session')
app.use(session({ secret: 'I am Anakin.', resave: true, saveUninitialized: true }))
app.use(passport.initialize())
app.use(passport.session())

passport.use(new LocalStrategy((username, password, done) => {
    if(username =="admin" && password=="1234") {
        user = {    
            _id : 1,
            fname : "Anakin ",
            lname : "Skywalker"
        }
        console.log('Correct Password.')
        return done(null,user)
    } else {
        console.log('Incorrect password.')
        return done(null, false, { message: 'Incorrect password.' })
    }
}))

passport.serializeUser((user, done) => {
    console.log('SerializeUser')
    done(null, user) 
})

passport.deserializeUser((user, done) => {
    console.log('DeserializeUser')
    done(null, user) 
})

app.get('/', (req, res) =>  {
    res.render('login')
})

app.post('/login', passport.authenticate('local', { 
    successRedirect: '/home',
    failureRedirect: '/' 
}))

function isLoggedIn(req, res, next) {
    if (req.isAuthenticated()) {
        return next()
    } else {
        res.redirect('/')
    }
}

app.get('/home',isLoggedIn,(req,res) => {
    res.render('home',req.user)
})

app.get('/logout',(req,res) => {
    req.logout()
    res.redirect('/')
})

app.listen(3000, () => {
    console.log('Server Started on localhost:3000...')
})

เราต้องเรียกใช้มอดูล passport เก็บไว้ในตัวแปร passport และเรียกใช้มอดูล passport-local เก็บไว้ในตัวแปร LocalStrategy สำหรับใช้ตรวจสอบผู้ใช้และรหัสผ่านแบบพื้นฐานได้

const passport = require('passport') 
const LocalStrategy = require('passport-local').Strategy

เรียกใช้มอดูล express-session เก็บไว้ในตัวแปร session สำหรับเก็บข้อมูลที่เก็บหลังจากตรวจสอบผู้ใช้และรหัสผ่านเรียบร้อยแล้ว

const session = require('express-session')
app.use(session({ secret: 'I am Anakin.', resave: true, saveUninitialized: true }))
app.use(passport.initialize())
app.use(passport.session())

กำหนดให้มอดูล password ใช้งานการตรวจสอบแบบ Local โดยนำชื่อผู้ใช้ที่อยู่ในตัวแปร username และ รหัสผ่านในตัวแปร password นำมาตรวจสอบแบบง่าย ซึ่งหากผู้ใช้ป้อนมาไม่ถูกต้องก็แสดงข้อความไม่ถูกต้อง และหากตรวจสอบแล้วผู้ใช้ป้อนข้อมูลมาถูกต้อง ก็กำหนดข้อมูลที่จะเก็บไว้ใน Session เพื่อเรียกใช้งานภายหลังได้ โดยในตัวอย่างนี้จะเก็บข้อมูล _id,fname,lname เก็บไว้ในตัวแปร user

passport.use(new LocalStrategy((username, password, done) => {
    if(username =="admin" && password=="1234") {
        user = {    
            _id : 1,
            fname : "Anakin ",
            lname : "Skywalker"
        }
        console.log('Correct Password.')
        return done(null,user)
    } else {
        console.log('Incorrect password.')
        return done(null, false, { message: 'Incorrect password.' })
    }
}))

เป็นการกำหนดว่าจะนำข้อมูลอะไรไปเก็บไว้ใน Session หลังจากผ่าน Login มาเรียบร้อบแล้ว

passport.serializeUser((user, done) => {
    console.log('SerializeUser')
    done(null, user) 
})

เป็นการกำหนดว่าจะนำข้อมูลออะไรใน Session ออกมาใช้งาน ซึ่งจะใช้ในหน้าเว็บเพจต่างๆ ที่สมาชิกเข้าถึงได้

passport.deserializeUser((user, done) => {
    console.log('DeserializeUser')
    done(null, user) 
})

ที่กล่าวไว้ข้างต้นจะเป็นการกำหนดค่าสำหรับใช้งานมอดูล passport-local ซึ่งรันหน้าแรก / ก็จะแสดงฟอร์ม Login เพื่อรับ Username และ Password จากผู้ใช้ ซึ่งข้อมูลทั้งหมดก็จะส่งมายัง /login เพื่อทำการตรวจสอบข้อมูล หากข้อมูลถูกต้องก็จะส่งไปหน้า /home และหากข้อมูลไม่ถูกต้องก็ย้อนกลับไปหน้าฟอร์ม login

app.get('/', (req, res) =>  {
    res.render('login')
})

app.post('/login', passport.authenticate('local', { 
    successRedirect: '/home',
    failureRedirect: '/' 
}))

ในระบบสมาชิกก็จะมีส่วนที่สมาชิกเข้าถึงได้หลายหน้า แต่ละหน้าก่อนจะเข้าไปใช้งานได้ต้องผ่านการตรวจสอบมาก่อนว่า ได้ผ่านการ Login มาแล้วหรือไม่ โดยเราจะสร้างฟังก์ชันชื่อ isLoggedIn()เอาไว้ตรวจสอบ โดย method ชื่อ isAuthenticated() เป็นตัวหลักในการตรวจสอบการ login ซึ่งหากผ่านการตรวจสอบแล้วก็ไปในขั้นตอนต่อไป แต่หากไม่ผ่านการตวจสอบก็จะกลับไปยังฟอร์มหน้า login

function isLoggedIn(req, res, next) {
    if (req.isAuthenticated()) {
        return next()
    } else {
        res.redirect('/')
    }
}

ไปหน้าหลักของสมาชิก แล้วแสดงข้อมูลสมาชิกออก user

app.get('/home',isLoggedIn,(req,res) => {
    res.render('home',req.user)
})

หากต้องการออกจากระบบก็จะต้องทำการ logout() และกลับไปหน้า Login ต่อไป

app.get('/logout',(req,res) => {
    req.logout()
    res.redirect('/')
})

สรุป

อย่างที่กล่าวไว้ข้างต้น บทความนี้แนะนำทำระบบ Authentication แบบพื้นฐานด้วยมอดูล Passport-local เพื่อที่จะทำให้เข้าใจหลักการตรวจสอบ Username และ Password อย่างง่ายของมอดูล Passport โดยเราจะใส่ Username และ Password เอาไว้ในสคริต์เลย

ซึ่งหากนำไปใช้งานจริงแนะนำว่าควรนำข้อมูล User เก็บไว้ในฐานข้อมูลจะทำให้ User จะใช้งานระบบได้มากกว่า 1 คนและเพื่อเพิ่มความปลอดภัยของระบบสมาชิกได้

และเราสามารถหาข้อมูลเพิ่มเติมของมอดูล passport ได้จาก https://www.npmjs.com/package/passport

Node.js : การเขียนสคริปต์ติดต่อฐานข้อมูล Mongo

Bhurisub Dejpipatpracha — Tue, 08 Oct 2019 11:57:19 +0000

บทความนี้จะแนะนำการเขียนสคริปต์ JavaScript ติดต่อกับฐานข้อมูล Mongo ซึ่งจะต้องอาศัยมอดูลในการติดต่อฐานข้อมูล Mongo ในตัวอย่างที่นี่ขอแนะนำมอดูลชื่อ mongodb ซึ่งมีชื่อเดียวกันกับฐานข้อมูลเลย

เริ่มจากติดตั้งมอดูล mongodb
npm i mongodb หรือ npm install mongodb

การติดต่อฐานข้อมูล Mongo

const MongoClient = require('mongodb').MongoClient
const url = 'mongodb://localhost:27017'
const option= { useNewUrlParser: true,useUnifiedTopology: true }
const dbName = 'webphuket'

MongoClient.connect(url,option,(err, client) => {
  if (err) throw err

  const mongo = client.db(dbName)
  console.log("Connected successfully to server")
  client.close()
})

กำหนดตัวแปร MongoClient เพื่อเรียกใช้มอดูล mongodb
กำหนดตัวแปร url เพื่อกำหนด URLและ port เพื่อติดต่อฐานข้อมูล Mongo
กำหนดตัวแปร dbName เพื่อกำหนดชื่อฐานข้อมูล

จากนั้นติดต่อฐานข้อมูล Mongo ด้วย method ชื่อ connect()

การเพิ่มข้อมูล

...
...
  var data = { 
    title : 'Product 1',
    price : 1000
  }
  mongo.collection('products').insertOne(data, (err, r) => {
    console.log('documents inserted  : ',r.insertedCount) 
    client.close()
  })

สำหรับการเพิ่มข้อมูลต้องกำหนดข้อมูลเก็บไว้ในตัวแปร data ขอยกตัวอย่างข้อมูลดังนี้ หัวข้อ title ชื่อสินค้า Product 1 และราคาสินค้า price เท่ากับ 1000 เป็นต้น

จากกำหนด Collection ที่ต้องการเพิ่มในตัวอย่างชื่อ products และใช้ method ชื่อ insertOne() เป็นการเพิ่มข้อมูลชุดเดียวกัน

และในกรณีต้องการเพิ่มข้อมูลหลายๆ ชุดในครั้งเดียว ก็สามารถใช้ method ชื่อ insertMany() ได้ดังตัวอย่าง

การเพิ่มข้อมูลหลายๆ ชุดในครั้งเดียว

...
...
  var data = [
    { title : 'Product 2', price : 2000},
    { title : 'Product 3', price : 3000},
    { title : 'Product 4', price : 4000}
  ]
  mongo.collection('products').insertMany(data, (err, r) => {
    console.log('documents inserted  : ',r.insertedCount)
    client.close()
  })
...

การแสดงข้อมูล

สำหรับการแสดงข้อมูลทั้งหมดสามารถทำได้โดยใช้ method ชื่อ find() แล้วยัดข้อมูลล
Array ซึ่งเราสามารถนำไปใช้งานต่อได้

...
...
    mongo.collection('products').find().toArray((err, result) => {
        console.log(result)
        client.close()
    })
...

ในกรณีต้องการแสดงข้อมูลเฉพาะ ก็สามารถทำได้กำหนดเงื่อนไข เช่น หากต้องการแสดงสินค้าที่มีการราคาเท่ากับ 2000 บาท ก็กำหนดให้แสดงข้อมูลดังนี้


    query = { price : 2000 } 
    mongo.collection('products').find(query).toArray((err, result) => {
        console.log(result)
        client.close()
    })
...

การแก้ไขข้อมูล

ในกรณีต้องการแก้ไขข้อมูล เราสามารถทำได้กำหนดชุดข้อมูลที่ต้องการแก้ไข สามารถกำหนด _id ที่ต้องการแก้ไข { _id : new MongoID.ObjectID('5d9c4eab7e4eda0b7418f0b8')

และกำหนดข้อมูลที่ต้องการแก้ไข
data = { $set: { price: 5555 }}

แล้วแก้ไขข้อมูลด้วย method ชื่อ updateOne() ซึ่งเป็นการแก้ไข 1 ชุด

...
...
    const MongoID = require('mongodb').ObjectID
...
...
    query = { _id : new MongoID.ObjectID('5d9c4eab7e4eda0b7418f0b8') }
    data = { $set: { price: 6000 }}

    mongo.collection('products').updateOne(query,data, (err, r) => {
        console.log("document updated")

        client.close()
    })
...

การลบข้อมูล

ในกรณีที่ต้องการข้อมูลสามารถทำได้โดยกำหนด _id ที่ต้องการลบแล้วเรียกใช้ method ชื่อ deleteOne() ดังตัวอย่าง

...
...
    const MongoID = require('mongodb').ObjectID
...
...
    query = { _id : new MongoID.ObjectID('5d9c4eab7e4eda0b7418f0b8') }

    mongo.collection('products').deleteOne(query,(err, r) => {
        console.log("document deleted")

        client.close()
    })
...
})

สรุป

สำหรับการติดต่อฐานข้อมูล Mongo สามารถใช้งานมอดูลชื่อ mongodb โดยมี method ให้เราเลือกใช้มากมาย ตัวอย่างเช่น insertOne() ,insertMany(), find(), updateOne() , deleteOne() ซึ่งสามารถเข้าไปดูรายละเอียดเพิ่มเติมที่ https://www.npmjs.com/package/mongodb