openecomp-be/tools/migration/1702_to_1707_zusammen/src/main/java/org/openecomp/core/migration/util/marker/MigrationMarker.java

   1 package org.openecomp.core.migration.util.marker;
   2
   3 import com.datastax.driver.mapping.annotations.Accessor;
   4 import com.datastax.driver.mapping.annotations.Query;
   5 import org.openecomp.core.migration.MigrationMain;
   6 import org.openecomp.core.nosqldb.api.NoSqlDb;
   7 import org.openecomp.core.nosqldb.factory.NoSqlDbFactory;
   8 import org.openecomp.sdc.logging.api.Logger;
   9 import org.openecomp.sdc.logging.api.LoggerFactory;
  10
  11 /**
  12  * @author katyr
  13  * @since May 01, 2017
  14  */
  15
  16 public class MigrationMarker {
  17
  18   private static Logger logger = LoggerFactory.getLogger(MigrationMain.class);
  19
  20   private static final NoSqlDb noSqlDb = NoSqlDbFactory.getInstance().createInterface();
  21   private static final MigrationTableAccessor accessor =
  22       noSqlDb.getMappingManager().createAccessor(MigrationMarker.MigrationTableAccessor.class);
  23
  24   public static Boolean isMigrated() {
  25
  26     MigrationMarkerEntity result = accessor.isMigrated();
  27     if (result == null) {
  28       return false;
  29     } else {
  30       return result.getMigrated();
  31     }
  32   }
  33
  34   public static void markMigrated() {
  35     accessor.markMigrated();
  36   }
  37
  38   @Accessor
  39   interface MigrationTableAccessor {
  40     @Query("SELECT * FROM migration where id='1'")
  41     MigrationMarkerEntity isMigrated();
  42
  43
  44     @Query("insert into migration (id,isMigrated) values('1',true)")
  45     void markMigrated();
  46
  47   }
  48
  49 }