Zde je několik způsobů, jak vytvořit instanci MongoClient , konfiguraci a používání v rámci aplikace Spring Boot.
(1) Registrace instance Mongo pomocí metadat založených na Javě:
@Configuration
public class AppConfig {
public @Bean MongoClient mongoClient() {
return MongoClients.create();
}
}
Použití z CommandLineRunner run metoda (všechny příklady jsou spuštěny podobně ):
@Autowired
MongoClient mongoClient;
// Retrieves a document from the "test1" collection and "test" database.
// Note the MongoDB Java Driver API methods are used here.
private void getDocument() {
MongoDatabase database = client.getDatabase("test");
MongoCollection<Document> collection = database.getCollection("test1");
Document myDoc = collection.find().first();
System.out.println(myDoc.toJson());
}
(2) Konfigurace pomocí třídy AbstractMongoClientConfiguration a použití s MongoOperations:
@Configuration
public class MongoClientConfiguration extends AbstractMongoClientConfiguration {
@Override
public MongoClient mongoClient() {
return MongoClients.create();
}
@Override
protected String getDatabaseName() {
return "newDB";
}
}
Všimněte si, že můžete nastavit název databáze (newDB ), ke kterému se můžete připojit. Tato konfigurace se používá pro práci s databází MongoDB pomocí rozhraní Spring Data MongoDB API:MongoOperations (a jeho implementace MongoTemplate ) a MongoRepository .
@Autowired
MongoOperations mongoOps;
// Connects to "newDB" database, and gets a count of all documents in the "test2" collection.
// Uses the MongoOperations interface methods.
private void getCollectionSize() {
Query query = new Query();
long n = mongoOps.count(query, "test2");
System.out.println("Collection size: " + n);
}
(3) Konfigurace pomocí třídy AbstractMongoClientConfiguration a použití s MongoRepository
Pomocí stejné konfigurace MongoClientConfiguration třída (výše v tématu 2 ), ale navíc anotovat pomocí @EnableMongoRepositories . V tomto případě použijeme MongoRepository metody rozhraní pro získání dat kolekce jako objektů Java.
Úložiště:
@Repository
public interface MyRepository extends MongoRepository<Test3, String> {
}
Soubor Test3.java Třída POJO představující test3 sbírkový dokument:
public class Test3 {
private String id;
private String fld;
public Test3() {
}
// Getter and setter methods for the two fields
// Override 'toString' method
...
}
Následující metoda pro získání dokumentů a tisk jako objekty Java:
@Autowired
MyRepository repository;
// Method to get all the `test3` collection documents as Java objects.
private void getCollectionObjects() {
List<Test3> list = repository.findAll();
list.forEach(System.out::println);
}