Skip to content

Instantly share code, notes, and snippets.

@ThomasVitale
Created April 17, 2018 19:29
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ThomasVitale/24b95893e07cebf504d8fc24e848f9d5 to your computer and use it in GitHub Desktop.
Save ThomasVitale/24b95893e07cebf504d8fc24e848f9d5 to your computer and use it in GitHub Desktop.
Spring Data MongoDB using Java Configuration
package com.thomasvitale;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import com.thomasvitale.model.Person;
import com.thomasvitale.repository.PersonRepository;
@SpringBootApplication
public class Application implements CommandLineRunner {
@Autowired
PersonRepository personRepository;
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
@Override
public void run(String... arg0) throws Exception {
// Save two Person documents on Mongo
personRepository.save(new Person("Sheldon", "Cooper"));
personRepository.save(new Person("Missy", "Cooper"));
personRepository.save(new Person("Leonard", "Hofstadter"));
// Get all people
System.out.println(">>> All people in the database:");
personRepository.findAll().forEach(System.out::println);
// Get all people with a specific last name
System.out.println(">>> All people with last name = 'Cooper'");
personRepository.findByLastName("Cooper").forEach(System.out::println);
// Update an individual person
Person person = personRepository.findByFirstName("Sheldon");
person.setFirstName("Shelly");
personRepository.save(person);
// Delete all
personRepository.deleteAll();
}
}
mongo.database=mydb
mongo.host=127.0.0.1
mongo.port=32769
package com.thomasvitale;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.core.env.Environment;
import org.springframework.data.mongodb.config.AbstractMongoConfiguration;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
import com.mongodb.Mongo;
import com.mongodb.MongoClient;
@Configuration
@EnableMongoRepositories(basePackages = "com.thomasvitale.repository")
@PropertySource("classpath:mongo.properties")
public class MongoConfig extends AbstractMongoConfiguration {
@Autowired
private Environment env;
@Override
protected String getDatabaseName() {
return env.getProperty("mongo.database");
}
@Override
public Mongo mongo() throws Exception {
return new MongoClient(env.getProperty("mongo.host"), Integer.parseInt(env.getProperty("mongo.port")));
}
@Override
protected String getMappingBasePackage() {
return "com.thomasvitale.model";
}
}
package com.thomasvitale.model;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
@Document(collection = "persons")
public class Person {
@Id
private String id;
private String firstName;
private String lastName;
public Person() {
}
public Person(String firstName, String lastName) {
this.firstName = firstName;
this.lastName = lastName;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getFirstName() {
return firstName;
}
public void setFirstName(String firstName) {
this.firstName = firstName;
}
public String getLastName() {
return lastName;
}
public void setLastName(String lastName) {
this.lastName = lastName;
}
@Override
public String toString() {
return firstName + " " + lastName;
}
}
package com.thomasvitale.repository;
import java.util.List;
import org.springframework.data.mongodb.repository.MongoRepository;
import com.thomasvitale.model.Person;
public interface PersonRepository extends MongoRepository<Person, String> {
public Person findByFirstName(String firstName);
public List<Person> findByLastName(String lastName);
}
<?xml version="1.0" encoding="UTF-8"?>
<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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.thomasvitale</groupId>
<artifactId>Application</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>Application</name>
<description>Demo application for Spring Data MongoDB</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.3.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment