Understanding Embedded Types in MongoDB with Java and Helidon

1
git clone git@github.com:soujava/mongodb-embedding-sample.git

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

1
# Define the database name
2
jnosql.document.database=products

1
import jakarta.json.bind.annotation.JsonbVisibility;
2
import jakarta.nosql.Column;
3
import jakarta.nosql.Convert;
4
import jakarta.nosql.Entity;
5
import jakarta.nosql.Id;
6
import org.eclipse.jnosql.databases.mongodb.mapping.ObjectIdConverter;
7
import org.soujava.samples.mongodb.products.infra.FieldVisibilityStrategy;
8
import java.util.List;
9
import java.util.Objects;
10
import java.util.Set;
11
12
@Entity
13
@JsonbVisibility(FieldVisibilityStrategy.class)
14
public class Product {
15
    @Id
16
    @Convert(ObjectIdConverter.class)
17
    private String id;
18
    @Column
19
    private String name;
20
    @Column
21
    private Manufacturer manufacturer;
22
    @Column
23
    private List<String> tags;
24
    @Column
25
    private Set<Category> categories;
26
}

1
import jakarta.json.bind.annotation.JsonbVisibility;
2
import jakarta.nosql.Column;
3
import jakarta.nosql.Embeddable;
4
import org.soujava.samples.mongodb.products.infra.FieldVisibilityStrategy;
5
6
@Embeddable(Embeddable.EmbeddableType.GROUPING)
7
@JsonbVisibility(FieldVisibilityStrategy.class)
8
public record Manufacturer(
9
    @Column String name,
10
    @Column String address,
11
    @Column String contactNumber
12
) {}

1
import jakarta.nosql.Column;
2
import jakarta.nosql.Embeddable;
3
4
@Embeddable(Embeddable.EmbeddableType.GROUPING)
5
public record Category(
6
    @Column String name,
7
    @Column String description
8
) {}

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

1
import jakarta.data.Order;
2
import jakarta.data.Sort;
3
import jakarta.data.page.PageRequest;
4
import jakarta.enterprise.context.ApplicationScoped;
5
import jakarta.inject.Inject;
6
import jakarta.ws.rs.DELETE;
7
import jakarta.ws.rs.DefaultValue;
8
import jakarta.ws.rs.GET;
9
import jakarta.ws.rs.POST;
10
import jakarta.ws.rs.Path;
11
import jakarta.ws.rs.PathParam;
12
import jakarta.ws.rs.QueryParam;
13
import jakarta.ws.rs.WebApplicationException;
14
import jakarta.ws.rs.core.Response;
15
import java.util.List;
16
import java.util.logging.Logger;
17
18
@ApplicationScoped
19
@Path("/products")
20
public class ProductResource {
21
    private static final Order<Product> ORDER = Order.by(Sort.asc("name"));
22
    private static final Logger LOGGER = Logger.getLogger(ProductResource.class.getName());
23
    private final ProductRepository repository;
24
25
    @Inject
26
    public ProductResource(ProductRepository repository) {
27
        this.repository = repository;
28
    }
29
30
    @Deprecated
31
    public ProductResource() {
32
        this(null);
33
    }
34
35
    @GET
36
    public List<Product> get(
37
            @QueryParam("page") @DefaultValue("1") int page,
38
            @QueryParam("size") @DefaultValue("10") int size) {
39
        LOGGER.info("Fetching page: " + page + ", size: " + size);
40
        var request = PageRequest.ofPage(page).size(size);
41
        return repository.findAll(request, ORDER).content();
42
    }
43
44
    @POST
45
    public Product insert(Product product) {
46
        LOGGER.info("Saving product: " + product);
47
        return repository.save(product);
48
    }
49
50
    @DELETE
51
    @Path("{id}")
52
    public void delete(@PathParam("id") String id) {
53
        repository.deleteById(id);
54
    }
55
56
    @GET
57
    @Path("{id}")
58
    public Product findById(@PathParam("id") String id) {
59
        return repository.findById(id)
60
                .orElseThrow(() -> new WebApplicationException("Product not found with ID: " + id, Response.Status.NOT_FOUND));
61
    }
62
}

1
mvn package
2
java -jar target/embedded-mongodb.jar

1
curl -X POST -H "Content-Type: application/json" -d '{
2
    "name": "Smartphone",
3
    "manufacturer": {
4
        "name": "Tech Co",
5
        "address": "1234 Tech Street",
6
        "contactNumber": "+123456789"
7
    },
8
    "tags": ["mobile", "smart"],
9
    "categories": [
10
        {"name": "Electronics", "description": "Devices and gadgets." },
11
        {"name": "Gadgets", "description": "Small useful tools and devices."}
12
    ]
13
}' http://localhost:8080/products

1
curl -X GET http://localhost:8080/products?page=1&size=10

1
curl -X GET http://localhost:8080/products/{id}

1
curl -X DELETE http://localhost:8080/products/{id}