mongodb的java客户端

1. springboot操作mongodb

1. maven配置

<dependency>      
<groupId>org.springframework.boot</groupId>    
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

2. application.properties中添加配置

spring.data.mongodb.uri=mongodb://name::27017/test

多个IP集群的可以采用下面的配置:

spring.data.mongodb.uri=mongodb://user::port1,ip2:port2/database

3. 创建数据库操作的实体类

import java.io.Serializable;
public class User implements Serializable {
      private static final long serialVersionUID = -3258839839160856613L;
      private Long id;
      private String userName;
      private String passWord;

      public Long getId() {
              return id;
      }

      public void setId(Long id) {
              this.id = id;
      }

      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;
      }

      @Override
      public String toString() {
              return "UserEntity{" +
                      "id=" + id +
                      ", userName=‘" + userName + ‘\‘‘ +
                      ", passWord=‘" + passWord + ‘\‘‘ +
                      ‘}‘;
      }
}

4. 实体类相关的增删改查操作

import com.mongodb.client.result.UpdateResult;
import com.neo.repository.UserRepository;
import com.neo.model.User;
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.data.mongodb.core.query.Update;
import org.springframework.stereotype.Component;

@Component
public class UserRepositoryImpl implements UserRepository {

  @Autowired
  private MongoTemplate mongoTemplate;

  /**
    * 创建对象
    * @param user
    */
  @Override
  public void saveUser(User user) {
      mongoTemplate.save(user);
  }

  /**
    * 根据用户名查询对象
    * @param userName
    * @return
    */
  @Override
  public User findUserByUserName(String userName) {
      Query query=new Query(Criteria.where("userName").is(userName));
      User user = mongoTemplate.findOne(query , User.class);
      return user;
  }

  /**
    * 更新对象
    * @param user
    */
  @Override
  public long updateUser(User user) {
      Query query=new Query(Criteria.where("id").is(user.getId()));
      Update update= new Update().set("userName", user.getUserName()).set("passWord", user.getPassWord());
      //更新查询返回结果集的第一条
      UpdateResult result =mongoTemplate.updateFirst(query,update,User.class);
      //更新查询返回结果集的所有
      // mongoTemplate.updateMulti(query,update,UserEntity.class);
      if(result!=null)
          return result.getMatchedCount();
      else
          return 0;
  }

  /**
    * 删除对象
    * @param id
    */
  @Override
  public void deleteUserById(Long id) {
      Query query=new Query(Criteria.where("id").is(id));
      mongoTemplate.remove(query,User.class);
  }
}

2. 多数据源MongoDB的使用

1. Maven配置

<dependency>      
<groupId>org.springframework.boot</groupId>    
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

2. 配置两条数据源

mongodb:
primary:
  host: localhost
  port: 27017
  database: test
secondary:
  host: localhost
  port: 27017
  database: data

3. 创建文件实体类

import lombok.Data;
import org.springframework.boot.autoconfigure.mongo.MongoProperties;

@Data //生成get、set方法等
public class MultipleMongoProperties {

  private MongoProperties primary = new MongoProperties();
  private MongoProperties secondary = new MongoProperties();

}

4. 配置两个数据库

数据库1

@Configuration
@EnableMongoRepositories(basePackages = "com.tedu.huawei.repository.primary",
      mongoTemplateRef = PrimaryMongoConfig.MONGO_TEMPLATE) //basePackages对应第一个库的repository所在的地址
public class PrimaryMongoConfig {
  protected static final String MONGO_TEMPLATE = "primaryMongoTemplate";
}

数据库2

@Configuration
@EnableMongoRepositories(basePackages = "com.tedu.huawei.repository.secondary",
      mongoTemplateRef = SecondaryMongoConfig.MONGO_TEMPLATE)
public class SecondaryMongoConfig {
  protected static final String MONGO_TEMPLATE = "secondaryMongoTemplate";
}

5. 构造对应的MongoTemplate

import com.mongodb.MongoClient;
import com.tedu.huawei.entity.MultipleMongoProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.mongo.MongoProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;

@Configuration
public class MultipleMongoConfig {

  @Autowired
  private MultipleMongoProperties mongoProperties;

  @Bean
  @ConfigurationProperties(prefix = "mongodb")
  public MultipleMongoProperties connectionSettings(){
      return new MultipleMongoProperties();

  }

  @Primary
  @Bean(name = PrimaryMongoConfig.MONGO_TEMPLATE)
  public MongoTemplate primaryMongoTemplate() throws Exception {
      return new MongoTemplate(primaryFactory(this.mongoProperties.getPrimary()));
  }

  @Bean
  @Qualifier(SecondaryMongoConfig.MONGO_TEMPLATE)
  public MongoTemplate secondaryMongoTemplate() throws Exception {
      return new MongoTemplate(secondaryFactory(this.mongoProperties.getSecondary()));
  }

  @Bean
  @Primary
  public MongoDbFactory primaryFactory(MongoProperties mongo) throws Exception {
      return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
              mongo.getDatabase());
  }

  @Bean
  public MongoDbFactory secondaryFactory(MongoProperties mongo) throws Exception {
      return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
              mongo.getDatabase());
  }
}