H2, Exposed Deprecated 걷어내기, H2 Datasource 추가하기

Ktor 강의를 따라가고 있는데, deprecated 된 부분이 있어서 개선해보도록 했다.

H2는 데이터베이스 로컬 서버(인메모리 DB)라고 볼수 있고, Exposed는 이걸 활용할 수 있는 일종의 ORM이자 프레임워크라고 이해했다.

fun Application.configureH2() {
    // h2 DB를 실행하는 함수
    // JDBC Driver같은 형태 - 인메모리(애플리케이션 상에서 접근)
    val h2Server = Server.createTcpServer("-tcp", "-tcpAllowOthers", "-tcpPort", "9092")
    environment.monitor.subscribe(ApplicationStarted) { application ->
        h2Server.start()
        application.environment.log.info("H2 server started. ${h2Server.url}")
    }

    environment.monitor.subscribe(ApplicationStopped) { application ->
        h2Server.stop()
        application.environment.log.info("H2 server stopped. ${h2Server.url}")
    }
}

이게 h2Server를 TCP연결로 보내고, Application 실행 시 h2서버가 실행되도록, 종료시 멈추도록 설정한 함수다. 문제는 이 부분이 deprecated 됐다는 점이다.

fun Application.configureH2() {
    val h2Server = Server.createTcpServer("-tcp", "-tcpAllowOthers", "-tcpPort", "9092")
    monitor.subscribe(ApplicationStarted) { application ->
        application.environment.log.info("H2 server started. ${h2Server.url}")
    }

    monitor.subscribe(ApplicationStopped) { application ->
        h2Server.stop()
        application.environment.log.info("H2 server stopped. ${h2Server.url}")
    }
}

아직 숙련도가 낮아서 자세히는 모르겠으나, 인터페이스 정도로만 구성되어있던 기존 구조가, coroutineScope로 감싸져 조금 더 괜찮게 바뀐 것 같다.

비동기로 이벤트를 모니터링하게 함으로 써 좀 더 효율적인 제어를 하게 되지않았나.. 추론해봤다.

### 기존 `monitor` 구조

package io.ktor.server.application

public interface ApplicationEnvironment {
    public abstract val classLoader: java.lang.ClassLoader

    public abstract val log: org.slf4j.Logger /* from: io.ktor.util.logging.Logger */

    public abstract val config: io.ktor.server.config.ApplicationConfig

    @kotlin.Deprecated public abstract val monitor: io.ktor.events.Events
}

 

### 현재 `monitor` 구조

package io.ktor.server.application

@io.ktor.utils.io.KtorDsl public final class Application internal constructor(environment: io.ktor.server.application.ApplicationEnvironment, developmentMode: kotlin.Boolean, rootPath: kotlin.String, monitor: io.ktor.events.Events, parentCoroutineContext: kotlin.coroutines.CoroutineContext, engineProvider: () -> io.ktor.server.engine.ApplicationEngine) : io.ktor.server.application.ApplicationCallPipeline, kotlinx.coroutines.CoroutineScope {
    public final var rootPath: kotlin.String /* compiled code */

    public final val monitor: io.ktor.events.Events /* compiled code */

    public final val parentCoroutineContext: kotlin.coroutines.CoroutineContext /* compiled code */

    private final val engineProvider: () -> io.ktor.server.engine.ApplicationEngine /* compiled code */

    private final val applicationJob: kotlinx.coroutines.CompletableJob /* compiled code */

    public final val engine: io.ktor.server.engine.ApplicationEngine /* compiled code */
        public final get

    public open val coroutineContext: kotlin.coroutines.CoroutineContext /* compiled code */

    public final fun dispose(): kotlin.Unit { /* compiled code */ }
}

Hikari는 원래 조금 들어봤지만 이번에 좀 제대로 보는 것 같다.

private fun connectDatabase() {
    val config =
        HikariConfig().apply {
            jdbcUrl = "jdbc:h2:mem:cafedb"
            driverClassName = "org.h2.Driver"
            validate()
        }

    val dataSource: DataSource = HikariDataSource(config)
    Database.connect(dataSource)
}

HikariCP는 고성능 JDBC 커넥션 풀링 라이브러리다. 데이터베이스와 애플리케이션 간의 연결을 관리하고, 여러 스레드에서 데이터베이스에 연결을 요청할 때 연결을 풀(pool)로 관리하여 성능과 안정성을 향상시킨다. 

 

HikariCP를 써서 H2 데이터베이스와 연결하고, HikariConfig 객체를 사용하여 JDBC URL과 드라이버 정보를 설정한다. 이를 기반으로 HikariDataSource를 생성하면 된다. Database.connect를 통해 Exposed ORM을 사용하여 데이터베이스와 연결한다. 그 뒤는 JDBC URL을 맞춰주는게 끝이다.

 

다음은 custom column type 문제다. 강의에서는 VARCHAR를 여러개 담을 수 있도록 한 클래스를 만들어뒀는데, 버전이 올라가면서 호환되지않는다. 

ColumnType의 형태가 바뀌어서 그런 것 같다. 좀 더 type safe 하게 바뀐 거니까 프레임워크 이용 상으로는 좋지만, 나한테는 좋지않다.

public abstract class ColumnType public constructor(nullable: kotlin.Boolean = COMPILED_CODE) : org.jetbrains.exposed.sql.IColumnType {
    public open var nullable: kotlin.Boolean /* compiled code */

    public open operator fun equals(other: kotlin.Any?): kotlin.Boolean { /* compiled code */ }

    public open fun hashCode(): kotlin.Int { /* compiled code */ }

    public open fun toString(): kotlin.String { /* compiled code */ }
}

// 변경 후 -> T가 생김
public abstract class ColumnType<T> public constructor(nullable: kotlin.Boolean = COMPILED_CODE) : org.jetbrains.exposed.sql.IColumnType<T> {
    public open var nullable: kotlin.Boolean /* compiled code */

    public open fun toString(): kotlin.String { /* compiled code */ }

    public open operator fun equals(other: kotlin.Any?): kotlin.Boolean { /* compiled code */ }

    public open fun hashCode(): kotlin.Int { /* compiled code */ }
}

일단 강의를 이어나가야하니까, Kotlin에서 가장 최상위 타입인 Any를 넣어서 해결했다.

import com.example.shared.CafeUserRole
import org.jetbrains.exposed.sql.Column
import org.jetbrains.exposed.sql.ColumnType
import org.jetbrains.exposed.sql.Table

class EnumListColumnType<T : Enum<T>>(
    private val enumClass: Class<T>,
    private val varcharLength: Int,
) : ColumnType<Any>() {
    ...
}

@Suppress("UNCHECKED_CAST")
fun <T : Enum<T>> Table.enumList(name: String, enumClass: Class<T>, varcharLength: Int): Column<List<CafeUserRole>> =
    registerColumn(name, EnumListColumnType(enumClass, varcharLength)) as Column<List<CafeUserRole>>

 

dbSchema를 제어하는 함수도 간단하다. transaction 블록 안에서 SchemaUtils.create를 호출하여 테이블들을 생성하고 addLogger(StdOutSqlLogger)를 같이 써서 SQL 로그를 표준 출력에 기록하도록 했다.

transaction {
    addLogger(StdOutSqlLogger)

    SchemaUtils.create(
        CafeMenuTable,
        CafeUserTable,
        CafeOrderTable
    )
}

그냥 jdbc였으면 DriverManager에 getConnection 걸고 뭐 다른거 다 했어야 했을 것이다.

로그 레벨은 resources 패키지 안의 `logback.xml`에서 제어할 수 있는데, root level기본이 trace이고 스프링에서 할 때 처럼 INFO로도 가능하다.

<configuration>
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
        <encoder>
            <pattern>%d{YYYY-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
        </encoder>
    </appender>
    <root level="INFO">
        <appender-ref ref="STDOUT"/>
    </root>
    <logger name="org.eclipse.jetty" level="INFO"/>
    <logger name="io.netty" level="INFO"/>
</configuration>

 

IntelliJ Ultimate를 사용한다면, Database 툴을 사용할 수 있다. 테이블이 시각화 된 채로 확인할 수 있는 건데, 이러려면 remote로 설정된 우리의 localhost 인메모리 h2 서버에 접근해야된다.

val h2Server = Server.createTcpServer("-tcp", "-tcpAllowOthers", "-tcpPort", "9092")

기본 h2포트가 9092같다. 기본 tcp는 외부 접속이 허용되지않는데, tcpAllowOthers 옵션을 달아서 remote에서 접근할 수 있도록 해준다.

HikariConfig에서 설정해둔 jdbcUrl을 입력해서 H2 Datasource에 접근할 것이다.

이렇게 하면 인메모리에 접근한다. 근데 H2의 remote 옵션말고 inmemory 옵션도 있다. 거기서 접근해버리면 우리가 만든 H2 서버와는 다른 url을 가져가기 때문에 지금 스키마로 만들어둔 테이블들에 접근할 수 없다.

 

 

도움이 됐다면 댓글이나 공감 버튼 한 번씩 누르고 가주세요! 로그인 안해도 됩니다 ^_^