Glue Query File(SQL)

GlueJdbcDao 에서는 2가지 유형의 SQL을 사용할 수 있습니다.

1. 기본SQL : SQL작성시 input이 물음표(?)로 표현됩니다.

   SELECT * FROM EMP WHERE DEPTNO=? AND SAL>?
   

2. Named SQL : SQL작성시 input에 콜론(:) 다음에 이름이 주어집니다.

   SELECT * FROM EMP WHERE DEPTNO=:deptno AND SAL>:sal
   

2가지 유형의 SQL은 Glue Query File에서 isNamed 속성을 통해 구분됩니다.

<?xml version="1.0" encoding="UTF-8"?>
<queryMap desc="sql" xmlns="http://www.poscoict.com/glueframework/query">
    <query id="sql.type.1" desc="기본SQL" isNamed="false">
        <![CDATA[ 
SELECT * FROM EMP WHERE DEPTNO=? AND SAL>?
        ]]> 
    </query>
    <query id="sql.type.2" desc="NamedSQL" isNamed="true">
        <![CDATA[ 
SELECT * FROM EMP WHERE DEPTNO=:deptno AND SAL>:sal
        ]]> 
    </query>
</queryMap>

Sequence

GlueSequence 를 통해 DB의 sequence값을 다음과 같이 얻어 올 수 있습니다.

GlueGenericJdbcDao dao = ...;
GlueSequence sequence = dao.getSequence()
long seq = sequence.getNextLongValue("SQ_BIZ_TABLE1");

GlueJdbcDao(GlueGenericJdbcDao) 는 DAO가 참고하는 DataSource를 이용해서 GlueSequence 를 자동으로 생성합니다.
oracle, db2 등의 일부 DB일 경우 자동으로 생성되며, 다음과 같은 INFO 레벨의 로그를 확인할 수 있습니다.

Sequence Increamenter is constructed successfully... : {}

그외 DB의 경우 GlueJdbcDao에서 자동으로 GlueSequence를 생성하지 않으며, 다음과 같은 INFO 레벨의 로그를 확인할 수 있습니다.\

Not support a sequence incrementer : {} 

GlueJdbcDao 에서 지원하지 않을 경우, sequence property를 통해 사용하고자 하는 DB에 맞는 GlueSequece를 생성해서 사용합니다.

• MariaDB ( MySQL ) 예시
• Phoenix 예시

Query Manager

QueryManager의 구현체인 GlueQueryManagerImpl은 다음과 같은 속성을 갖습니다 (GlueAPI).

• cacheManager : 참조할 Cache Manager Bean(Cache Manager 참고).
• queryLoader : 참조할 Cache Loader Bean

다음은 applicationContext.xml 예제입니다.
QueryManager를 사용하기 위해서는 관련 빈(bean)을 다음과 같이 추가할 수 있습니다.

<bean id="queryManager" class="com.poscoict.glueframework.dao.manager.GlueQueryManagerImpl">
    <property name="cacheManager" ref="cacheManager"/>
    <property name="queryLoader" ref="queryLoader"/>
</bean>
<bean id="queryLoader" class="com.poscoict.glueframework.dao.manager.GlueQueryLoader"/>
<bean id="cacheManager" class= . . . />

Activity에서의 dao 사용

GlueJdbcDao는 2종류의 Query를 사용할 수 있습니다.

1. 기본SQL : SQL작성시 input이 물음표(?)로 표현되며, SQL실행시 input parameter는 순서대로 입력되어야 한다. 즉 다음같은 SQL 입니다.

   SELECT * FROM EMP WHERE DEPTNO=? AND SAL>?
   

   • 기본SQL이 위와 같을 경우 Activity 예제 코드입니다.

     public class BizActivity extends GlueActivity<GlueContext>
     {
         public String runActivity( GlueContext ctx )
         {
             Object deptno = . . .;
             Object sal = . . .;
             String queryId = . . .;
             List paramList = new ArrayList();
             paramList.add( deptno );
             paramList.add( sal );
             
             GlueParameter<List> param = new GlueParameter<List>();
             param.setParameter( paramList );
             // GlueParameter<List> param = new GlueParameter<List>( paramList );
             GlueGenericDao dao = this.getDao( "biz-dao" ); // this.getDao( this.getProperty( "dao" ) )
             List<Map> result = dao.find( queryId, param ); 
             . . .
     

     Query File을 사용하지 않은 경우는, 즉 Java Code에 다음과 같이 SQL을 포함할 수 있습니다.

     List<Map> result = dao.findByQueryStatement("SELECT * FROM EMP WHERE DEPTNO=? AND SAL>?", param)
     

2. Named SQL : SQL 작성시 input에 콜론(:) 다음에 이름을 주어 SQL 실행시 동일 이름의 값으로 input parameter을 입력한다. 즉 다음같은 SQL 입니다.

   SELECT * FROM EMP WHERE DEPTNO=:deptno AND SAL>:sal
   

   • Named SQL이 위와 같을 경우 Activity 예제 코드입니다.

     public class BizActivity extends GlueActivity<GlueContext>
     {
         public String runActivity( GlueContext ctx )
         {
             Object deptno = . . .;
             Object sal = . . .;
             String queryId = . . .;
             Map paramMap = new HashMap();
             paramMap.put( "deptno", deptno );
             paramMap.put( "sal", sal );
     
             GlueParameter<Map> param = new GlueParameter<Map>();
             param.setParameter( paramMap );
             // GlueParameter<Map> param = new GlueParameter<Map>( paramMap );
     
             GlueGenericDao dao = this.getDao( "biz-dao" ); // this.getDao( this.getProperty( "dao" ) )
             List<Map> result = dao.find( queryId, param );
             . . .
     

     Query File을 사용하지 않은 경우는, 즉 Java Code에 다음과 같이 SQL을 포함할 수 있습니다.

     result = dao.findByQueryStatement("SELECT * FROM EMP WHERE DEPTNO=:deptno AND SAL>:sal", param)
     

GlueColumnManager

ColumnManager는 dao의 find() 실행결과를 List<Map> 구조에서 GlueRowSet<GlueRow>의 구조로 변환하는 기능을 갖습니다. 이러한 변환과정을 통해 GlueRowSet은 GlueColumnDef 정보를 포함하게 됩니다.
이러한 기능은 기본SQL(? 사용)일 경우 지원됩니다.

GlueColumnManager는 다음과 같은 속성을 갖습니다 (GlueAPI).

• cacheManager : 참조할 Cache Manager Bean(Cache Manager 참고).

  <bean id="dao" class="com.poscoict.glueframework.dao.jdbc.GlueJdbcDao">
      . . .
      <property name="columnManager" ref="columnManager"/>
  </bean>
  <bean id="columnManager" class="com.poscoict.glueframework.dao.manager.GlueColumnManager">
      <property name="cacheManager" ref="cacheManager"/>
  </bean>
  <bean id="cacheManager" class= . . . />
  

다음은 GlueColumnManager 사용과 관련된 Class입니다.

• GlueRowSet : select 문의 실행결과를 담는 VO (GlueAPI 참고).
• GlueColumnDef : 각 column의 Name, Type, Length, Precision, Scale 정보를 나타냄 (GlueAPI 참고).
• GlueRow : 한개의 row를 담은 VO (GlueAPI 참고).

  <bean id="biz-dao" class="com.poscoict.glueframework.dao.jdbc.GlueJdbcDao">
      <property name="dataSource" ref="dataSource"/>
      <property name="queryManager" ref="queryManager"/>
      <property name="columnManager" ref="columnManager"/>
  </bean>
  <bean id="columnManager" class="com.poscoict.glueframework.dao.manager.GlueColumnManager">
      <property name="cacheManager" ref="cacheManager"/>
  </bean>
  

  public class SampleActivity extends GlueActivity<GlueContext> {
      @Override
      public String runActivity( GlueContext ctx )
      {
          GlueGenericJdbcDao dao = (GlueGenericJdbcDao)this.getDao("biz-dao"); 
          List paramList = . . .
          GlueRowSet rowSet = (GlueRowSet)dao.findByQueryStatement("select * from EMP where deptno=?", new GlueParameter<List>(paramList) );
          GlueColumnDef[] def = rowSet.getColumnDefs();
          while(rowSet.hasNext())
          { 
              GlueRow row = rowSet.next();
              for(int i=0, iz=def.length; i < iz; i++)
              {
                  System.out.println("ColumnDef - Name : "+def[i].getName());
                  System.out.println("ColumnDef - Type : "+def[i].getType());
                  System.out.println("ColumnDef - Length : "+def[i].getLength());
                  System.out.println("ColumnDef - Precision : "+def[i].getPrecision());
                  System.out.println("ColumnDef - Scale : "+def[i].getScale());
                  System.out.println("Data : "+row.getAttribute(def[i].getName()));
              }
          }
          return GlueBizControlConstants.SUCCESS;
      }
  }
  

Audit Data 처리

관계형 데이타베이스에서 모든 테이블이 not null 제약조건의 audit 컬럼들을 동일하게 포함할 때, insert/update 수행시 해당 컬럼값을 자동으로 binding 해 줄 수 있습니다.
이를 위해 glue.property에 다음 property가 포함되어 있어야 합니다.

• audit.insert.key : insert SQL문에서 참고하는 property 입니다.
• audit.update.key : update SQL문에서 참고하는 property 입니다.

  여러 개의 Audit항목이 존재 할 경우 컴마(,)를 구분자로 사용합니다. Audit 항목이 시간정보일 경우 timestamp 유형은 #current_timestamp# 를 붙여주고, Date 유형은#current_date# 를 붙여줍니다.

glue.properties 가 다음과 같을 경우 SQL 유형별 예제입니다.

audit.insert.key=cid,cip,cdt#current_timestamp#,uid,uip,udt#current_timestamp#
audit.update.key=uid,uip,udt#current_timestamp#

• 기본 SQL : GlueJdbcDao를 사용하는 경우 insert와 update SQL문 작성시 Audit 항목이 맨 앞에 glue.properties에 정의한 순서대로 나오도록 합니다. (순서 중요)

  insert into EMP_AUDIT(
      CREATE_ID, CREATE_IP, CREATE_DT, UPDATE_ID, UPDATE_IP, UPDATE_DT, EMPNO, ENAME, SAL, DEPTNO
  ) values(?,?,?,?,?,?,?,?,?,?)
  

  기본 SQL이 위와 같을 때 GlueParameter의 setAuditAttributes() 를 사용한 Java Code 예제입니다.

  List<Object> paramList = new ArrayList<Object>();
  paramList.put( 1118 ); //EMPNO
  paramList.put( "USER8" ); //ENAME
  paramList.add( 7000 ); //SAL
  paramList.put( 10 ); //DEPTNO
  
  param = new GlueParameter<ArrayList<Object>>( paramList );
  param.setAuditAttributes( ctx.getAuditAttributes(); );
  dao.insert( queryid, param );
  

  기본 SQL이 위와 같을 때 reuse activity의 is-audit property를 사용한 예제입니다.

  <activity name="Insert" class="com.poscoict.glueframework.biz.activity.GlueJdbcInsert">
      <property name="dao" value=". . ." />
      <property name="sql-key" value=". . ." />
      <property name="param-count" value="4" />
      <property name="param0" value="EMPNO" />
      <property name="param1" value="ENAME" />
      <property name="param2" value="SAL" />
      <property name="param3" value="DEPTNO" />
      <property name="is-audit" value="true" />
      <transition name="success" value=". . ." />
  </activity>
  

• Named SQL : GlueJdbcDao를 사용하는 경우 insert와 update SQL문 작성시 Audit 항목의 binding name( :name) 이 glue.properties에 정의한 name과 일치하도록 합니다. (위치무관, name 일치 중요)

  insert into EMP_AUDIT
  (EMPNO, ENAME, SAL, DEPTNO, CREATE_ID, CREATE_IP, CREATE_DT, UPDATE_ID, UPDATE_IP, UPDATE_DT
  )values(:empno, :ename, :sal, :deptno, :cid, :cip, :cdt, :uid, :uip, :udt )
  

  Named SQL이 위와 같을 때 GlueParameter의 setAuditAttributes() 를 사용한 Java Code 예제입니다.

  Map<String, Object> paramMap = new HashMap<String, Object>();
  paramMap.put( "sal", 7000 );
  paramMap.put( "ename", "USER8" );
  paramMap.put( "empno", 1118 );
  paramMap.put( "deptno", 10 );
  
  param = new GlueParameter<HashMap<String, Object>>( paramMap );
  param.setAuditAttributes( ctx.getAuditAttributes(); );
  dao.insert( queryid, param );
  

  기본 SQL이 위와 같을 때 reuse activity의 is-audit property를 사용한 예제입니다.

  <activity name="Insert" class="com.poscoict.glueframework.biz.activity.GlueJdbcInsert">
      <property name="dao" value=". . ." />
      <property name="sql-key" value=". . ." />
      <property name="param-bindings" value="empno=EMPNO|ename=ENAME|sal=SAL|deptno=DEPTNO" />
      <property name="is-audit" value="true" />
      <transition name="success" value=". . ." />
  </activity>
  

if ( GlueStaticContext.isAudit() )
{
    ctx.setAuditAttributes( new GlueAuditAttributes( ctx ) );  
}

if ( GlueStaticContext.isAudit() )
{
    Map map = new HashMap()
    map.put( "cid", id );
    map.put( "cip", ip );
    map.put( "uid", id );
    map.put( "uip", ip );
    ctx.setAuditAttributes( new GlueAuditAttributes( map ) );  
}

Reuse Activity

GlueJdbcDao를 사용한 reuse Activity는 다음과 같은 것이 제공되고 있습니다.

• com.poscoict.glueframework.biz.activity.GlueJdbcSearch
• com.poscoict.glueframework.biz.activity.GlueJdbcDelete
• com.poscoict.glueframework.biz.activity.GlueJdbcInsert
• com.poscoict.glueframework.biz.activity.GlueJdbcModify
• com.poscoict.glueframework.biz.activity.GlueJdbcNativeRun

GlueCursorBasedRowSet

GlueCursorBasedRowSet 은 내부적으로 java.sql.Connection, java.sql.Statement, java.sql.ResultSet 을 갖는 특별한 클래스입니다.

GlueLazyJdbcDao 를 통해 조회용 SQL이 실행되는 경우 그 결과값은 List<Map> 형태의 Collection객체와는 다릅니다.
GlueCursorBasedRowSet 은 java.util.List 인터페이스를 확장하였으나, 사용가능한 method는 다음과 같습니다.

• GlueColumnDef[] getColumnDefs()

  GlueLazyJdbcDao 에 GlueColumnManager 가 설정된 경우, 조회용 SQL의 실행결과에 GlueColumnDef 를 포함합니다.

• boolean hasNext()
• E next()

  GlueQueryDefinition의 resultType 에 해당하는 객체는 반환합니다. default는 java.util.Map 으로 반환합니다.

  • resultType이 없는 경우 org.springframework.jdbc.core.ColumnMapRowMapper 을 통해 Map에 Data에 담깁니다.

    다음은 GlueQueryEditor와 JavaCode 예입니다.

    <query id="emp.select.map" desc="Map">
        <![CDATA[ 
    SELECT * FROM EMP
        ]]> 
    </query>
    

    GlueGenericJdbcDao dao = ... 
    GlueCursorBasedRowSet rowSet = (GlueCursorBasedRowSet)dao.find("emp.select.map");
    while(rowSet.hasNext()){
        Map row = rowSet.next();
        empno = row.get("empno");
    }
    

  • resultType이 지정된 경우, org.springframework.jdbc.core.BeanPropertyRowMapper 을 통해 VO에 Data가 담깁니다.

    다음은 GlueQueryEditor와 JavaCode 예입니다.

    <query id="emp.select.vo" desc="VO" resultType="sample.vo.EmpVO">
        <![CDATA[ 
    SELECT * FROM EMP
        ]]> 
    </query>
    

    GlueGenericJdbcDao dao = ... 
    GlueCursorBasedRowSet rowSet = (GlueCursorBasedRowSet)dao.find("emp.select.map");
    while(rowSet.hasNext()){
        EmpVO row = rowSet.next();
        empno = row.getEmpno();
    }
    

• void reset()
• void clear()

  clear()가 실행된 경우, hasNext(), next(), reset() 메소드를 사용할 수 없습니다.
  clear()가 실행되는 경우, ResultSet, Statement, Connection을 반납합니다.

GlueLazyTransactionManagerHolder

GlueService에서 GlueLazyJdbcDao가 사용된 경우, Service Layer에서 Transcation 종료처리를 할 수 없습니다.
Service Layer에서는 GlueService에 설정된 Transaction Manager를 따로 GlueLazyTransactionManagerHolder 에 담아두어 Control Layer 에서 처리할 수 있도록 하고 있습니다.

다음은 Control Layer에 해당하는 클래스입니다.

• com.poscoict.glueframework.web.GlueLazyTransactionReleaseFilter

  다은 유형의 Control layer가 필요한 경우 아래 코드를 참고해서 작성하도록 합니다.

  boolan isError = . . . 
  List<GlueLazyTransactionManager> txList = GlueLazyTransactionManagerHolder.get();
  if ( txList != null )
  {
      for ( int i = txList.size() - 1; i > -1; i-- )
      {
          GlueLazyTransactionManager transactionManager = txList.get( i );
          try
          {
              if ( isError )
              {
                  transactionManager.lazyRollback();
              } else
              {
                  transactionManager.lazyCommit();
              }
          } catch ( GlueException e )
          {
              . . .
          }
      }
  }
  GlueLazyTransactionManagerHolder.clear();