mirror of
https://github.com/hanzoai/otel-collector.git
synced 2026-11-03 02:20:04 +00:00
zeekay
9a2c38391e
- imports: ClickHouse/ch-go, clickhouse-go/v2, srikanthccv/ClickHouse-go-mock
-> github.com/hanzo-ds/{native,go,mock} (require, clean semver, NO replace)
- identifiers/aliases/type-names/config-keys/type-IDs: clickhouse -> datastore
(receiver dir clickhousesystemtablesreceiver -> datastoresystemtablesreceiver)
- DSN scheme clickhouse:// -> datastore:// (driver treats non-http/https as Native)
- removed the go.opencensus.io version-pin replace (require-pinned instead)
- kept: real external refs (github.com/ClickHouse, clickhouse.com docs) and the
hanzo-ds/mock test API (NewClickHouseNative) pending the mock's own rename
Full ./... build passes. 0 replace directives, 0 signoz.
66 lines
1.8 KiB
Go
66 lines
1.8 KiB
Go
package schemamigrator
|
|
|
|
import "strings"
|
|
|
|
// InsertIntoTable represents an INSERT INTO statement.
|
|
// InsertIntoTable can only be used for INSERTs into ReplacingMergeTree tables as of now.
|
|
type InsertIntoTable struct {
|
|
cluster string
|
|
|
|
Database string
|
|
Table string
|
|
Columns []string
|
|
LightWeight bool
|
|
Synchronous bool
|
|
// Values should be a pre-formatted string representing the VALUES clause,
|
|
// for example: "('col1', 123), ('col2', 456)".
|
|
// The caller is responsible for proper formatting and escaping.
|
|
Values string
|
|
}
|
|
|
|
// OnCluster is a no-op for INSERTs (Datastore does not support INSERT ... ON CLUSTER).
|
|
func (i InsertIntoTable) OnCluster(cluster string) Operation {
|
|
i.cluster = cluster
|
|
return &i
|
|
}
|
|
|
|
// WithReplication is a no-op for this operation.
|
|
func (i InsertIntoTable) WithReplication() Operation {
|
|
return &i
|
|
}
|
|
|
|
// ShouldWaitForDistributionQueue returns false as INSERTs do not start DDL queues.
|
|
func (i InsertIntoTable) ShouldWaitForDistributionQueue() (bool, string, string) {
|
|
return false, i.Database, i.Table
|
|
}
|
|
|
|
// IsMutation returns false (does not alter existing data parts).
|
|
func (i InsertIntoTable) IsMutation() bool { return false }
|
|
|
|
func (i InsertIntoTable) IsIdempotent() bool { return false }
|
|
|
|
// IsLightweight returns true.
|
|
func (i InsertIntoTable) IsLightweight() bool { return i.LightWeight }
|
|
|
|
func (i InsertIntoTable) ForceMigrate() bool {
|
|
return i.Synchronous
|
|
}
|
|
|
|
func (i InsertIntoTable) ToSQL() string {
|
|
var sql strings.Builder
|
|
sql.WriteString("INSERT INTO ")
|
|
sql.WriteString(i.Database)
|
|
sql.WriteString(".")
|
|
sql.WriteString(i.Table)
|
|
|
|
if len(i.Columns) > 0 {
|
|
sql.WriteString(" (")
|
|
sql.WriteString(strings.Join(i.Columns, ", "))
|
|
sql.WriteString(")")
|
|
}
|
|
|
|
sql.WriteString(" VALUES ")
|
|
sql.WriteString(i.Values)
|
|
return sql.String()
|
|
}
|