cluster mode

AntonOyung · AntonOyung · commit 6307580f0922 · 2024-10-07T23:29:00.000-04:00
diff --git a/database/clickhouse/clickhouse.go b/database/clickhouse/clickhouse.go
@@ -279,6 +279,10 @@ func (ch *ClickHouse) Drop() (err error) {
 
 		query = "DROP TABLE IF EXISTS " + quoteIdentifier(ch.config.DatabaseName) + "." + quoteIdentifier(table)
 
+		if len(ch.config.ClusterName) > 0 {
+			query = query + " ON CLUSTER " + ch.config.ClusterName
+		}
+
 		if _, err := ch.conn.Exec(query); err != nil {
 			return &database.Error{OrigErr: err, Query: []byte(query)}
 		}

Original file line number	Diff line number	Diff line change
`@@ -279,6 +279,10 @@ func (ch *ClickHouse) Drop() (err error) {`
`279`	`279`
`280`	`280`	`query = "DROP TABLE IF EXISTS " + quoteIdentifier(ch.config.DatabaseName) + "." + quoteIdentifier(table)`
`281`	`281`
	`282`	`+ if len(ch.config.ClusterName) > 0 {`
	`283`	`+ query = query + " ON CLUSTER " + ch.config.ClusterName`
	`284`	`+ }`
	`285`	`+`
`282`	`286`	`if _, err := ch.conn.Exec(query); err != nil {`
`283`	`287`	`return &database.Error{OrigErr: err, Query: []byte(query)}`
`284`	`288`	`}`