SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

fix schema for quartz store

Browse source
This commit is contained in:
Mohamed Ali 2024-02-02 14:49:34 +03:00
parent 011233b17d
commit 6cddfabf6b
2 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

0
src/modules/Elsa.Quartz.EntityFrameworkCore.PostgreSql/SqlServerQuartzDbContext.cs → src/modules/Elsa.Quartz.EntityFrameworkCore.PostgreSql/PostgreSqlQuartzDbContext.cs
View file

11
src/modules/Elsa.Quartz.EntityFrameworkCore.PostgreSql/SqlServerQuartzExtensions.cs → src/modules/Elsa.Quartz.EntityFrameworkCore.PostgreSql/PostgreSqlQuartzExtensions.cs
View file

@ -18,7 +18,7 @@ public static class PostgreSqlQuartzExtensions
/// <summary>
/// Configures the <see cref="QuartzFeature"/> to use the PostgreSQL job store.
/// </summary>
public static QuartzFeature UseSqlServer(this QuartzFeature feature, string connectionString = Constants.DefaultConnectionString, bool useClustering = true)
public static QuartzFeature UsePostgreSql(this QuartzFeature feature, string connectionString = Constants.DefaultConnectionString, bool useClustering = true)
{
feature.Services.AddDbContextFactory<PostgreSqlQuartzDbContext>(options =>
{
@ -31,8 +31,13 @@ public static class PostgreSqlQuartzExtensions
quartz.UsePersistentStore(store =>
{
store.UseNewtonsoftJsonSerializer();
store.UsePostgres(connectionString);
store.UsePostgres(options =>
{
options.ConnectionString = connectionString;
options.TablePrefix = "quartz.qrtz_";
});
if (useClustering)
store.UseClustering();
});