mongodb与spring集成案例

假设现在我们已经安装好了mongodb，并且都熟悉spring项目的配置。

 

spring 配置文件 spring-context.xml

与mongodb不相关的配置都已经去掉

 

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
	xmlns:p="http://www.springframework.org/schema/p" xmlns:task="http://www.springframework.org/schema/task"
	xmlns:mongo="http://www.springframework.org/schema/data/mongo"
	xmlns:mvc="http://www.springframework.org/schema/mvc"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
                        http://www.springframework.org/schema/beans/spring-beans-3.1.xsd 
                        http://www.springframework.org/schema/context 
                        http://www.springframework.org/schema/context/spring-context-3.1.xsd 
                        http://www.springframework.org/schema/aop 
                        http://www.springframework.org/schema/aop/spring-aop-2.0.xsd 
                        http://www.springframework.org/schema/tx 
                        http://www.springframework.org/schema/tx/spring-tx-2.0.xsd
                        http://www.springframework.org/schema/task 
                        http://www.springframework.org/schema/task/spring-task-3.0.xsd
                        http://www.springframework.org/schema/data/mongo 
						http://www.springframework.org/schema/data/mongo/spring-mongo.xsd
						http://www.springframework.org/schema/mvc 
        				http://www.springframework.org/schema/mvc/spring-mvc.xsd
                        ">
	<context:property-placeholder
		ignore-resource-not-found="false" location="classpath:mongodb.properties" />
	
	<bean class="com.qing.utils.PropertyUtils">
		<property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE" />
		<property name="ignoreResourceNotFound" value="false" />
		<property name="locations">
			<list>
				<value>classpath*:/mongodb.properties</value>
			</list>
		</property>
	</bean>

    <context:component-scan base-package="com.qing"/>
    <mongo:mongo id="mongo" replica-set="${mongo.host}">
        <mongo:options connections-per-host="${mongo.connectionsPerHost}"
             threads-allowed-to-block-for-connection-multiplier="${mongo.threadsAllowedToBlockForConnectionMultiplier}"
             connect-timeout="${mongo.connectTimeout}"
             max-wait-time="${mongo.maxWaitTime}"
             auto-connect-retry="${mongo.autoConnectRetry}"
             socket-keep-alive="${mongo.socketKeepAlive}"
             socket-timeout="${mongo.socketTimeout}"
             slave-ok="${mongo.slaveOk}"
             write-number="1"
             write-timeout="0"
             write-fsync="true"/>     
    </mongo:mongo>  
    
	<mongo:db-factory id="mongoDbFactory" dbname="${mongo.database}" mongo-ref="mongo" username="${mongo.username}" password="${mongo.password}"/>
		
	<mongo:mapping-converter id="mongoConverter" base-package="com.qing.core.entity">
		<mongo:custom-converters base-package="com.qing.core.entity" />
	</mongo:mapping-converter>

	<bean id="nearest" class="com.mongodb.TaggableReadPreference.NearestReadPreference"/>
	<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
		<constructor-arg ref="mongoDbFactory" />
		<constructor-arg ref="mongoConverter" />
		<property name="writeConcern" value="SAFE" />
		<property name="readPreference" ref="nearest" />
	</bean>
	<mongo:repositories base-package="com.qing.core.repository" /> 

</beans>

 

mongodb.properties的属性配置文件

#The number of connections per host agreed, when the connection pool is used up, will be blocked, the default value is 10 --int
mongo.connectionsPerHost=10
#multiplier for connectionsPerHost for # of threads that can block if connectionsPerHost is 10, and threadsAllowedToBlockForConnectionMultiplier is 5, then 50 threads can block more than that and an exception will be throw --int
mongo.threadsAllowedToBlockForConnectionMultiplier=5
#Blocked thread connections from the connection pool gets the longest waiting time (MS) --int
mongo.maxWaitTime=0
#To establish a socket connection when timeout (MS), the default value is 0 (infinite)
mongo.connectTimeout=0
#Whether the control system in the event of a connection error retry,Defaults to false
mongo.autoConnectRetry=false
#This controls whether or not to have socket keep alive turned on (SO_KEEPALIVE). defaults to false --boolean
mongo.socketKeepAlive=false
#Socket timeout; this value will be passed to the Socket.setSoTimeout (int). The default value is 0 (infinite) --int
mongo.socketTimeout=0
#Indicates whether the promised to drive from the secondary nodes or the slave node reads the data, defaults to false
mongo.slaveOk=false

mongo.database=mongodbtest
mongo.host=192.168.23.4:27017
mongo.username=mongo
mongo.password=123456

 

编写实体类、Controller、Service、Dao相关 

实体类

import java.math.BigInteger;

import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;

@Document(collection = "student")
public class Student extends BaseDocument<BigInteger> implements Comparable<Student> {

	private static final long serialVersionUID = -3711325228602088792L;
	
	@Field("userId")
	private String userId;
	
	@Field("userName")
	private String userName;
	
	@Field("password")
	private String password;
	
	@Field("mobilPhone")
	private String mobilPhone;
	
	/////////get/set方法省略///////
	@Override
	public int compareTo(Student o) {
		if (o == null)
			return -1;
		return this.userId.compareTo(o.getUserId());
	}
}

 

import java.io.Serializable;

import org.springframework.data.annotation.Id;

/**
 * <p> 抽象实体基类，提供统一的ID，和相关的基本功能方法
 */
public abstract class BaseDocument<ID extends Serializable> extends AbstractDocument<ID> {

	@Id
	private ID id;
	@Override
    public ID getId() {
        return id;
    }

    @Override
    public void setId(ID id) {
        this.id = id;
    }

}

 

import java.io.Serializable;

/**
 * 抽象实体基类
 */
public abstract class AbstractDocument<ID extends Serializable> implements Serializable  {

	/**
	 * Returns the identifier of the document.
	 * 
	 * @return the id
	 */
	public abstract ID getId();
	/**
     * Sets the id of the document.
     *
     * @param id the id to set
     */
	public abstract void setId(final ID id);

	/* 
	 * (non-Javadoc)
	 * @see java.lang.Object#equals(java.lang.Object)
	 */
	@Override
	public boolean equals(Object obj) {

		if (this == obj) {
			return true;
		}

		if (this.getId() == null || obj == null || !(this.getClass().equals(obj.getClass()))) {
			return false;
		}

		AbstractDocument<?> that = (AbstractDocument<?>) obj;

		return this.getId().equals(that.getId());
	}

	/* 
	 * (non-Javadoc)
	 * @see java.lang.Object#hashCode()
	 */
	@Override
	public int hashCode() {
		return this.getId() == null ? 0 : this.getId().hashCode();
	}
}

 

 

dao

import java.math.BigInteger;
import java.util.List;

import org.springframework.data.mongodb.repository.Query;
import org.springframework.data.repository.CrudRepository;

import com.qing.core.entity.Student;

public interface StudentRepository extends CrudRepository<Student, BigInteger>{
	
	List<Student> findByUserIdAndUserName(String userId,String userName);

	@Query("{userId:?0,$or:[{userName:{ $regex:?1}},{password:{ $regex:?1}}]}")
	List<Student> findStudentByUserIdAndUserName(String userId, String userName);
}

 

service

@Service
public class StudentService {

	@Autowired
	private StudentRepository studentRepository;
	
	@Autowired
	MongoTemplate mongoTemplate;

	public Message create(Student stu) {
		this.studentRepository.save(stu);
		Message message = new Message();
		message.setData(stu);
		return message;
	}

	public Message delete(Student stu) {
//		this.studentRepository.delete(stu);
		mongoTemplate.remove(new Query(Criteria.where("userName").is(stu.getUserName())), Student.class);
		Message message = new Message();
		message.setData(stu);
		return message;
	}
	
	public void update(Student stu) {
		Update update = new Update();
		update.set("password", stu.getPassword());
		mongoTemplate.updateFirst(new Query(Criteria.where("userId").is(stu.getUserId())), update, Student.class);
	}
	
	public List<Student> findByUserIdAndUserName(Student stu) {
		
		String userId = stu.getUserId();
		String userName = stu.getUserName();
		List<Student> studentList = studentRepository.findByUserIdAndUserName(userId, userName);
		
		return studentList;
	}
	
	public List<Student> findStudents(Student stu) {
		
		String userId = stu.getUserId();
		String userName = stu.getUserName();
		
		List<Student> studentList = studentRepository.findStudentByUserIdAndUserName(userId, userName);
		return studentList;
	}
}

 

controller

这个类就自己发挥写吧，就是springmvc的controller调用service层。