MongoDB配置，CRUD操作，條件查詢

簡單記錄一下自己使用的MongoDB的一些操作。

配置

處理了_class的不必要的生成，自定義一個遞增的註解：

//mongodb中生成的記錄忽略_class欄位
@Configuration
public class MongoConfig {
	@Bean
	public MappingMongoConverter mappingMongoConverter(MongoDbFactory factory, MongoMappingContext context,
			BeanFactory beanFactory) {
		DbRefResolver dbRefResolver =
 
 new DefaultDbRefResolver(factory);
		MappingMongoConverter mappingConverter = new MappingMongoConverter(dbRefResolver, context);
		try {
			mappingConverter.setCustomConversions(beanFactory.getBean(CustomConversions.class));
		} catch (NoSuchBeanDefinitionException ignore) {
		}
		// Don't save _class to mongo
 

		mappingConverter.setTypeMapper(new DefaultMongoTypeMapper(null));
		return mappingConverter;
	}
}

自定義遞增註解，mongodb無法設定欄位自動遞增，mongodb資料型別是一些基本資料型別，如果欄位不設定int,long型別無法實現自動註解的功能。通過監聽mongodb的生命週期事件，然後進行重寫實現。

@Component
public class MongoDBEventListener extends AbstractMongoEventListener<Object>
 
 {
	
	@SuppressWarnings("unused")
	private static final Logger LOG = LoggerFactory.getLogger(MongoDBEventListener.class);
	
	@Autowired
	private MongoTemplate mongoTemplate;
 
	/**
	 * 在新增記錄的時候，回撥介面方法，監聽文件插入記錄的操作，使用反射方法對ID進行自增
	 * 
	 * @param event
	 * @since 1.8
	 */
	@Override
	public void onBeforeConvert(BeforeConvertEvent<Object> event) {
		final Object source = event.getSource(); // 獲取事件最初發生的物件
		if (source != null) {
			// 使用反射工具類，實現回撥介面的方法，對成員進行操作
			ReflectionUtils.doWithFields(source.getClass(), new FieldCallback() {
				
				@Override
				public void doWith(Field field) throws IllegalArgumentException, IllegalAccessException {
					ReflectionUtils.makeAccessible(field); // 使操作的成員可訪問
					// 如果是帶有@AutoIncrement註解的，成員呼叫getter方法返回的型別是Number型別的，返回的型別都是0的(沒有賦值，預設為0)
					if (field.isAnnotationPresent(AutoIncrement.class) && field.get(source) instanceof Number
							&& field.getLong(source) == 0) {
						String collName = source.getClass().getSimpleName().substring(0, 1).toLowerCase()
								+ source.getClass().getSimpleName().substring(1);
						// setter方法的呼叫，使ID成員屬性，進行自增
						field.set(source, getNextId(collName));
					}
				}
			});
		}
	}
	
	/**
	 * 返回下一個自增的ID
	 * 
	 * @param collName
	 *            集合名稱（一般規則是，類名的第一個字母小寫，然後按照駝峰書寫法）
	 * @return Long 序列值
	 */
	private Long getNextId(String collName) {
		Query query = new Query(Criteria.where("collName").is(collName));
		List<SequenceId> list = mongoTemplate.find(query, SequenceId.class);
		SequenceId seq = null;
		Date now = new Date();
		if(list.size() > 0){
			Update update = new Update();
			update.inc("seqId", 1).set("gmtUpdate",now);
			FindAndModifyOptions options = new FindAndModifyOptions();
			options.upsert(true);
			options.returnNew(true);
			seq = mongoTemplate.findAndModify(query, update, options, SequenceId.class);
			return seq.getSeqId();
		}else{
			seq = new SequenceId();
			seq.setCollName(collName);
			seq.setGmtCreate(now);
			seq.setIsDelete("0");
			seq.setSeqId((long) 1);
			mongoTemplate.save(seq);
			return seq.getSeqId();
		}
	}
	
	/**
	 * Captures {@link BeforeSaveEvent}.
	 * 
	 * @param event will never be {@literal null}.
	 * @since 1.8
	 */
	@Override
	public void onBeforeSave(BeforeSaveEvent<Object> event) {
		//super.onBeforeSave(event);
	}

	/**
	 * Captures {@link AfterSaveEvent}.
	 * 
	 * @param event will never be {@literal null}.
	 * @since 1.8
	 */
	@Override
	public void onAfterSave(AfterSaveEvent<Object> event) {
		//super.onAfterSave(event);
	}

	/**
	 * 過濾掉isDelete=1 的資料
	 * 
	 */
	@Override
	public void onAfterLoad(AfterLoadEvent<Object> event) {
		//super.onAfterLoad(event);
	}

	/**
	 * Captures {@link AfterConvertEvent}.
	 * 
	 * @param event will never be {@literal null}.
	 * @since 1.8
	 */
	@Override
	public void onAfterConvert(AfterConvertEvent<Object> event) {
		//super.onAfterConvert(event);
	}

	/**
	 * Captures {@link AfterDeleteEvent}.
	 * 
	 * @param event will never be {@literal null}.
	 * @since 1.8
	 */
	@Override
	public void onAfterDelete(AfterDeleteEvent<Object> event) {
		//super.onAfterDelete(event);
	}

	/**
	 * Capture {@link BeforeDeleteEvent}.
	 * 
	 * @param event will never be {@literal null}.
	 * @since 1.8
	 */
	@Override
	public void onBeforeDelete(BeforeDeleteEvent<Object> event) {
		//super.onBeforeDelete(event);
	}


}

CRUD操作

簡單的CRUD操作可以繼承MongoRepository。也可以注入MongoTemplate 或者是MongoOperations進行一些操作，這兩個類裡面封裝了很多原生的方法。

條件查詢

• 繼承MongoRepository

   @Override
	<S extends T> List<S> findAll(Example<S> example);

	/* 
	 * (non-Javadoc)
	 * @see org.springframework.data.repository.query.QueryByExampleExecutor#findAll(org.springframework.data.domain.Example, org.springframework.data.domain.Sort)
	 */
	@Override
	<S extends T> List<S> findAll(Example<S> example, Sort sort);

Example 的使用利用一個物件設定欄位值，

/*
 * Copyright 2016 the original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.springframework.data.domain;

import org.springframework.util.ClassUtils;

/**
 * Support for query by example (QBE). An {@link Example} takes a {@code probe} to define the example. Matching options
 * and type safety can be tuned using {@link ExampleMatcher}.
 *
 * @author Christoph Strobl
 * @author Mark Paluch
 * @author Oliver Gierke
 * @param <T> the type of the probe.
 * @since 1.12
 */
public interface Example<T> {

	/**
	 * Create a new {@link Example} including all non-null properties by default.
	 *
	 * @param probe must not be {@literal null}.
	 * @return
	 */
	static <T> Example<T> of(T probe) {
		return new TypedExample<>(probe, ExampleMatcher.matching());
	}

	/**
	 * Create a new {@link Example} using the given {@link ExampleMatcher}.
	 *
	 * @param probe must not be {@literal null}.
	 * @param matcher must not be {@literal null}.
	 * @return
	 */
	static <T> Example<T> of(T probe, ExampleMatcher matcher) {
		return new TypedExample<>(probe, matcher);
	}

	/**
	 * Get the example used.
	 *
	 * @return never {@literal null}.
	 */
	T getProbe();

	/**
	 * Get the {@link ExampleMatcher} used.
	 *
	 * @return never {@literal null}.
	 */
	ExampleMatcher getMatcher();

	/**
	 * Get the actual type for the probe used. This is usually the given class, but the original class in case of a
	 * CGLIB-generated subclass.
	 *
	 * @return
	 * @see ClassUtils#getUserClass(Class)
	 */
	@SuppressWarnings("unchecked")
	default Class<T> getProbeType() {
		return (Class<T>) ClassUtils.getUserClass(getProbe().getClass());
	}
}

利用ExampleMatcher matcher可以設定一些條件

• 另外的一種條件拼接採用MongoTemplate 的方法

    @Override
	public List<RecordApi> findByPage(RecordApiForm form, Pageable pageable) {
		Query query = new Query();
		if (StringUtils.isNotBlank(form.getChannel())) {
			query.addCriteria(Criteria.where("channel").regex("^.*" + form.getChannel() + ".*$"));
		}
		if (StringUtils.isNotBlank(form.getBusiness())) {
			query.addCriteria(Criteria.where("business").regex("^.*" + form.getBusiness() + ".*$"));
		}
		if (StringUtils.isNotBlank(form.getMethod())) {
			query.addCriteria(Criteria.where("method").regex("^.*" + form.getMethod() + ".*$"));
		}
		if (isEmpty(form.getStart_time()) && isEmpty(form.getEnd_time())) {
			query.addCriteria(Criteria.where("gmtCreate").gte(form.getStart_time()).lte(form.getEnd_time()));
		} else if (isEmpty(form.getStart_time())) {
			query.addCriteria(Criteria.where("gmtCreate").gte(form.getStart_time()));
		} else if (isEmpty(form.getEnd_time())) {
			query.addCriteria(Criteria.where("gmtCreate").lte(form.getEnd_time()));
		}
		if (isEmpty(pageable)) {
			query.with(pageable);
		}
		return mongoTemplate.find(query, RecordApi.class);
	}