Commit 01db68d1 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade la posibilidad de usar índices por tiempo 

De esta manera se comunica a la base que debe aplicar el template
parent 75e64971

src/main/java/es/redmic/elasticsearchlib/data/repository/RDataESRepository.java

+4 −0
Original line number Diff line number Diff line
@@ -33,6 +33,10 @@ public abstract class RDataESRepository<TModel extends BaseES<?>, TQueryDTO exte 
		super(index, type);

	}



	public RDataESRepository(String[] index, String type, Boolean rollOverIndex) {

		super(index, type, rollOverIndex);

	}



	public DataHitWrapper<?> findById(String id) {



		return getResponseToWrapper(getRequest(id), getSourceType(DataHitWrapper.class));

src/main/java/es/redmic/elasticsearchlib/data/repository/RWDataESRepository.java

+8 −2
Original line number Diff line number Diff line
@@ -23,6 +23,10 @@ public abstract class RWDataESRepository<TModel extends BaseES<?>, TQueryDTO ext 
		super(index, type);

	}



	public RWDataESRepository(String[] index, String type, Boolean rollOverIndex) {

		super(index, type, rollOverIndex);

	}



	@Override

	public EventApplicationResult save(TModel modelToIndex) {
@@ -32,7 +36,8 @@ public abstract class RWDataESRepository<TModel extends BaseES<?>, TQueryDTO ext 
			return checkInsert;

		}



		return elasticPersistenceUtils.save(getIndex()[0], getType(), modelToIndex, modelToIndex.getId().toString());

		return elasticPersistenceUtils.save(getIndex(modelToIndex), getType(), modelToIndex,

				modelToIndex.getId().toString());

	}



	@Override
@@ -44,7 +49,8 @@ public abstract class RWDataESRepository<TModel extends BaseES<?>, TQueryDTO ext 
			return checkUpdate;

		}



		return elasticPersistenceUtils.update(getIndex()[0], getType(), modelToIndex, modelToIndex.getId().toString());

		return elasticPersistenceUtils.update(getIndex(modelToIndex), getType(), modelToIndex,

				modelToIndex.getId().toString());

	}



	@Override