Free cookie consent management tool by TermsFeed Policy Generator

source: branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive.DataAccess/3.4/HiveDao.cs @ 5786

Last change on this file since 5786 was 5786, checked in by cneumuel, 13 years ago

#1233

  • implemented correct numbering of BatchRuns
  • improvements in ExperimentManager
  • fixed bug in server (jobs were scheduled multiple times)
  • added exception handling for task in slave
  • improved timeout handling of jobs (LifecycleManager)
File size: 24.0 KB
Line 
1#region License Information
2/* HeuristicLab
3 * Copyright (C) 2002-2010 Heuristic and Evolutionary Algorithms Laboratory (HEAL)
4 *
5 * This file is part of HeuristicLab.
6 *
7 * HeuristicLab is free software: you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation, either version 3 of the License, or
10 * (at your option) any later version.
11 *
12 * HeuristicLab is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15 * GNU General Public License for more details.
16 *
17 * You should have received a copy of the GNU General Public License
18 * along with HeuristicLab. If not, see <http://www.gnu.org/licenses/>.
19 */
20#endregion
21
22using System;
23using System.Collections.Generic;
24using System.Linq;
25using System.Linq.Expressions;
26
27namespace HeuristicLab.Services.Hive.DataAccess {
28  using HeuristicLab.Services.Hive.Common.DataTransfer;
29  using HeuristicLab.Services.Hive.DataAccess.Properties;
30  using DT = HeuristicLab.Services.Hive.Common.DataTransfer;
31
32  public class HiveDao : IHiveDao {
33    public static HiveDataContext CreateContext() {
34      return new HiveDataContext(Settings.Default.HeuristicLab_Hive_LinqConnectionString);
35    }
36
37    public HiveDao() { }
38
39    #region Job Methods
40    public DT.Job GetJob(Guid id) {
41      using (var db = CreateContext()) {
42        return Convert.ToDto(db.Jobs.SingleOrDefault(x => x.JobId == id));
43      }
44    }
45
46    public IEnumerable<DT.Job> GetJobs(Expression<Func<Job, bool>> predicate) {
47      using (var db = CreateContext()) {
48        return db.Jobs.Where(predicate).Select(x => Convert.ToDto(x)).ToArray();
49      }
50    }
51
52    public Guid AddJob(DT.Job dto) {
53      using (var db = CreateContext()) {
54        var entity = Convert.ToEntity(dto);
55        db.Jobs.InsertOnSubmit(entity);
56        db.SubmitChanges();
57        foreach (Guid pluginId in dto.PluginsNeededIds) {
58          db.RequiredPlugins.InsertOnSubmit(new RequiredPlugin() { JobId = entity.JobId, PluginId = pluginId });
59        }
60        db.SubmitChanges();
61        return entity.JobId;
62      }
63    }
64
65    public void UpdateJob(DT.Job dto) {
66      using (var db = CreateContext()) {
67        var entity = db.Jobs.FirstOrDefault(x => x.JobId == dto.Id);
68        if (entity == null) db.Jobs.InsertOnSubmit(Convert.ToEntity(dto));
69        else Convert.ToEntity(dto, entity);
70        // todo: update required plugins
71        db.SubmitChanges();
72      }
73    }
74
75    public void DeleteJob(Guid id) {
76      using (var db = CreateContext()) {
77        var entity = db.Jobs.FirstOrDefault(x => x.JobId == id);
78        if (entity != null) db.Jobs.DeleteOnSubmit(entity);
79        db.SubmitChanges(); // JobData and child jobs are deleted by db-trigger
80      }
81    }
82
83    /// <summary>
84    /// returns all parent jobs which are waiting for their child jobs to finish
85    /// </summary>
86    /// <param name="resourceIds">list of resourceids which for which the jobs should be valid</param>
87    /// <param name="count">maximum number of jobs to return</param>
88    /// <param name="finished">if true, all parent jobs which have FinishWhenChildJobsFinished=true are returned, otherwise only FinishWhenChildJobsFinished=false are returned</param>
89    /// <returns></returns>
90    public IEnumerable<DT.Job> GetParentJobs(IEnumerable<Guid> resourceIds, int count, bool finished) {
91      using (var db = CreateContext()) {
92        var query = from ar in db.AssignedResources
93                    where resourceIds.Contains(ar.ResourceId)
94                       && ar.Job.State == JobState.Waiting
95                       && ar.Job.IsParentJob
96                       && (finished ? ar.Job.FinishWhenChildJobsFinished : !ar.Job.FinishWhenChildJobsFinished)
97                       && (from child in db.Jobs
98                           where child.ParentJobId == ar.Job.JobId
99                           select child.State == JobState.Finished
100                               || child.State == JobState.Aborted
101                               || child.State == JobState.Failed).All(x => x)
102                       && (from child in db.Jobs // avoid returning WaitForChildJobs jobs where no child-jobs exist (yet)
103                           where child.ParentJobId == ar.Job.JobId
104                           select child).Count() > 0
105                    orderby ar.Job.Priority descending
106                    select Convert.ToDto(ar.Job);
107        return count == 0 ? query.ToArray() : query.Take(count).ToArray();
108      }
109    }
110
111    public IEnumerable<DT.Job> GetWaitingJobs(DT.Slave slave, int count) {
112      using (var db = CreateContext()) {
113        var resourceIds = GetParentResources(slave.Id).Select(r => r.Id);
114        var waitingParentJobs = GetParentJobs(resourceIds, count, false);
115        if (count > 0 && waitingParentJobs.Count() >= count) return waitingParentJobs.Take(count).ToArray();
116
117        var query = from ar in db.AssignedResources
118                    where resourceIds.Contains(ar.ResourceId)
119                       && !(ar.Job.IsParentJob && ar.Job.FinishWhenChildJobsFinished)
120                       && ar.Job.State == JobState.Waiting
121                       && ar.Job.CoresNeeded <= slave.FreeCores
122                       && ar.Job.MemoryNeeded <= slave.FreeMemory
123                    orderby ar.Job.Priority descending
124                    select Convert.ToDto(ar.Job);
125        var waitingJobs = (count == 0 ? query : query.Take(count)).ToArray();
126        return waitingJobs.Union(waitingParentJobs).OrderByDescending(x => x.Priority);
127      }
128    }
129
130    public DT.Job UpdateJobState(Guid jobId, JobState jobState, Guid? slaveId, Guid? userId, string exception) {
131      using (var db = CreateContext()) {
132        var job = db.Jobs.SingleOrDefault(x => x.JobId == jobId);
133        job.State = jobState;
134        db.StateLogs.InsertOnSubmit(new StateLog {
135          JobId = jobId,
136          State = jobState,
137          SlaveId = slaveId,
138          UserId = userId,
139          Exception = exception,
140          DateTime = DateTime.Now
141        });
142        db.SubmitChanges();
143        job = db.Jobs.SingleOrDefault(x => x.JobId == jobId);
144        return Convert.ToDto(job);
145      }
146    }
147    #endregion
148
149    #region JobData Methods
150
151    public DT.JobData GetJobData(Guid id) {
152      using (var db = CreateContext()) {
153        return Convert.ToDto(db.JobDatas.SingleOrDefault(x => x.JobId == id));
154      }
155    }
156
157    public IEnumerable<DT.JobData> GetJobDatas(Expression<Func<JobData, bool>> predicate) {
158      using (var db = CreateContext()) {
159        return db.JobDatas.Where(predicate).Select(x => Convert.ToDto(x)).ToArray();
160      }
161    }
162
163    public Guid AddJobData(DT.JobData dto) {
164      using (var db = CreateContext()) {
165        var entity = Convert.ToEntity(dto);
166        db.JobDatas.InsertOnSubmit(entity);
167        db.SubmitChanges();
168        return entity.JobId;
169      }
170    }
171
172    public void UpdateJobData(DT.JobData dto) {
173      using (var db = CreateContext()) {
174        var entity = db.JobDatas.FirstOrDefault(x => x.JobId == dto.JobId);
175        if (entity == null) db.JobDatas.InsertOnSubmit(Convert.ToEntity(dto));
176        else Convert.ToEntity(dto, entity);
177        db.SubmitChanges();
178      }
179    }
180
181    public void DeleteJobData(Guid id) {
182      using (var db = CreateContext()) {
183        var entity = db.JobDatas.FirstOrDefault(x => x.JobId == id); // check if all the byte[] is loaded into memory here. otherwise work around to delete without loading it
184        if (entity != null) db.JobDatas.DeleteOnSubmit(entity);
185        db.SubmitChanges();
186      }
187    }
188    #endregion
189
190    #region StateLog Methods
191
192    public DT.StateLog GetStateLog(Guid id) {
193      using (var db = CreateContext()) {
194        return Convert.ToDto(db.StateLogs.SingleOrDefault(x => x.StateLogId == id));
195      }
196    }
197
198    public IEnumerable<DT.StateLog> GetStateLogs(Expression<Func<StateLog, bool>> predicate) {
199      using (var db = CreateContext()) {
200        return db.StateLogs.Where(predicate).Select(x => Convert.ToDto(x)).ToArray();
201      }
202    }
203
204    public Guid AddStateLog(DT.StateLog dto) {
205      using (var db = CreateContext()) {
206        var entity = Convert.ToEntity(dto);
207        db.StateLogs.InsertOnSubmit(entity);
208        db.SubmitChanges();
209        return entity.StateLogId;
210      }
211    }
212
213    public void UpdateStateLog(DT.StateLog dto) {
214      using (var db = CreateContext()) {
215        var entity = db.StateLogs.FirstOrDefault(x => x.StateLogId == dto.Id);
216        if (entity == null) db.StateLogs.InsertOnSubmit(Convert.ToEntity(dto));
217        else Convert.ToEntity(dto, entity);
218        db.SubmitChanges();
219      }
220    }
221
222    public void DeleteStateLog(Guid id) {
223      using (var db = CreateContext()) {
224        var entity = db.StateLogs.FirstOrDefault(x => x.StateLogId == id);
225        if (entity != null) db.StateLogs.DeleteOnSubmit(entity);
226        db.SubmitChanges();
227      }
228    }
229    #endregion
230
231    #region HiveExperiment Methods
232    public DT.HiveExperiment GetHiveExperiment(Guid id) {
233      using (var db = CreateContext()) {
234        return Convert.ToDto(db.HiveExperiments.SingleOrDefault(x => x.HiveExperimentId == id));
235      }
236    }
237
238    public IEnumerable<DT.HiveExperiment> GetHiveExperiments(Expression<Func<HiveExperiment, bool>> predicate) {
239      using (var db = CreateContext()) {
240        return db.HiveExperiments.Where(predicate).Select(x => Convert.ToDto(x)).ToArray();
241      }
242    }
243
244    public Guid AddHiveExperiment(DT.HiveExperiment dto) {
245      using (var db = CreateContext()) {
246        var entity = Convert.ToEntity(dto);
247        db.HiveExperiments.InsertOnSubmit(entity);
248        db.SubmitChanges();
249        return entity.HiveExperimentId;
250      }
251    }
252
253    public void UpdateHiveExperiment(DT.HiveExperiment dto) {
254      using (var db = CreateContext()) {
255        var entity = db.HiveExperiments.FirstOrDefault(x => x.HiveExperimentId == dto.Id);
256        if (entity == null) db.HiveExperiments.InsertOnSubmit(Convert.ToEntity(dto));
257        else Convert.ToEntity(dto, entity);
258        db.SubmitChanges();
259      }
260    }
261
262    public void DeleteHiveExperiment(Guid id) {
263      using (var db = CreateContext()) {
264        var entity = db.HiveExperiments.FirstOrDefault(x => x.HiveExperimentId == id);
265        if (entity != null) db.HiveExperiments.DeleteOnSubmit(entity);
266        db.SubmitChanges();
267      }
268    }
269    #endregion
270
271    #region HiveExperimentPermission Methods
272
273    public DT.HiveExperimentPermission GetHiveExperimentPermission(Guid hiveExperimentId, Guid grantedUserId) {
274      using (var db = CreateContext()) {
275        return Convert.ToDto(db.HiveExperimentPermissions.SingleOrDefault(x => x.HiveExperimentId == hiveExperimentId && x.GrantedUserId == grantedUserId));
276      }
277    }
278
279    public IEnumerable<DT.HiveExperimentPermission> GetHiveExperimentPermissions(Expression<Func<HiveExperimentPermission, bool>> predicate) {
280      using (var db = CreateContext()) {
281        return db.HiveExperimentPermissions.Where(predicate).Select(x => Convert.ToDto(x)).ToArray();
282      }
283    }
284
285    public void AddHiveExperimentPermission(DT.HiveExperimentPermission dto) {
286      using (var db = CreateContext()) {
287        var entity = Convert.ToEntity(dto);
288        db.HiveExperimentPermissions.InsertOnSubmit(entity);
289        db.SubmitChanges();
290      }
291    }
292
293    public void UpdateHiveExperimentPermission(DT.HiveExperimentPermission dto) {
294      using (var db = CreateContext()) {
295        var entity = db.HiveExperimentPermissions.FirstOrDefault(x => x.HiveExperimentId == dto.HiveExperimentId && x.GrantedUserId == dto.GrantedUserId);
296        if (entity == null) db.HiveExperimentPermissions.InsertOnSubmit(Convert.ToEntity(dto));
297        else Convert.ToEntity(dto, entity);
298        db.SubmitChanges();
299      }
300    }
301
302    public void DeleteHiveExperimentPermission(Guid hiveExperimentId, Guid grantedUserId) {
303      using (var db = CreateContext()) {
304        var entity = db.HiveExperimentPermissions.FirstOrDefault(x => x.HiveExperimentId == hiveExperimentId && x.GrantedUserId == grantedUserId);
305        if (entity != null) db.HiveExperimentPermissions.DeleteOnSubmit(entity);
306        db.SubmitChanges();
307      }
308    }
309
310    #endregion
311
312    #region Plugin Methods
313    public DT.Plugin GetPlugin(Guid id) {
314      using (var db = CreateContext()) {
315        return Convert.ToDto(db.Plugins.SingleOrDefault(x => x.PluginId == id));
316      }
317    }
318
319    public IEnumerable<DT.Plugin> GetPlugins(Expression<Func<Plugin, bool>> predicate) {
320      using (var db = CreateContext()) {
321        return db.Plugins.Where(predicate).Select(x => Convert.ToDto(x)).ToArray();
322      }
323    }
324
325    public Guid AddPlugin(DT.Plugin dto) {
326      using (var db = CreateContext()) {
327        var entity = Convert.ToEntity(dto);
328        db.Plugins.InsertOnSubmit(entity);
329        db.SubmitChanges();
330        return entity.PluginId;
331      }
332    }
333
334    public void UpdatePlugin(DT.Plugin dto) {
335      using (var db = CreateContext()) {
336        var entity = db.Plugins.FirstOrDefault(x => x.PluginId == dto.Id);
337        if (entity == null) db.Plugins.InsertOnSubmit(Convert.ToEntity(dto));
338        else Convert.ToEntity(dto, entity);
339        db.SubmitChanges();
340      }
341    }
342
343    public void DeletePlugin(Guid id) {
344      using (var db = CreateContext()) {
345        var entity = db.Plugins.FirstOrDefault(x => x.PluginId == id);
346        if (entity != null) db.Plugins.DeleteOnSubmit(entity);
347        db.SubmitChanges();
348      }
349    }
350    #endregion
351
352    #region PluginData Methods
353
354    public DT.PluginData GetPluginData(Guid id) {
355      using (var db = CreateContext()) {
356        return Convert.ToDto(db.PluginDatas.SingleOrDefault(x => x.PluginDataId == id));
357      }
358    }
359
360    public IEnumerable<DT.PluginData> GetPluginDatas(Expression<Func<PluginData, bool>> predicate) {
361      using (var db = CreateContext()) {
362        return db.PluginDatas.Where(predicate).Select(x => Convert.ToDto(x)).ToArray();
363      }
364    }
365
366    public Guid AddPluginData(DT.PluginData dto) {
367      using (var db = CreateContext()) {
368        var entity = Convert.ToEntity(dto);
369        db.PluginDatas.InsertOnSubmit(entity);
370        db.SubmitChanges();
371        return entity.PluginDataId;
372      }
373    }
374
375    public void UpdatePluginData(DT.PluginData dto) {
376      using (var db = CreateContext()) {
377        var entity = db.PluginDatas.FirstOrDefault(x => x.PluginId == dto.PluginId);
378        if (entity == null) db.PluginDatas.InsertOnSubmit(Convert.ToEntity(dto));
379        else Convert.ToEntity(dto, entity);
380        db.SubmitChanges();
381      }
382    }
383
384    public void DeletePluginData(Guid id) {
385      using (var db = CreateContext()) {
386        var entity = db.PluginDatas.FirstOrDefault(x => x.PluginDataId == id); // todo: check if all the byte[] is loaded into memory here. otherwise work around to delete without loading it
387        if (entity != null) db.PluginDatas.DeleteOnSubmit(entity);
388        db.SubmitChanges();
389      }
390    }
391    #endregion
392
393    #region Slave Methods
394    public DT.Slave GetSlave(Guid id) {
395      using (var db = CreateContext()) {
396        return Convert.ToDto(db.Resources.OfType<Slave>().SingleOrDefault(x => x.ResourceId == id));
397      }
398    }
399
400    public IEnumerable<DT.Slave> GetSlaves(Expression<Func<Slave, bool>> predicate) {
401      using (var db = CreateContext()) {
402        return db.Resources.OfType<Slave>().Where(predicate).Select(x => Convert.ToDto(x)).ToArray();
403      }
404    }
405
406    public Guid AddSlave(DT.Slave dto) {
407      using (var db = CreateContext()) {
408        var entity = Convert.ToEntity(dto);
409        db.Resources.InsertOnSubmit(entity);
410        db.SubmitChanges();
411        return entity.ResourceId;
412      }
413    }
414
415    public void UpdateSlave(DT.Slave dto) {
416      using (var db = CreateContext()) {
417        var entity = db.Resources.OfType<Slave>().FirstOrDefault(x => x.ResourceId == dto.Id);
418        if (entity == null) db.Resources.InsertOnSubmit(Convert.ToEntity(dto));
419        else Convert.ToEntity(dto, entity);
420        db.SubmitChanges();
421      }
422    }
423
424    public void DeleteSlave(Guid id) {
425      using (var db = CreateContext()) {
426        var entity = db.Resources.OfType<Slave>().FirstOrDefault(x => x.ResourceId == id);
427        if (entity != null) db.Resources.DeleteOnSubmit(entity);
428        db.SubmitChanges();
429      }
430    }
431    #endregion
432
433    #region SlaveGroup Methods
434    public DT.SlaveGroup GetSlaveGroup(Guid id) {
435      using (var db = CreateContext()) {
436        return Convert.ToDto(db.Resources.OfType<SlaveGroup>().SingleOrDefault(x => x.ResourceId == id));
437      }
438    }
439
440    public IEnumerable<DT.SlaveGroup> GetSlaveGroups(Expression<Func<SlaveGroup, bool>> predicate) {
441      using (var db = CreateContext()) {
442        return db.Resources.OfType<SlaveGroup>().Where(predicate).Select(x => Convert.ToDto(x)).ToArray();
443      }
444    }
445
446    public Guid AddSlaveGroup(DT.SlaveGroup dto) {
447      using (var db = CreateContext()) {
448        if (dto.Id == Guid.Empty)
449          dto.Id = Guid.NewGuid();
450        var entity = Convert.ToEntity(dto);
451        db.Resources.InsertOnSubmit(entity);
452        db.SubmitChanges();
453        return entity.ResourceId;
454      }
455    }
456
457    public void UpdateSlaveGroup(DT.SlaveGroup dto) {
458      using (var db = CreateContext()) {
459        var entity = db.Resources.OfType<SlaveGroup>().FirstOrDefault(x => x.ResourceId == dto.Id);
460        if (entity == null) db.Resources.InsertOnSubmit(Convert.ToEntity(dto));
461        else Convert.ToEntity(dto, entity);
462        db.SubmitChanges();
463      }
464    }
465
466    public void DeleteSlaveGroup(Guid id) {
467      using (var db = CreateContext()) {
468        var entity = db.Resources.OfType<SlaveGroup>().FirstOrDefault(x => x.ResourceId == id);
469        if (entity != null) {
470          if (db.Resources.Where(r => r.ParentResourceId == id).Count() > 0) {
471            throw new DaoException("Cannot delete SlaveGroup as long as there are Slaves in the group");
472          }
473          db.Resources.DeleteOnSubmit(entity);
474        }
475        db.SubmitChanges();
476      }
477    }
478    #endregion
479
480    #region Resource Methods
481    public DT.Resource GetResource(Guid id) {
482      using (var db = CreateContext()) {
483        return Convert.ToDto(db.Resources.SingleOrDefault(x => x.ResourceId == id));
484      }
485    }
486
487    public IEnumerable<DT.Resource> GetResources(Expression<Func<Resource, bool>> predicate) {
488      using (var db = CreateContext()) {
489        return db.Resources.Where(predicate).Select(x => Convert.ToDto(x)).ToArray();
490      }
491    }
492
493    public Guid AddResource(DT.Resource dto) {
494      using (var db = CreateContext()) {
495        var entity = Convert.ToEntity(dto);
496        db.Resources.InsertOnSubmit(entity);
497        db.SubmitChanges();
498        return entity.ResourceId;
499      }
500    }
501
502    public void UpdateResource(DT.Resource dto) {
503      using (var db = CreateContext()) {
504        var entity = db.Resources.FirstOrDefault(x => x.ResourceId == dto.Id);
505        if (entity == null) db.Resources.InsertOnSubmit(Convert.ToEntity(dto));
506        else Convert.ToEntity(dto, entity);
507        db.SubmitChanges();
508      }
509    }
510
511    public void DeleteResource(Guid id) {
512      using (var db = CreateContext()) {
513        var entity = db.Resources.FirstOrDefault(x => x.ResourceId == id);
514        if (entity != null) db.Resources.DeleteOnSubmit(entity);
515        db.SubmitChanges();
516      }
517    }
518
519    public void AssignJobToResource(Guid jobId, Guid resourceId) {
520      using (var db = CreateContext()) {
521        var job = db.Jobs.Where(x => x.JobId == jobId).Single();
522        job.AssignedResources.Add(new AssignedResource() { JobId = jobId, ResourceId = resourceId });
523        db.SubmitChanges();
524      }
525    }
526
527    public IEnumerable<DT.Resource> GetAssignedResources(Guid jobId) {
528      using (var db = CreateContext()) {
529        var job = db.Jobs.Where(x => x.JobId == jobId).Single();
530        return job.AssignedResources.Select(x => Convert.ToDto(x.Resource)).ToArray();
531      }
532    }
533
534    /// <summary>
535    /// Returns all parent resources of a resource (the given resource is also added)
536    /// </summary>
537    private IEnumerable<DT.Resource> GetParentResources(Guid resourceId) {
538      using (var db = CreateContext()) {
539        var resources = new List<Resource>();
540        CollectParentResources(resources, db.Resources.Where(r => r.ResourceId == resourceId).Single());
541        return resources.Select(r => Convert.ToDto(r)).ToArray();
542      }
543    }
544
545    private void CollectParentResources(List<Resource> resources, Resource resource) {
546      if (resource == null) return;
547      resources.Add(resource);
548      CollectParentResources(resources, resource.ParentResource);
549    }
550    #endregion
551
552    #region Authorization Methods
553    public Permission GetPermissionForJob(Guid jobId, Guid userId) {
554      using (var db = CreateContext()) {
555        return GetPermissionForExperiment(GetExperimentForJob(jobId), userId);
556      }
557    }
558
559    public Permission GetPermissionForExperiment(Guid experimentId, Guid userId) {
560      using (var db = CreateContext()) {
561        HiveExperimentPermission permission = db.HiveExperimentPermissions.SingleOrDefault(p => p.HiveExperimentId == experimentId && p.GrantedUserId == userId);
562        return permission != null ? permission.Permission : Permission.NotAllowed;
563      }
564    }
565
566    public Guid GetExperimentForJob(Guid jobId) {
567      using (var db = CreateContext()) {
568        var job = db.Jobs.SingleOrDefault(j => j.JobId == jobId);
569        if (job.ParentJobId.HasValue) {
570          return GetExperimentForJob(job.ParentJobId.Value);
571        } else {
572          return db.HiveExperiments.SingleOrDefault(he => he.RootJobId == jobId).HiveExperimentId;
573        }
574      }
575    }
576
577    #endregion
578
579    #region Lifecycle Methods
580    public DateTime GetLastCleanup() {
581      using (var db = CreateContext()) {
582        var entity = db.Lifecycles.SingleOrDefault();
583        return entity != null ? entity.LastCleanup : DateTime.MinValue;
584      }
585    }
586
587    public void SetLastCleanup(DateTime datetime) {
588      using (var db = CreateContext()) {
589        var entity = db.Lifecycles.SingleOrDefault();
590        if (entity != null) {
591          entity.LastCleanup = datetime;
592        } else {
593          entity = new Lifecycle();
594          entity.LifecycleId = 0; // always only one entry with ID:0
595          entity.LastCleanup = datetime;
596          db.Lifecycles.InsertOnSubmit(entity);
597        }
598        db.SubmitChanges();
599      }
600    }
601    #endregion
602
603    #region AppointmentMethods
604    public Appointment GetAppointment(Guid id) {
605      using (var db = CreateContext()) {
606        return Convert.ToDto(db.UptimeCalendars.SingleOrDefault(x => x.UptimeCalendarId == id));
607      }
608    }
609
610    public IEnumerable<Appointment> GetAppointments(Expression<Func<UptimeCalendar, bool>> predicate) {
611      using (var db = CreateContext()) {
612        return db.UptimeCalendars.Where(predicate).Select(x => Convert.ToDto(x)).ToArray();
613      }
614    }
615
616    public Guid AddAppointment(Appointment dto) {
617      using (var db = CreateContext()) {
618        var entity = Convert.ToEntity(dto);
619        db.UptimeCalendars.InsertOnSubmit(entity);
620        db.SubmitChanges();
621        return entity.UptimeCalendarId;
622      }
623    }
624
625    public void UpdateAppointment(Appointment dto) {
626      using (var db = CreateContext()) {
627        var entity = db.UptimeCalendars.FirstOrDefault(x => x.UptimeCalendarId == dto.Id);
628        if (entity == null) db.UptimeCalendars.InsertOnSubmit(Convert.ToEntity(dto));
629        else Convert.ToEntity(dto, entity);
630        db.SubmitChanges();
631      }
632    }
633
634    public void DeleteAppointment(Guid id) {
635      using (var db = CreateContext()) {
636        var entity = db.UptimeCalendars.FirstOrDefault(x => x.UptimeCalendarId == id);
637        if (entity != null) db.UptimeCalendars.DeleteOnSubmit(entity);
638        db.SubmitChanges();
639      }
640    }
641    #endregion
642  }
643}
Note: See TracBrowser for help on using the repository browser.