springboot操作MongoDB

1. 启动类及配置

import com.mongodb.client.MongoClient;

import com.mongodb.client.MongoClients;

import com.mongodb.client.internal.MongoClientImpl;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.context.annotation.Bean;

import org.springframework.data.mongodb.MongoDatabaseFactory;

import org.springframework.data.mongodb.MongoTransactionManager;

import org.springframework.data.mongodb.core.MongoTemplate;

import org.springframework.data.mongodb.core.SimpleMongoClientDatabaseFactory;

import org.springframework.transaction.annotation.EnableTransactionManagement;

@SpringBootApplication

// 开始事务

@EnableTransactionManagement

public class DemoApplication {

public static void main(String[] args) {

SpringApplication.run(DemoApplication.class, args);

}

@Bean

public MongoTemplate mongoTemplate() {

return new MongoTemplate(mongoDatabaseFactory());

}

@Bean

MongoTransactionManager transactionManager(MongoDatabaseFactory mongoDbFactory){

return new MongoTransactionManager(mongoDbFactory);

}

@Bean

public MongoClient mongoClient() {

// 使用更高级的配置MongoClientSettings（请注意，这些不是建议值）

// MongoClientSettings settings = MongoClientSettings.builder()

// .applyConnectionString(new ConnectionString("mongodb://127.0.0.1:37017/db_name"))

// .applyToConnectionPoolSettings(builder -> ConnectionPoolSettings.builder()

// .maxConnectionLifeTime(10, TimeUnit.SECONDS)

// .maxWaitTime(15, TimeUnit.SECONDS)

// .maxConnectionIdleTime(30, TimeUnit.SECONDS)

// .maintenanceFrequency(10, TimeUnit.SECONDS)

// .maintenanceInitialDelay(11, TimeUnit.SECONDS)

// .minSize(10)

// .maxSize(20)

// .build())

// .build();

// return MongoClients.create(settings);

return MongoClients.create("mongodb://127.0.0.1:27017/appdb");

}

@Bean

public MongoDatabaseFactory mongoDatabaseFactory() {

// new SimpleMongoClientDatabaseFactory()

return new SimpleMongoClientDatabaseFactory(mongoClient(), "appdb");

}

}

2. 实体类

@Document("book")

@Data

@NoArgsConstructor

@AllArgsConstructor

public class Book {

@Id

private String id;

private String title;

private Integer page;

}

3. mapper类

@Repository

public interface BookDao extends MongoRepository<Book, String> {

@Query("{'page' : {\"$gt\" : ?0}}")

public List<Book> findByPageGreaterThan(int page);

}

4. 测试

@Test

public void test16(){

Criteria criteria = Criteria.where("page").gte(10).lte(20);

Query query = new Query(criteria);

List<Book> list = mongoTemplate.find(query, Book.class);

System.out.println(list.size());

}

@Test

// 字段distinct查询

public void testkl(){

Criteria c = Criteria.where("title").is("China");

Query q = new Query();

List<String> distinct = mongoTemplate.findDistinct(

q, //查询条件

"title", //需要去重的列

"book", //表名

String.class //该表对应的实体类

);

distinct.forEach(System.out::println);

}

// 模糊查询

@Test

public void test05(){

Query query = new Query();

String pattern_name = "Zh";

Pattern pattern = Pattern.compile("^"+pattern_name, Pattern.CASE_INSENSITIVE);

query.addCriteria(Criteria.where("title").regex(pattern));

System.out.println(mongoTemplate.find(query, Book.class,"book").size());

}