[ Spring_Mybatis] Mybatis와 Oracle을 연결하기위한 Dialect 구현_paging_rownum

안녕하세요.

 

오늘은 Java SpringFramework에서 Mybatis를 이용하여 Oracle 데이터베이스를 연결할때 구현하게되는 Dialect에 대하여 알아보겠습니다. 

 

아래 내용은 Oracle 11g 이하에서의 호환성을 고려한 방식입니다.

 

Oracle 12c 이상에서는 OFFSET과 FETCH NEXT 구문을 지원하므로 getLimitString을 간소화할 수 있습니다.

필요하다면, Dialect를 확장하여 더 간단한 구현을 추가할 수 있습니다.

 

[ 1 ]  구현 이유

 

MybatisOracleDialect(가칭)를 구현하는 이유는 Oracle 데이터베이스의 특수한 SQL 문법, 페이징 처리, 함수 및 데이터 유형 지원을 효율적으로 관리하고, 다양한 데이터베이스를 사용하는 환경에서 Oracle에 최적화된 SQL을 생성하기 위함입니다. 이를 통해 개발자는 Oracle 데이터베이스의 복잡성을 신경 쓰지 않고 ORM의 장점을 활용할 수 있습니다.

기본적으로 Dialect는 데이터베이스마다 상이한 SQL 문법이나 기능을 추상화하여 ORM과 데이터베이스 간의 호환성을 보장합니다.

 

1. 페이징 쿼리 구현

Oracle 11g 이하 버전에서는 ROWNUM 기반의 페이징 처리가 필요합니다. Oracle은 LIMIT와 OFFSET 같은 간단한 구문을 지원하지 않으므로, ORM에서 이를 처리하기 위해 커스텀 Dialect를 구현해야 합니다.

2. Oracle 전용 SQL 문법 지원

Oracle 데이터베이스는 표준 SQL과 일부 문법 차이가 있으며, 고유한 함수나 데이터 유형을 사용합니다. MybatisOracleDialect는 이러한 Oracle의 특징을 반영해 맞춤형 SQL 문을 생성합니다.

 

• SYSDATE (현재 날짜)
• SYSTIMESTAMP (현재 타임스탬프)
• 데이터 유형 매핑 (VARCHAR → VARCHAR2, DOUBLE → DOUBLE PRECISION 등)

 

3. 다양한 데이터베이스 호환성

MyBatis나 Hibernate 같은 ORM은 다양한 데이터베이스를 지원하기 위해 추상화된 SQL을 사용합니다. 이를 데이터베이스에 맞게 변환하는 작업은 Dialect에서 담당합니다. Oracle은 다른 데이터베이스와 다르게 동작하는 특성이 많아 별도의 MybatisOracleDialect가 필요합니다.

 

4. 효율적인 SQL 최적화

Oracle에서는 대규모 데이터를 처리할 때 효율적인 쿼리를 작성하는 것이 중요합니다. MybatisOracleDialect는 이러한 최적화를 ORM 레벨에서 처리할 수 있도록 지원합니다.

5. 유지보수 및 확장성

Oracle 데이터베이스에서 프로젝트를 진행하는 경우, 데이터베이스의 특정 기능이 자주 변경되거나 추가될 수 있습니다. MybatisOracleDialect를 구현하면:

• 코드 중복 없이 일관된 SQL 생성을 보장할 수 있습니다.
• 데이터베이스 관련 변경 사항이 발생해도 Dialect만 수정하면 전체 시스템에 반영됩니다.

 

 

[ 2 ]  MybatisOracleDialect 구현 예제

 

아래는 Hibernate의 Dialect를 상속받아 MybatisOracleDialect를 구현하는 예제입니다.

 

package com.example.dialect;

import org.hibernate.dialect.Dialect;
import org.hibernate.sql.Alias;
import org.hibernate.type.StandardBasicTypes;

public class MybatisOracleDialect extends Dialect {

    public MybatisOracleDialect() {
        super();
        // 기본적으로 Oracle에서 사용하는 데이터 유형 등록
        registerColumnType(java.sql.Types.INTEGER, "number(10,0)");
        registerColumnType(java.sql.Types.VARCHAR, "varchar2($l)");
        registerColumnType(java.sql.Types.TIMESTAMP, "timestamp");
        registerColumnType(java.sql.Types.DOUBLE, "double precision");
        
        // 함수 등록 (필요에 따라 커스터마이징 가능)
        registerFunction("current_date", new NoArgSQLFunction("SYSDATE", StandardBasicTypes.DATE, false));
        registerFunction("current_timestamp", new NoArgSQLFunction("SYSTIMESTAMP", StandardBasicTypes.TIMESTAMP, false));
    }

    /**
     * Oracle용 페이징 쿼리를 생성합니다.
     *
     * @param sql    원본 SQL 쿼리
     * @param offset 시작 위치 (0부터 시작)
     * @param limit  가져올 행 수
     * @return 페이징 처리가 적용된 SQL 쿼리
     */
    public String getLimitString(String sql, int offset, int limit) {
        StringBuilder pagingQuery = new StringBuilder();

        pagingQuery.append("SELECT * FROM ( ");
        pagingQuery.append("SELECT inner_query.*, ROWNUM rownum_ ");
        pagingQuery.append("FROM ( ");
        pagingQuery.append(sql); // 원본 쿼리 삽입
        pagingQuery.append(" ) inner_query ");
        pagingQuery.append("WHERE ROWNUM <= ").append(offset + limit); // 상위 limit까지 가져오기
        pagingQuery.append(") WHERE rownum_ > ").append(offset); // offset 이후 데이터만 선택

        return pagingQuery.toString();
    }

    /**
     * 기본적으로 Oracle에서 Identifier를 대문자로 처리하도록 설정.
     *
     * @param name 원본 Identifier
     * @return 대문자로 변환된 Identifier
     */
    @Override
    public String quote(String name) {
        return super.quote(name).toUpperCase();
    }

    /**
     * Dialect 이름 반환 (디버깅 및 설정 확인용).
     *
     * @return Dialect 이름
     */
    @Override
    public String toString() {
        return "MybatisOracleDialect";
    }
}

 

1. registerColumnType
   • Oracle 데이터베이스의 특정 데이터 유형과 SQL 타입을 매핑합니다.
   • 필요한 경우 추가 데이터 유형을 등록할 수 있습니다.
2. registerFunction
   • Oracle 고유 함수(SYSDATE, SYSTIMESTAMP 등)를 Hibernate에서 사용할 수 있도록 등록합니다.
3. getLimitString
   • Oracle의 페이징 처리를 위해 ROWNUM 기반 쿼리를 생성합니다.
   • Hibernate의 Dialect는 기본적으로 페이징 지원이 없으므로 이를 커스터마이징합니다.
4. quote
   • 기본적으로 Oracle은 식별자를 대문자로 처리합니다. quote 메서드를 오버라이드해 이를 반영합니다.
5. toString
   • 이 Dialect의 이름을 반환합니다. Hibernate 설정 디버깅이나 로그에서 유용합니다.

 

 

[ 3 ]  application.properties에 등록

 

<property name="hibernate.dialect">com.example.dialect.MybatisOracleDialect</property>

 

 

감사합니다.