clickhouse

package

v0.0.0-...-6f847f4 Latest Latest Go to latest Published: Jan 18, 2026 License: AGPL-3.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/PeerDB-io/peerdb

Links

Open Source Insights

Documentation ¶

Index ¶

func CheckIfClickHouseCloudHasSharedMergeTreeEnabled(ctx context.Context, logger log.Logger, conn clickhouse.Conn) error
func CheckIfTablesEmptyAndEngine(ctx context.Context, logger log.Logger, conn clickhouse.Conn, tables []string, ...) error
func CheckNotSystemDatabase(database string) error
func EscapeStr(value string) string
func Exec(ctx context.Context, logger log.Logger, conn clickhouse.Conn, query string, ...) error
func GetTableColumnsMapping(ctx context.Context, logger log.Logger, conn clickhouse.Conn, tables []string) (map[string][]ClickHouseColumn, error)
func Query(ctx context.Context, logger log.Logger, conn clickhouse.Conn, query string, ...) (driver.Rows, error)
func QueryRow(ctx context.Context, logger log.Logger, conn clickhouse.Conn, query string, ...) driver.Row
func QuoteIdentifier(value string) string
func QuoteLiteral(value string) string
type ClickHouseColumn

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CheckIfClickHouseCloudHasSharedMergeTreeEnabled ¶

func CheckIfClickHouseCloudHasSharedMergeTreeEnabled(ctx context.Context, logger log.Logger,
	conn clickhouse.Conn,
) error

func CheckIfTablesEmptyAndEngine ¶

func CheckIfTablesEmptyAndEngine(ctx context.Context, logger log.Logger, conn clickhouse.Conn,
	tables []string, initialSnapshotEnabled bool, checkForCloudSMT bool, allowNonEmpty bool,
) error

func CheckNotSystemDatabase ¶

func CheckNotSystemDatabase(database string) error

func EscapeStr ¶

func EscapeStr(value string) string

func Exec ¶

func Exec(ctx context.Context, logger log.Logger,
	conn clickhouse.Conn, query string, args ...any,
) error

func GetTableColumnsMapping ¶

func GetTableColumnsMapping(ctx context.Context, logger log.Logger, conn clickhouse.Conn,
	tables []string,
) (map[string][]ClickHouseColumn, error)

func Query ¶

func Query(ctx context.Context, logger log.Logger,
	conn clickhouse.Conn, query string, args ...any,
) (driver.Rows, error)

func QueryRow ¶

func QueryRow(ctx context.Context, logger log.Logger,
	conn clickhouse.Conn, query string, args ...any,
) driver.Row

func QuoteIdentifier ¶

func QuoteIdentifier(value string) string

func QuoteLiteral ¶

func QuoteLiteral(value string) string

Types ¶

type ClickHouseColumn ¶

type ClickHouseColumn struct {
	Name        string
	Type        string
	DefaultKind string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL