🐛 fix: 피드크롤러 쿼리 에러 전파용 실행 메서드 추가

Author: asn6878

feed-crawler/src/common/mysql-access.ts

@@ -23,7 +23,10 @@ export class MySQLConnection implements DatabaseConnection {
     });
   }
 
-  async executeQuery<T>(query: string, params: any[] = []) {
+  async executeQuery<T>(
+    query: string,
+    params: any[] = [],
+  ): Promise<T[] | null> {
     let connection: PoolConnection;
     try {
       connection = await this.pool.getConnection();
@@ -33,7 +36,7 @@ export class MySQLConnection implements DatabaseConnection {
       logger.error(
         `${this.nameTag} 쿼리 ${query} 실행 중 오류 발생
           오류 메시지: ${error.message}
-          스택 트레이스: ${error.stack}`
+          스택 트레이스: ${error.stack}`,
       );
     } finally {
       if (connection) {
@@ -43,13 +46,42 @@ export class MySQLConnection implements DatabaseConnection {
           logger.error(
             `${this.nameTag} connection release 중 오류 발생
             오류 메시지: ${error.message}
-            스택 트레이스: ${error.stack}`
+            스택 트레이스: ${error.stack}`,
           );
         }
       }
     }
   }
 
+  async executeQueryStrict<T>(query: string, params: any[] = []): Promise<T[]> {
+    let connection: PoolConnection;
+    try {
+      connection = await this.pool.getConnection();
+      const [rows] = await connection.query(query, params);
+      return rows as T[];
+    } catch (error) {
+      logger.error(
+        `${this.nameTag} 쿼리 ${query} 실행 중 오류 발생
+          오류 메시지: ${error.message}
+          스택 트레이스: ${error.stack}`,
+      );
+      throw error;
+    } finally {
+      if (connection) {
+        try {
+          if (connection) connection.release();
+        } catch (error) {
+          logger.error(
+            `${this.nameTag} connection release 중 오류 발생
+            오류 메시지: ${error.message}
+            스택 트레이스: ${error.stack}`,
+          );
+          throw error;
+        }
+      }
+    }
+  }
+
   public async end() {
     await this.pool.end();
   }

feed-crawler/src/repository/feed.repository.ts

@@ -23,7 +23,7 @@ export class FeedRepository {
 
     const insertPromises = resultData.map(async (feed, index) => {
       try {
-        const result = await this.dbConnection.executeQuery(query, [
+        const result = await this.dbConnection.executeQueryStrict(query, [
           feed.blogId,
           feed.pubDate,
           feed.title,

feed-crawler/src/types/database-connection.ts

@@ -1,4 +1,5 @@
 export interface DatabaseConnection {
-  executeQuery<T>(query: string, params: any[]): Promise<T[]>;
+  executeQuery<T>(query: string, params: any[]): Promise<T[] | null>;
+  executeQueryStrict<T>(query: string, params: any[]): Promise<T[]>;
   end(): Promise<void>;
 }