|
@@ -81,12 +81,15 @@ public class DbJobPersistence : IJobPersistence
|
|
|
case PersistenceBehavior.Appended:
|
|
case PersistenceBehavior.Appended:
|
|
|
jobRepository.AsInsertable(jobDetail).ExecuteCommand();
|
|
jobRepository.AsInsertable(jobDetail).ExecuteCommand();
|
|
|
break;
|
|
break;
|
|
|
|
|
+
|
|
|
case PersistenceBehavior.Updated:
|
|
case PersistenceBehavior.Updated:
|
|
|
jobRepository.AsUpdateable(jobDetail).WhereColumns(u => new { u.JobId }).IgnoreColumns(u => new { u.Id }).ExecuteCommand();
|
|
jobRepository.AsUpdateable(jobDetail).WhereColumns(u => new { u.JobId }).IgnoreColumns(u => new { u.Id }).ExecuteCommand();
|
|
|
break;
|
|
break;
|
|
|
|
|
+
|
|
|
case PersistenceBehavior.Removed:
|
|
case PersistenceBehavior.Removed:
|
|
|
jobRepository.AsDeleteable().Where(u => u.JobId == jobDetail.JobId).ExecuteCommand();
|
|
jobRepository.AsDeleteable().Where(u => u.JobId == jobDetail.JobId).ExecuteCommand();
|
|
|
break;
|
|
break;
|
|
|
|
|
+
|
|
|
default:
|
|
default:
|
|
|
throw new ArgumentOutOfRangeException();
|
|
throw new ArgumentOutOfRangeException();
|
|
|
}
|
|
}
|
|
@@ -106,12 +109,15 @@ public class DbJobPersistence : IJobPersistence
|
|
|
case PersistenceBehavior.Appended:
|
|
case PersistenceBehavior.Appended:
|
|
|
triggerRepository.AsInsertable(jobTrigger).ExecuteCommand();
|
|
triggerRepository.AsInsertable(jobTrigger).ExecuteCommand();
|
|
|
break;
|
|
break;
|
|
|
|
|
+
|
|
|
case PersistenceBehavior.Updated:
|
|
case PersistenceBehavior.Updated:
|
|
|
triggerRepository.AsUpdateable(jobTrigger).WhereColumns(u => new { u.TriggerId, u.JobId }).IgnoreColumns(u => new { u.Id }).ExecuteCommand();
|
|
triggerRepository.AsUpdateable(jobTrigger).WhereColumns(u => new { u.TriggerId, u.JobId }).IgnoreColumns(u => new { u.Id }).ExecuteCommand();
|
|
|
break;
|
|
break;
|
|
|
|
|
+
|
|
|
case PersistenceBehavior.Removed:
|
|
case PersistenceBehavior.Removed:
|
|
|
triggerRepository.AsDeleteable().Where(u => u.TriggerId == jobTrigger.TriggerId && u.JobId == jobTrigger.JobId).ExecuteCommand();
|
|
triggerRepository.AsDeleteable().Where(u => u.TriggerId == jobTrigger.TriggerId && u.JobId == jobTrigger.JobId).ExecuteCommand();
|
|
|
break;
|
|
break;
|
|
|
|
|
+
|
|
|
default:
|
|
default:
|
|
|
throw new ArgumentOutOfRangeException();
|
|
throw new ArgumentOutOfRangeException();
|
|
|
}
|
|
}
|