Changeset 12551 for branches/HiveStatistics/sources/HeuristicLab.Services.Hive.DataAccess/3.3/Daos/HiveStatistics/FactTaskDao.cs
- Timestamp:
- 06/30/15 13:12:07 (9 years ago)
- Location:
- branches/HiveStatistics/sources
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/HiveStatistics/sources
-
branches/HiveStatistics/sources/HeuristicLab.Services.Hive.DataAccess
- Property svn:mergeinfo changed
/branches/HeuristicLab.DatasetRefactor/sources/HeuristicLab.Services.Hive.DataAccess (added) merged: 12031 /trunk/sources/HeuristicLab.Services.Hive.DataAccess (added) merged: 12524
- Property svn:mergeinfo changed
-
branches/HiveStatistics/sources/HeuristicLab.Services.Hive.DataAccess/3.3/Daos/HiveStatistics/FactTaskDao.cs
r12516 r12551 27 27 namespace HeuristicLab.Services.Hive.DataAccess.Daos.HiveStatistics { 28 28 public class FactTaskDao : GenericDao<Guid, FactTask> { 29 30 private static readonly TaskState[] CompletedStates = { TaskState.Finished, TaskState.Aborted, TaskState.Failed }; 31 32 private Table<DimClient> DimClientTable { 33 get { return DataContext.GetTable<DimClient>(); } 34 } 35 private Table<DimJob> DimJobTable { 36 get { return DataContext.GetTable<DimJob>(); } 37 } 38 29 39 private const string BatchDeleteQuery = 30 40 @"DELETE FROM [statistics].[FactTask] … … 52 62 } 53 63 64 public IQueryable<FactTask> GetTasksWithException() { 65 return Table.Where(x => x.Exception.Trim() != string.Empty); 66 } 67 68 public IQueryable<FactTask> GetByGroupId(Guid id) { 69 return from factTask in Table 70 join client in DimClientTable on factTask.LastClientId equals client.Id 71 where client.ResourceGroupId == id 72 select factTask; 73 } 74 75 public IQueryable<FactTask> GetByUserId(Guid id) { 76 return from factTask in Table 77 join job in DimJobTable on factTask.JobId equals job.JobId 78 where job.UserId == id 79 select factTask; 80 } 81 82 public IQueryable<FactTask> GetCompletedTasks() { 83 return Table.Where(x => CompletedStates.Contains(x.TaskState)); 84 } 85 54 86 public override void Delete(IEnumerable<Guid> ids) { 55 87 string paramIds = string.Join(",", ids.Select(x => string.Format("'{0}'", x)));
Note: See TracChangeset
for help on using the changeset viewer.