MongoDB example

connect_db.js

const mongoose = require('mongoose')
const {
  DB_HOST,
  DB_PORT,
  DB_USER,
  DB_PASSWORD,
  DB_NAME } = require('../../config')
const getLogger = require('../utils/logger')

const logger = getLogger(__filename)

const _uri = Symbol('uri')
const _database = Symbol('database')

class DBModel {

  constructor () {
    this[_uri] = `mongodb://${(DB_USER && DB_PASSWORD) ? `${DB_USER}:${DB_PASSWORD}@`: ''}${DB_HOST}:${DB_PORT}/${DB_NAME}`
    this[_database]
  }

  connect () {
    this[_database] = mongoose
      .connect(this[_uri], { useNewUrlParser: true,
        useCreateIndex: true })
      .catch(err => logger.error(err.message))
  }

  disconnect () {
    mongoose.disconnect()
  }

}

module.exports.DBModel = DBModel

insert.js

const InsertResultItemDataModel = require('../models/spiders')
const uuid = require('uuid/v3')
const { DBModel } = require('../connect_db')

const dbModel = new DBModel()

async function test () {
  dbModel.connect()
  let date = Date.parse(new Date())
  let url = `https://example.com/${date}`
  await InsertResultItemDataModel.insertMany([{
    uuid: uuid(url, uuid.URL),
    url,
    filename: `${date}.pdf`,
    content: 'asdasdasdasdasdasdasd',
    created_at: date,
    updated_at: date
  }])
  dbModel.disconnect()

}

test()

model.js

const mongoose = require('mongoose')
const uuid = require('uuid/v3')

const insertResultItemData = new mongoose.Schema({
  uuid: {
    type: String,
    index: true,
    required: true
  },
  url: {
    type: String,
    required: true
  },
  filename: {
    type: String,
    required: true
  },
  content: {
    type: String,
    required: true
  },
  created_at: {
    type: String,
    required: true
  },
  updated_at: {
    type: String,
    required: true
  }
}, { timestamp: true })

const InsertResultItemDataModel
  = mongoose.model('datas', insertResultItemData)

module.exports = InsertResultItemDataModel