Java连接MongoDB进行增删改查
2024-08-27 20:11:49
1.导入必须的包：
详情看项目：http://pan.baidu.com/s/1cvDAOY
2.通过Myeclipse创建WEB项目
3.
3.bean:创建实体类
package com.bean; import java.io.Serializable;
import java.util.Date;
/**
* @since 对应于mongodb中的数据库test中的表com
* @author think
*
*/
public class Company implements Serializable {
private static final long serialVersionUID = 4379611409753357157L; private String id;
private String companyName;
private String url;
private String ip;
private Date createTime;
private Date updateTime; public Company() {
} public Company(String id, String companyName, String url, String ip,
Date createTime, Date updateTime) {
super();
this.id = id;
this.companyName = companyName;
this.url = url;
this.ip = ip;
this.createTime = createTime;
this.updateTime = updateTime;
} public String getId() {
return id;
} public void setId(String id) {
this.id = id;
} public String getCompanyName() {
return companyName;
} public void setCompanyName(String companyName) {
this.companyName = companyName;
} public String getUrl() {
return url;
} public void setUrl(String url) {
this.url = url;
} public String getIp() {
return ip;
} public void setIp(String ip) {
this.ip = ip;
} public Date getCreateTime() {
return createTime;
} public void setCreateTime(Date createTime) {
this.createTime = createTime;
} public Date getUpdateTime() {
return updateTime;
} public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
} public static long getSerialversionuid() {
return serialVersionUID;
} }
4.创建工具类，主要是获取本机的ip地址
package com.common;
import javax.servlet.http.HttpServletRequest;
public class Util {
public static String getIpAddr(HttpServletRequest request) {
String ip = request.getHeader("x-forwarded-for");
if (ip == null || "".equals(ip) || ip.length() == 0
|| "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("Proxy-Client-IP");
}
if (ip == null || "".equals(ip) || ip.length() == 0
|| "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("WL-Proxy-Client-IP");
}
if (ip == null || "".equals(ip) || ip.length() == 0
|| "unknown".equalsIgnoreCase(ip)) {
ip = request.getRemoteAddr();
}
return ip;
}
}
5.创建：控制器类(通过控制器来执行不同的操作)
package com.controller; import java.util.Date;
import java.util.List; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.servlet.ModelAndView; import com.bean.Company;
import com.service.ICompany;
@Controller
@RequestMapping("/company")
public class CompanyController {
private static Log log = LogFactory.getLog(CompanyController.class
.getName());
@Autowired
private ICompany icompany; // 查询所有公司
@RequestMapping("/companys")
public ModelAndView companys() {
List<Company> list = icompany.findCompanys();
ModelAndView mdl = new ModelAndView();
mdl.setViewName("/companys");
mdl.addObject("user", list);
return mdl;
}
//更新
@RequestMapping("/toUpdateCompany")
public ModelAndView toUpdateCompany(@RequestParam("id")String id){
ModelAndView mdl=new ModelAndView();
mdl.setViewName("/company_update");
Company company=icompany.findCompany(id);
mdl.addObject("company", company);
return mdl;
}
//更新保存
@RequestMapping("/updateCompany")
public String update(@ModelAttribute Company company){
try {
company.setUpdateTime(new Date());
icompany.updateCompany(company);
} catch (Exception e) {
log.error(e);
}
return companyList();
}
private String companyList() {
return "redirect:/company/companys.action";
}
//删除
@RequestMapping("/delCompany")
public String delCompany(@RequestParam("id") String id){
icompany.delCompany(id);
return companyList();
}
//增加
@RequestMapping("/toAddCompany")
public ModelAndView addCompany(){
return returnUrl("/company_add");
}
private ModelAndView returnUrl(String url) {
ModelAndView mav = new ModelAndView();
mav.setViewName(url);
return mav; }
//增加到数据库
@RequestMapping("/addCompany")
public String add(@ModelAttribute Company company){
company.setCreateTime(new Date());
company.setUpdateTime(new Date());
icompany.addCompany(company);
return companyList();
}
}
（登陆验证，在实际过程中要在数据库中匹配验证）
package com.controller; import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam; import com.sun.org.apache.commons.logging.Log;
import com.sun.org.apache.commons.logging.LogFactory; @Controller
@RequestMapping("/sys")
public class SysController {
private static Log log = LogFactory.getLog(SysController.class.getName()); @RequestMapping("/login")
public String Login(@RequestParam("userName") String userName,@RequestParam("userPwd") String userPwd) {
try {
if ("admin".equals(userName) && "123456".equals(userPwd)) {
return "redirect:/company/companys.action";
}
} catch (Exception e) {
log.error(e);
}
return "redirect:/index.jsp";
} @RequestMapping("/welcome")
public String welcome() {
return "redirect:/index.jsp";
}
}
6.创建数据库的连接，进行增删改查
（分别为接口和实现类）
package com.dao; 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.bean.Company; @Repository
public class RepositoryImpl implements AbstractRepository {
@Autowired
private MongoTemplate mongoTemplate; // 查询所有数据
public List<?> findAll(Class<?> entity) {
return mongoTemplate.findAll(entity);
} // 更新数据
public Company findOne(String id, Class<?> entity) {
return (Company) mongoTemplate.findOne(new Query(Criteria.where("id")
.is(id)), entity); } // 添加到数据库
public void updateEntity(Company company) {
mongoTemplate.save(company);
} // 删除选中的数据
public void delete(String id, Class<Company> class1) {
Criteria criteria = Criteria.where("id").in(id);
if (criteria != null) {
Query query = new Query(criteria);
if (query != null && mongoTemplate.findOne(query, class1) != null)
mongoTemplate.remove(mongoTemplate.findOne(query, class1));
} }
//增加到数据库
public void insert(Company company) {
mongoTemplate.insert(company); } }
package com.dao;
import java.util.List;
import com.bean.Company;
public interface AbstractRepository {
public List<?> findAll(Class<?> entity);
public Company findOne(String id,Class<?> entity);
public void updateEntity(Company company);
public void delete(String id, Class<Company> class1);
public void insert(Company company);
}
7.创建service类，对业务进行处理
package com.service;
import java.util.List;
import com.bean.Company;
public interface ICompany {
/**
* 查询所有公司
*/
public List<Company> findCompanys();
/**
* 更新数据
* @param id
* @return
*/
public Company findCompany(String id);
//更新到数据库
public void updateCompany(Company company);
//删除选中的数据
public void delCompany(String id);
//增加
public void addCompany(Company company);
}
package com.service; import java.util.List; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import com.bean.Company;
import com.dao.AbstractRepository;
@Service
public class CompanyImpl implements ICompany {
@Autowired
private AbstractRepository dao;
public List<Company> findCompanys() {
List<Company> list=(List<Company>) dao.findAll(Company.class);
return list;
}
//更新数据
public Company findCompany(String id) {
return dao.findOne(id, Company.class);
}
public void updateCompany(Company company) {
dao.updateEntity(company);
}
//删除选中的数据
public void delCompany(String id) {
dao.delete(id,Company.class);
}
//增加到数据哭
public void addCompany(Company company) {
dao.insert(company);
} }
8.配置对应的配置文件(applicationContext.xml--spring配置(依赖注入)，dispatcher-servlet.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: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/data/mongo
http://www.springframework.org/schema/data/mongo/spring-mongo-1.3.xsd
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
<context:property-placeholder location="classpath:mongodb.properties" />
<!-- 定义mongo对象，对应的是mongodb官方jar包中的Mongo，replica-set设置集群副本的ip地址和端口 -->
<mongo:mongo id="mongo" replica-set="127.0.0.1:27017">
<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}" write-number="1"
write-timeout="0" write-fsync="true" />
<!--<mongo:options connections-per-host="${mongo.connectionsPerHost}" 每个主机答应的连接数（每个主机的连接池大小），当连接池被用光时，会被阻塞住
，默以为10 threads-allowed-to-block-for-connection-multiplier="${mongo.threadsAllowedToBlockForConnectionMultiplier}"
connect-timeout="${mongo.connectTimeout}" 在建立（打开）套接字连接时的超时时间（ms） max-wait-time="${mongo.maxWaitTime}"
被阻塞线程从连接池获取连接的最长等待时间 auto-connect-retry="${mongo.autoConnectRetry}" 控制系统在发生连接错误时是否重试
，默以为false boolean socket-keep-alive="${mongo.socketKeepAlive}" 这个控制是打开(SO_KEEPALIVE)。默认值为false,布尔
socket-timeout="${mongo.socketTimeout}" #套接字超时时间;该值会被传递给Socket.setSoTimeout(int)。默以为0（无穷）
write-number="1" write-timeout="0" safe="false" #假如为true，驱动每次update后会发出一个getLastError命令来保证成功，默以为false
write-fsync="true"/> -->
</mongo:mongo>
<!-- mongo的工厂，通过它来取得mongo实例,dbname为mongodb的数据库名，没有的话会自动创建 -->
<mongo:db-factory dbname="test" mongo-ref="mongo" />
<!-- mongodb的主要操作对象，所有对mongodb的增删改查的操作都是通过它完成 -->
<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
<constructor-arg name="mongoDbFactory" ref="mongoDbFactory"></constructor-arg>
</bean> </beans>
<?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:mvc="http://www.springframework.org/schema/mvc"
xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
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/aop
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.0.xsd">
<!-- 使Spring支持自动检测组件，如注解的Controller -->
<mvc:annotation-driven />
<context:annotation-config />
<context:component-scan base-package="com" />
<!-- 视频解析 -->
<bean
class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<property name="prefix" value="/" />
<property name="suffix" value=".jsp" />
<property name="viewClass"
value="org.springframework.web.servlet.view.JstlView"></property>
</bean>
</beans>
9.log4j与数据库参数的配置
log4j.rootLogger=INFO,CONSOLE
log4j.category.com=DEBUG,messageWEB log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss,SSS}[%C]-[%p] %m%n log4j.appender.messageWEB=org.apache.log4j.DailyRollingFileAppender
log4j.appender.messageWEB.File=F\:\\logsdaily_rolling.log
log4j.appender.messageWEB.DatePattern=.yyyy-MM-dd
log4j.appender.messageWEB.layout=org.apache.log4j.PatternLayout
log4j.appender.messageWEB.layout.ConversionParttern=%-d{yyyy-MM-dd HH\:mm\:ss} [%c]-[%p] %m%n
log4j.appender.messageWEB.Encoding=UTF-8
mongo.connectionsPerHost=4
mongo.threadsAllowedToBlockForConnectionMultiplier=20
mongo.connectTimeout=0
mongo.maxWaitTime=10000
mongo.autoConnectRetry=true
mongo.socketKeepAlive=true
mongo.socketTimeout=0
10---前端展示--jsp文件
company_add.jsp
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%> <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
<title>客户验证平台</title>
</head>
<body>
<p align="left"><font size="7">客户添加</font></p>
<form action="<%=path%>/company/addCompany.action" method="post">
<p>客户名称:<input type="text" name="companyName" value=""/></p>
<p>客户网址:<input type="text" name="url" value=""/></p>
<p>客户ip:<input type="text" name="ip" value=""/></p>
<p><input type="submit" value="保存"/></p>
</form>
</body>
</html>
company_update.jsp
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%> <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
<title>客户验证平台</title>
</head>
<body>
<p align="left"><font size="7">客户修改</font></p>
<form action="<%=path%>/company/updateCompany.action" method="post">
<input type="hidden" name="id" value="${company.id}"/>
<input type="hidden" name="createTime" value="${company.createTime}"/>
<p>客户名称:<input type="text" name="companyName" value="${company.companyName}"/></p>
<p>客户网址:<input type="text" name="url" value="${company.url}"/></p>
<p>客户ip:<input type="text" name="ip" value="${company.ip}"/></p>
<p><input type="submit" value="保存"/></p>
</form>
</body>
</html>
companys.jsp
<%@taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core"%>
<%@ taglib uri="http://java.sun.com/jsp/jstl/fmt" prefix="fmt"%>
<%@ page language="java" contentType="text/html; charset=utf-8"
pageEncoding="utf-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme() + "://"
+ request.getServerName() + ":" + request.getServerPort()
+ path + "/";
%> <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
<title>客户验证平台</title>
</head>
<body>
<p align="left">
<font size="7">客户列表</font>
</p>
<table border="1">
<tr>
<td>id</td>
<td>客户名称</td>
<td>客户网址</td>
<td>客户ip</td>
<td>创建时间</td>
<td>最后修改时间</td>
<td>操作</td>
</tr>
<c:forEach items="${user}" var="user">
<tr>
<td>${user.id}</td>
<td>${user.companyName }</td>
<td>${user.url }</td>
<td>${user.ip }</td>
<td><fmt:formatDate value="${user.createTime}"></fmt:formatDate></td>
<td><fmt:formatDate value="${user.updateTime }"/></td>
<td>
<a href="<%=path%>/company/toUpdateCompany.action?id=${user.id}">修改</a>
<a href="<%=path%>/company/delCompany.action?id=${user.id}">删除</a>
<a href="<%=path%>/company/toAddCompany.action">添加</a>
</td>
</tr>
</c:forEach>
</table>
</body>
</html>
index.jsp
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme() + "://"
+ request.getServerName() + ":" + request.getServerPort()
+ path + "/";
%> <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
<title>客户验证平台</title>
</head>
<body>
<p align="center">
<font size="7">客户验证平台</font>
</p>
<form action="<%=path%>/sys/login.action" method="post">
<p align="center">
用户名:
<input type="text" name="userName" />
密码:
<input type="password" name="userPwd" />
<input type="submit" value="登录" />
</p>
</form>
</body>
</html>
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></display-name>
<welcome-file-list>
<welcome-file>index.jsp</welcome-file>
</welcome-file-list> <servlet>
<servlet-name>spring</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<init-param>
<description>加载目录下的所有XML作为Spring MVC的配置文件</description>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:dispatcher-servlet.xml</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>spring</servlet-name>
<url-pattern>*.action</url-pattern>
</servlet-mapping>
<!-- WEB项目中的上下文 -->
<context-param>
<description></description>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:applicationContext.xml</param-value>
</context-param>
<listener>
<description>监听器</description>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
<error-page>
<error-code>404</error-code>
<location>/404.html</location>
</error-page>
</web-app>
---404.html错误页面
<html>
<head>
<style type="text/css">
h2{
color: red;
}
</style>
</head>
<body>
<h2>
错误了!!!
</h2>
</body>
</html>
总结：与关系型数据库的连接一样，没有什么区别。
最新文章
- mysql max_allowed_packet 设置过小导致记录写入失败
- jave ee之 servlet 记录
- Selenium2(WebDriver)_如何判断WebElement元素对象是否存在
- 【javascript基础】7、继承
- gitbook使用
- BZOJ4297 : [PA2015]Rozstaw szyn
- wiki-editor语法
- 为什么我们不喜欢用富UI控件
- 【Linux&amp;Unix--文件描述叙事的性格和权柄】
- .NET的SqlHelper应用代码
- 【动画】JQuery实现冒泡排序算法动画演示
- openlayers4 入门开发系列之地图展示篇（附源码下载）
- Could not create local repository at /home/yizhenn/.m、IDEA倒入maven项目无法导报问题
- [C++]最小生成元 (Digit Generator, ACM/ICPC Seoul 2005, UVa1583)
- hdu 4738 Caocao's Bridges 求无向图的桥【Tarjan】
- bzoj2856: [ceoi2012]Printed Circuit Board
- 利用xshell远程连接centos安装oracle11g时在图形界面登录
- 基于Disruptor并发框架的分类任务并发
- Winform DatagridviewcomboboxColumn Disable Style
- “全栈2019”Java异常第三章：try代码块作用域详解
热门文章
- A List of Social Tagging Datasets Made Available for Research
- React Native填坑之旅--Navigation篇
- Linux:-bash: ***: command not found,系统很多命令都用不了
- ASDM through site to site VPN
- android wifi SWOL低功耗模式
- 利用HtmlAgilityPack库进行HTML数据抓取
- PCWIFI--无线网络共享软件
- 免费的HTML5版uploadify送上
- 团队项目——站立会议DAY14
- Asp.Net MVC中使用ACE模板之Jqgrid