Skip to content

Commit 7d0960b

Browse files
authored
Merge pull request #39 from wwwu/master
Dictionary Key name ignore case
2 parents 53afcdf + 285656f commit 7d0960b

3 files changed

Lines changed: 99 additions & 74 deletions

File tree

src/main/Hangfire.Storage.SQLite/HangfireSQLiteConnection.cs

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ public HangfireSQLiteConnection(HangfireDbContext database, PersistentJobQueuePr
2828
{
2929
}
3030

31-
#pragma warning disable 1591
31+
#pragma warning disable 1591
3232
public HangfireSQLiteConnection(
3333
HangfireDbContext database,
3434
SQLiteStorageOptions storageOptions,
@@ -104,7 +104,7 @@ public override string CreateExpiredJob(Job job, IDictionary<string, string> par
104104

105105
var parametersArray = parameters.ToArray();
106106

107-
foreach (var parameter in parametersArray)
107+
foreach (var parameter in parametersArray)
108108
{
109109
DbContext.Database.Insert(new JobParameter()
110110
{
@@ -158,7 +158,7 @@ public override Dictionary<string, string> GetAllEntriesFromHash(string key)
158158
.Where(_ => _.Key == key)
159159
.Select(_ => new { _.Field, _.Value })
160160
.ToList()
161-
.ToDictionary(x => x.Field, x => x.Value);
161+
.ToDictionary(x => x.Field, x => x.Value, StringComparer.OrdinalIgnoreCase);
162162

163163
return result.Count != 0 ? result : null;
164164
}
@@ -310,11 +310,14 @@ public override StateData GetStateData(string jobId)
310310
if (state == null)
311311
return null;
312312

313+
var data = JsonConvert.DeserializeObject<Dictionary<string, string>>(state.Data);
314+
data = new Dictionary<string, string>(data, StringComparer.OrdinalIgnoreCase);
315+
313316
return new StateData
314317
{
315318
Name = state.Name,
316319
Reason = state.Reason,
317-
Data = JsonConvert.DeserializeObject<Dictionary<string, string>>(state.Data)
320+
Data = data
318321
};
319322
}
320323

@@ -382,7 +385,7 @@ public override void SetJobParameter(string id, string name, string value)
382385
jobParameter.Value = value;
383386
DbContext.Database.Update(jobParameter);
384387
}
385-
else
388+
else
386389
{
387390
var newParameter = new JobParameter()
388391
{

src/main/Hangfire.Storage.SQLite/SQLiteDistributedLock.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ public class SQLiteDistributedLock : IDisposable
1616
private static readonly ILog Logger = LogProvider.For<SQLiteDistributedLock>();
1717

1818
private static readonly ThreadLocal<Dictionary<string, int>> AcquiredLocks
19-
= new ThreadLocal<Dictionary<string, int>>(() => new Dictionary<string, int>());
19+
= new ThreadLocal<Dictionary<string, int>>(() => new Dictionary<string, int>(StringComparer.OrdinalIgnoreCase));
2020

2121
private readonly string _resource;
2222

0 commit comments

Comments
 (0)