@SqlQuery("SELECT * FROM ENGINE_ENTITY")
List<EngineEntity> getAllEntities();
+ @SqlQuery("SELECT DISTINCT(ENGINEINSTANCE) FROM APLUS_RULE")
+ List<String> getLegacyEngines();
+
@SqlUpdate("INSERT INTO ENGINE_ENTITY VALUES (:id, :ip, :port, :lastModified)")
void insertEntity(@BindBean EngineEntity entity);
package org.onap.holmes.common.engine.service;
-import org.glassfish.jersey.spi.Contract;
+import org.jvnet.hk2.annotations.Contract;
import org.onap.holmes.common.engine.entity.EngineEntity;
import java.util.List;
public interface EngineEntityService {
EngineEntity getEntity(String id);
List<EngineEntity> getAllEntities();
+ List<String> getLegacyEngines();
void updateEntity(EngineEntity entity);
void insertEntity(EngineEntity entity);
void deleteEntity(String id);
import org.onap.holmes.common.engine.service.EngineEntityService;
import org.onap.holmes.common.utils.DbDaoUtil;
-import java.util.ArrayList;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Set;
+import java.util.*;
import static com.google.common.base.Predicates.notNull;
import static org.hamcrest.core.Is.is;
import static org.junit.Assert.*;
public class EngineEntityServiceImplTest {
-
private EngineEntityService service = new EngineEntityServiceImpl(new DbDaoUtilStub());
+ @Test
+ public void getLegacyEngines() {
+ List<String> legacyEngines = service.getLegacyEngines();
+ assertThat(legacyEngines.size(), is(2));
+ }
+
@Test
public void getEntity() throws Exception {
EngineEntity entity = service.getEntity("org.onap.holmes_9201");
return new ArrayList<>(entitySet);
}
+ @Override
+ public List<String> getLegacyEngines() {
+ return Arrays.asList("org.onap.holmes", "org.onap.holmes.legacy.1");
+ }
+
@Override
public void insertEntity(EngineEntity entity) {
entitySet.add(entity);