Improved functionality to allow different parameters to be applied to each sheet in the same SQL statement.

happysoft2018 · happysoft2018 · commit 1396fbe81b39 · 2025-08-29T21:23:08.000+09:00
diff --git a/queries/queries-with-dynamic-variables.json b/queries/queries-with-dynamic-variables.json
@@ -42,14 +42,26 @@
         "query": "SELECT OrderID, OrderNumber, OrderDate FROM SampleDB.dbo.Orders WHERE OrderDate >= '${startDate}' AND OrderDate <= '${endDate}' AND OrderDate >= DATEADD(day, -30, '${CURRENT_DATE}') ORDER BY OrderDate DESC"
       }
   ],
+  "queryDefs": {
+    "customer_base": {
+      "name": "customer_base",
+      "description": "Base customer query",
+      "query": "SELECT c.CustomerID as 고객ID, c.CustomerName as 고객명, c.City as 도시, c.Region as 지역, c.CustomerType as 고객유형 FROM SampleDB.dbo.Customers c WHERE c.CustomerID IN (${customerData.CustomerID}) AND c.Region IN (${regionList}) ORDER BY c.CustomerID"
+    }
+  },
   "sheets": [
     {
       "name": "${envType}_동적변수_테스트",
       "use": true,
+      "queryRef": "customer_base",
       "aggregateColumn": "지역",
       "maxRows": 100,
       "db": "sampleDB",
-      "query": "SELECT c.CustomerID as 고객ID, c.CustomerName as 고객명, c.City as 도시, c.Region as 지역, c.CustomerType as 고객유형 FROM SampleDB.dbo.Customers c WHERE c.CustomerID IN (${customerData.CustomerID}) AND c.Region IN (${regionList}) ORDER BY c.CustomerID"
+      "params": {
+        "regionList": ["서울", "부산", "대구"],
+        "startDate": "2024-03-01",
+        "endDate": "2024-12-31"
+      }
     },
     {
       "name": "주문상세_동적변수_테스트2",
diff --git a/queries/queries-with-dynamic-variables.xml b/queries/queries-with-dynamic-variables.xml
@@ -80,7 +80,17 @@
 
 
   <!-- 시트 정의 -->
-  <sheet name="${envType}_동적변수_테스트" use="true" queryRef="customer_base" aggregateColumn="지역" maxRows="100" db="sampleDB"/>
+  <sheet name="${envType}_동적변수_서울_테스트" use="true" queryRef="customer_base" aggregateColumn="지역" maxRows="100" db="sampleDB">
+    <params>
+      <param name="regionList">["서울"]</param>
+    </params>
+  </sheet>
+  
+  <sheet name="${envType}_동적변수_부산_테스트" use="true" queryRef="customer_base" aggregateColumn="지역" maxRows="100" db="sampleDB">
+    <params>
+      <param name="regionList">["부산"]</param>
+    </params>
+  </sheet>
   
   <sheet name="주문상세_동적변수_테스트2" use="false" aggregateColumn="주문상태">
     <![CDATA[
diff --git a/src/index.js b/src/index.js
@@ -177,8 +177,8 @@ async function main() {
       continue;
     }
     
-    let sql = variableProcessor.substituteVars(sheetDef.query, mergedVars);
-    const sheetName = variableProcessor.substituteVars(sheetDef.name, mergedVars);
+    let sql = variableProcessor.substituteVars(sheetDef.query, mergedVars, sheetDef.params || {});
+    const sheetName = variableProcessor.substituteVars(sheetDef.name, mergedVars, sheetDef.params || {});
     
     // maxRows 제한 적용 (개별 시트 설정 > 전역 설정 우선)
     const effectiveMaxRows = sheetDef.maxRows || globalMaxRows;
diff --git a/src/query-parser.js b/src/query-parser.js
@@ -117,13 +117,48 @@ class QueryParser {
     
     const sheets = parsed.queries.sheet.map(s => {
       let query = '';
+      let sheetParams = {};
+      
+      // 시트별 파라미터 파싱
+      if (s.params && s.params[0] && s.params[0].param) {
+        const paramElements = Array.isArray(s.params[0].param) 
+          ? s.params[0].param 
+          : [s.params[0].param];
+        
+        for (const param of paramElements) {
+          if (param.$ && param.$.name && param._) {
+            let value = param._.toString();
+            // 배열 형태 문자열을 실제 배열로 변환
+            if (value.startsWith('[') && value.endsWith(']')) {
+              try {
+                value = JSON.parse(value);
+              } catch (e) {
+                // JSON 파싱 실패 시 문자열 그대로 사용
+              }
+            }
+            // boolean 값 처리
+            if (value === 'true') value = true;
+            if (value === 'false') value = false;
+            // 숫자 값 처리
+            if (!isNaN(value) && !isNaN(parseFloat(value)) && typeof value === 'string') {
+              value = parseFloat(value);
+            }
+            sheetParams[param.$.name] = value;
+          }
+        }
+      }
       
       // queryRef 속성이 있으면 쿼리 정의에서 참조
       if (s.$.queryRef) {
         const queryRef = s.$.queryRef;
         if (queryDefs[queryRef]) {
           query = queryDefs[queryRef].query;
           console.log(`[쿼리 참조] 시트 "${s.$.name}"이(가) 쿼리 정의 "${queryRef}"을(를) 참조합니다.`);
+          
+          // 시트별 파라미터가 있으면 로그 출력
+          if (Object.keys(sheetParams).length > 0) {
+            console.log(`[파라미터 재설정] 시트 "${s.$.name}"에서 파라미터 재설정:`, sheetParams);
+          }
         } else {
           throw new Error(`쿼리 정의를 찾을 수 없습니다: ${queryRef} (시트: ${s.$.name})`);
         }
@@ -140,6 +175,7 @@ class QueryParser {
         db: s.$.db || null,
         queryRef: s.$.queryRef || null,
         style: s.$.style || null, // 시트별 스타일 추가
+        params: sheetParams, // 시트별 파라미터 추가
         query: query
       };
     });
@@ -167,19 +203,26 @@ class QueryParser {
     // JSON 시트에서 queryRef 처리
     const sheets = (queries.sheets || []).map(sheet => {
       let query = sheet.query || '';
+      let sheetParams = sheet.params || {};
       
       // queryRef가 있으면 쿼리 정의에서 참조
       if (sheet.queryRef) {
         if (queryDefs[sheet.queryRef]) {
           query = queryDefs[sheet.queryRef].query || queryDefs[sheet.queryRef];
           console.log(`[쿼리 참조] 시트 "${sheet.name}"이(가) 쿼리 정의 "${sheet.queryRef}"을(를) 참조합니다.`);
+          
+          // 시트별 파라미터가 있으면 로그 출력
+          if (Object.keys(sheetParams).length > 0) {
+            console.log(`[파라미터 재설정] 시트 "${sheet.name}"에서 파라미터 재설정:`, sheetParams);
+          }
         } else {
           throw new Error(`쿼리 정의를 찾을 수 없습니다: ${sheet.queryRef} (시트: ${sheet.name})`);
         }
       }
       
       return {
         ...sheet,
+        params: sheetParams,
         query: query
       };
     });
diff --git a/src/variable-processor.js b/src/variable-processor.js
@@ -117,16 +117,20 @@ class VariableProcessor {
    * 향상된 변수 치환 함수 (동적 변수 지원)
    * @param {string} str - 치환할 문자열
    * @param {Object} vars - 변수 객체
+   * @param {Object} sheetParams - 시트별 파라미터 (선택사항)
    * @returns {string} 치환된 문자열
    */
-  substituteVars(str, vars) {
+  substituteVars(str, vars, sheetParams = {}) {
     let result = str;
     const debugVariables = process.env.DEBUG_VARIABLES === 'true';
     
     if (debugVariables) {
       console.log(`변수 치환 시작: ${str.substring(0, 200)}${str.length > 200 ? '...' : ''}`);
     }
     
+    // 시트별 파라미터를 전역 변수에 병합 (우선순위 높음)
+    const mergedVars = { ...vars, ...sheetParams };
+    
     // 동적 변수 치환 (우선순위 높음)
     Object.entries(this.dynamicVariables).forEach(([key, value]) => {
       const pattern = new RegExp(`\\$\\{${key}\\}`, 'g');
@@ -203,7 +207,7 @@ class VariableProcessor {
     
     // 일반 변수 치환 (기존 방식)
     result = result.replace(/\$\{(\w+)\}/g, (_, v) => {
-      const value = vars[v];
+      const value = mergedVars[v];
       if (value === undefined || value === null) return '';
       
       // 배열 타입인 경우 IN절 처리

Original file line number	Diff line number	Diff line change
`@@ -177,8 +177,8 @@ async function main() {`
`177`	`177`	`continue;`
`178`	`178`	`}`
`179`	`179`
`180`		`- let sql = variableProcessor.substituteVars(sheetDef.query, mergedVars);`
`181`		`- const sheetName = variableProcessor.substituteVars(sheetDef.name, mergedVars);`
	`180`	`+ let sql = variableProcessor.substituteVars(sheetDef.query, mergedVars, sheetDef.params \|\| {});`
	`181`	`+ const sheetName = variableProcessor.substituteVars(sheetDef.name, mergedVars, sheetDef.params \|\| {});`
`182`	`182`
`183`	`183`	`// maxRows 제한 적용 (개별 시트 설정 > 전역 설정 우선)`
`184`	`184`	`const effectiveMaxRows = sheetDef.maxRows \|\| globalMaxRows;`