Improved functionality to allow db attributes in dynamic variable definitions.

Author: mrjung72

src/index.js

@@ -247,15 +247,12 @@ async function main() {
     return await adapter.createConnectionPool(configObj[dbKey], dbKey);
   }
 
-  // 기본 DB 어댑터 가져오기
-  const defaultAdapter = dbAdapters[defaultDbKey];
-  
   // 기본 DB 연결
   const defaultPool = await getDbPool(defaultDbKey);
 
   // 동적 변수 처리 (DB 연결 후, 시트 처리 전)
   if (dynamicVars && dynamicVars.length > 0) {
-    await variableProcessor.processDynamicVariables(dynamicVars, defaultAdapter, defaultDbKey, mergedVars, configObj);
+    await variableProcessor.processDynamicVariables(dynamicVars, dbAdapters, defaultDbKey, mergedVars, configObj);
   }
 
   // 엑셀 파일 경로 결정 (CLI > excel > 쿼리파일 > 기본값)

src/query-parser.js

@@ -135,8 +135,8 @@ class QueryParser {
     const allowedAttributes = {
       excel: ['db', 'output', 'maxRows', 'style', 'aggregateInfoTemplate'],
       var: ['name'],
-      dynamicVar: ['name', 'description', 'type', 'database'],
-      queryDef: ['id', 'description'],
+      dynamicVar: ['name', 'description', 'type', 'database', 'db'],
+      queryDef: ['id', 'description', 'db'],
       // exceptColumns 속성 사용 (대소문자 구분 없이 허용), 하위호환: except_columns도 파싱에서 지원
       sheet: ['name', 'use', 'queryRef', 'aggregateColumn', 'aggregateInfoTemplate', 'maxRows', 'db', 'style', 'exceptColumns'],
       param: ['name']
@@ -339,7 +339,7 @@ class QueryParser {
           const query = dv._.toString().trim();
           const type = dv.$.type || 'column_identified';
           const description = dv.$.description || '';
-          const database = dv.$.database || '';
+          const database = dv.$.database || dv.$.db || '';
 
           dynamicVars.push({
             name: dv.$.name,

src/variable-processor.js

@@ -124,12 +124,12 @@ class VariableProcessor {
   /**
    * 동적 변수 처리
    * @param {Array} dynamicVars - 동적 변수 정의 배열
-   * @param {Object} dbAdapter - 데이터베이스 어댑터 인스턴스
-   * @param {string} dbKey - 데이터베이스 키
+   * @param {Object} dbAdapters - 데이터베이스 어댑터 맵 (dbKey -> adapter)
+   * @param {string} defaultDbKey - 기본 데이터베이스 키
    * @param {Object} globalVars - 전역 변수
    * @param {Object} configObj - 데이터베이스 설정 객체
    */
-  async processDynamicVariables(dynamicVars, dbAdapter, dbKey, globalVars, configObj) {
+  async processDynamicVariables(dynamicVars, dbAdapters, defaultDbKey, globalVars, configObj) {
     // 동적 변수 초기화
     this.dynamicVariables = {};
 
@@ -140,17 +140,23 @@ class VariableProcessor {
         if (dynamicVar.name && dynamicVar.query) {
           try {
             console.log(`${this.msg.dynamicVarProcessing} ${dynamicVar.name} (${dynamicVar.description || this.msg.noDesc})`);
-            
+              
             // 쿼리에서 변수 치환 (기존 변수들로)
             const processedQuery = this.substituteVars(dynamicVar.query, globalVars);
 
             // 동적 변수에 지정된 데이터베이스 사용 (있으면), 없으면 기본값 사용
-            const targetDbKey = dynamicVar.database || dbKey;
+            const targetDbKey = dynamicVar.database || defaultDbKey;
             console.log(`${this.msg.database} ${targetDbKey} (${dynamicVar.database ? this.msg.dynamicVarSpecified : this.msg.default})`);
 
+            // 대상 DB에 맞는 어댑터 선택
+            const adapter = dbAdapters[targetDbKey] || dbAdapters[defaultDbKey];
+            if (!adapter) {
+              throw new Error(`DB adapter not found for key: ${targetDbKey}`);
+            }
+            
             // DB에서 데이터 조회
-            const pool = await dbAdapter.createConnectionPool(configObj[targetDbKey], targetDbKey);
-            const result = await dbAdapter.executeQuery(pool, processedQuery);
+            const pool = await adapter.createConnectionPool(configObj[targetDbKey], targetDbKey);
+            const result = await adapter.executeQuery(pool, processedQuery);
 
             if (result.recordset && result.recordset.length > 0) {
               const data = result.recordset;