Building Quarkus Application with MongoDB and Panache

1
mvn io. quarkus:quarkus-maven-plugin:create \
2
    -DprojectGroupId=io.quarkus.platform \
3
    -DprojectArtifactId=quarkus-bom \
4
    -DclassName="com.example.BookResource" \
5
    -Dpath="/books"

1
    <dependencies>
2
        <dependency>
3
            <groupId>io.quarkus</groupId>
4
            <artifactId>quarkus-arc</artifactId>
5
        </dependency>
6
        <dependency>
7
            <groupId>io.quarkus</groupId>
8
            <artifactId>quarkus-rest</artifactId>
9
        </dependency>
10
        <dependency>
11
            <groupId>io.quarkus</groupId>
12
            <artifactId>quarkus-rest-client-jackson</artifactId>
13
            <version>3.16.2</version>
14
        </dependency>
15
        <dependency>
16
            <groupId>io.quarkus</groupId>
17
            <artifactId>quarkus-resteasy-reactive-jackson</artifactId>
18
            <version>3.15.1</version>
19
        </dependency>
20
        <dependency>
21
            <groupId>io.rest-assured</groupId>
22
            <artifactId>rest-assured</artifactId>
23
            <scope>test</scope>
24
        </dependency>
25
26
        <dependency>
27
            <groupId>io.quarkus</groupId>
28
            <artifactId>quarkus-mongodb-panache</artifactId>
29
        </dependency>
30
31
    </dependencies>

1
mvn clean install

1
{
2
_id: ..
3
title: ..
4
author: ..
5
genre: ..
6
year: ..
7
}

1
    @Inject
2
    BookRepository bookRepository;   
3
 @POST
4
    public Response addBook(Book book) {
5
        bookRepository.persist(book);
6
        return Response.status(Response.Status.CREATED).entity(book).build();
7
    }

1
import com.quarkusWithPanache.model.Book;
2
import io.quarkus.mongodb.panache.PanacheMongoRepository;
3
import jakarta.enterprise.context.ApplicationScoped;
4
5
@ApplicationScoped
6
public class BookRepository implements PanacheMongoRepository<Book> {
7
}

1
 @POST
2
    @Path("/bulk")
3
    public Response bulkAddBooks(List<Book> books) {
4
        // Prepare documents for bulk write
5
        List<Document> documents = new ArrayList<>();
6
        for (Book book : books) {
7
            documents.add(new Document("title", book.title)
8
                    .append("author", book.author)
9
                    .append("genre", book.genre)
10
                    .append("year", book.year));
11
        }
12
        getCollection().insertMany(documents);
13
14
        return Response.status(Response.Status.CREATED).entity(books).build();
15
    }

1
@GET
2
    public List<Book> getAllBooks() {
3
        return bookRepository.listAll();
4
    }

1
@GET
2
    @Path("/{id}")
3
    public Book getBookById(@PathParam("id") String id) {
4
        return bookRepository.findById(new ObjectId(id));
5
    }

1
    @DELETE
2
    @Path("/{id}")
3
    public Response deleteBook(@PathParam("id") String id) {
4
        boolean deleted = bookRepository.deleteById(new ObjectId(id));
5
        return deleted ? Response.noContent().build() : Response.status(Response.Status.NOT_FOUND).build();
6
    }

1
@PUT
2
    @Path("/{id}")
3
    public Response updateBook(@PathParam("id") String id, Book book) {
4
        Book entity = bookRepository.findById(new ObjectId(id));
5
        if (entity == null) {
6
            return Response.status(Response.Status.NOT_FOUND).build();
7
        }
8
        entity.title = book.title;
9
        entity.author = book.author;
10
        entity.genre = book.genre;
11
        entity.year = book.year;
12
        bookRepository.update(entity);
13
        return Response.ok(entity).build();
14
    }

1
@GET
2
    @Path("/aggregate/genre-count")
3
    public Response countBooksByGenre() {
4
5
        List<Document> pipeline = new ArrayList<>();
6
        pipeline.add(new Document("$group", new Document("_id", "$genre")
7
                .append("count", new Document("$sum", 1))));
8
9
        List<Document> result = getCollection()
10
                .aggregate(pipeline)
11
                .into(new ArrayList<>());
12
13
        return Response.ok(result).build();
14
    }

1
curl -X POST "http://localhost:8080/books" -H "Content-Type: application/json" -d '{                        
2
  "title": "Quarkus in Action",
3
  "author": "John Doe",
4
  "genre": "Programming",
5
  "year": 2023
6
}'

1
curl -X POST http://localhost:8080/books/bulk \
2
   -H "Content-Type: application/json" \
3
   -d '[
4
        {
5
            "title": "The Midnight Library",
6
            "author": "Matt Haig",
7
            "genre": "Fiction",
8
            "year": 2020
9
        },
10
                {
11
            "title": "Sapiens: A Brief History of Humankind",
12
            "author": "Yuval Noah Harari",
13
            "genre": "Non-Fiction",
14
            "year": 2011
15
        },
16
        .......
17
    ]'

1
curl -X GET "http://localhost:8080/books" | jq

1
curl -X GET "http://localhost:8080/books/672f873b421eaa0c3e4da49f" | jq

1
curl -X DELETE "http://localhost:8080/books/673f81b65750de0757a4bbfb" | jq

1
curl -X PUT "http://localhost:8080/books/672f856f421eaa0c3e4da49e" \
2
   -H "Content-Type: application/json" \
3
   -d '{
4
         "title": "Quarkus in Action",
5
         "author": "John Doe",
6
         "genre": "Programming",
7
         "year": 2021
8
       }'

1
curl -X GET "http://localhost:8080/books/aggregate/genre-count" | jq