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

บทความนี้จะแนะนำการเขียนสคริปต์ 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