ClickHouse/tests/integration/test_compression_codec_read/test.py

import pytest

from helpers.cluster import ClickHouseCluster
from helpers.test_tools import assert_eq_with_retry

cluster = ClickHouseCluster(__file__)

node1 = cluster.add_instance(
    "node1",
    image="yandex/clickhouse-server",
    tag="20.8.11.17",
    with_installed_binary=True,
    stay_alive=True,
    allow_analyzer=False,
)


@pytest.fixture(scope="module")
def start_cluster():
    try:
        cluster.start()

        yield cluster
    finally:
        cluster.shutdown()


def test_default_codec_read(start_cluster):
    node1.query("DROP TABLE IF EXISTS test_18340")

    node1.query(
        """
        CREATE TABLE test_18340
        (
            `lns` LowCardinality(Nullable(String)),
            `ns` Nullable(String),
            `s` String,
            `ni64` Nullable(Int64),
            `ui64` UInt64,
            `alns` Array(LowCardinality(Nullable(String))),
            `ans` Array(Nullable(String)),
            `dt` DateTime,
            `i32` Int32
        )
        ENGINE = MergeTree()
        PARTITION BY i32
        ORDER BY (s, farmHash64(s))
        SAMPLE BY farmHash64(s)
    """
    )

    node1.query(
        "insert into test_18340 values ('test', 'test', 'test', 0, 0, ['a'], ['a'], now(), 0)"
    )

    assert node1.query("SELECT COUNT() FROM test_18340") == "1\n"

    node1.restart_with_latest_version()

    assert node1.query("SELECT COUNT() FROM test_18340") == "1\n"