MySQL

import mysql from 'mysql2';

import { config } from '../config.js';

const pool = mysql.createPool({
  host: config.msdb.host,
  user: config.msdb.user,
  database: config.msdb.database,
  password: config.msdb.password,
});

// 데이터베이스 연결을 비동기 적으로 연결
export const msDB = pool.promise();

MongoDB

// MongoDB Node Driver
// -> MongoDB 와 Nodejs를 연결해 주는 중간 다리를 driver 라고하며
//    이와 관련된 api를 제공한다.

// MongoDB Connection
import MongoDB from 'mongodb';
import { config } from '../config.js';

let db;
export async function connectDB() {
  return MongoDB.MongoClient.connect(config.mongo.host)
    .then((client) => {
      db = client.db();
    });
}

// mongoDB 에서 users 의 Collection 정보를 가져온다.
export function getUsers() {
  return db.collection('users'); // users 이름은 MongoDB Atlas에서 자동으로 대문자로 변경된다.
}

// mongoDB 에서 tweets 의 Collection 정보를 가져온다.
export function getTweets() {
  return db.collection('tweets');
}