Commit 288ee3f7 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade nueva función para obtener el índice 

En los repositorios de tipo rollover el índice se construye a partir de
el índice base + una fecha que debe definir el propio repositorio.

Esto solo es necesario en operaciones add y update. En otro tipo, como
delete o search se puede acceder por el alias
parent a0585e78

src/main/java/es/redmic/elasticsearchlib/geodata/repository/RGeoDataESRepository.java

+4 −0
Original line number Diff line number Diff line
@@ -19,6 +19,10 @@ import es.redmic.models.es.geojson.wrapper.GeoSearchWrapper; 
public abstract class RGeoDataESRepository<TModel extends Feature<?, ?>, TQueryDTO extends SimpleQueryDTO>

		extends RBaseESRepository<TModel, TQueryDTO> {



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

		super(index, type, rollOverIndex);

	}



	public RGeoDataESRepository(String[] index, String[] type) {

		super(index, type);

	}

src/main/java/es/redmic/elasticsearchlib/geodata/repository/RWGeoDataESRepository.java

+15 −2
Original line number Diff line number Diff line
@@ -15,6 +15,10 @@ public abstract class RWGeoDataESRepository<TModel extends Feature<?, ?>, TQuery 
	@Autowired

	ElasticPersistenceUtils<TModel> elasticPersistenceUtils;



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

		super(index, type, rollOverIndex);

	}



	public RWGeoDataESRepository(String[] index, String[] type) {

		super(index, type);

	}
@@ -28,7 +32,7 @@ public abstract class RWGeoDataESRepository<TModel extends Feature<?, ?>, TQuery 
			return checkInsert;

		}



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

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

	}



	@Override
@@ -40,7 +44,7 @@ public abstract class RWGeoDataESRepository<TModel extends Feature<?, ?>, TQuery 
			return checkUpdate;

		}



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

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

				modelToIndex.getId().toString());

	}
@@ -80,4 +84,13 @@ public abstract class RWGeoDataESRepository<TModel extends Feature<?, ?>, TQuery 
	 * cumplen. Por ejemplo que no esté referenciado en otros servicios.

	 */

	protected abstract EventApplicationResult checkDeleteConstraintsFulfilled(String modelToIndex);



	/*

	 * Función para obtener el índice a partir del indice original + un campo de los

	 * datos Solo en series temporales, en otros casos, devolver directamente el

	 * índice.

	 */

	protected String getIndex(TModel modelToIndex) {

		return getIndex()[0];

	};

}
 
 No newline at end of file