Background Image
Java
2009.12.30 02:50

SELECT ~ FOR UPDATE 대체 방법

조회 수 31775 추천 수 0 댓글 0
?

단축키

Prev이전 문서

Next다음 문서

크게 작게 위로 아래로 댓글로 가기 인쇄

소개: DBMS에서 SELECT 문을 통해 row level lock을 거는 방법으로 사용되는 SELECT ~ FOR UPDATE 구문이 CUBRID에는 존재하지 않는다. 이를 대체하는 방법으로 CUBRID 확장 JDBC APIsetWriteLock를 소개한다.

적용 대상: CUBRID2008R1.x 이상, JDK1.5이상

 

SELECT ~ FOR UPDATE 대체 방법

DBMS에서 SELECT 문을 통해 특정 row lock을 거는 문장으로 사용되는 것이 SELECT ~ FOR UPDATE 구문이다. 사용 예는 아래와 같다.

SELECT * FROM code where s_name=’X’ FOR UPDATE;

CUBRID에서는 위 구문을 지원하지 않는다. 이를 대체하기 위해서 CUBRID 확장 JDBC API setWriteLock를 제공하고 있다.

구문은

void setWriteLock()

CUBRIDOID 클래스에 포함된 메소드 이다.

setWriteLock 예제

아래는 setWriteLock을 사용하는 예제로 code 테이블의 s_name‘X’ row를 조회하면서 쓰기 잠금을 설정한 후 해당 row f_name‘XXX’ update 시키는 예제이다.

import java.sql.*;

import cubrid.sql.*;              //1

public class TestWriteLock1{

  public static void main(String arg[]) throws Exception {

    Connection conn = null;

    PreparedStatement  ps = null;

    ResultSet rs = null;

    try {

      Class.forName("cubrid.jdbc.driver.CUBRIDDriver");

      conn = DriverManager.getConnection("jdbc:cubrid:localhost:39000:demodb:::","","");

      conn.setAutoCommit(false);          //2

      Object result = null;

      String sbQuery = "SELECT class(a), a.* FROM code a WHERE a.s_name=?";                            //3

      String s_name = "X";

      String f_name = "XXX";

      ps = conn.prepareStatement(sbQuery);

      ps.setString(1, s_name);

      rs = ps.executeQuery();

      if(rs.next()) {

        result = rs.getObject(1);             //4

        CUBRIDOID oid = (CUBRIDOID)result;          //5

        oid.setWriteLock();     //6

        if(ps != null) ps.close();

        ps = conn.prepareStatement("UPDATE code SET f_name = ? WHERE CLASS(code) = ?");         //7

        ps.setString(1, f_name);

        ps.setObject(2, result);               //8

        ps.executeUpdate();

      }

      if(rs != null) rs.close();

      if(ps != null) ps.close();

      conn.commit();

    }catch ( SQLException e ) {

      conn.rollback();

      e.printStackTrace();

    } catch(Exception e) {

      conn.rollback();

      e.printStackTrace();

    } finally {

      if(rs != null) rs.close();

      if(ps != null) ps.close();

      if(conn != null) conn.close();

    }

  }

}

·      1 : setWriteLock CUBRIDOID의 메소드로 CUBRIDOID를 사용하기 위해서는 cubrid.sql.* import 해야한다.

·      2 : 동일 트랜잭션 내에서 select update를 수행하여야 하므로 autoCommit false로 설정한다.

·      3 : 해당 row OID를 가져오기 위해서는 SELECT 문에 class(table_name) 형식으로 명시해준다. 위 예제는 code 테이블의 alias a로 부여 하였기 때문에 class(a)와 같이 명시 하였다.

·      4, 5 : 조회된 OID getObject() 를 사용하여 Object 형태로 받은 후, CUBRIDOID로 형변환을 수행한다.

·      6 : CUBRIDOID.setWriteLock()를 호출하여 해당 row를 쓰기 잠금 설정한다.

·      7 : 쓰기 잠금 설정된 row의 데이터를 update하기 위해서 비교 조건으로 위에서 받아온 OID를 사용한다. OID를 조회 조건으로 사용하기 위해서는 class(table_name) 형식으로 명시해준다.

·      8 : OID 값을 해당 위치에 바인딩 하기 위해서는 setObject()를 사용한다.

 


  1. CUBRID 복제 설계 가이드

  2. CUBRID 사용 포트와 iptables(방화벽) 설정

  3. 자동증가 속성 사용 방법 및 주의 사항

  4. CUBRID 관련 유용한 기술 자료...

  5. Server HA 구성 시 CUBRID 설정과 방법

  6. Vista_IIS_CUBRID_ASP연동

  7. CUBRID2008 R2.1 업그레이드시 serial 관련 문제 해결 방법

  8. CUBRID 데이터베이스와 연동하여 Qt어플리케이션 개발하기 - 2

  9. CUBRID 데이터베이스와 연동하여 Qt어플리케이션 개발하기 - 1

  10. CUBRID인덱스 구성 전략

  11. 조인 방법(Join Method) 설명

  12. 스칼라 서브쿼리 사용 가이드

  13. CUBRID 에 텍스트큐브 설치하기

  14. 예제로 배우는 CUBRID 스터디

  15. 독자적 테이블 사용되는 복제 재구성

  16. SELECT ~ FOR UPDATE 대체 방법

  17. 멀티미디어 데이터 관리를 위한 CUBRID GLO Method 활용

  18. QTADO를 이용하여 CUBRID접속하기

  19. CUBRID 개발 가이드

  20. 서비스 오픈을 위한 CUBRID 구성 가이드

Board Pagination Prev 1 2 3 4 5 6 7 8 9 Next
/ 9

Contact Cubrid

대표전화 070-4077-2110 / 기술문의 070-4077-2147 / 영업문의 070-4077-2112 / Email. contact_at_cubrid.com
Contact Sales