diff --git a/dao/src/main/java/org/thingsboard/server/dao/model/sql/AttributeKvCompositeKey.java b/dao/src/main/java/org/thingsboard/server/dao/model/sql/AttributeKvCompositeKey.java index 7424e1fb89..0efda29230 100644 --- a/dao/src/main/java/org/thingsboard/server/dao/model/sql/AttributeKvCompositeKey.java +++ b/dao/src/main/java/org/thingsboard/server/dao/model/sql/AttributeKvCompositeKey.java @@ -18,6 +18,7 @@ package org.thingsboard.server.dao.model.sql; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; +import org.thingsboard.server.common.data.EntityType; import java.io.Serializable; import java.util.UUID; @@ -26,7 +27,7 @@ import java.util.UUID; @AllArgsConstructor @NoArgsConstructor public class AttributeKvCompositeKey implements Serializable { - private String entityType; + private EntityType entityType; private UUID entityId; private String attributeType; private String attributeKey; diff --git a/dao/src/main/java/org/thingsboard/server/dao/sql/attributes/AttributeKvRepository.java b/dao/src/main/java/org/thingsboard/server/dao/sql/attributes/AttributeKvRepository.java index a090049eb1..9b937f63b7 100644 --- a/dao/src/main/java/org/thingsboard/server/dao/sql/attributes/AttributeKvRepository.java +++ b/dao/src/main/java/org/thingsboard/server/dao/sql/attributes/AttributeKvRepository.java @@ -16,6 +16,7 @@ package org.thingsboard.server.dao.sql.attributes; import org.springframework.data.repository.CrudRepository; +import org.thingsboard.server.common.data.EntityType; import org.thingsboard.server.dao.annotation.SqlDao; import org.thingsboard.server.dao.model.sql.AttributeKvCompositeKey; import org.thingsboard.server.dao.model.sql.AttributeKvEntity; @@ -26,7 +27,7 @@ import java.util.UUID; @SqlDao public interface AttributeKvRepository extends CrudRepository { - List findAllByEntityTypeAndEntityIdAndAttributeType(String entityType, + List findAllByEntityTypeAndEntityIdAndAttributeType(EntityType entityType, UUID entityId, String attributeType); } diff --git a/dao/src/main/java/org/thingsboard/server/dao/sql/attributes/JpaAttributeDao.java b/dao/src/main/java/org/thingsboard/server/dao/sql/attributes/JpaAttributeDao.java index c77d339bd2..82662729bb 100644 --- a/dao/src/main/java/org/thingsboard/server/dao/sql/attributes/JpaAttributeDao.java +++ b/dao/src/main/java/org/thingsboard/server/dao/sql/attributes/JpaAttributeDao.java @@ -46,7 +46,7 @@ public class JpaAttributeDao extends JpaAbstractDaoListeningExecutorService impl public ListenableFuture> find(EntityId entityId, String attributeType, String attributeKey) { AttributeKvCompositeKey compositeKey = new AttributeKvCompositeKey( - entityId.getEntityType().name(), + entityId.getEntityType(), entityId.getId(), attributeType, attributeKey); @@ -61,7 +61,7 @@ public class JpaAttributeDao extends JpaAbstractDaoListeningExecutorService impl .stream() .map(attributeKey -> new AttributeKvCompositeKey( - entityId.getEntityType().name(), + entityId.getEntityType(), entityId.getId(), attributeType, attributeKey)) @@ -75,7 +75,7 @@ public class JpaAttributeDao extends JpaAbstractDaoListeningExecutorService impl return service.submit(() -> DaoUtil.convertDataList(Lists.newArrayList( attributeKvRepository.findAllByEntityTypeAndEntityIdAndAttributeType( - entityId.getEntityType().name(), + entityId.getEntityType(), entityId.getId(), attributeType)))); } diff --git a/dao/src/main/java/org/thingsboard/server/dao/sql/timeseries/JpaTimeseriesDao.java b/dao/src/main/java/org/thingsboard/server/dao/sql/timeseries/JpaTimeseriesDao.java index 7b64a4fdb0..91450551d6 100644 --- a/dao/src/main/java/org/thingsboard/server/dao/sql/timeseries/JpaTimeseriesDao.java +++ b/dao/src/main/java/org/thingsboard/server/dao/sql/timeseries/JpaTimeseriesDao.java @@ -173,7 +173,7 @@ public class JpaTimeseriesDao extends JpaAbstractDaoListeningExecutorService imp return service.submit(() -> DaoUtil.convertDataList(Lists.newArrayList( tsKvLatestRepository.findAllByEntityTypeAndEntityId( - entityId.getEntityType().name(), + entityId.getEntityType(), entityId.getId())))); } diff --git a/dao/src/main/java/org/thingsboard/server/dao/sql/timeseries/TsKvLatestRepository.java b/dao/src/main/java/org/thingsboard/server/dao/sql/timeseries/TsKvLatestRepository.java index 7c447f190b..b2b7dea02e 100644 --- a/dao/src/main/java/org/thingsboard/server/dao/sql/timeseries/TsKvLatestRepository.java +++ b/dao/src/main/java/org/thingsboard/server/dao/sql/timeseries/TsKvLatestRepository.java @@ -16,6 +16,7 @@ package org.thingsboard.server.dao.sql.timeseries; import org.springframework.data.repository.CrudRepository; +import org.thingsboard.server.common.data.EntityType; import org.thingsboard.server.dao.annotation.SqlDao; import org.thingsboard.server.dao.model.sql.TsKvLatestCompositeKey; import org.thingsboard.server.dao.model.sql.TsKvLatestEntity; @@ -26,5 +27,5 @@ import java.util.UUID; @SqlDao public interface TsKvLatestRepository extends CrudRepository { - List findAllByEntityTypeAndEntityId(String entityType, UUID entityId); + List findAllByEntityTypeAndEntityId(EntityType entityType, UUID entityId); }