catalog-dao/src/main/java/org/openecomp/sdc/be/dao/cassandra/MigrationTasksAccessor.java

   1 package org.openecomp.sdc.be.dao.cassandra;
   2
   3 import com.datastax.driver.core.ResultSet;
   4 import com.datastax.driver.mapping.annotations.Accessor;
   5 import com.datastax.driver.mapping.annotations.Param;
   6 import com.datastax.driver.mapping.annotations.Query;
   7
   8 @Accessor
   9 public interface MigrationTasksAccessor {
  10
  11     @Query("SELECT minor_version FROM sdcrepository.migrationTasks WHERE major_version = :majorVersion order by minor_version desc limit 1")
  12     ResultSet getLatestMinorVersion(@Param("majorVersion") Long majorVersion);
  13
  14     @Query("DELETE FROM sdcrepository.migrationTasks WHERE major_version = :majorVersion")
  15     void deleteTasksForMajorVersion(@Param("majorVersion") Long majorVersion);
  16
  17 }