Stage 13: connect the Stage 12 application to MongoDB Atlas

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>4.1.1</version>
    <relativePath/>
  </parent>
  <groupId>com.edupoly</groupId>
  <artifactId>spring-products-mongodb-connectivity</artifactId>
  <version>1.0.0</version>
  <properties>
    <java.version>21</java.version>
  </properties>
  <dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-webmvc</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-thymeleaf</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-mongodb</artifactId>
    </dependency>
  </dependencies>
  <build>
    <plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>
</project>

# HTTP port: change this if another application uses 8091.
server.port=8091

# Set MONGODB_URI in your terminal to use your own Atlas cluster.
# Without that variable, use a running local MongoDB server on 27017.
spring.mongodb.uri=${MONGODB_URI:mongodb://localhost:27017}
spring.mongodb.database=${MONGODB_DATABASE:spring_stage13_products}

package com.edupoly.products;

import java.math.BigDecimal;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;

@Document("products")
public class Product {
    @Id
    private int id;
    private String name;
    private String category;
    private BigDecimal price;
    private String brand;
    private int stock;
    private String description;
    private int warrantyMonths;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getCategory() {
        return category;
    }

    public void setCategory(String category) {
        this.category = category;
    }

    public BigDecimal getPrice() {
        return price;
    }

    public void setPrice(BigDecimal price) {
        this.price = price;
    }

    public String getBrand() {
        return brand;
    }

    public void setBrand(String brand) {
        this.brand = brand;
    }

    public int getStock() {
        return stock;
    }

    public void setStock(int stock) {
        this.stock = stock;
    }

    public String getDescription() {
        return description;
    }

    public void setDescription(String description) {
        this.description = description;
    }

    public int getWarrantyMonths() {
        return warrantyMonths;
    }

    public void setWarrantyMonths(int warrantyMonths) {
        this.warrantyMonths = warrantyMonths;
    }
}

package com.edupoly.products;

import org.springframework.data.mongodb.repository.MongoRepository;

public interface ProductRepository extends MongoRepository<Product, Integer> {
}

package com.edupoly.products;

import java.util.Arrays;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

@Component
public class ProductDataSeeder implements CommandLineRunner {
    private final ProductRepository repository;
    private final ProductFileReader reader;

    public ProductDataSeeder(ProductRepository repository, ProductFileReader reader) {
        this.repository = repository;
        this.reader = reader;
    }

    @Override
    public void run(String... args) {
        if (repository.count() == 0) {
            repository.saveAll(Arrays.asList(reader.getProducts()));
            System.out.println("Seeded 30 products into the empty demo database");
        }
    }
}

package com.edupoly.products;

import org.bson.Document;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
public class DatabaseInfoController {
    private final MongoTemplate mongoTemplate;
    private final ProductRepository repository;

    public DatabaseInfoController(MongoTemplate mongoTemplate,
                                  ProductRepository repository) {
        this.mongoTemplate = mongoTemplate;
        this.repository = repository;
    }

    @GetMapping(value = "/database-info", produces = "text/plain")
    @ResponseBody
    public String databaseInfo() {
        var database = mongoTemplate.getDb();
        Document result = database.runCommand(new Document("ping", 1));
        return "Connected to MongoDB\n"
                + "Database: " + database.getName() + "\n"
                + "Ping result: " + result.get("ok") + "\n"
                + "Product count: " + repository.count();
    }
}

package com.edupoly.products;

import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
public class BeanInfoController {
    private final ConfigurableApplicationContext context;

    public BeanInfoController(ConfigurableApplicationContext context) {
        this.context = context;
    }

    @GetMapping(value = "/bean-info", produces = "text/plain")
    @ResponseBody
    public String beanInfo() {
        StringBuilder text = new StringBuilder();
        for (String name : new String[] {"jsonMapper", "catalogSettings", "productFileReader",
                "productRepository", "productService", "productController"}) {
            text.append(name)
                .append(" | definition registered: ").append(context.containsBeanDefinition(name))
                .append(" | singleton: ").append(context.isSingleton(name)).append("\n");
        }
        text.append("Same settings bean on two lookups: ")
            .append(context.getBean(CatalogSettings.class) == context.getBean(CatalogSettings.class));
        return text.toString();
    }
}