기타

select .. for update 처리를 위한 Stored Procudure 등록 및 사용법

by 남재우 posted Dec 10, 2011
ORACLE 에서 사용되는 select .. for update wait 가 현재 CUBRID 에서는 지원되지 않아 이의 처리를 위한 Stored Procedure 를 제공합니다.
Stored Procedure 는 java 기반으로 동작하며 Java 기반의 Stored Procedure 사용을 위한 세부 설정은 매뉴얼을 참고하시기 바라며, 여기서는 간단한 정보만 정리합니다.

* $CUBRID/conf/cubrid.conf 에 다음의 내용 추가후 데이터베이스 재구동. demodb 는 SP를 사용할 데이터베이스 이름
[@demodb]
java_stored_procedure=yes
* 환경변수에 JAVA VM 위치 지정 (LINUX 64bit, JDK1.6 기준), 다음 설정 추가
LD_LIBRARY_PATH=$JAVA_HOME/jre/lib/amd64:$JAVA_HOME/jre/lib/amd64/server:$LD_LIBRARY_PATH

1. 다음의 내용으로 SpCubrid.java 화일을 만듭니다.

import java.sql.*;
import cubrid.jdbc.driver.*;
import cubrid.sql.*;

public class SpCubrid {
 public static int mf_select_for_update(Object objid, String col_name) throws Exception {
  int  rtn = -1;
  Connection conn = null;
  ResultSet rs = null;
  try {
   String[] attr = { col_name };

   Class.forName("cubrid.jdbc.driver.CUBRIDDriver");
   conn = DriverManager.getConnection("jdbc:default:connection");
   CUBRIDOID oid = (CUBRIDOID)objid;

   oid.setWriteLock();
   rs = oid.getValues(attr);
   rs.next();
   rtn = rs.getInt(1);

   return rtn;
  } catch (SQLException e) {
   System.err.println(e.getMessage());
  } catch (Exception e) {
   System.err.println(e.getMessage());
  } finally {
   if (rs != null) rs.close();
   if (conn != null) conn.close();
  }

  return rtn;
 }
}

* 반드시 read lock 이 아닌, write lock으로 선점한 후 값을 가져와야 합니다.
select for update 는 내가 이 레코드의 값을 변경할 것이므로, 다른 사용자가 내 작업을 완료할때까지 읽지 못하게 하는 것입니다.
그런데 read lock 상호간에는 데이터에 대한 접근을 허용하므로 read lock 을 잡아놓아도 다른 사용자가 값을 읽어갈 수 있습니다.
또한 값을 lock 보다 먼저 읽어오면 동시에 접근한 다른 사용자와 같은 값을 가져오게 되므로, 읽어온 값을 이용하여 값을 변경시 먼저 변경한 사용자의 값은 잃어버리게 됩니다.

2. java class로 compile 합니다.

3. compile 된 class file 을 데이터베이스에 등록합니다.
% loadjava demodb SpClass.class

4. 질의편집기를 이용하여 SP 를 등록합니다.
create function select_for_update(objid object, col_name varchar) return int
as language java
name 'SpCubrid.mf_select_for_update(java.lang.Object, java.lang.String) return int'

5. 질의는 다음과 같이 사용합니다.
* 원질의 : select no from no_table where ... for update wait 10
* CUBRID : select select_for_update(no_table, 'no') from no_table where ...
select_for_update(<테이블명>, '<컬럼명>') * lock waiting 시간은 질의로 처리할 수는 없습니다. CUBRID 설정화일인 cubrid.conf 상에서 [lock_timeout_in_secs] 의 값을 초 단위로 설정하여 사용할 수 있습니다. 설정을 변경한 후에는 cubrid broker restart 를 통해 CUBRID broker 를 재구동시켜야 반영됩니다.

Articles

1 2 3 4 5 6 7 8 9