Skip to content

Commit 2d91750

Browse files
committed
Remove system variable from SetVersion method
1 parent aa32239 commit 2d91750

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

database/bigquery/bigquery.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -272,10 +272,9 @@ func (b *BigQuery) SetVersion(version int, dirty bool) error {
272272
ctx := context.Background()
273273

274274
query := fmt.Sprintf(`
275-
SET @@dataset_id = '%[1]s';
276275
BEGIN TRANSACTION;
277-
DELETE FROM %[2]s WHERE true;
278-
INSERT INTO %[2]s (version, dirty) VALUES (%[3]d, %[4]t);
276+
DELETE FROM `+"`%[1]s.%[2]s`"+` WHERE true;
277+
INSERT INTO `+"`%[1]s.%[2]s`"+` (version, dirty) VALUES (%[3]d, %[4]t);
279278
COMMIT TRANSACTION;
280279
`, b.config.DatasetID, b.config.MigrationsTable, version, dirty)
281280

0 commit comments

Comments
 (0)