@Test @DirtiesContext public void testBuildMigrationEvent() { MigrationEvent event = migrationEventDao.buildMigrationEvent(2); Assert.assertNotNull(event); Assert.assertEquals(2, event.getMigrationCluster(2).getMigrationShards().size()); }
public MigrationEvent buildMigrationEvent(final long eventId) { List<MigrationEventTbl> eventDetails = queryHandler.handleQuery(new DalQuery<List<MigrationEventTbl>>() { @Override public List<MigrationEventTbl> doQuery() throws DalException { return migrationEventTblDao.findWithAllDetails(eventId, MigrationEventTblEntity.READSET_FULL_ALL); } }); return loadMigrationEvent(eventDetails); }
MigrationEventDao extends AbstractXpipeConsoleDAO { public MigrationEvent buildMigrationEvent(final long eventId) { List<MigrationEventTbl> eventDetails = queryHandler.handleQuery(new DalQuery<List<MigrationEventTbl>>() { @Override public List<MigrationEventTbl> doQuery() throws DalException { return migrationEventTblDao.findWithAllDetails(eventId, MigrationEventTblEntity.READSET_FULL_ALL); } }); return loadMigrationEvent(eventDetails); } }
MigrationEventDao extends AbstractXpipeConsoleDAO { public MigrationEvent buildMigrationEvent(final long eventId) { List<MigrationEventTbl> eventDetails = queryHandler.handleQuery(new DalQuery<List<MigrationEventTbl>>() { @Override public List<MigrationEventTbl> doQuery() throws DalException { return migrationEventTblDao.findWithAllDetails(eventId, MigrationEventTblEntity.READSET_FULL_ALL); } }); return loadMigrationEvent(eventDetails); }  }
MigrationEventDao extends AbstractXpipeConsoleDAO { public MigrationEvent buildMigrationEvent(final long eventId) { List<MigrationEventTbl> eventDetails = queryHandler.handleQuery(new DalQuery<List<MigrationEventTbl>>() { @Override public List<MigrationEventTbl> doQuery() throws DalException { return migrationEventTblDao.findWithAllDetails(eventId, MigrationEventTblEntity.READSET_FULL_ALL); } }); return loadMigrationEvent(eventDetails); }  List<MigrationClusterModel> getMigrationCluster(final long eventId); MigrationEvent buildMigrationEvent(final long eventId); @DalTransaction MigrationEvent createMigrationEvent(MigrationRequest migrationRequest); List<Long> findAllUnfinished(); }
MigrationEventDao extends AbstractXpipeConsoleDAO { public MigrationEvent buildMigrationEvent(final long eventId) { List<MigrationEventTbl> eventDetails = queryHandler.handleQuery(new DalQuery<List<MigrationEventTbl>>() { @Override public List<MigrationEventTbl> doQuery() throws DalException { return migrationEventTblDao.findWithAllDetails(eventId, MigrationEventTblEntity.READSET_FULL_ALL); } }); return loadMigrationEvent(eventDetails); }  List<MigrationClusterModel> getMigrationCluster(final long eventId); MigrationEvent buildMigrationEvent(final long eventId); @DalTransaction MigrationEvent createMigrationEvent(MigrationRequest migrationRequest); List<Long> findAllUnfinished();  }