Define test query statements for each DB adapter

Author: mrjung72

src/database/MSSQLAdapter.js

@@ -181,6 +181,11 @@ class MSSQLAdapter {
   getType() {
     return this.dbType;
   }
+
+  /** 연결 테스트용 쿼리 */
+  getTestQuery() {
+    return 'SELECT 1 as test';
+  }
 }
 
 module.exports = MSSQLAdapter;

src/database/MySQLAdapter.js

@@ -212,6 +212,11 @@ class MySQLAdapter {
   getType() {
     return this.dbType;
   }
+
+  /** 연결 테스트용 쿼리 */
+  getTestQuery() {
+    return 'SELECT 1 as test';
+  }
 }
 
 module.exports = MySQLAdapter;

src/database/OracleAdapter.js

@@ -181,6 +181,11 @@ class OracleAdapter {
 
   /** DB 타입 */
   getType() { return this.dbType; }
+
+  /** 연결 테스트용 쿼리 */
+  getTestQuery() {
+    return 'SELECT 1 FROM dual';
+  }
 }
 
 module.exports = OracleAdapter;

src/database/PostgreSQLAdapter.js

@@ -218,6 +218,11 @@ class PostgreSQLAdapter {
   getType() {
     return this.dbType;
   }
+
+  /** 연결 테스트용 쿼리 */
+  getTestQuery() {
+    return 'SELECT 1';
+  }
 }
 
 module.exports = PostgreSQLAdapter;

src/database/SQLiteAdapter.js

@@ -227,6 +227,11 @@ class SQLiteAdapter {
   getType() {
     return this.dbType;
   }
+
+  /** 연결 테스트용 쿼리 */
+  getTestQuery() {
+    return 'SELECT 1';
+  }
 }
 
 module.exports = SQLiteAdapter;

src/excel-cli.js

@@ -350,7 +350,6 @@ function loadDatabaseConfig(configPath) {
     }
 }
 
-// 데이터베이스 연결 테스트
 async function testDatabaseConnection(dbKey, dbConfig) {
     let connection = null;
     let adapter = null;
@@ -364,8 +363,9 @@ async function testDatabaseConnection(dbKey, dbConfig) {
         adapter = DatabaseFactory.createAdapter(dbType, dbConfig, LANGUAGE);
         connection = await adapter.createConnectionPool(dbConfig, dbKey);
 
-        // 연결 테스트 쿼리 실행
-        await adapter.executeQuery(connection, 'SELECT 1 as test');
+        // 연결 테스트 쿼리 실행 (각 Adapter에 정의된 테스트 쿼리 사용)
+        const testSql = (typeof adapter.getTestQuery === 'function') ? adapter.getTestQuery() : 'SELECT 1 as test';
+        await adapter.executeQuery(connection, testSql);
 
         console.log(msg.dbConnectionSuccess.replace('{dbKey}', dbKey));
         return { success: true, message: msg.dbConnectionSuccess.replace('{dbKey}', '') };