基于MongoDB的JAVA开发
架构：基于Spring框架+Maven
通用配置
配置pom文件
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<!--只有这里需要注意一下-->
<groupId>com.fuful</groupId> <!--对应JAVA的main目录下的包结构-->
<artifactId>mongodev</artifactId> <!--指定了当前maven项目在组中唯一的ID（标识符）。maven创建的目录就叫这个名字-->
<version>1.0-SNAPSHOT</version>
<name>mongodev</name>
<!-- FIXME change it to the project's website -->
<url>http://www.example.com</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.7</maven.compiler.source>
<maven.compiler.target>1.7</maven.compiler.target>
<spring.version>5.2.5.RELEASE</spring.version>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.11</version>
<scope>test</scope>
</dependency>
<!--spring-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>${spring.version}</version>
</dependency>
<!--引入异常处理-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-expression</artifactId>
<version>${spring.version}</version>
</dependency>
<!--mongo-->
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-mongodb -->
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-mongodb</artifactId>
<version>2.1.1.RELEASE</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>1.7.25</version>
</dependency>
</dependencies>
<repositories>
<repository>
<id>Spring</id>
<name>Spring Releases</name>
<url>https://repo.spring.io/libs-release</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
<build>
</build>
</project>配置applicationContext.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:mongo="http://www.springframework.org/schema/data/mongo"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="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-2.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
<!--扫描所有bean对象-->
<context:component-scan base-package="包路径"/>
<!--配置mongodb信息-->
<mongo:mongo-client id="mongo" host="自己的ip地址" port="27017"/>
<mongo:db-factory id="mongoDbFactory"
dbname="访问数据库"
mongo-ref="mongo"/>
<bean id="mappingContext"
class="org.springframework.data.mongodb.core.mapping.MongoMappingContext"/>
<bean id="defaultMongoTypeMapper"
class="org.springframework.data.mongodb.core.convert.DefaultMongoTypeMapper">
<constructor-arg name="typeKey">
<null/>
</constructor-arg>
</bean>
<bean id="mappingMongoConverter"
class="org.springframework.data.mongodb.core.convert.MappingMongoConverter">
<constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
<constructor-arg name="mappingContext" ref="mappingContext"/>
<property name="typeMapper" ref="defaultMongoTypeMapper"/>
</bean>
<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
<constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
<constructor-arg name="mongoConverter" ref="mappingMongoConverter"/>
</bean>
</beans>以操作blogs表为例
映射类（pojo类）
@Document(collection = "blogs")
public class Blogs {
@Id
private String id;
@Field("title")
private String title;
@Field
private String contents;
@Field
private String cname;
@Field
private Date ctime;
public Blogs() {
}
public Blogs(String title, String contents, String cname, Date ctime) {
this.title = title;
this.contents = contents;
this.cname = cname;
this.ctime = ctime;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getContents() {
return contents;
}
public void setContents(String contents) {
this.contents = contents;
}
public String getCname() {
return cname;
}
public void setCname(String cname) {
this.cname = cname;
}
public Date getCtime() {
return ctime;
}
public void setCtime(Date ctime) {
this.ctime = ctime;
}
}与Hibernate原理一致，一个集合对应一个pojo类，一个字段对应一个属性，一个实例对应一个文档
一些说明：
@Document(collection="")对应MongoDB表中的集合名词Id对应集合的id属性@Field对应字段属性。
注意：若数据库的字段名跟集合中的属性名不一致，需要给出字段名@Field("字段名")。
创建Service类，用于具体操作
@Service("blogsservice")
public class BlogsService {
@Autowired
private MongoTemplate template;
//插入一个数据insertOne
public void addBlog(Blogs blog){
template.insert(blog,"blogs");
}
//插入多个数据insertmany
public void addManyBlog(List<Blogs> blogs){
template.insert(blogs,"blogs");
}
}主函数（APP）
public class APP2 {
public static void main(String[] args) {
ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml");
BlogsService bs = (BlogsService) ac.getBean("blogsservice");
bs.addBlog(new Blogs("MongoDB手册","我是手册内容","Liu",new Date()));
}
}运行APP后数据库结果如下：
例：根据blogs集合的title名更新内容
blogService：
//根据title名更新内容
public void updateBlogForTitle(String title, String newContent){
//构造查询对象
Query query = new Query();
query.addCriteria(Criteria.where("title").is(title));
//构造修改对象
Update update = new Update();
update.set("contents",newContent);
update.currentDate("ctime");
template.updateFirst(query,update,"blogs");
}APP：
public class APP2 {
public static void main(String[] args) {
ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml");
BlogsService bs = (BlogsService) ac.getBean("blogsservice");
bs.updateBlogForTitle("MongoDB手册","我才是手册内容！");
}
}
Comments | NOTHING