Java 클라이언트

my-app-01/1.0 clickhouse-java-v2/0.9.6-SNAPSHOT (Linux; jvm:17.0.17) Apache-HttpClient/5.4.4

CompletableFuture<InsertResponse> insert(String tableName, InputStream data, ClickHouseFormat format, InsertSettings settings)
CompletableFuture<InsertResponse> insert(String tableName, InputStream data, ClickHouseFormat format)

client.insert(String tableName, List<?> data, InsertSettings settings)
client.insert(String tableName, List<?> data)

CompletableFuture<QueryResponse> query(String sqlQuery, QuerySettings settings)
CompletableFuture<QueryResponse> query(String sqlQuery)

final String sql = "select * from " + TABLE_NAME + " where title <> '' limit 10";

// 기본 포맷은 RowBinaryWithNamesAndTypesFormatReader이므로 reader가 컬럼에 대한 모든 정보를 가집니다
try (QueryResponse response = client.query(sql).get(3, TimeUnit.SECONDS);) {

    // 데이터에 편리하게 접근하기 위한 reader를 생성합니다
    ClickHouseBinaryFormatReader reader = client.newBinaryFormatReader(response);

    while (reader.hasNext()) {
        reader.next(); // 스트림에서 다음 레코드를 읽고 파싱합니다

        // 값 가져오기
        double id = reader.getDouble("id");
        String title = reader.getString("title");
        String url = reader.getString("url");

        // 데이터 수집
    }
} catch (Exception e) {
    log.error("Failed to read data", e);
}

// HTTP connection을 최대한 빨리 해제하려면 비즈니스 로직을 읽기 블록 외부에 작성하십시오.

CompletableFuture<QueryResponse> query(String sqlQuery, Map<String, Object> queryParams, QuerySettings settings)

List<GenericRecord> queryAll(String sqlQuery)

TableSchema getTableSchema(String table)
TableSchema getTableSchema(String table, String database)

TableSchema getTableSchemaFromQuery(String sql)

void register(Class<?> clazz, TableSchema schema)

try (QueryResponse response = client.query("SELECT * FROM my_table").get()) {
    ClickHouseBinaryFormatReader reader = client.newBinaryFormatReader(response);
    while (reader.next() != null) {
        
        Object[] uint64 = reader.getObjectArray("uint64_arr"); // Array(UInt64) -> BigInteger[]
        Object[] arr2d = reader.getObjectArray("arr2d");       // Array(Array(Int64)) -> Object[]

        // 중첩 배열은 중첩된 Object[] 형태로 반환됩니다:
        Object[] firstInner = (Object[]) arr2d[0];
        Long firstValue = (Long) firstInner[0];
    }
}

try (QueryResponse response = client.query("SELECT * FROM my_table").get()) {
    List<GenericRecord> rows = client.queryAll(
        "SELECT int_arr, arr2d_nullable FROM test_arrays ORDER BY id");

    for (GenericRecord row : rows) {
        Object[] intArr = row.getObjectArray("int_arr");                 // Array(Int32) -> Integer[]
        Object[] arr2d = row.getObjectArray("arr2d_nullable");           // Array(Array(Nullable(Int32)))

        Object[] inner = (Object[]) arr2d[0];
        Object maybeNull = inner[1]; // may be null
    }
}

InputStream inData = getInData();
ClickHouseRequest.Mutation request = client.read(server)
        .write()
        .table(tableName)
        .format(ClickHouseFormat.TSV);
ClickHouseConfig config = request.getConfig();
CompletableFuture<ClickHouseResponse> future;
try (ClickHousePipedOutputStream requestBody = ClickHouseDataStreamFactory.getInstance()
        .createPipedOutputStream(config)) {
    // 입력 데이터를 ClickHouse로 전송하는 워커 스레드를 시작합니다
    future = request.data(requestBody.getInputStream()).execute();

    // inData 스트림에서 requestBody 스트림으로 데이터를 복사합니다

    // 응답을 받기 전에 스트림을 닫아야 합니다
    requestBody.close();

    try (ClickHouseResponse response = future.get()) {
        ClickHouseResponseSummary summary = response.getSummary();
        Assert.assertEquals(summary.getWrittenRows(), numRows, "Num of written rows");
    }
}

InputStream inData = getInData();
InsertSettings settings = new InsertSettings().setInputStreamCopyBufferSize(8198 * 2); // 복사 버퍼 크기 설정
try (InsertResponse response = client.insert(tableName, inData, ClickHouseFormat.TSV, settings).get(30, TimeUnit.SECONDS)) {

  // 이 시점에서 삽입 완료

} catch (Exception e) {
 // 예외 처리
}

Collection<GenericRecord> records = client.queryAll("SELECT * FROM table");
for (GenericRecord record : records) {
    int rowId = record.getInteger("rowID");
    String name = record.getString("name");
    LocalDateTime ts = record.getLocalDateTime("ts");
}