asdctool/src/main/java/org/openecomp/sdc/asdctool/migration/service/SdcRepoService.java

   1 package org.openecomp.sdc.asdctool.migration.service;
   2
   3 import org.openecomp.sdc.asdctool.migration.core.DBVersion;
   4 import org.openecomp.sdc.be.dao.cassandra.MigrationTasksDao;
   5 import org.openecomp.sdc.be.resources.data.MigrationTaskEntry;
   6
   7 import java.math.BigInteger;
   8
   9 public class SdcRepoService {
  10
  11     private MigrationTasksDao migrationTasksDao;
  12
  13     public SdcRepoService(MigrationTasksDao migrationTasksDao) {
  14         this.migrationTasksDao = migrationTasksDao;
  15     }
  16
  17     public DBVersion getLatestDBVersion() {
  18         BigInteger currentMajorVersion = DBVersion.CURRENT_VERSION.getMajor();
  19         BigInteger latestMinorVersion = migrationTasksDao.getLatestMinorVersion(currentMajorVersion);
  20         return latestMinorVersion == null ? DBVersion.from(currentMajorVersion, BigInteger.valueOf(Integer.MIN_VALUE)) : DBVersion.from(currentMajorVersion, latestMinorVersion);
  21     }
  22
  23     public void clearTasksForCurrentMajor() {
  24         BigInteger currentMajorVersion = DBVersion.CURRENT_VERSION.getMajor();
  25         migrationTasksDao.deleteAllTasksForVersion(currentMajorVersion);
  26     }
  27
  28     public void createMigrationTask(MigrationTaskEntry migrationTaskEntry) {
  29         migrationTasksDao.createMigrationTask(migrationTaskEntry);
  30     }
  31
  32
  33
  34 }