Method testCompressChunk

test/storage/compress_chunk_test.cpp:127–154

template<std::floating_point T>
void CompressChunkTest::testCompressChunk(const std::vector<T>& bufferToCompress,
    check_func_t checkFunc) {
    auto* mm = getMemoryManager(*database);
    auto* storageManager = getStorageManager(*database);
    auto* dataFH = storageManager->getDataFH();

    const auto dataType = std::is_same_v<float, T> ? LogicalType::FLOAT() : LogicalType::DOUBLE();
    const auto alg = std::make_shared<FloatCompression<T>>();

    const auto preScanMetadata = getFloatMetadata(bufferToCompress, alg);
    auto chunkMetadata =
        compressBuffer(bufferToCompress, alg, preScanMetadata.get(), dataFH, dataType);

    auto columnReader = ColumnReadWriterFactory::createColumnReadWriter(dataType.getPhysicalType(),
        dataFH, &storageManager->getShadowFile());

    conn->query("BEGIN TRANSACTION;");

    SegmentState state;
    state.metadata = chunkMetadata;
    state.numValuesPerPage = state.metadata.compMeta.numValues(LBUG_PAGE_SIZE, dataType);
    if (chunkMetadata.compMeta.compression == CompressionType::ALP) {
        state.alpExceptionChunk = std::make_unique<InMemoryExceptionChunk<T>>(state, dataFH, mm,
            &storageManager->getShadowFile());
    }

    checkFunc(columnReader.get(), state, dataType);
}

template<std::floating_point T>
void CompressChunkTest::testUpdateChunk(std::vector<T>& bufferToCompress, check_func_t updateFunc) {