Add PG indexes

packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/dataservice/project/ProjectAsset.java

@@ -4,7 +4,9 @@
 import jakarta.persistence.Entity;
 import jakarta.persistence.EnumType;
 import jakarta.persistence.Enumerated;
+import jakarta.persistence.Index;
 import jakarta.persistence.ManyToOne;
+import jakarta.persistence.Table;
 import jakarta.validation.constraints.NotNull;
 import java.io.Serial;
 import java.util.UUID;
@@ -21,6 +23,15 @@
 @Accessors(chain = true)
 @TSModel
 @Entity
+@Table(
+	name = "project_asset",
+	indexes = {
+		@Index(name = "idx_asset_id", columnList = "assetId"),
+		@Index(name = "idx_asset_type", columnList = "assetType"),
+		@Index(name = "idx_project_id", columnList = "project_id"),
+		@Index(name = "idx_project_asset_count", columnList = "project_id, assetType, deletedOn")
+	}
+)
 public class ProjectAsset extends TerariumAsset {
 
 	@Serial

packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/notification/NotificationEvent.java

@@ -9,7 +9,9 @@
 import jakarta.persistence.Entity;
 import jakarta.persistence.EnumType;
 import jakarta.persistence.Enumerated;
+import jakarta.persistence.Index;
 import jakarta.persistence.ManyToOne;
+import jakarta.persistence.Table;
 import jakarta.validation.constraints.NotNull;
 import java.io.Serial;
 import java.sql.Timestamp;
@@ -26,6 +28,10 @@
 @EqualsAndHashCode(callSuper = true)
 @TSModel
 @Entity
+@Table(
+	name = "notification_event",
+	indexes = { @Index(name = "idx_notification_group_id", columnList = "notification_group_id") }
+)
 public class NotificationEvent extends TerariumEntity {
 
 	@Serial

packages/server/src/main/java/software/uncharted/terarium/hmiserver/models/notification/NotificationGroup.java

@@ -5,8 +5,10 @@
 import jakarta.persistence.CascadeType;
 import jakarta.persistence.Entity;
 import jakarta.persistence.FetchType;
+import jakarta.persistence.Index;
 import jakarta.persistence.OneToMany;
 import jakarta.persistence.OrderBy;
+import jakarta.persistence.Table;
 import jakarta.validation.constraints.NotNull;
 import java.io.Serial;
 import java.util.ArrayList;
@@ -24,6 +26,12 @@
 @EqualsAndHashCode(callSuper = true)
 @TSModel
 @Entity
+@Table(
+	name = "notification_group",
+	indexes = {
+		@Index(name = "idx_user_id", columnList = "userId"), @Index(name = "idx_created_on", columnList = "createdOn")
+	}
+)
 public class NotificationGroup extends TerariumEntity {
 
 	@Serial

packages/server/src/main/java/software/uncharted/terarium/hmiserver/repository/PSCrudSoftDeleteRepository.java

@@ -5,6 +5,7 @@
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.repository.NoRepositoryBean;
+import software.uncharted.terarium.hmiserver.models.dataservice.model.ModelFramework;
 
 @NoRepositoryBean
 public interface PSCrudSoftDeleteRepository<T, ID> extends PSCrudRepository<T, ID> {
@@ -13,4 +14,6 @@ public interface PSCrudSoftDeleteRepository<T, ID> extends PSCrudRepository<T, I
 	Optional<T> getByIdAndDeletedOnIsNull(final ID id);
 
 	Page<T> findAllByPublicAssetIsTrueAndTemporaryIsFalseAndDeletedOnIsNull(final Pageable pageable);
+
+	List<ModelFramework> findAllByDeletedOnIsNull();
 }

packages/server/src/main/java/software/uncharted/terarium/hmiserver/repository/data/FrameworkRepository.java

@@ -1,17 +1,9 @@
 package software.uncharted.terarium.hmiserver.repository.data;
 
-import java.util.List;
-import java.util.Optional;
 import java.util.UUID;
 import org.springframework.stereotype.Repository;
 import software.uncharted.terarium.hmiserver.models.dataservice.model.ModelFramework;
 import software.uncharted.terarium.hmiserver.repository.PSCrudRepository;
 
 @Repository
-public interface FrameworkRepository extends PSCrudRepository<ModelFramework, UUID> {
-	List<ModelFramework> findAllByDeletedOnIsNull();
-
-	List<ModelFramework> findAllByIdInAndDeletedOnIsNull(final List<UUID> ids);
-
-	Optional<ModelFramework> getByIdAndDeletedOnIsNull(final UUID id);
-}
+public interface FrameworkRepository extends PSCrudRepository<ModelFramework, UUID> {}

packages/server/src/main/java/software/uncharted/terarium/hmiserver/repository/data/ProjectRepository.java

@@ -18,38 +18,39 @@ public interface ProjectRepository extends PSCrudRepository<Project, UUID>, JpaS
 	Optional<Project> getByIdAndDeletedOnIsNull(final UUID id);
 
 	@Query(
-		"select " +
-		" p.id as id, " +
-		" p.createdOn as createdOn, " +
-		" p.updatedOn as updatedOn, " +
-		" p.deletedOn as deletedOn, " +
-		" p.description as description, " +
-		" p.fileNames as fileNames, " +
-		" p.name as name, " +
-		" p.overviewContent as overviewContent, " +
-		" p.publicAsset as publicAsset, " +
-		" p.temporary as temporary, " +
-		" p.thumbnail as thumbnail, " +
-		" p.userId as userId, " +
-		" p2.assetCount as assetCount, " +
-		" p2.assetType as assetType " +
-		"from " +
-		" Project p " +
-		"left join (" +
-		"select " +
-		" pa.project.id as projectId, " +
-		" pa.assetType as assetType, " +
-		" count(*) as assetCount " +
-		"from " +
-		" ProjectAsset pa " +
-		"where " +
-		" pa.deletedOn is null " +
-		"group by pa.project.id, pa.assetType " +
-		") as p2 " +
-		"on p.id = p2.projectId " +
-		"where " +
-		" p.id in (:ids) " +
-		" and p.deletedOn is null"
+		"""
+			select
+				p.id as id,
+				p.createdOn as createdOn,
+				p.updatedOn as updatedOn,
+				p.deletedOn as deletedOn,
+				p.description as description,
+				p.fileNames as fileNames,
+				p.name as name,
+				p.overviewContent as overviewContent,
+				p.publicAsset as publicAsset,
+				p.temporary as temporary,
+				p.thumbnail as thumbnail,
+				p.userId as userId,
+				p2.assetCount as assetCount,
+				p2.assetType as assetType
+			from
+				Project p
+			left join (
+				select
+					pa.project.id as projectId,
+					pa.assetType as assetType,
+					count(*) as assetCount
+				from
+					ProjectAsset pa
+				where
+					pa.deletedOn is null
+				group by pa.project.id, pa.assetType) as p2
+			on p.id = p2.projectId
+			where
+				p.id in (:ids)
+				and p.deletedOn is null
+		"""
 	)
 	List<ProjectAndAssetAggregate> findByIdsWithAssets(@Param("ids") final List<UUID> ids);
 

packages/server/src/main/resources/db/migration/V15__Remove_Project_Asset_Aggregation_Index.sql

@@ -0,0 +1,3 @@
+
+-- Remove this, due to flyway baseline, we need indexes created in the code / entity
+DROP INDEX IF EXISTS pa_count;