Skip to content

Commit edbf5b9

Browse files
authored
Merge pull request #247 from dario-hd/add-index-on-set
Create index on the "set" table
2 parents aec4776 + 7a808b8 commit edbf5b9

File tree

2 files changed

+16
-2
lines changed

2 files changed

+16
-2
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
SET search_path = 'hangfire';
2+
3+
DO
4+
$$
5+
BEGIN
6+
IF EXISTS(SELECT 1 FROM "schema" WHERE "version"::integer >= 17) THEN
7+
RAISE EXCEPTION 'version-already-applied';
8+
END IF;
9+
END
10+
$$;
11+
12+
CREATE INDEX IF NOT EXISTS ix_hangfire_set_key_score ON "set" (key, score);
13+
14+
RESET search_path;

tests/Hangfire.PostgreSql.Tests/PostgreSqlInstallerFacts.cs

+2-2
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ public void InstallingSchemaUpdatesVersionAndShouldNotThrowAnException()
1919
PostgreSqlObjectsInstaller.Install(connection, schemaName);
2020

2121
int lastVersion = connection.Query<int>($@"SELECT version FROM ""{schemaName}"".""schema""").Single();
22-
Assert.Equal(16, lastVersion);
22+
Assert.Equal(17, lastVersion);
2323

2424
connection.Execute($@"DROP SCHEMA ""{schemaName}"" CASCADE;");
2525
});
@@ -38,7 +38,7 @@ public void InstallingSchemaWithCapitalsUpdatesVersionAndShouldNotThrowAnExcepti
3838
PostgreSqlObjectsInstaller.Install(connection, schemaName);
3939

4040
int lastVersion = connection.Query<int>($@"SELECT version FROM ""{schemaName}"".""schema""").Single();
41-
Assert.Equal(16, lastVersion);
41+
Assert.Equal(17, lastVersion);
4242

4343
connection.Execute($@"DROP SCHEMA ""{schemaName}"" CASCADE;");
4444
});

0 commit comments

Comments
 (0)