Trino.Ado 소개와 ODBC 연결과의 차이

C#에서 Hive 테이블을 읽는 방법은 크게 둘입니다. ODBC 드라이버로 HiveServer2에 붙거나, Trino.Ado로 Trino에 붙거나. 둘 다 결국 같은 Hive 테이블을 읽지만, 거쳐 가는 길과 준비할 것, 코드에서 신경 쓸 점이 꽤 다릅니다.

1Trino와 Trino.Ado

Trino는

Trino는 여러 데이터 저장소를 SQL 하나로 조회하는 분산 SQL 엔진입니다(예전 이름 PrestoSQL). Hive 테이블은 Hive 커넥터(카탈로그)를 통해 읽습니다. Hive 메타스토어에서 테이블 정보를 받고, HDFS·S3의 파일을 Trino가 직접 읽기 때문에 HiveServer2를 거치지 않습니다. 그래서 쿼리에서 hive.default.sample_table처럼 카탈로그.스키마.테이블로 부르고, 연결할 때 기본 카탈로그를 hive로 지정합니다.

Trino.Ado는

Trino.Ado는 C#에서 Trino에 붙는 ADO.NET 클라이언트입니다. SqlConnection, OdbcConnection을 쓰던 방식 그대로 TrinoConnection → TrinoCommand → IDataReader로 씁니다.

정체

Trino 공식 C# 클라이언트(trino-csharp-client)를 포크해 NuGet에 배포한 패키지. 공식 Trino.Data.ADO는 nuget.org에 없습니다.

구성

Trino.Core(Trino REST API 통신) + Trino.Ado(ADO.NET 래퍼). Trino.Ado를 설치하면 Trino.Core가 같이 들어옵니다.

대상

.NET Standard 2.0 · .NET 8. .NET Framework는 4.7.2 이상(4.8 권장).

통신

Trino 코디네이터에 HTTP(S)로 쿼리를 보내고 결과를 페이지 단위로 받아 옵니다.

버전

1.1.0 (2026-07-30 공개). 라이선스 Apache-2.0.

var props = new TrinoConnectionProperties
{
    Server = new Uri("http://trino-server01:8080"),
    Catalog = "hive",
    Schema = "default",
    User = "etl_user"
};
using (var conn = new TrinoConnection(props))
using (var cmd = new TrinoCommand(conn, "SELECT * FROM sample_table LIMIT 10"))
{
    conn.Open();
    using (IDataReader reader = cmd.ExecuteReader())
        while (reader.Read()) Console.WriteLine(reader.GetValue(0));
}

실무용 전체 코드(App.config, 타입 변환, DataTable 채우기, 적재)는 C#에서 Trino(Hive 카탈로그) 조회하기에 있습니다.

2연결 경로가 다릅니다

가장 큰 차이는 누가 쿼리를 실행하느냐입니다. ODBC는 HiveServer2가 Hive 엔진(Tez·MapReduce 등)으로 실행하고, Trino.Ado는 Trino가 직접 파일을 읽어 실행합니다.

두 길 모두 마지막에는 같은 HDFS·S3의 같은 테이블 파일을 읽습니다. 그래서 같은 테이블이라면 결과 데이터도 같습니다.

3한눈에 비교

4코드는 얼마나 다를까

ADO.NET 모양은 같아서 흐름은 거의 그대로입니다. 바뀌는 건 연결 객체와 SQL 문법, 그리고 결과를 받는 부분입니다.

// 덮어쓰기는 문법이 아니라 세션 속성으로
props.SessionProperties = new Dictionary<string, string>
    { { "hive.insert_existing_partitions_behavior", "OVERWRITE" } };

using (var conn = new TrinoConnection(props))
using (var cmd = new TrinoCommand(conn,
    "INSERT INTO mart.daily_sales " +
    "SELECT store_id, SUM(amount), COUNT(*), dt FROM raw.orders " +
    "WHERE dt = '20261027' GROUP BY store_id, dt"))
{
    conn.Open();
    cmd.ExecuteNonQuery();
}

using (var conn = new OdbcConnection("DSN=HiveProd;UID=etl_user;PWD=********;"))
using (var cmd = conn.CreateCommand())
{
    cmd.CommandText =
        "INSERT OVERWRITE TABLE mart.daily_sales PARTITION (dt = '20261027') " +
        "SELECT store_id, SUM(amount), COUNT(*) FROM raw.orders " +
        "WHERE dt = '20261027' GROUP BY store_id";
    cmd.CommandTimeout = 3600;   // 기본 30초로는 끊김
    conn.Open();
    cmd.ExecuteNonQuery();
}

5무엇을 고를까

회사 클러스터에 무엇이 떠 있는지가 먼저입니다. Trino가 없으면 Trino.Ado는 쓸 수 없고, HiveServer2를 닫아 둔 곳이면 ODBC를 쓸 수 없습니다. 둘 다 있다면 아래 기준으로 고르세요.

다음에 읽을 글