sql

Sep 28, 2026

Changes in this version

+ const SchemaVersionKey

+ const SchemaVersionV1

type Catalog

+ func (c *Catalog) Close() error

+ func (c *Catalog) PurgeTable(ctx context.Context, identifier table.Identifier) error

Oct 9, 2025

Changes in this version

+ const TableType

+ const ViewType

type Catalog

+ func (c *Catalog) CheckViewExists(ctx context.Context, identifier table.Identifier) (bool, error)

+ func (c *Catalog) CreateView(ctx context.Context, identifier table.Identifier, schema *iceberg.Schema, ...) error

+ func (c *Catalog) DropView(ctx context.Context, identifier table.Identifier) error

+ func (c *Catalog) ListViews(ctx context.Context, namespace table.Identifier) iter.Seq2[table.Identifier, error]

+ func (c *Catalog) LoadView(ctx context.Context, identifier table.Identifier) (map[string]interface{}, error)

May 21, 2025

Changes in this version

type Catalog

+ func (c *Catalog) CheckNamespaceExists(ctx context.Context, namespace table.Identifier) (bool, error)

+ func (c *Catalog) CheckTableExists(ctx context.Context, identifier table.Identifier) (bool, error)

Mar 20, 2025

Changes in this version

+ const DialectKey

+ const DriverKey

+ type Catalog struct

+ func NewCatalog(name string, db *sql.DB, dialect SupportedDialect, props iceberg.Properties) (*Catalog, error)

+ func (c *Catalog) CatalogType() catalog.Type

+ func (c *Catalog) CommitTable(ctx context.Context, tbl *table.Table, reqs []table.Requirement, ...) (table.Metadata, string, error)

+ func (c *Catalog) CreateNamespace(ctx context.Context, namespace table.Identifier, props iceberg.Properties) error

+ func (c *Catalog) CreateSQLTables(ctx context.Context) error

+ func (c *Catalog) CreateTable(ctx context.Context, ident table.Identifier, sc *iceberg.Schema, ...) (*table.Table, error)

+ func (c *Catalog) DropNamespace(ctx context.Context, namespace table.Identifier) error

+ func (c *Catalog) DropSQLTables(ctx context.Context) error

+ func (c *Catalog) DropTable(ctx context.Context, identifier table.Identifier) error

+ func (c *Catalog) ListNamespaces(ctx context.Context, parent table.Identifier) ([]table.Identifier, error)

+ func (c *Catalog) ListTables(ctx context.Context, namespace table.Identifier) iter.Seq2[table.Identifier, error]

+ func (c *Catalog) LoadNamespaceProperties(ctx context.Context, namespace table.Identifier) (iceberg.Properties, error)

+ func (c *Catalog) LoadTable(ctx context.Context, identifier table.Identifier, props iceberg.Properties) (*table.Table, error)

+ func (c *Catalog) Name() string

+ func (c *Catalog) RenameTable(ctx context.Context, from, to table.Identifier) (*table.Table, error)

+ func (c *Catalog) UpdateNamespaceProperties(ctx context.Context, namespace table.Identifier, removals []string, ...) (catalog.PropertiesUpdateSummary, error)

+ type SupportedDialect string

+ const MSSQL

+ const MySQL

+ const Oracle

+ const Postgres

+ const SQLite