go/go-clickhouse
1
0
Fork 0
mirror of https://github.com/uptrace/go-clickhouse.git synced 2025-06-10 23:27:25 +02:00
Code Issues Releases Activity

chore: rename WithQuery to Apply

Browse Source
This commit is contained in:
Vladimir Mihailenco 2023-03-29 15:19:49 +03:00
parent 59dcbc03a4
commit 5cd79b48c3
5 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ch/query_select.go
View File

@ -68,7 +68,7 @@ func (q *SelectQuery) Err(err error) *SelectQuery {
return q return q
} }
func (q *SelectQuery) WithQuery(fn func(*SelectQuery) *SelectQuery) *SelectQuery { func (q *SelectQuery) Apply(fn func(*SelectQuery) *SelectQuery) *SelectQuery {
return fn(q) return fn(q)
} }

2
ch/query_table_create.go
View File

@ -34,7 +34,7 @@ func (q *CreateTableQuery) Model(model any) *CreateTableQuery {
return q return q
} }
func (q *CreateTableQuery) WithQuery(fn func(*CreateTableQuery) *CreateTableQuery) *CreateTableQuery { func (q *CreateTableQuery) Apply(fn func(*CreateTableQuery) *CreateTableQuery) *CreateTableQuery {
return fn(q) return fn(q)
} }

2
ch/query_view_create.go
View File

@ -36,7 +36,7 @@ func (q *CreateViewQuery) Model(model any) *CreateViewQuery {
return q return q
} }
func (q *CreateViewQuery) WithQuery(fn func(*CreateViewQuery) *CreateViewQuery) *CreateViewQuery { func (q *CreateViewQuery) Apply(fn func(*CreateViewQuery) *CreateViewQuery) *CreateViewQuery {
return fn(q) return fn(q)
} }

2
ch/query_view_drop.go
View File

@ -32,7 +32,7 @@ func (q *DropViewQuery) Model(model any) *DropViewQuery {
return q return q
} }
func (q *DropViewQuery) WithQuery(fn func(*DropViewQuery) *DropViewQuery) *DropViewQuery { func (q *DropViewQuery) Apply(fn func(*DropViewQuery) *DropViewQuery) *DropViewQuery {
return fn(q) return fn(q)
} }

4
chmigrate/migrator.go
View File

@ -109,7 +109,7 @@ func (m *Migrator) migrationsWithStatus(ctx context.Context) (MigrationSlice, in
func (m *Migrator) Init(ctx context.Context) error { func (m *Migrator) Init(ctx context.Context) error {
if _, err := m.db.NewCreateTable(). if _, err := m.db.NewCreateTable().
Model((*Migration)(nil)). Model((*Migration)(nil)).
WithQuery(func(q *ch.CreateTableQuery) *ch.CreateTableQuery { Apply(func(q *ch.CreateTableQuery) *ch.CreateTableQuery {
if m.replicated { if m.replicated {
return q.Engine("ReplicatedCollapsingMergeTree(sign)") return q.Engine("ReplicatedCollapsingMergeTree(sign)")
} }
@ -123,7 +123,7 @@ func (m *Migrator) Init(ctx context.Context) error {
} }
if _, err := m.db.NewCreateTable(). if _, err := m.db.NewCreateTable().
Model((*migrationLock)(nil)). Model((*migrationLock)(nil)).
WithQuery(func(q *ch.CreateTableQuery) *ch.CreateTableQuery { Apply(func(q *ch.CreateTableQuery) *ch.CreateTableQuery {
if m.replicated { if m.replicated {
return q.Engine("ReplicatedMergeTree") return q.Engine("ReplicatedMergeTree")
} }