pupustory@

크리에이티브 커먼즈 라이선스

이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이선스에 따라 이용하실 수 있습니다.

Pupustory Dev/iBATIS framework

크리에이티브 커먼즈 라이선스

이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이선스에 따라 이용하실 수 있습니다.

코드 보기

Pupustory Dev/iBATIS framework

크리에이티브 커먼즈 라이선스

이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이선스에 따라 이용하실 수 있습니다.

Pupustory Dev/iBATIS framework

크리에이티브 커먼즈 라이선스

이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이선스에 따라 이용하실 수 있습니다.

Pupustory Dev/iBATIS framework

크리에이티브 커먼즈 라이선스

이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이선스에 따라 이용하실 수 있습니다.

출력 결과

Pupustory Dev/iBATIS framework

크리에이티브 커먼즈 라이선스

이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이선스에 따라 이용하실 수 있습니다.

Pupustory Dev/iBATIS framework

크리에이티브 커먼즈 라이선스

이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이선스에 따라 이용하실 수 있습니다.

DBManager.javapackage pupustory.ibatis.manager; import com.ibatis.sqlmap.client.SqlMapClient; import com.ibatis.sqlmap.client.SqlMapClientBuilder; import com.ibatis.common.resources.Resources; import java.sql.SQLException; import java.io.Reader; public class DBManager { private SqlMapClient mapper; private Reader reader; private static DBManager instance = null; private DBManager() { init(); } private void init() { try { String resource = "SqlMapConfig.xml"; reader = Resources.getResourceAsReader(resource); mapper = SqlMapClientBuilder.buildSqlMapClient(reader); reader.close(); } catch (Exception ee) { ee.printStackTrace(); } finally { try { reader.close(); } catch (Exception _e) {} } } public static DBManager getInstance() { if (instance == null) { synchronized (DBManager.class) { if (instance == null) instance = new DBManager(); } } return instance; } public SqlMapClient getMapper() { return this.mapper; } public void startBatch() throws SQLException { mapper.startBatch(); } public void executeBatch() throws SQLException { mapper.executeBatch(); } // 트랜젝션 시작 public void startTransaction() throws SQLException { mapper.startTransaction(); } // 트랜젝션 커밋 public void commitTransaction() throws SQLException { mapper.commitTransaction(); } // 트랜젝션 종료(commit를 호출하지 않으면 적용하지 않음) public void endTransaction() throws SQLException { mapper.endTransaction(); } }

TransactionBiz.javapackage pupustory.ibatis.batch; import java.sql.SQLException; import pupustory.ibatis.beans.UserBean; import pupustory.ibatis.manager.DBManager; public class TransactionBiz { private DBManager manager = DBManager.getInstance(); public void insertUserInfo(UserBean[] bean) throws SQLException { try { // 트랜잭션 시작 manager.startTransaction(); for (int i=0; i<bean.length;i++) { manager.getMapper().insert("Tb_User_Insert",bean[i]); } // 정상 완료 후 커밋 manager.commitTransaction(); } catch (Exception e) { e.printStackTrace(); // 문제 발생시 트랜잭션 종료(작업 적용안함) } finally {manager.endTransaction();} } }

StartApp.javapackage pupustory.ibatis.batch; import pupustory.ibatis.beans.*; public class StartApp { public static void main(String args[]) { // 총 1만건 가상 정보 삽입 final int MAX_USER_COUNT = 10000; TransactionBiz biz = new TransactionBiz(); UserBean userBean[] = new UserBean[MAX_USER_COUNT]; // 소요시간 점검 변수 long startTime = 0; // 가상 데이터 bean 만들기 for (int i=0; i<MAX_USER_COUNT;i++) { userBean[i] = new UserBean(); userBean[i].setUserid("pupu"+i); userBean[i].setUsername("Min"+i); userBean[i].setPassword(i+"pw"); userBean[i].setEmail("pupu"+i+"@"+i+".com"); userBean[i].setUpdate_id("pupu"+i); userBean[i].setInsert_id("pupu"+i); StringBuffer sql = new StringBuffer(); sql.delete(0, 0); sql.setLength(0); } try { // 소요시간 점검을 위한 시작시간 저장 startTime = System.currentTimeMillis(); // 작업 시작 biz.insertUserInfo(userBean); } catch (Exception e) { e.printStackTrace(); } finally {} // 총 소요시간 출력 System.out.println("총 소요시간 : " + (System.currentTimeMillis()-startTime)+"ms"); } }

트렌잭션 시작과 종료(커밋하지 않으므로 롤백. 적용안함.) 적용(commit)를 위해 외부에 호출하는 메소드를 추가했다. 평소 DAO에서 많이 사용해온 방식대로 트랜잭션을 시작하고 처리가 정상적으로 끝나면 트랜잭션 커밋을 수행 한다. 단, 예외적 상황이 발생할 경우 트랜잭션을 커밋하지 않고 종료 한다.

이번엔 좀 더 일괄처리에 유용한 방법을 말하고자 한다. 바로 일괄처리(배치) 부분인데 .. 흔히 알고있는 배치라 함은 메인과 별도로 백단에서 작업을 처리하고, 처리완료 후 결과를 알려주는 방식이다. 보통 처리량이 많을 경우. 혹은 사용자가 오래걸리는 작업을 수행하고 계속 완료되길 기다릴 수 없는 경우에 이러한 방법을 많이 사용 한다.

이와 조금 다르게 iBATIS에선 별도로 백단에서 수행되는 것은 아니다. 하지만 데이터 량이 많은 정보를 하나의 트랜잭션을 물고 일일이 누적시키는게 아니라 실제 쿼리 수행은 하지 않고 작업을 준비하다 executeBatch();를 수행하면 이때 작업을 일괄적으로 수행 한다.

따라서 배치를 처리하는 중에는 실제 sql을 수행하지 않으므로 작업 내용의 SQLException등이 발생하지 않는다.(실제 db에 수행하지 않는다.) 처리 후 executeBatch()를 만나 배치를 수행할때 실제 쿼리가 수행되는 것이다. 코드는 다음과 같다.

TransactionBiz.javapackage pupustory.ibatis.batch; import java.sql.SQLException; import pupustory.ibatis.beans.UserBean; import pupustory.ibatis.manager.DBManager; public class TransactionBiz { private DBManager manager = DBManager.getInstance(); public void insertUserInfo(UserBean[] bean) throws SQLException { try { // 트랜잭션 시작 manager.startTransaction(); // 배치작업 준비 시작 manager.startBatch(); for (int i=0; i<bean.length;i++) { manager.getMapper().insert("Tb_User_Insert",bean[i]); } // 배치작업 실행. manager.executeBatch(); // 정상 완료 후 커밋 manager.commitTransaction(); } catch (Exception e) { e.printStackTrace(); } finally { // 문제 발생시 트랜잭션 종료(작업 적용안함) manager.endTransaction();} } }

그외의 코드는 위와 같아 별도로 작성하지 않았다. 단순히 트랜잭선 내부에서 블럭을 이루듯 배치를 시작하고, 배치를 실행하는 두개의 문장만 추가 되었다. 배치를 통해 성능향상이 어느정도 되었는지 확인하기위해 결과값을 보면 다음과 같다.

Pupustory Dev/iBATIS framework

크리에이티브 커먼즈 라이선스

이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이선스에 따라 이용하실 수 있습니다.

이전 포스트에서 우리는 iBATIS를 이용하기 위해 설정파일(SqlMapConfig.xml)과 sqlmap파일(UserManager.xml) 을 간단히 작성해 봤다. 이제 이부분에 대해 좀 더 세밀한 부분을 얘기하고자 한다.

SqlMapConfig.xml ?
이것은 iBATIS를 이용하는데 가장 중요한 부분이다. 간단하게 이용하려고 빠진부분이 많이 있다. 그중 <setting /> 부분이 있는데 이것은 나중에 다루도록 할 것이고, 예제에서 진행한 부분에 대해서만 얘기하고자 한다.

SqlMapConfig.xml <properties resource="db.properties"/> <transactionManager type="JDBC" commitRequired="false"> <dataSource type="SIMPLE"> <property name="JDBC.Driver" value="${db_driver}"/> <property name="JDBC.ConnectionURL" value="${db_url}"/> <property name="JDBC.Username" value="${db_user}"/> <property name="JDBC.Password" value="${db_password}"/> </dataSource> <sqlMap resource="UserManager.xml"/> </transactionManager>

db.properties #db imformation db_driver=oracle.jdbc.driver.OracleDriver db_url=jdbc:oracle:thin:@127.0.0.1:1521:XE db_user=pupustory db_password=stares<SPAN id=tx_marker_caret></SPAN>

SqlMapConfig.xml에 작성된 properties resource는 db정보를 관리하는 프로퍼티 설정 파일을 읽는 부분이다. 예상했다시피 ${key} 부분을 통해 프로퍼티 파일의 값을 가져온다. 물론 직접 작성할 수도 있다. 직접 작성한다면하단의 소스가 될 것이다.

<sqlMap resource="UserManager.xml"/> 부분은 우리가 작성한 sql map의 파일을 서술한다. 마찬가지로 직접 작성이 가능하지만 차후 프로그램이 커졌을때 유지보수를 위해 별도로 관리하는 것이 편리 하다.

sqlMap ? 

이제 sqlmap부분을 살펴보자. 부분 부분의 세밀한 설명을 위해 파일의 주요 내용은 잘라서 설명하기로 한다.

SqlMapConfig.xml<transactionManager type="JDBC" commitRequired="false"> <dataSource type="SIMPLE"> <property name="JDBC.Driver" <br/> value="oracle.jdbc.driver.OracleDriver"/> <property name="JDBC.ConnectionURL" value="jdbc:oracle:thin:@127.0.0.1:1521:XE"/> <property name="JDBC.Username" value="pupustory"/> <property name="JDBC.Password" value="stares"/> </dataSource> <sqlMap resource="UserManager.xml"/> </transactionManager>
UserManager.xml<sqlMap namespace="UserManager">

c에서 많이 보던 namespace이다.  sqlmap는 내부에서 하나의 큰 덩어리로 관리 되므로 각각의 영역별로 namespace를 이용하는것이 도움이 된다. 

UserManager.xml <resultMap class="UserBean" id="UserBean_result"> <result property="userid" column="USERID" /> <result property="username" column="USERNAME" /> <result property="password" column="PASSWORD" /> <result property="email" column="EMAIL" /> <result property="update_dt" column="UPDATE_DT" /> <result property="update_id" column="UPDATE_ID" /> <result property="insert_dt" column="INSERT_DT" /> <result property="insert_id" column="INSERT_ID" /> </resultMap>

UserManager.xml <select id="Tb_User_Count" resultClass="int"> SELECT COUNT(*) FROM TB_PUPUSTORY_USER </select>

UserManager.xml <update id="Tb_User_Update" parameterClass="UserBean"> UPDATE TB_PUPUSTORY_USER SET PASSWORD = #password#, EMAIL = #email#, UPDATE_DT = SYSDATE, UPDATE_ID = #userid# WHERE USERID = #userid# </update>

UserManager.xml <insert id="Tb_User_Insert_Map" parameterClass="java.util.HashMap" > INSERT INTO TB_PUPUSTORY_USER (USERID, USERNAME,PASSWORD,EMAIL,UPDATE_DT, UPDATE_ID,INSERT_DT,INSERT_ID) VALUES (#userid#,#username#,#password#, #email#,SYSDATE,#userid#,SYSDATE,#userid#) </insert>

StartApp.java java.util.Map<String, String> map = new java.util.HashMap<String,String>(); map.put("userid" ,"mapuser"); map.put("username" ,"mapname"); map.put("password" ,"map_pw"); map.put("email" ,"mapuser@mapuser.com"); map.put("update_id","mapuser"); map.put("insert_id","mapuser"); mapper.insert("Tb_User_Insert_Map",usermap);

실행되는 풀 소스는 작성하지 않았지만, 일단 저런식으로 작성이 가능하다는 예로 작성했다. 반환값도 마찬가지로 값을 가져올 수 있다. 단, 반환에 대한 key는 db의 컬럼명을 통해 가져오면 된다. 사실 Map을 이용할땐 이 변수의 형식을 알 수가 없다. 즉 db에 DATE형식인데 이러한 것은 #value:DATE#와 같이 :TYPE를 기입해 줘야 한다. 여기서 TYPE는 java.sql.Types에 있는 방식을 사용해야 한다.(만약 jdbc타입으로 작성하고자 한다면 #value:jdbcType=TYPE#로 사용하면 된다.)

iBATIS in action 에선 이러한 bean과 map의 장단점은 다음과 같다.

<select id="Tb_User_Count" resultClass="BbsBean"> SELECT * FROM TB_PUPUSTORY_BBS WHERE TITLE = #title# </select>

이럴경우엔 검색 파라미터로 넘어오는 변수에 직접 '%'와일드 카드를 넣어주거나 아니면 앞 뒤에 '%' || title || '%' 식으로 추가해 줘야 한다.

<sql id="ref_sql"> select * from tb_pupustory_user </sql> <sql id="ref_sql_where"> WHERE USERID = #userid# </sql> <select id="select_user" parameterClass="UserBean" resultMap="UserBean_result"> <include refid="ref_sql"/> <include refid="ref_sql_where"/> </select>

Pupustory Dev/iBATIS framework

크리에이티브 커먼즈 라이선스

이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이선스에 따라 이용하실 수 있습니다.

Pupustory Dev/iBATIS framework