👨‍💻 사건

Node.js 를 통하여, data.json 파일의 데이터를 MySQL에 접근시켜, 원하는 테이블에 삽입하는 것을 목표로 코드를 작성하다가 MySQL 관련 메서드에 대해 잘몰라 어려움이 있었다. 이에 따라 GPT 선생님 과 구글링을 통해 이를 해결하고자 하였다.

✅ 해결

해결한 코드를 통해 정리를 해보려한다. ( 역시,,GPT짱,,구글짱,,)

const fs = require('fs');
const mysql = require('mysql');

// MySQL 데이터베이스에 연결하기 위한 객체 생성
const connection = mysql.createConnection({
  host: process.env.DB_HOST,
  user: process.env.DB_USER,
  password: process.env.DB_PASSWORD,
  database: process.env.DB_NAME,
})

const loadData = async () => {
  return new Promise((resolve, reject) => {
    // connect 메서드를 통해 데이터 베이스 연결
    connection.connect((err) => {
      if (err) {
        console.error(err)
        reject(err)
        return
      }
      console.log('Connected to database');
      
	  // fs 함수를 통해, data.json 파일을 비동기적으로 읽음
      fs.readFile('data.json', 'utf8', async (err, data) => {
        if (err) {
          console.error(err)
          reject(err)
          return
        }
        
        // json파일의 데이터를 객체로 변환
        const jsonData = JSON.parse(data);
        
        // map으로 돌면서, 각 데이터 항목에 대해 삽입작업 수행
        const promises = jsonData.map((item) => {
          
          //각 요소들에 대해 새로운 프로미스 객체 생성
          return new Promise((resolve, reject) => {
            
            // INSERT INTO 쿼리문 생성
            const query = 'INSERT INTO fm_table SET ?';
            
          	// query 메서드를 사용하여 쿼리 동작 ( query는 위의 변수, item 은 데이터 객체  
            connection.query(query, item, (err, result) => {
              if (err) {
                console.error(err);
                reject(err);
                return;
              }
              
              // 프로미스 정상적으로 실행되면 console.log 실행 후, 프로미스 수행
              console.log('Data inserted', result);
              resolve();
            });
          });
        });

        try {
          
          //모든 프로미스가 수행될때까지 대기
          await Promise.all(promises);
          // 전부다 실행되면, resolve 됨
          resolve();
        } catch (error) {
          reject(error);
        }
      });
    });
  });
};

loadData()
  .then(() => console.log('All data inserted'))
  .catch(err => console.error(err));

💭 개선

• node.js 에서 실행해보니, MySQL 데이터베이스에 삽입될때 DATE 가 'YYYY-MM-DD" 형식이 아니라 오류가 발생했다. 이를 수정해야할것같다.