Introdução ao MongoDB e Helidon

1
git clone git@github.com:soujava/helidon-mongodb-introduction.git  

1
docker run --rm -d --name mongodb-instance -p 27017:27017 mongo

1
<dependency>
2
<groupId>org.eclipse.jnosql.databases</groupId>
3
<artifactId>jnosql-mongodb</artifactId>
4
<version>1.1.2</version>
5
</dependency>

1
<?xml version="1.0" encoding="UTF-8"?>
2
<project xmlns="http://maven.apache.org/POM/4.0.0"
3
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
5
    <modelVersion>4.0.0</modelVersion>
6
    <parent>
7
        <groupId>io.helidon.applications</groupId>
8
        <artifactId>helidon-mp</artifactId>
9
        <version>4.1.1</version>
10
        <relativePath/>
11
    </parent>
12
    <groupId>expert.os.samples</groupId>
13
    <artifactId>intro-helidon-mongodb</artifactId>
14
    <version>0.0.1</version>
15
16
17
    <dependencies>
18
        <dependency>
19
            <groupId>org.eclipse.jnosql.databases</groupId>
20
            <artifactId>jnosql-mongodb</artifactId>
21
            <version>1.1.2</version>
22
        </dependency>
23
        <dependency>
24
            <groupId>io.helidon.microprofile.bundles</groupId>
25
            <artifactId>helidon-microprofile-core</artifactId>
26
        </dependency>
27
        <dependency>
28
            <groupId>io.helidon.microprofile.openapi</groupId>
29
            <artifactId>helidon-microprofile-openapi</artifactId>
30
        </dependency>
31
        <dependency>
32
            <groupId>io.helidon.microprofile.health</groupId>
33
            <artifactId>helidon-microprofile-health</artifactId>
34
        </dependency>
35
        <dependency>
36
            <groupId>jakarta.json.bind</groupId>
37
            <artifactId>jakarta.json.bind-api</artifactId>
38
        </dependency>
39
        <dependency>
40
            <groupId>org.glassfish.jersey.media</groupId>
41
            <artifactId>jersey-media-json-binding</artifactId>
42
            <scope>runtime</scope>
43
        </dependency>
44
        <dependency>
45
            <groupId>io.helidon.logging</groupId>
46
            <artifactId>helidon-logging-jul</artifactId>
47
            <scope>runtime</scope>
48
        </dependency>
49
        <dependency>
50
            <groupId>io.smallrye</groupId>
51
            <artifactId>jandex</artifactId>
52
            <scope>runtime</scope>
53
        </dependency>
54
        <dependency>
55
            <groupId>org.eclipse.microprofile.metrics</groupId>
56
            <artifactId>microprofile-metrics-api</artifactId>
57
        </dependency>
58
        <dependency>
59
            <groupId>io.helidon.microprofile.metrics</groupId>
60
            <artifactId>helidon-microprofile-metrics</artifactId>
61
        </dependency>
62
        <dependency>
63
            <groupId>org.junit.jupiter</groupId>
64
            <artifactId>junit-jupiter-api</artifactId>
65
            <scope>test</scope>
66
        </dependency>
67
        <dependency>
68
            <groupId>io.helidon.microprofile.testing</groupId>
69
            <artifactId>helidon-microprofile-testing-junit5</artifactId>
70
            <scope>test</scope>
71
        </dependency>
72
        <dependency>
73
            <groupId>org.hamcrest</groupId>
74
            <artifactId>hamcrest-all</artifactId>
75
            <scope>test</scope>
76
        </dependency>
77
    </dependencies>
78
79
    <build>
80
        <plugins>
81
            <plugin>
82
                <groupId>org.apache.maven.plugins</groupId>
83
                <artifactId>maven-dependency-plugin</artifactId>
84
                <executions>
85
                    <execution>
86
                        <id>copy-libs</id>
87
                    </execution>
88
                </executions>
89
            </plugin>
90
            <plugin>
91
                <groupId>io.smallrye</groupId>
92
                <artifactId>jandex-maven-plugin</artifactId>
93
                <executions>
94
                    <execution>
95
                        <id>make-index</id>
96
                    </execution>
97
                </executions>
98
            </plugin>
99
        </plugins>
100
    </build>
101
</project>

1
# configure the MongoDB client for a replica set of two nodes
2
quarkus.mongodb.connection-string=mongodb://localhost
3
4
# mandatory if you don't specify the name of the database
5
jnosql.document.database=tools

1
import jakarta.nosql.Column;
2
import jakarta.nosql.Entity;
3
import jakarta.nosql.Id;
4
5
@Entity(value = "tool")
6
public record Tool (@Id String sku, @Column String name, @Column String type, @Column int quantity) 
7
{ }

1
import jakarta.data.repository.BasicRepository;
2
import jakarta.data.repository.Repository;
3
4
@Repository
5
public interface ToolRepository extends BasicRepository<Tool, String> {
6
}

1
import jakarta.data.Direction;
2
import jakarta.data.Order;
3
import jakarta.data.Sort;
4
import jakarta.data.page.PageRequest;
5
import jakarta.inject.Inject;
6
import jakarta.ws.rs.Consumes;
7
import jakarta.ws.rs.DELETE;
8
import jakarta.ws.rs.DefaultValue;
9
import jakarta.ws.rs.GET;
10
import jakarta.ws.rs.POST;
11
import jakarta.ws.rs.Path;
12
import jakarta.ws.rs.PathParam;
13
import jakarta.ws.rs.Produces;
14
import jakarta.ws.rs.QueryParam;
15
import jakarta.ws.rs.WebApplicationException;
16
import jakarta.ws.rs.core.MediaType;
17
import jakarta.ws.rs.core.Response;
18
19
import java.util.List;
20
import java.util.logging.Logger;
21
22
@Path("/tools")
23
@Produces(MediaType.APPLICATION_JSON)
24
@Consumes(MediaType.APPLICATION_JSON)
25
public class ToolResource {
26
27
    private static final Logger LOGGER = Logger.getLogger(ToolResource.class.getName());
28
29
    private final ToolRepository toolRepository;
30
31
    @Inject
32
    public ToolResource(ToolRepository toolRepository) {
33
        this.toolRepository = toolRepository;
34
    }
35
36
37
    @GET
38
    public List<Tool> findAllTools(@QueryParam("page") @DefaultValue("1") long page,
39
                                   @QueryParam("size") @DefaultValue("2") int size,
40
                                   @QueryParam("order") @DefaultValue("sku") String order,
41
                                   @QueryParam("direction") @DefaultValue("ASC") Direction direction) {
42
43
        LOGGER.info("Find all tools, page: " + page + ", size: " + size + ", order: " + order + ", direction: " + direction);
44
        var pageRequest = PageRequest.ofPage(page).size(size);
45
        return toolRepository.findAll(pageRequest, Order.by(Sort.of(order, direction, false))).content();
46
    }
47
48
    @POST
49
    public void save(Tool tool) {
50
        LOGGER.info("Save tool: " + tool);
51
        toolRepository.save(tool);
52
    }
53
54
    @GET
55
    @Path("/{id}")
56
    public Tool findById(@PathParam("id") String id) {
57
        LOGGER.info("Find tool by id: " + id);
58
        return toolRepository.findById(id).orElseThrow(() -> new WebApplicationException("Tool not found", Response.Status.NOT_FOUND));
59
    }
60
61
    @DELETE
62
    @Path("/{id}")
63
    public void deleteById(@PathParam("id") String id) {
64
        LOGGER.info("Delete tool by id: " + id);
65
        toolRepository.deleteById(id);
66
    }
67
68
69
}

1
mvn package
2
java -jar target/intro-helidon-mongodb.jar

1
curl -X POST http://localhost:8080/tools -H "Content-Type: application/json" -d '{"sku": "SKU006", "name": "Pliers", "type": "Hand Tools", "quantity": 75}'
2
curl -X POST http://localhost:8080/tools -H "Content-Type: application/json" -d '{"sku": "SKU007", "name": "Cordless Screwdriver", "type": "Power Tools", "quantity": 50}'
3
curl -X POST http://localhost:8080/tools -H "Content-Type: application/json" -d '{"sku": "SKU008", "name": "Chisel", "type": "Hand Tools", "quantity": 90}'
4
curl -X POST http://localhost:8080/tools -H "Content-Type: application/json" -d '{"sku": "SKU009", "name": "Power Drill", "type": "Power Tools", "quantity": 60}'
5
curl -X POST http://localhost:8080/tools -H "Content-Type: application/json" -d '{"sku": "SKU010", "name": "Tape Measure", "type": "Measuring Tools", "quantity": 120}'
6
curl -X POST http://localhost:8080/tools -H "Content-Type: application/json" -d '{"sku": "SKU011", "name": "Level", "type": "Measuring Tools", "quantity": 45}'
7
curl -X POST http://localhost:8080/tools -H "Content-Type: application/json" -d '{"sku": "SKU012", "name": "Wrench Set", "type": "Hand Tools", "quantity": 30}'
8
curl -X POST http://localhost:8080/tools -H "Content-Type: application/json" -d '{"sku": "SKU013", "name": "Circular Saw", "type": "Power Tools", "quantity": 20}'
9
curl -X POST http://localhost:8080/tools -H "Content-Type: application/json" -d '{"sku": "SKU014", "name": "Angle Grinder", "type": "Power Tools", "quantity": 35}'
10
curl -X POST http://localhost:8080/tools -H "Content-Type: application/json" -d '{"sku": "SKU015", "name": "Allen Wrench", "type": "Hand Tools", "quantity": 200}'

1
curl --location 'http://localhost:8080/tools/SKU006'

1
curl --location --request DELETE 'http://localhost:8080/tools/SKU005'

1
curl --location 'http://localhost:8080/tools/'
2
curl --location 'http://localhost:8080/tools/?page=2'
3
curl --location 'http://localhost:8080/tools/?page=3'
4
curl --location 'http://localhost:8080/tools/?size=10'
5
curl --location 'http://localhost:8080/tools/?size=10&order=name'