mongod java轻松入门

缺乏、安全感 2023-02-25 03:37 0阅读 0赞

直接上代码

pom.xml

<?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>pers.wwz.mongodb.study</groupId>
        <artifactId>mondodb-es</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <dependencies>
            <dependency>
                <groupId>org.mongodb</groupId>
                <artifactId>mongodb-driver-sync</artifactId>
                <version>3.9.1</version>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</version>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</version>
                <scope>compile</scope>
            </dependency>
        </dependencies>
        <build>
            <plugins>
                 <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.2</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                    <encoding>UTF-8</encoding>
                </configuration>
            </plugin>
            </plugins>
        </build>
    </project>

测试包

测试类:

import com.mongodb.client.MongoClient;
    import com.mongodb.client.MongoClients;
    import com.mongodb.client.MongoCollection;
    import com.mongodb.client.MongoDatabase;
    import com.mongodb.client.model.Projections;
    import com.mongodb.client.model.Sorts;
    import com.mongodb.client.model.Updates;
    import com.mongodb.client.result.DeleteResult;
    import com.mongodb.client.result.UpdateResult;
    import org.bson.Document;
    import org.junit.Before;
    import org.junit.Test;
    
    import java.util.function.Consumer;
    
    import static com.mongodb.client.model.Filters.*;
    
    /**
     * mongodb入门示例
     * 增删改查
     */
    public class MongodbDemo {
    
        private MongoCollection<Document> mongoCollection;
    
        public static void main(String[] args) {
    
        }
        @Before
        public void init(){
            // 建立连接
            MongoClient mongoClient = MongoClients.create("mongodb://192.168.168.156:27200");
            // 选择数据库
            MongoDatabase mongoDatabase = mongoClient.getDatabase("testdb");
            // 选择表
            this.mongoCollection = mongoDatabase.getCollection("user");
        }
        // 查询age<=50并且id>=100的用户信息，并且按照id倒序排序，只返回id，age,name,sex字段，不返回_id字段
        @Test
        public void testQuery(){
            this.mongoCollection.find(
                    and(
                            lte("age", 50),
                            gte("id", 100)
                    ) )
                    .sort(Sorts.descending("id"))
                    .projection(
                            Projections.fields(
                                    Projections.include("id","age","name","sex","wealth"),
                                    Projections.excludeId()
                            ) )
                    .forEach((Consumer<? super Document>) document -> {
                        System.out.println(document.toJson());
                    }); ;
        }
        @Test
        public void testInsert(){
            Document document = new Document("id",10001)
                    .append("name", "张三丰")
                    .append("age", 15)
                    .append("sex","male")
                    .append("wealth","1000w RMB");
            this.mongoCollection.insertOne(document); System.out.println("插入数据成功!");
            this.mongoCollection.find(eq("id", 10001))
                    .forEach((Consumer<? super Document>) doc->{
                        System.out.println(doc.toJson());
    
                    });
        }
    
        @Test
        public void testUpdate(){
            UpdateResult updateResult = this.mongoCollection
                    .updateOne(eq("id", 10001), Updates.set("age", 18));
            System.out.println(updateResult);
            this.mongoCollection.find(eq("id", 10001))
                    .forEach((Consumer<? super Document>) doc->{
                    });
        }
    
        @Test
        public void testDelete(){
            DeleteResult deleteResult = this.mongoCollection.deleteOne(eq("id",
                    10001));
            System.out.println(deleteResult);
        }
    }