MongoDB с проектом Spring Data

Все мы наблюдаем взрыв решений NoSql в эти дни. Я привыкаю к RDBMS, но это не решение всех проблем, с которыми вы можете столкнуться. По моему недавнему опыту я получил возможность работать с MongoDB — база данных документов. В этом посте я собираюсь охватить некоторые основы (и некоторые дополнительные возможности в следующем посте) использования MongoDB вместе с проектом Spring Data . Прежде чем мы начнем, небольшой отказ от ответственности: в данный момент Spring Data все еще находится в фазе этапа, поэтому некоторые классы / интерфейсы могут измениться.

Прежде чем мы начнем, пожалуйста, скачайте и запустите MongoDB для вашей операционной системы. Это очень просто, поэтому я не буду тратить время на это, и давайте начнем с простого файла POM для нашего проекта:

4.0.0
 
mongodb
com.example.spring
0.0.1-SNAPSHOT
jar
 
    UTF-8
    3.0.5.RELEASE
 
        org.springframework.data
        spring-data-mongodb
        1.0.0.M3
     
        log4j
        log4j
        1.2.16
     
        org.mongodb
        mongo-java-driver
        2.5.3
     
        org.springframework
        spring-core
        ${spring.version}
     
        org.springframework
        spring-context
        ${spring.version}
     
        springsource-milestone
        Spring Framework Milestone Repository
        http://maven.springframework.org/milestone

Здесь есть две ключевые зависимости:

— MongoDB Java-драйвер
— Spring Data для MongoDB

Есть несколько способов определить MongoDB в контексте приложения Spring . Позвольте мне показать немного многословно, но более гибко:

<beans xmlns:context="http://www.springframework.org/schema/context" xmlns:mongo="http://www.springframework.org/schema/data/mongo" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://www.springframework.org/schema/beans" xsi:schemalocation="
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context-3.0.xsd
        http://www.springframework.org/schema/data/mongo
        http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd
        http://www.springframework.org/schema/beans 
        http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
 
        <constructor-arg index="0" ref="mongo" />
        <constructor-arg index="1" value="elements-db"/>
     
        <constructor-arg name="mongoDbFactory" ref="mongoDbFactory" />
        <constructor-arg name="mappingContext" ref="mappingContext" />         
      
        <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
        <constructor-arg name="mongoConverter" ref="converter" />        
        <property name="writeResultChecking" value="EXCEPTION" />
        <property name="writeConcern" value="NORMAL"/>

Роль каждого боба здесь:

Монго определяет соединение с базой данных MongoDB (мы используем настройки по умолчанию, порт 27027)
конвертер используется для преобразования классов Java в / из DBObject MongoDB (== JSON)
mongoTemplate предоставляет операции, которые мы можем выполнять над MongoDB

Итак, мы готовы к работе!

Вот несколько фрагментов кода для начала:

package com.example.mongodb;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.data.document.mongodb.CollectionCallback;
import org.springframework.data.document.mongodb.MongoOperations;
import org.springframework.data.document.mongodb.query.Index;
import org.springframework.data.document.mongodb.query.Index.Duplicates;
import org.springframework.data.document.mongodb.query.Order;
import org.springframework.stereotype.Service;
 
import com.mongodb.BasicDBObject;
import com.mongodb.DBCollection;
import com.mongodb.MongoException;
 
@Service
public class MongoService  {
    @Autowired private MongoOperations template;
 
    public void createCollection( final String name ) {
        template.createCollection( name  );
    }
 
    public void dropCollection( final String name ) {
        template.dropCollection( name  );
    }
 
    public void insert( final Object object, final String collection ) {
        template.insert( object, collection );
    }
    
    public void createIndex( final String name, final String collection ) {
        template.ensureIndex( 
            new Index()
                .on( name, Order.DESCENDING )
                .unique( Duplicates.DROP ), 
            collection  
        );
    }
  
    // Remove / save / ... operations here
}

Вот и все с основами. В следующем посте будут рассмотрены расширенные функции: использование массовых вставок, операции обновления или вставки и выполнение команд MongoDB . 🙂

После обсуждения проектов MongoDB и Spring Data я хотел бы показать некоторые расширенные функции (которые могут быть доступны в следующем выпуске Spring Data или выпуске как часть основных функций).

Прежде всего, давайте расширим наш MongoService с помощью метода, который подсчитывает документы в коллекции, которые соответствуют конкретному запросу.

package com.example.mongodb;
import java.util.Arrays;
import java.util.Collection;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.data.document.mongodb.CollectionCallback;
import org.springframework.data.document.mongodb.MongoOperations;
import org.springframework.data.document.mongodb.convert.MongoConverter;
import org.springframework.data.document.mongodb.query.Criteria;
import org.springframework.data.document.mongodb.query.Index;
import org.springframework.data.document.mongodb.query.Index.Duplicates;
import org.springframework.data.document.mongodb.query.Order;
import org.springframework.data.document.mongodb.query.Query;
 
import org.springframework.stereotype.Service;
import org.springframework.util.Assert;
 
import com.mongodb.BasicDBObject;
import com.mongodb.DBCollection;
import com.mongodb.MongoException;
 
@Service
public class MongoService {
    public long countDocuments( final String collection, final Query query ) {  
        return template.executeCommand( 
            "{ " +
                "\"count\" : \"" + collection + "\"," +
                "\"query\" : " + query.getQueryObject().toString() + 
            " }"  ).getLong( "n" );
    }
}

Подход для этой конкретной функции состоит в том, чтобы вызвать собственный счетчик команд MongoDB, передавая запрос в качестве параметра. Возвращающая структура содержит количество документов в n свойстве.

Или, более дружественным к коду способом:

import org.springframework.dao.DataAccessException;
import org.springframework.data.document.mongodb.CollectionCallback;
 
import com.mongodb.DBCollection;
import com.mongodb.MongoException;
 
public long countDocuments( final String collection, final Query query ) {  
    return template.execute( collection,
        new CollectionCallback< Long >() {
            @Override
            public Long doInCollection( DBCollection collection ) 
                    throws MongoException, DataAccessException {
                return collection.count( q.getQueryObject() ) );
            }
        }
    );
}

Следующая полезная функция — массовые вставки. Обратите внимание, что в текущей версии MongoDB 1.8.1, когда в коллекции вставок документов есть дубликат, массовая вставка останавливается на первом дубликате и возвращается, поэтому все остальные документы не будут вставлены . Будьте в курсе такого поведения. Прежде чем перейти к фрагменту кода, позвольте мне представить простой класс SimpleDocument, который мы будем сохранять в MongoDB :

package com.example.mongodb;
 
import org.springframework.data.document.mongodb.mapping.Document;
 
@Document( collection = "documents" )
public class SimpleDocument {
    private String id;
    private String name;
    private String content;
 
    public SimpleDocument() { 
    }
 
    public SimpleDocument( final String id, final String name ) {
        this.id = id;
        this.name = name;
    }
 
    public String getName() {
        return name;
    }
 
    public void setName(String name) {
        this.name = name;
    }
 
    public String getId() {
        return id;
    }
 
    public void setId(String id) {
        this.id = id;
    }
 
    public String getContent() {
        return content;
    }
 
    public void setContent(String content) {
        this.content = content;
    }
}

Следующий метод вставляет все документы как единое массовое обновление:

public void insert( final Collection< SimpleDocument > documents ) {  
    template.insert( documents, SimpleDocument.class );     
}

Еще одна очень полезная и полезная функция для изучения — upserts MongoDB (подробнее об этом здесь http://www.mongodb.org/display/DOCS/Updating): если документ, соответствующий определенным критериям, существует, он будет обновлен, в противном случае — новый документ будет быть вставленным в коллекцию. Ниже приведен код, демонстрируемый с помощью следующего варианта использования: если SimpleDocument с таким именем существует, он будет обновлен, в противном случае новый документ будет добавлен в коллекцию:

@Autowired private MongoConverter converter;
 
public void insertOrUpdate( final SimpleDocument document ) {
    final BasicDBObject dbDoc = new BasicDBObject();
    converter.write( document, dbDoc );
 
    template.execute( SimpleDocument.class, 
        new CollectionCallback< Object >() {
            public Object doInCollection( DBCollection collection ) 
                    throws MongoException, DataAccessException {
                collection.update( 
                    new Query()
                        .addCriteria( new Criteria( "name" ).is( document.getName() ) )
                        .getQueryObject(), 
                    dbDoc,  
                    true, 
                    false
                );
 
                return null;
            }
        }
    );
}

Обратите внимание на использование bean-компонента converter, который помогает конвертировать Java-класс в DBObject MongoDB .

Последнее, что я хотел бы показать, это операция findAndModify, которая делает несколько вещей в виде одной атомарной последовательности:

— найти критерии соответствия документа
— выполнить обновление
— вернуть обновленный документ (или старый, в зависимости от ваших потребностей)

public void findAndModify( final Query query, final Update update ) {
    return template.execute( SimpleDocument.class,
        new CollectionCallback< SimpleDocument >() {
            @Override
            public SimpleDocument doInCollection( DBCollection collection ) 
                    throws MongoException, DataAccessException {
                return converter.read( SimpleDocument.class,       
                    collection.findAndModify( 
                        query.getQueryObject(), 
                        null,
                        null,
                        false,
                        update.getUpdateObject(),
                        true,
                        false
                    ) 
                );
            }
        }   
    );
}

Пока это все интересные случаи использования, с которыми я столкнулся. Честно говоря, я очень рад MongoDB и настоятельно рекомендую его, если он подходит для вашего приложения.

Справка: Использование MongoDB вместе с проектом Spring Data: основные понятия и Использование MongoDB вместе с проектом Spring Data: передовые концепции от нашего партнера по JCG Андрея Редько в блоге Андрея Редько .

MongoDB с проектом Spring Data

Категории

Последние статьи

Рефакторинг Hudson God Class

Альтернативы синтаксиса Java лямбда

Morphia и MongoDB: развивающиеся структуры документов

OpenShift Express: развертывание приложения Java EE (с поддержкой AS7)

Интеграция jqGrid, REST, AJAX и Spring MVC