原生mongo包編程

maven:

 <dependency>
            <groupId>org.mongodb</groupId>
            <artifactId>mongo-java-driver</artifactId>
            <version>3.4.2</version>
        </dependency>
        <dependency>
            <groupId>com.google.code.gson</groupId>
            <artifactId>gson</artifactId>
            <version>2.8.0</version>
        </dependency>```


MongoTest1.java

import com.google.gson.Gson;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import java.util.ArrayList;
import java.util.List;
import static com.mongodb.client.model.Sorts.descending;
import static com.mongodb.client.model.Sorts.orderBy;

public class MongoTest1 {
public static void main(String[] args) {
try{
//獲得連接(無需驗(yàn)證用戶名密碼)
MongoClient mongoClient=new MongoClient("localhost",27017);

        //連接數(shù)據(jù)庫
        MongoDatabase mongoDatabase=mongoClient.getDatabase("5");
        System.out.println("Connect to database successfully");

        //創(chuàng)建集合
        //mongoDatabase.createCollection("testCollection");
        //System.out.println("集合創(chuàng)建成功");

        //獲取集合,打印文檔
        MongoCollection<Document> collection=mongoDatabase.getCollection("6");
        System.out.println("集合 testCollection 選擇成功");

        //插入文擋
        /*Document document=new Document();
        document.append("name","cc")
                .append("age", 24)
                .append("job","battery");
        List<Document> documents=new ArrayList<Document>();
        documents.add(document);
        collection.insertMany(documents);
        System.out.println("文檔插入成功");*/

        //檢索所有文檔
        /*FindIterable<Document> findIterable=collection.find();
        MongoCursor<Document> mongoCursor=findIterable.iterator();
        while (mongoCursor.hasNext()){
            System.out.println(mongoCursor.next());
        }*/

        //更新文檔   將文檔中age=18的文檔修改為age=24
        /*collection.updateMany(Filters.eq("age", 18), new Document("$set",new Document("age",24)));
        FindIterable<Document> findIterable=collection.find();
        MongoCursor<Document> mongoCursor=findIterable.iterator();
        while (mongoCursor.hasNext()){
            System.out.println(mongoCursor.next());
        }*/

        //刪除符合條件的第一個(gè)文檔
        //collection.deleteOne(Filters.eq("age", 24));

        //刪除所有符合條件的文檔
        //collection.deleteMany(Filters.eq("age", 24));


        //Document document=new Document();
        //以time排序獲得最后一條記錄
        /*document=collection.find().sort(orderBy(descending("time"))).first();
        String documentStr=document.toJson();
        MongoResult mongoResult=new Gson().fromJson(documentStr, MongoResult.class);*/

        //分頁
        int pageNo=1;
        int pageSize=3;

        List<MongoResult> list=new ArrayList<MongoResult>();
        MongoCursor<Document> cursor=collection.find().sort(orderBy(descending("time"))).skip((pageNo - 1) * pageSize).limit(pageSize).iterator();

        try {
            while (cursor.hasNext()) {
                String docStr=cursor.next().toJson();
                MongoResult mongoResult=new Gson().fromJson(docStr,MongoResult.class);
                System.out.println(mongoResult.getResult());
                list.add(mongoResult);
            }
        } finally {
            cursor.close();
        }

    }catch (Exception e){
        System.out.println("出現(xiàn)異常");
    }
}

}


MongoResult.java:

/**

  • Created by ztc on 2017/3/30.
    */
    public class MongoResult {
    private String result;
    private String time;

    public String getResult() {
    return result;
    }

    public void setResult(String result) {
    this.result = result;
    }

    public String getTime() {
    return time;
    }

    public void setTime(String time) {
    this.time = time;
    }
    }

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容