将MongoDB与 Quarkus 集成

quarkus create app quarkus-quickstart --extensions=jnosql-mongodb,resteasy-jackson

cd quarkus-quickstart

jnosql.document.database=sample_restaurantsquarkus.mongodb.connection-string=<connection string>

package org.acme;
import jakarta.nosql.Column;import jakarta.nosql.Entity;import jakarta.nosql.Id;
/** * Represents a restaurant entity from the sample_restaurants database . * This class is used as an entity in the MongoDB database. */@Entity("restaurants")public class Restaurant {        @Id     private String id;        @Column     private String name;        @Column     private String borough;        @Column     private String cuisine;
    // Default constructor required by JNoSQL    public Restaurant() {}
    // Constructor    public Restaurant(String id, String name, String borough,String cuisine) {        this.id = id;        this.name = name;        this.borough = borough;        this.cuisine = cuisine;    }
    // Getters and setters    public String getId() { return id; }    public void setId(String id) { this.id = id; }        public String getName() { return name; }    public void setName(String name) { this.name = name; }        public String getBorough() { return borough; }    public void setBorough(String borough) { this.borough = borough; }        public String getCuisine() { return cuisine; }    public void setCuisine(String cuisine) { this.cuisine = cuisine; }}

package org.acme;
import jakarta.data.repository.Repository;import org.eclipse.jnosql.mapping.NoSQLRepository;
import java.util.List;
/** * Interface for managing restaurant data. * * It uses the Jakarta Data Specification capabilities. * */@Repositorypublic interface RestaurantRepository extends NoSQLRepository<Restaurant, String> {
    List<Restaurant> findByBorough(String borough);
    List<Restaurant> findByCuisine(String cuisine);}

package org.acme;
import jakarta.inject.Inject;import jakarta.ws.rs.*;import jakarta.ws.rs.core.MediaType;import jakarta.ws.rs.core.Response;import java.util.List;
/** * REST API controller for restaurant operations. * Provides endpoints for retrieving restaurant data from MongoDB. */@Path("/restaurants")@Produces(MediaType.APPLICATION_JSON)@Consumes(MediaType.APPLICATION_JSON)public class RestaurantResource {
    @Inject    RestaurantRepository restaurantRepository;
    /**     * Retrieves all restaurants from the database.     *      * @return List of all restaurants     */    @GET    public Response getAllRestaurants() {        try {            List<Restaurant> restaurants = restaurantRepository.findAll().toList();            System.out.println("Found " + restaurants.size() + " restaurants");            return Response.ok(restaurants).build();        } catch (Exception e) {            e.printStackTrace();            return Response.status(Response.Status.INTERNAL_SERVER_ERROR)                    .entity("Error retrieving restaurants: " + e.getMessage())                    .build();        }    }
    /**     * Retrieves filtered restaurants in Queens that contain "Moon" in the name.     *      * @return List of filtered restaurants     */    @GET    @Path("/browse")    public Response getFilteredRestaurants() {        try {            // Temporarily use findAll() to test basic connectivity            List<Restaurant> allRestaurants = restaurantRepository.findAll().toList();            System.out.println("Total restaurants found: " + allRestaurants.size());                        // Filter for Queens restaurants that also have "Moon" in the name            List<Restaurant> queensRestaurants = allRestaurants.stream()                    .filter(restaurant -> "Queens".equals(restaurant.getBorough()) &&                            restaurant.getName() != null &&                             restaurant.getName().toLowerCase().contains("moon"))                    .toList();            System.out.println("Queens restaurants found: " + queensRestaurants.size());                        return Response.ok(queensRestaurants).build();        } catch (Exception e) {            e.printStackTrace();            return Response.status(Response.Status.INTERNAL_SERVER_ERROR)                    .entity("Error retrieving filtered restaurants: " + e.getMessage())                    .build();        }    }
    /**     * Retrieves restaurants by cuisine type.     *      * @param cuisine The cuisine type to filter for     * @return List of restaurants that have the specified cuisine     */    @GET    @Path("/cuisine/{cuisine}")    public Response getRestaurantsByCuisine(@PathParam("cuisine") String cuisine) {        try {            List<Restaurant> restaurants = restaurantRepository.findByCuisine(cuisine);            return Response.ok(restaurants).build();        } catch (Exception e) {            return Response.status(Response.Status.INTERNAL_SERVER_ERROR)                    .entity("Error retrieving restaurants by cuisine: " + e.getMessage())                    .build();        }    }}

package org.acme;
import io.quarkus.test.junit.QuarkusTest;import jakarta.inject.Inject;import org.junit.jupiter.api.DisplayName;import org.junit.jupiter.api.Test;
import java.util.List;
import static org.assertj.core.api.Assertions.assertThat;
/** * RestaurantRepositoryTest is a test class for testing the RestaurantRepository operations. * * It uses the Quarkus Test framework to test the restaurant data access. */@QuarkusTestpublic class RestaurantRepositoryTest {
    @Inject    RestaurantRepository restaurantRepository;
    @Test    @DisplayName("Should retrieve restaurants from the database")    public void testRetrieveRestaurants() {        // Test repository injection and MongoDB connection        assertThat(restaurantRepository).isNotNull();    }
    @Test    @DisplayName("Should find restaurants by borough")    public void testFindRestaurantsByBorough() {        // Test that the method exists and returns data        List<Restaurant> restaurants = restaurantRepository.findByBorough("Queens");        assertThat(restaurants).isNotNull();    }}

./mvnw test

[INFO] Results:[INFO][INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0[INFO][INFO] ------------------------------------------------------------------------[INFO] BUILD SUCCESS[INFO] ------------------------------------------------------------------------[INFO] Total time:  ... s[INFO] Finished at: ...[INFO] ------------------------------------------------------------------------

./mvnw quarkus:dev