fix: drop table if exists

go-faster · Jan 3, 2024 · b3d0860 · b3d0860
1 parent 41da4a6
commit b3d0860
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/chstorage/schema.go b/internal/chstorage/schema.go
@@ -186,7 +186,7 @@ func (t Tables) Create(ctx context.Context, c chClient) error {
 			)
 			if err := c.Do(ctx, ch.Query{
 				Logger: zctx.From(ctx).Named("ch"),
-				Body:   fmt.Sprintf("DROP TABLE %s", name),
+				Body:   fmt.Sprintf("DROP TABLE IF EXISTS %s", name),
 			}); err != nil {
 				return errors.Wrapf(err, "drop %q", name)
 			}