How to Build a CRUD Application With MongoDB, Quarkus, and GraalVM

1
git clone git@github.com:mongodb-developer/quarkus-mongodb-crud.git

1
docker run --rm -d -p 27017:27017 -h $(hostname) --name mongo mongo:latest --replSet=RS && sleep 5 && docker exec mongo mongosh --quiet --eval "rs.initiate();"

1
quarkus.mongodb.connection-string=mongodb://localhost:27017

1
./mvnw compile quarkus:dev

1
curl http://localhost:8080/hello

1
Hello from Quarkus REST

1
package com.mongodb;
2
3
import jakarta.ws.rs.GET;
4
import jakarta.ws.rs.Path;
5
import jakarta.ws.rs.Produces;
6
import jakarta.ws.rs.core.MediaType;
7
8
@Path("/hello")
9
public class GreetingResource {
10
11
    @GET
12
    @Produces(MediaType.TEXT_PLAIN)
13
    public String hello() {
14
        return "Hello from Quarkus REST";
15
    }
16
}

1
package com.mongodb;
2
3
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
4
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
5
import org.bson.types.ObjectId;
6
7
import java.util.Objects;
8
9
public class PersonEntity {
10
11
    @JsonSerialize(using = ToStringSerializer.class)
12
    public ObjectId id;
13
    public String name;
14
    public Integer age;
15
16
    public PersonEntity() {
17
    }
18
19
    public PersonEntity(ObjectId id, String name, Integer age) {
20
        this.id = id;
21
        this.name = name;
22
        this.age = age;
23
    }
24
25
    @Override
26
    public int hashCode() {
27
        int result = id != null ? id.hashCode() : 0;
28
        result = 31 * result + (name != null ? name.hashCode() : 0);
29
        result = 31 * result + (age != null ? age.hashCode() : 0);
30
        return result;
31
    }
32
33
    @Override
34
    public boolean equals(Object o) {
35
        if (this == o) return true;
36
        if (o == null || getClass() != o.getClass()) return false;
37
38
        PersonEntity that = (PersonEntity) o;
39
40
        if (!Objects.equals(id, that.id)) return false;
41
        if (!Objects.equals(name, that.name)) return false;
42
        return Objects.equals(age, that.age);
43
    }
44
45
    public ObjectId getId() {
46
        return id;
47
    }
48
49
    public void setId(ObjectId id) {
50
        this.id = id;
51
    }
52
53
    public String getName() {
54
        return name;
55
    }
56
57
    public void setName(String name) {
58
        this.name = name;
59
    }
60
61
    public Integer getAge() {
62
        return age;
63
    }
64
65
    public void setAge(Integer age) {
66
        this.age = age;
67
    }
68
}

1
package com.mongodb;
2
3
import com.mongodb.client.MongoClient;
4
import com.mongodb.client.MongoCollection;
5
import jakarta.enterprise.context.ApplicationScoped;
6
7
@ApplicationScoped
8
public class PersonRepository {
9
10
    private final MongoClient mongoClient;
11
    private final MongoCollection<PersonEntity> coll;
12
13
    public PersonRepository(MongoClient mongoClient) {
14
        this.mongoClient = mongoClient;
15
        this.coll = mongoClient.getDatabase("test").getCollection("persons", PersonEntity.class);
16
    }
17
18
    // CRUD methods will go here
19
20
}

1
package com.mongodb;
2
3
import jakarta.inject.Inject;
4
import jakarta.ws.rs.*;
5
import jakarta.ws.rs.core.MediaType;
6
7
@Path("/api")
8
@Consumes(MediaType.APPLICATION_JSON)
9
@Produces(MediaType.APPLICATION_JSON)
10
public class PersonResource {
11
12
    @Inject
13
    PersonRepository personRepository;
14
15
    @GET
16
    @Path("/hello")
17
    public String hello() {
18
        return "Hello from Quarkus REST";
19
    }
20
21
    // CRUD routes will go here
22
23
}

1
package com.mongodb;
2
3
import io.quarkus.test.junit.QuarkusTest;
4
import org.junit.jupiter.api.Test;
5
6
import static io.restassured.RestAssured.given;
7
import static org.hamcrest.CoreMatchers.is;
8
9
@QuarkusTest
10
class PersonResourceTest {
11
    @Test
12
    void testHelloEndpoint() {
13
        given().when().get("/api/hello").then().statusCode(200).body(is("Hello from Quarkus REST"));
14
    }
15
}

1
public String add(PersonEntity person) {
2
    return coll.insertOne(person).getInsertedId().asObjectId().getValue().toHexString();
3
}

1
@POST
2
@Path("/person")
3
public String createPerson(PersonEntity person) {
4
    return personRepository.add(person);
5
}

1
curl -X POST http://localhost:8080/api/person \
2
     -H 'Content-Type: application/json' \
3
     -d '{"name": "John Doe", "age": 30}'

1
661dccf785cd323349ca42f7

1
RS [direct: primary] test> db.persons.find()
2
[
3
  {
4
    _id: ObjectId('661dccf785cd323349ca42f7'),
5
    age: 30,
6
    name: 'John Doe'
7
  }
8
]

1
public List<PersonEntity> getPersons() {
2
    return coll.find().into(new ArrayList<>());
3
}

1
@GET
2
@Path("/persons")
3
public List<PersonEntity> getPersons() {
4
    return personRepository.getPersons();
5
}

1
curl http://localhost:8080/api/persons

1
[
2
  {
3
    "id": "661dccf785cd323349ca42f7",
4
    "name": "John Doe",
5
    "age": 30
6
  }
7
]

1
public long anniversaryPerson(String id) {
2
    Bson filter = eq("_id", new ObjectId(id));
3
    Bson update = inc("age", 1);
4
    return coll.updateOne(filter, update).getModifiedCount();
5
}

1
@PUT
2
@Path("/person/{id}")
3
public long anniversaryPerson(@PathParam("id") String id) {
4
    return personRepository.anniversaryPerson(id);
5
}

1
curl -X PUT http://localhost:8080/api/person/661dccf785cd323349ca42f7

1
public long deletePerson(String id) {
2
    Bson filter = eq("_id", new ObjectId(id));
3
    return coll.deleteOne(filter).getDeletedCount();
4
}

1
@DELETE
2
@Path("/person/{id}")
3
public long deletePerson(@PathParam("id") String id) {
4
    return personRepository.deletePerson(id);
5
}

1
curl -X DELETE http://localhost:8080/api/person/661dccf785cd323349ca42f7

1
./mvnw package -Dnative

1
./mvnw package -Dnative -Dquarkus.native.container-build=true

1
./target/quarkus-mongodb-crud-1.0.0-SNAPSHOT-runner