spring集成mongodb及基础使用

一、在spring框架中启用mongo db

spring集成mongodb可以通过java和xml两种方式进行集成，下面是xml方式：

<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-4.1.xsd          http://www.springframework.org/schema/data/mongo          http://www.springframework.org/schema/data/mongo/spring-mongo.xsd"         >          <!--启用repository扫描功能-->         <mongo:repositories base-package="com.qcsy"/>          <!--定义用于访问 MongoDB 的 MongoClient 实例-->         <mongo:mongo-client id="mongoClient" host="${mongo.host}" port="${mongo.port}">                 <mongo:client-options                         connections-per-host="${mongo.connectionsPerHost}"                         threads-allowed-to-block-for-connection-multiplier="${mongo.threadsAllowedToBlockForConnectionMultiplier}"                         connect-timeout="${mongo.connectTimeout}"                         max-wait-time="${mongo.maxWaitTime}"                         socket-keep-alive="${mongo.socketKeepAlive}"                         socket-timeout="${mongo.socketTimeout}"                 />         </mongo:mongo-client>         <!--定义用于连接到数据库的连接工厂-->         <mongo:db-factory dbname="${mongo.dbname}" mongo-ref="mongoClient"/>          <!--实际操作 mongodb 的 template,在代码中注入。注意如果此处id不叫mongoTemplate。可能会导致使用Repositry的时候找不到，需要特殊映射-->         <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">                 <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>         </bean>          </beans>

配置文件：

#mongo db的配置，如果不启用则不需要配置 mongo.host=localhost mongo.port=27017 # 数据库名称. 默认是'db'. mongo.dbname=test # 每个主机允许的连接数 mongo.connectionsPerHost=10 # 线程队列数，它和上面connectionsPerHost值相乘的结果就是线程队列最大值。如果连接线程排满了队列就会抛出异常 mongo.threadsAllowedToBlockForConnectionMultiplier=5 # 连接超时的毫秒 0是默认值且无限大。 mongo.connectTimeout=1000 # 最大等待连接的线程阻塞时间 默认是120000 ms (2 minutes). mongo.maxWaitTime=1500 # 保持活动标志，控制是否有套接字保持活动超时 官方默认为true 且不建议禁用 mongo.socketKeepAlive=true # 用于群集心跳的连接的套接字超时。 mongo.socketTimeout=1500

二、映射模型实体

@Document public class User {     @Id     private String userid;     @Field("userinfo")     private String username;     private String userpassword;     ......get\set方法........ }

@Document与@Entity类似，表明是一个实体，@Id表明是主键

其他的Spring data mongoDB注解还有：

@Document

把一个java类声明为mongodb的文档，可以通过collection参数指定这个类对应的文档。@Document(collection="mongodb 对应 collection 名")

@Id

文档的唯一标识，在mongodb中为ObjectId，它是唯一的

@Indexed

声明该字段需要索引，建索引可以大大的提高查询效率。

@CompoundIndex

复合索引的声明，建复合索引可以有效地提高多字段的查询效率。

@Field

给映射存储到 mongodb 的字段取别名

@Dbref

标识引用其他文档，这个文档有可能在另外的数据库中

@Version

标识改属性作为版本控制

@Transient

默认情况下所有的私有字段都映射到文档，该注解标识的字段从存储在数据库中的字段列中排除（即该字段不保存到 mongodb）

三、使用MongoTemplate访问mongodb

@Autowired private MongoOperations mongoOperations;

在这里，我们将MongoTemplate注入到MongoOperations ，因为MongoTemplate是MongoOperations 实现类，使用接口注入是一个好的做法

/**  * 保存数据  */ @Override public void templateSave() {     User user=new User();     user.setUserid("001");     user.setUsername("测试");     user.setUserpassword("11");     mongoOperations.save(user,"user"); }  /**  * 更新数据  */ @Override public void templateUpdate() {     //where跟的是字段，is相当于等于     Query query=Query.query(Criteria.where("userid").is("001"));     mongoOperations.updateFirst(query, Update.update("username","修改"),User.class); } /**  * 查询数据  * @return  */ @Override public User templateQuery() {     Query query=Query.query(Criteria.where("userid").is("001"));     return   mongoOperations.find(query,User.class).get(0); }

四、使用MongoDb Repository访问mongodb

• 与spring data jpa类似，spring data mongodb同样有类似的操作方式，实现一个接口继承MongoRepository<T,id>：

public interface MongoDemoRepository extends MongoRepository<User,String> {   User findFirstByUsername(String username);  }

通过继承接口，spring data会自动实现基本的crud方法，同时，还支持通过方法的形式扩展自己想要的方法，例如通过以下关键词扩展(图片在网上找的)：

自定义查询方法，格式为“find/get/readBy+字段名+方法后缀”，方法传进的参数即字段的值。

支持的部分常用方法后缀有：

• 除此之外，与spring data jpa 类似，它也支持@Query的方式自定义指定。但它不是指定的sql而是一个json .

@Query("{'userpassid':'qq','username':?0}")  List<User> findUsername(String username);

• 它同样可以通过接口的方式和spring data jpa 类似实现mongotemplate与repository混合方法。此处不做介绍