feat: include code

Signed-off-by: Otavio Santana <[email protected]>

Author: otaviojava

src/main/java/org/soujava/demos/mongodb/document/CleanStatus.java

@@ -0,0 +1,7 @@
+package org.soujava.demos.mongodb.document;
+
+public enum CleanStatus {
+    CLEAN,
+    DIRTY,
+    INSPECTION_NEEDED
+}

src/main/java/org/soujava/demos/mongodb/document/Room.java

@@ -0,0 +1,110 @@
+package org.soujava.demos.mongodb.document;
+
+import jakarta.nosql.Column;
+import jakarta.nosql.Entity;
+import jakarta.nosql.Id;
+
+import java.util.Objects;
+
+@Entity
+public class Room {
+
+    @Id
+    private String id;
+
+    @Column
+    private int number;
+
+    @Column
+    private RoomType type;
+
+    @Column
+    private RoomStatus status;
+
+    @Column
+    private CleanStatus cleanStatus;
+
+    @Column
+    private boolean smokingAllowed;
+
+    @Column
+    private boolean underMaintenance;
+
+
+    public Room() {
+    }
+
+    public Room(String id, int number,
+                RoomType type, RoomStatus status,
+                CleanStatus cleanStatus,
+                boolean smokingAllowed, boolean underMaintenance) {
+        this.id = id;
+        this.number = number;
+        this.type = type;
+        this.status = status;
+        this.cleanStatus = cleanStatus;
+        this.smokingAllowed = smokingAllowed;
+        this.underMaintenance = underMaintenance;
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public int getNumber() {
+        return number;
+    }
+
+    public RoomType getType() {
+        return type;
+    }
+
+    public RoomStatus getStatus() {
+        return status;
+    }
+
+    public CleanStatus getCleanStatus() {
+        return cleanStatus;
+    }
+
+    public boolean isSmokingAllowed() {
+        return smokingAllowed;
+    }
+
+    public boolean isUnderMaintenance() {
+        return underMaintenance;
+    }
+
+
+    @Override
+    public boolean equals(Object o) {
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
+        Room room = (Room) o;
+        return Objects.equals(id, room.id);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hashCode(id);
+    }
+
+    @Override
+    public String toString() {
+        return "Room{" +
+                "id='" + id + '\'' +
+                ", roomNumber=" + number +
+                ", type=" + type +
+                ", status=" + status +
+                ", cleanStatus=" + cleanStatus +
+                ", smokingAllowed=" + smokingAllowed +
+                ", underMaintenance=" + underMaintenance +
+                '}';
+    }
+
+
+    public static RoomBuilder builder() {
+        return new RoomBuilder();
+    }
+}

src/main/java/org/soujava/demos/mongodb/document/RoomBuilder.java

@@ -0,0 +1,50 @@
+package org.soujava.demos.mongodb.document;
+
+public class RoomBuilder {
+    private String id;
+    private int roomNumber;
+    private RoomType type;
+    private RoomStatus status;
+    private CleanStatus cleanStatus;
+    private boolean smokingAllowed;
+    private boolean underMaintenance;
+
+    public RoomBuilder id(String id) {
+        this.id = id;
+        return this;
+    }
+
+    public RoomBuilder roomNumber(int roomNumber) {
+        this.roomNumber = roomNumber;
+        return this;
+    }
+
+    public RoomBuilder type(RoomType type) {
+        this.type = type;
+        return this;
+    }
+
+    public RoomBuilder status(RoomStatus status) {
+        this.status = status;
+        return this;
+    }
+
+    public RoomBuilder cleanStatus(CleanStatus cleanStatus) {
+        this.cleanStatus = cleanStatus;
+        return this;
+    }
+
+    public RoomBuilder smokingAllowed(boolean smokingAllowed) {
+        this.smokingAllowed = smokingAllowed;
+        return this;
+    }
+
+    public RoomBuilder underMaintenance(boolean underMaintenance) {
+        this.underMaintenance = underMaintenance;
+        return this;
+    }
+
+    public Room build() {
+        return new Room(id, roomNumber, type, status, cleanStatus, smokingAllowed, underMaintenance);
+    }
+}

src/main/java/org/soujava/demos/mongodb/document/RoomRepository.java

@@ -0,0 +1,34 @@
+package org.soujava.demos.mongodb.document;
+
+import jakarta.data.repository.Param;
+import jakarta.data.repository.Query;
+import jakarta.data.repository.Repository;
+import jakarta.data.repository.Save;
+
+import java.util.List;
+
+@Repository
+public interface RoomRepository {
+
+    @Query("WHERE type = 'VIP_SUITE' AND status = 'AVAILABLE' AND underMaintenance = false")
+    List<Room> findVipRoomsReadyForGuests();
+
+    @Query(" WHERE type <> 'VIP_SUITE' AND status = 'AVAILABLE' AND cleanStatus = 'CLEAN'")
+    List<Room> findAvailableStandardRooms();
+
+    @Query("WHERE cleanStatus <> 'CLEAN' AND status <> 'OUT_OF_SERVICE'")
+    List<Room> findRoomsNeedingCleaning();
+
+    @Query("WHERE smokingAllowed = true AND status = 'AVAILABLE'")
+    List<Room> findAvailableSmokingRooms();
+
+    @Save
+    void save(List<Room> rooms);
+
+    @Save
+    Room newRoom(Room room);
+    void deleteBy();
+
+    @Query("WHERE type = :type")
+    List<Room> findByType(@Param("type") RoomType type);
+}

src/main/java/org/soujava/demos/mongodb/document/RoomStatus.java

@@ -0,0 +1,8 @@
+package org.soujava.demos.mongodb.document;
+
+public enum RoomStatus {
+    AVAILABLE,
+    RESERVED,
+    UNDER_MAINTENANCE,
+    OUT_OF_SERVICE
+}

src/main/java/org/soujava/demos/mongodb/document/RoomType.java

@@ -0,0 +1,8 @@
+package org.soujava.demos.mongodb.document;
+
+public enum RoomType {
+    STANDARD,
+    DELUXE,
+    SUITE,
+    VIP_SUITE
+}

src/main/resources/META-INF/beans.xml

@@ -0,0 +1,17 @@
+<!--
+  ~ Copyright (c) 2022 Contributors to the Eclipse Foundation
+  ~  All rights reserved. This program and the accompanying materials
+  ~  are made available under the terms of the Eclipse Public License v1.0
+  ~  and Apache License v2.0 which accompanies this distribution.
+  ~  The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
+  ~  and the Apache License v2.0 is available at http://www.opensource.org/licenses/apache2.0.php.
+  ~
+  ~ You may elect to redistribute this code under either of these licenses.
+  -->
+
+<beans xmlns="http://xmlns.jcp.org/xml/ns/javaee"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee
+		http://xmlns.jcp.org/xml/ns/javaee/beans_1_1.xsd"
+       bean-discovery-mode="all">
+</beans>

src/main/resources/META-INF/microprofile-config.properties

@@ -0,0 +1,13 @@
+#
+# Copyright (c) 2022 Contributors to the Eclipse Foundation
+#  All rights reserved. This program and the accompanying materials
+#  are made available under the terms of the Eclipse Public License v1.0
+#  and Apache License v2.0 which accompanies this distribution.
+#  The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
+#  and the Apache License v2.0 is available at http://www.opensource.org/licenses/apache2.0.php.
+#
+# You may elect to redistribute this code under either of these licenses.
+#
+jnosql.mongodb.url=mongodb://localhost:27017
+# mandatory define the database name
+jnosql.document.database=products

src/test/java/org/soujava/demos/mongodb/document/AppTest.java

@@ -0,0 +1,57 @@
+package org.soujava.demos.mongodb.document;
+
+import jakarta.inject.Inject;
+import org.assertj.core.api.SoftAssertions;
+import org.eclipse.jnosql.databases.mongodb.mapping.MongoDBTemplate;
+import org.eclipse.jnosql.mapping.Database;
+import org.eclipse.jnosql.mapping.core.Converters;
+import org.eclipse.jnosql.mapping.document.DocumentTemplate;
+import org.eclipse.jnosql.mapping.document.spi.DocumentExtension;
+import org.eclipse.jnosql.mapping.reflection.Reflections;
+import org.eclipse.jnosql.mapping.reflection.spi.ReflectionEntityMetadataExtension;
+import org.eclipse.jnosql.mapping.semistructured.EntityConverter;
+import org.jboss.weld.junit5.auto.AddExtensions;
+import org.jboss.weld.junit5.auto.AddPackages;
+import org.jboss.weld.junit5.auto.EnableAutoWeld;
+import org.junit.jupiter.api.Test;
+
+
+@EnableAutoWeld
+@AddPackages(value = {Database.class, EntityConverter.class, DocumentTemplate.class, MongoDBTemplate.class})
+@AddPackages(Room.class)
+@AddPackages(ManagerSupplier.class)
+@AddPackages(MongoDBTemplate.class)
+@AddPackages(Reflections.class)
+@AddPackages(Converters.class)
+@AddExtensions({ReflectionEntityMetadataExtension.class, DocumentExtension.class})
+class AppTest {
+
+    @Inject
+    private DocumentTemplate template;
+
+    @Test
+    void shouldTest() {
+        Room room = new RoomBuilder()
+                .id("room-1")
+                .roomNumber(101)
+                .type(RoomType.SUITE)
+                .status(RoomStatus.AVAILABLE)
+                .cleanStatus(CleanStatus.CLEAN)
+                .smokingAllowed(false)
+                .underMaintenance(false)
+                .build();
+
+        Room insert = template.insert(room);
+        SoftAssertions.assertSoftly(softly -> {
+            softly.assertThat(room.getId()).isEqualTo(insert.getId());
+            softly.assertThat(room.getNumber()).isEqualTo(insert.getNumber());
+            softly.assertThat(room.getType()).isEqualTo(insert.getType());
+            softly.assertThat(room.getStatus()).isEqualTo(insert.getStatus());
+            softly.assertThat(room.getCleanStatus()).isEqualTo(insert.getCleanStatus());
+            softly.assertThat(room.isSmokingAllowed()).isEqualTo(insert.isSmokingAllowed());
+            softly.assertThat(room.isUnderMaintenance()).isEqualTo(insert.isUnderMaintenance());
+            softly.assertThat(insert.getId()).isNotNull();
+        });
+    }
+
+}

src/test/java/org/soujava/demos/mongodb/document/DatabaseContainer.java

@@ -0,0 +1,44 @@
+package org.soujava.demos.mongodb.document;
+
+import org.eclipse.jnosql.communication.Settings;
+import org.eclipse.jnosql.databases.mongodb.communication.MongoDBDocumentConfiguration;
+import org.eclipse.jnosql.databases.mongodb.communication.MongoDBDocumentConfigurations;
+import org.eclipse.jnosql.databases.mongodb.communication.MongoDBDocumentManager;
+import org.eclipse.jnosql.databases.mongodb.communication.MongoDBDocumentManagerFactory;
+import org.eclipse.jnosql.mapping.core.config.MappingConfigurations;
+import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.containers.wait.strategy.Wait;
+
+import java.util.HashMap;
+import java.util.Map;
+public enum DatabaseContainer {
+
+    INSTANCE;
+
+    private final GenericContainer<?> mongodb =
+            new GenericContainer<>("mongo:latest")
+                    .withExposedPorts(27017)
+                    .waitingFor(Wait.defaultWaitStrategy());
+
+    {
+        mongodb.start();
+    }
+    public MongoDBDocumentManager get(String database) {
+        Settings settings = getSettings(database);
+        MongoDBDocumentConfiguration configuration = new MongoDBDocumentConfiguration();
+        MongoDBDocumentManagerFactory factory = configuration.apply(settings);
+        return factory.apply(database);
+    }
+
+
+    private Settings getSettings(String database) {
+        Map<String,Object> settings = new HashMap<>();
+        settings.put(MongoDBDocumentConfigurations.HOST.get()+".1", host());
+        settings.put(MappingConfigurations.DOCUMENT_DATABASE.get(), database);
+        return Settings.of(settings);
+    }
+
+    public String host() {
+        return mongodb.getHost() + ":" + mongodb.getFirstMappedPort();
+    }
+}