catalog_store_sqlpp23_internal.h File Reference

#include <algorithm>
#include <condition_variable>
#include <cstdint>
#include <exception>
#include <functional>
#include <mutex>
#include <optional>
#include <string>
#include <string_view>
#include <utility>
#include <vector>
#include <sqlpp23/sqlpp23.h>
#include "iceberg/catalog/sql/catalog_store.h"
#include "iceberg/catalog/sql/sql_catalog_tables_internal.h"
#include "iceberg/result.h"

Go to the source code of this file.

Classes
class	iceberg::sql::SingleConnectionSource< Connection >
class	iceberg::sql::PooledConnectionSource< Pool >
class	iceberg::sql::Sqlpp23CatalogStore< ConnectionSource, Traits >
	CatalogStore backed by a concrete sqlpp23 connection source. More...

Detailed Description

Generic CatalogStore implementation on top of sqlpp23.

The query bodies are identical across connectors: sqlpp23 serializes the same typed statements into each SQL dialect automatically. Only two things vary per connector, both supplied by the Traits policy:

• how driver errors are recognized as unique-constraint violations (Traits::IsUniqueViolation).
• how driver errors are recognized as duplicate-column migrations (Traits::IsDuplicateColumn).

This is an internal header that pulls in sqlpp23; it is only included by the per-connector factory translation units (catalog_store_*.cc).