(1)pom.xml依赖文件
#mongoDB数据库名
mongo.dbname=test
#主机ip
mongo.host=127.0.0.1
#mongoDB端口
mongo.port=27017
#mongo.username=root
#mongo.password=root
#每台主机的连接数
mongo.connectionsPerHost=8
#\u7EBF\u7A0B\u961F\u5217\u6570,\u5B83\u4EE5\u4E0A\u9762connectionsPerHost\u503C\u76F8\u4E58\u7684\u7ED3\u679C\u5C31\u662F\u7EBF\u7A0B\u961F\u5217\u6700\u5927\u503C
mongo.threadsAllowedToBlockForConnectionMultiplier=4
#连接超时时间
mongo.connectTimeout=1500
#最大等待时间
mongo.maxWaitTime=1500
#\u81EA\u52A8\u91CD\u8FDE
mongo.autoConnectRetry=true
#scoket\u4FDD\u6301\u6D3B\u52A8
mongo.socketKeepAlive= true
#scoket\u8D85\u65F6\u65F6\u95F4
mongo.socketTimeout=1500
#\u8BFB\u5199\u5206\u79BB
mongo.slaveOk=true
(3)建立spring-mongodb.xml文件
<?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:mongo="http://www.springframework.org/schema/data/mongo"
xsi:schemaLocation="http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-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/tx
http://www.springframework.org/schema/tx/spring-tx.xsd
">
<!-- 加载mongodb的属性配置文件 -->
<context:property-placeholder location="classpath:properties/mongodb.properties" />
<!--1.开启注解-->
<context:annotation-config/>
<!--2.注解激活器 -->
<context:component-scan base-package="com.yzh.maven.*"/>
<!--3.服务器连接信息-->
<mongo:mongo-client host="${mongo.host}" port="${mongo.port}"></mongo:mongo-client>
<!--4.创建mongoTemplate模板-->
<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
<constructor-arg ref="mongo"/>
<!-- 设置使用的数据库名-->
<constructor-arg name="databaseName" value="${mongo.dbname}"/>
</bean>
</beans>
(4)建立springmvc.xml
<?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:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:util="http://www.springframework.org/schema/util"
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.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://www.springframework.org/schema/util
http://www.springframework.org/schema/util/spring-util-3.0.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc.xsd
">
<!-- 扫包 -->
<context:component-scan base-package="com.yzh.maven.controller" />
<!--以下映射器和适配器的配置可以通过注解驱动来代替 -->
<mvc:annotation-driven></mvc:annotation-driven>
<!--对静态资源文件的访问 必须要设置,因为在springmvc的配置中配置了/匹配所有请求,
此工程所有的请求(.do ,addUser,js/image/css)都会被springmvc解析,
必须对所有的静态资源文件进行过滤放行 -->
<mvc:resources mapping="/resource/**" location="/resource/" />
<!-- 拦截器定义 -->
<mvc:interceptors>
<mvc:interceptor>
<!-- 个人中心也需要登陆 以admin开头的配置都会进行拦截-->
<mvc:mapping path="/admin/**"></mvc:mapping>
<!-- 这个是设置不会进入拦截器的路径 -->
<mvc:exclude-mapping path="/resource/**"/>
<!-- 拦截器进入的类,返回false表示不会进入输入的路径 -->
<bean class="com.yzh.maven.interceptor.HandlerInterceptor1" />
</mvc:interceptor>
</mvc:interceptors>
<!-- 视图渲染 jsp/freemaker/velocity-->
<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<!-- 制定页面存放的路径 -->
<property name="prefix" value="/WEB-INF/pages/"></property>
<!-- 文件的后缀 -->
<property name="suffix" value=".jsp"></property>
</bean>
</beans>
(5)建立web.xml文件
<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
<display-name>mongoDBTestPro</display-name>
<!-- 加载Spring IOC容器 -->
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:spring-mongodb.xml</param-value>
</context-param>
<!-- spring上下文监听器 -->
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
<!-- Introspector缓存清除监听器 -->
<listener>
<listener-class>org.springframework.web.util.IntrospectorCleanupListener</listener-class>
</listener>
<filter>
<filter-name>encoding</filter-name>
<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
<init-param>
<param-name>encoding</param-name>
<param-value>UTF-8</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>encoding</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>
<!-- 配置DispatcherServlet -->
<servlet>
<servlet-name>yzh_mongodb</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<!-- 配置springMVC的配置文件 -->
<!-- 如果不配置下面选项,系统默认加载classpath下面名为[servlet-name]-servlet.xml的文件 springmvc01-servlet.xml -->
<init-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:springmvc.xml</param-value>
</init-param>
</servlet>
<!-- 过滤controller层请求,只能通过*.action请求 -->
<servlet-mapping>
<servlet-name>yzh_mongodb</servlet-name>
<url-pattern>*.action</url-pattern>
</servlet-mapping>
<welcome-file-list>
<welcome-file>index.jsp</welcome-file>
</welcome-file-list>
</web-app>
(6)建立实体类
package com.yzh.maven.entity;
import org.springframework.data.mongodb.core.mapping.Document;
@Document(collection="userInfo")
public class UserInfo{
private String userName;
private String password;
private int age;
private String sex;
private String tel;
private String email;
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
public String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
public String getTel() {
return tel;
}
public void setTel(String tel) {
this.tel = tel;
}
public String getEmail() {
return email;
}
public void setEmail(String email) {
this.email = email;
}
public UserInfo(String userName, String password, int age, String sex,
String tel, String email) {
super();
this.userName = userName;
this.password = password;
this.age = age;
this.sex = sex;
this.tel = tel;
this.email = email;
}
public UserInfo() {
super();
}
@Override
public String toString() {
return "UserInfo [userName=" + userName + ", password=" + password
+ ", age=" + age + ", sex=" + sex + ", tel=" + tel + ", email="
+ email + "]";
}
}
注意:实体类的命名需要与mongoDB中的集合名字一一对应,例如:在mongoDB中的集合为userInfo,那么实体类为UserInfo;或者我们更推荐在实体类上方添加@Document(collection=”集合名”),以此来注明该实体类对应的是哪一个集合名称。
(7)建立UserInfoService接口
package com.yzh.maven.service;
import java.util.List;
import com.yzh.maven.base.plugin.Pagination;
import com.yzh.maven.entity.UserInfo;
/**
*
* @author
*/
public interface UserInfoService{
/**
* 添加
* @param User
*/
public void addUser(UserInfo User);
/**
* 删除
* @param id
*/
public void removeUser(String id);
/**
* 保存或修改
* @param User
*/
public void saveOrUpdateUser(UserInfo User);
/**
* 根据id查询单个
* @param id
* @return
*/
public UserInfo findById(String id);
/**
* 根据用户名查询
* @param id
* @return
*/
public UserInfo findByUsername(String username);
/**
* 查询所有
* @return
*/
public List<UserInfo> findAll();
/**
* 分页查询
* @return
*/
public void queryPage(Pagination<UserInfo> pagination);
}
(8)建立UserServiceImpl实现类
package com.yzh.maven.service.impl;
import java.util.ArrayList;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Repository;
import com.yzh.maven.base.plugin.Pagination;
import com.yzh.maven.entity.UserInfo;
import com.yzh.maven.service.UserInfoService;
/**
* @author
*/
@Repository
public class UserServiceImpl implements UserInfoService {
@Autowired
private MongoTemplate mongoTemplate;
public void addUser(UserInfo User) {
//1.如果没有指定集合,则默认添加到和对象名称相同的集合中,没有则创建一个
//2.也可以指定集合 mongoTemplate.save(User, "User_db");
mongoTemplate.save(User);
}
public void removeUser(String id) {
UserInfo User = findById(id);
mongoTemplate.remove(User);
}
public void saveOrUpdateUser(UserInfo User) {
mongoTemplate.save(User);
}
public UserInfo findById(String id) {
return mongoTemplate.findById(id, UserInfo.class);
}
public List<UserInfo> findAll() {
return mongoTemplate.findAll(UserInfo.class);
}
public UserInfo findByUsername(String username) {
//根据username查询
Query sql = new Query(Criteria.where("username").is(username));
return mongoTemplate.findOne(sql,UserInfo.class);
}
@Override
public void queryPage(Pagination<UserInfo> pagination){
//当前页
int pageNow = pagination.getPageNo();
//每页记录数
int pageSize = pagination.getPageSize();
//总记录数
int totalRecord = findAll().size();
int endRow = pageNow*pageSize;
if(totalRecord<endRow){
endRow = totalRecord;
}
//获取当前页信息
List<UserInfo> newResultList = new ArrayList<UserInfo>();
for(int i = (pageNow-1)*pageSize;i<endRow;i++){
newResultList.add(findAll().get(i));
}
//分页查询参数设置
List<UserInfo> results = newResultList;
pagination.setResults(results);
pagination.setTotalPage((int)Math.ceil(totalRecord/pageSize));
pagination.setTotalRecord(totalRecord);
}
}
说明:MongoTemplate类封装了Java对MongoDB数据库的基本操作,因此我们可以直接通过该类来操作MongoDB数据库。
(9)建立controller控制器
package com.yzh.maven.controller;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.yzh.maven.base.model.DataMessage;
import com.yzh.maven.base.plugin.Pagination;
import com.yzh.maven.entity.UserInfo;
import com.yzh.maven.service.UserInfoService;
/**
* @FileName UserInfoController.java
* @Description: 用户信息操作Controller
* @Date 2018年8月31日
* @author yzh
* @version 1.0
*/
@Controller
@RequestMapping("/list")
public class UserInfoController{
@Autowired
private UserInfoService userInfoService;
private static final Logger LOG = LoggerFactory.getLogger(UserInfoController.class);
@ResponseBody
@RequestMapping(value = "/listUserInfos.action")
/**
* @FunctionName listUserInfos
* @Description: 分页查询
* @Date 2018年8月31日
* @author yzh
* @version 1.0
*/
public DataMessage listUserInfos(Pagination<UserInfo> pageParams) throws Exception {
userInfoService.queryPage(pageParams);
return DataMessage.successData(pageParams);
}
}