投稿
  1. 簡單一點首頁
  2. 編程

javamongodb獲取所有json,Java mongodb

OBDX • • 編程

本文目錄一覽：

如何用Java操作MongoDB

HelloWorld程序

學習任何程序的第一步，都是編寫HelloWorld程序，我們也不例外，看下如何通過Java編寫一個HelloWorld的程序。

首先，要通過Java操作Mongodb，必須先下載Mongodb的Java驅動程序，可以在這裡下載。

新建立一個Java工程，將下載的驅動程序放在庫文件路徑下，程序代碼如下：

package com.mkyong.core;

import java.net.UnknownHostException;

import com.mongodb.BasicDBObject;

import com.mongodb.DB;

import com.mongodb.DBCollection;

import com.mongodb.DBCursor;

import com.mongodb.Mongo;

import com.mongodb.MongoException;

/**

* Java + MongoDB Hello world Example

* 

*/

public class App {

    public static void main(String[] args) {

        try {

            //實例化Mongo對象，連接27017端口

            Mongo mongo = new Mongo(“localhost”, 27017);

                               //連接名為yourdb的數據庫，假如數據庫不存在的話，mongodb會自動建立

            DB db = mongo.getDB(“yourdb”);

            // Get collection from MongoDB, database named “yourDB”

//從Mongodb中獲得名為yourColleection的數據集合，如果該數據集合不存在，Mongodb會為其新建立

            DBCollection collection = db.getCollection(“yourCollection”);

    // 使用BasicDBObject對象創建一個mongodb的document,並給予賦值。

            BasicDBObject document = new BasicDBObject();

            document.put(“id”, 1001);

            document.put(“msg”, “hello world mongoDB in Java”);

            //將新建立的document保存到collection中去

            collection.insert(document);

            // 創建要查詢的document

            BasicDBObject searchQuery = new BasicDBObject();

            searchQuery.put(“id”, 1001);

            // 使用collection的find方法查找document

            DBCursor cursor = collection.find(searchQuery);

            //循環輸出結果

            while (cursor.hasNext()) {

            System.out.println(cursor.next());

            }

            System.out.println(“Done”); 

        } catch (UnknownHostException e) {

            e.printStackTrace();

        } catch (MongoException e) {

            e.printStackTrace();

        }

    }

}

最後，輸出的結果為：

{ “_id” : { “$oid” : “4dbe5596dceace565d229dc3”} , 

                “id” : 1001 , “msg” : “hello world mongoDB in Java”}

Done

在上面的例子中，演示了使用Java對Mongodb操作的重要方法和步驟，首先通過創建Mongodb對象，傳入構造函數的參數是Mongodb的數據庫所在地址和端口，然後使用

getDB方法獲得要連接的數據庫名，使用getCollection獲得數據集合的名，然後通過新建立BasicDBObject對象去建立document,最後通過collection的insert方法，將建立的document保存到數據庫中去。而collection的find方法，則是用來在數據庫中查找document。

從Mongodb中獲得collection數據集

在Mongodb中，可以通過如下方法獲得數據庫中的collection:

DBCollection collection = db.getCollection(“yourCollection”);

如果你不知道collection的名稱，可以使用db.getCollectionNames()獲得集合，然後再遍歷，如下：

DB db = mongo.getDB(“yourdb”);

Set collections = db.getCollectionNames();

for(String collectionName : collections){

System.out.println(collectionName);

}

完成的一個例子如下：

package com.mkyong.core;

import java.net.UnknownHostException;

import java.util.Set;

import com.mongodb.DB;

import com.mongodb.DBCollection;

import com.mongodb.Mongo;

import com.mongodb.MongoException;

/**

* Java : Get collection from MongoDB

* 

*/

public class GetCollectionApp {

public static void main(String[] args) {

try {

Mongo mongo = new Mongo(“localhost”, 27017);

DB db = mongo.getDB(“yourdb”);

SetString collections = db.getCollectionNames();

for (String collectionName : collections) {

System.out.println(collectionName);

}

DBCollection collection = db.getCollection(“yourCollection”);

System.out.println(collection.toString());

System.out.println(“Done”);

} catch (UnknownHostException e) {

e.printStackTrace();

} catch (MongoException e) {

e.printStackTrace();

}

}

}

Mongodb中如何插入數據

下面，講解下如何使用4種方式，將JSON數據插入到Mongodb中去。首先我們準備JSON

格式的數據，如下：

　

　{

“database” : “mkyongDB”,

“table” : “hosting”,

“detail” :

{

records : 99,

index : “vps_index1”,

active : “true”

}

}

}

我們希望用不同的方式，通過JAVA代碼向Mongodb插入以上格式的JSON數據

第一種方法，是使用BasicDBObject，方法如下代碼所示：

BasicDBObject document = new BasicDBObject();

document.put(“database”, “mkyongDB”);

document.put(“table”, “hosting”);

BasicDBObject documentDetail = new BasicDBObject();

documentDetail.put(“records”, “99”);

documentDetail.put(“index”, “vps_index1”);

documentDetail.put(“active”, “true”);

document.put(“detail”, documentDetail);

collection.insert(document);

第二種方法是使用BasicDBObjectBuilder對象，如下代碼所示：

BasicDBObjectBuilder documentBuilder = BasicDBObjectBuilder.start()

.add(“database”, “mkyongDB”)

.add(“table”, “hosting”);

BasicDBObjectBuilder documentBuilderDetail = BasicDBObjectBuilder.start()

.add(“records”, “99”)

.add(“index”, “vps_index1”)

.add(“active”, “true”);

documentBuilder.add(“detail”, documentBuilderDetail.get());

collection.insert(documentBuilder.get());

第三種方法是使用Map對象，代碼如下：

　

　Map documentMap =new HashMap();

documentMap.put(“database”, “mkyongDB”);

documentMap.put(“table”, “hosting”);

Map documentMapDetail =new HashMap();

documentMapDetail.put(“records”, “99”);

documentMapDetail.put(“index”, “vps_index1”);

documentMapDetail.put(“active”, “true”);

documentMap.put(“detail”, documentMapDetail);

collection.insert(new BasicDBObject(documentMap));

第四種方法，也就是最簡單的，即直接插入JSON格式數據

String json =”{‘database’ : ‘mkyongDB’,’table’ : ‘hosting’,”+

“‘detail’ : {‘records’ : 99, ‘index’ : ‘vps_index1’, ‘active’ : ‘true’}}}”;

DBObject dbObject =(DBObject)JSON.parse(json);

collection.insert(dbObject);

這裡使用了JSON的parse方法，將解析後的JSON字符串轉變為DBObject對象後再直接插入到collection中去。

完整的代碼如下所示：

packagecom.mkyong.core;

importjava.net.UnknownHostException;

importjava.util.HashMap;

importjava.util.Map;

importcom.mongodb.BasicDBObject;

importcom.mongodb.BasicDBObjectBuilder;

importcom.mongodb.DB;

importcom.mongodb.DBCollection;

importcom.mongodb.DBCursor;

importcom.mongodb.DBObject;

importcom.mongodb.Mongo;

importcom.mongodb.MongoException;

importcom.mongodb.util.JSON;

/**

* Java MongoDB : Insert a Document

*

*/

publicclass InsertDocumentApp {

publicstaticvoid main(String[] args){

try{

Mongo mongo =new Mongo(“localhost”, 27017);

DB db = mongo.getDB(“yourdb”);

// get a single collection

DBCollection collection = db.getCollection(“dummyColl”);

// BasicDBObject example

System.out.println(“BasicDBObject example…”);

BasicDBObject document =new BasicDBObject();

document.put(“database”, “mkyongDB”);

document.put(“table”, “hosting”);

BasicDBObject documentDetail =new BasicDBObject();

documentDetail.put(“records”, “99”);

documentDetail.put(“index”, “vps_index1”);

documentDetail.put(“active”, “true”);

document.put(“detail”, documentDetail);

collection.insert(document);

DBCursor cursorDoc = collection.find();

while(cursorDoc.hasNext()){

System.out.println(cursorDoc.next());

}

collection.remove(new BasicDBObject());

// BasicDBObjectBuilder example

System.out.println(“BasicDBObjectBuilder example…”);

BasicDBObjectBuilder documentBuilder = BasicDBObjectBuilder.start()

.add(“database”, “mkyongDB”)

.add(“table”, “hosting”);

BasicDBObjectBuilder documentBuilderDetail = BasicDBObjectBuilder.start()

.add(“records”, “99”)

.add(“index”, “vps_index1”)

.add(“active”, “true”);

documentBuilder.add(“detail”, documentBuilderDetail.get());

collection.insert(documentBuilder.get());

DBCursor cursorDocBuilder = collection.find();

while(cursorDocBuilder.hasNext()){

System.out.println(cursorDocBuilder.next());

}

collection.remove(new BasicDBObject());

// Map example

System.out.println(“Map example…”);

Map documentMap =new HashMap();

documentMap.put(“database”, “mkyongDB”);

documentMap.put(“table”, “hosting”);

Map documentMapDetail =new HashMap();

documentMapDetail.put(“records”, “99”);

documentMapDetail.put(“index”, “vps_index1”);

documentMapDetail.put(“active”, “true”);

documentMap.put(“detail”, documentMapDetail);

collection.insert(new BasicDBObject(documentMap));

DBCursor cursorDocMap = collection.find();

while(cursorDocMap.hasNext()){

System.out.println(cursorDocMap.next());

}

collection.remove(new BasicDBObject());

// JSON parse example

System.out.println(“JSON parse example…”);

String json =”{‘database’ : ‘mkyongDB’,’table’ : ‘hosting’,”+

“‘detail’ : {‘records’ : 99, ‘index’ : ‘vps_index1’, ‘active’ : ‘true’}}}”;

DBObject dbObject =(DBObject)JSON.parse(json);

collection.insert(dbObject);

DBCursor cursorDocJSON = collection.find();

while(cursorDocJSON.hasNext()){

System.out.println(cursorDocJSON.next());

}

collection.remove(new BasicDBObject());

}catch(UnknownHostException e){

e.printStackTrace();

}catch(MongoException e){

e.printStackTrace();

}

}

}

　

Java如何獲取JSON的內容

如果不是Android開發環境的話，首先需要引入處理JSON數據的包：json-lib-2.2.3-jdk15.jar

Java樣例程序如下：

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

import net.sf.json.JSONArray;

import net.sf.json.JSONObject;

public class DoJSON {

public static void main(String[] args) {

JSONArray employees = new JSONArray(); //JSON數組

JSONObject employee = new JSONObject(); //JSON對象

employee.put(“firstName”, “Bill”); //按“鍵-值”對形式存儲數據到JSON對象中

employee.put(“lastName”, “Gates”);

employees.add(employee); //將JSON對象加入到JSON數組中

employee.put(“firstName”, “George”);

employee.put(“lastName”, “Bush”);

employees.add(employee);

employee.put(“firstName”, “Thomas”);

employee.put(“lastName”, “Carter”);

employees.add(employee);

System.out.println(employees.toString());

for(int i=0; iemployees.size(); i++) {

JSONObject emp = employees.getJSONObject(i);

System.out.println(emp.toString());

System.out.println(“FirstName :\t” + emp.get(“firstName”));

System.out.println(“LastName : \t” + emp.get(“lastName”));

}

}

}

運行效果：

[{“firstName”:”Bill”,”lastName”:”Gates”},{“firstName”:”George”,”lastName”:”Bush”},{“firstName”:”Thomas”,”lastName”:”Carter”}]

{“firstName”:”Bill”,”lastName”:”Gates”}

FirstName : Bill

LastName : Gates

{“firstName”:”George”,”lastName”:”Bush”}

FirstName : George

LastName : Bush

{“firstName”:”Thomas”,”lastName”:”Carter”}

FirstName : Thomas

LastName : Carter

java+mongodb的正確使用方法！

package maven.demo.test;

import java.util.ArrayList;

import java.util.List;

import com.mongodb.BasicDBObject;

import com.mongodb.DB;

import com.mongodb.DBCollection;

import com.mongodb.DBObject;

import com.mongodb.Mongo;

import com.mongodb.QueryOperators;

public class MongoDB {

private static void print(String str){

System.out.println(str);

}

public static void main(String[] args) {

try {

//創建連接

Mongo m=new Mongo(“127.0.0.1”, 27017);

//得到數據庫

DB db=m.getDB(“sun”);

//得到所有數據庫

// ListString colls=m.getDatabaseNames();

// for(String str:colls){

// System.out.println(str);

// }

// //得到所有的集合（表）

// for(String collection:db.getCollectionNames()){

// System.out.println(collection);

// }

//刪除一個數據庫

//m.dropDatabase(“sun”);

//得到sun表

DBCollection coll=db.getCollection(“stu”);

//查看一個表的索引

// for(DBObject index:coll.getIndexInfo()){

// System.out.println(index);

// }

// DBObject myDoc=coll.findOne();

// System.out.println(myDoc);

//添加

// BasicDBObject doc=new BasicDBObject();

// doc.put(“name”, “sunshan”);

// doc.put(“sex”, “男”);

// doc.put(“age”, 22);

//coll.insert(doc);

//刪除

//coll.remove(doc);

// BasicDBObject doc1=new BasicDBObject();

// doc1.put(“i”, 0);

// doc1.put(“j”, “foo”);

// BasicDBObject doc2=new BasicDBObject();

// doc2.put(“hello”, “world”);

// doc1.put(“doc2”, doc2);

// coll.insert(doc1);

//修改

// BasicDBObject doc3=new BasicDBObject();

// doc3.put(“x”, 6);

// BasicDBObject doc4=new BasicDBObject();

// doc4.put(“x”, 1);

// coll.update(doc3, doc4,true,false);

//如果數據庫不存在就添加 |多條修改 false只修改第一天，true如果有多條就不修改

//條件查詢

//System.out.println(coll.find(doc4));

//coll.findAndRemove(doc4);

// //批量插入

// ListDBObject datas=new ArrayListDBObject();

// for(int i=0;i10;i++){

// BasicDBObject bd=new BasicDBObject();

// bd.put(“name”, “data”);

// bd.append(“age”, i);

// datas.add(bd);

// }

// coll.insert(datas);

//添加

// BasicDBObjectBuilder documentBuilder = BasicDBObjectBuilder.start();

// documentBuilder.add(“database”, “mkyongDB”);

// documentBuilder.add(“table”, “hosting”);

// BasicDBObjectBuilder documentBuilderDetail = BasicDBObjectBuilder.start();

// documentBuilderDetail.add(“records”, “99”);

// documentBuilderDetail.add(“index”, “vps_index1”);

// documentBuilderDetail.add(“active”, “true”);

// documentBuilder.add(“detail”, documentBuilderDetail.get());

// coll.insert(documentBuilder.get());

//添加

// MapObject,Object map=new HashMapObject,Object();

// map.put(“a”, 1);

// map.put(“b”, “b”);

// coll.insert(new BasicDBObject(map));

//添加

// String json =”{‘1’ : ‘1’,’2′ : ‘2’,”+”’11’ : {‘1’ : 1, ‘2’ : ‘2’, ‘3’ : ‘3’}}”;

// DBObject dbobject=(DBObject)JSON.parse(json);

// coll.insert(dbobject);

//更新

// BasicDBObject bdo=new BasicDBObject();

// bdo.put(“x”, 11);

// coll.update(new BasicDBObject().append(“x”, 0), bdo);

//更新

// BasicDBObject bdo=new BasicDBObject().append(“$inc”, new BasicDBObject().append(“x”, 12));

// coll.update(new BasicDBObject().append(“x”, 11), bdo);

//更新

//如果不使用$set 直接是 age則所有的都會更新

//根據age為9條件把name：data修改為 name：sun

// BasicDBObject bdo=new BasicDBObject().append(“$set”, new BasicDBObject().append(“name”, “sunshan”));

// coll.update(new BasicDBObject().append(“age”, 9), bdo);

//更新

//根據name為data條件把age：批量修改為 age:age

// BasicDBObject bdo=new BasicDBObject().append(“$set”, new BasicDBObject().append(“age”, “age”));

// coll.update(new BasicDBObject().append(“name”, “data”), bdo,false, true);

//查詢age=1

// print(“find：”+coll.find(new BasicDBObject(“age”, 1)).toArray());

//查詢age=1

// print(“find: “+coll.find(new BasicDBObject(“age”, new BasicDBObject(“$lte”, 1))).toArray());

//查詢age=1

// print(“fint: “+coll.find(new BasicDBObject(“age”, new BasicDBObject(“$gte”, 1))).toArray());

//查詢age！=1

// print(“fint: “+coll.find(new BasicDBObject(“age”, new BasicDBObject(“$ne”, 1))).toArray());

//查詢age=1,2,3

// print(“fint: “+coll.find(new BasicDBObject(“age”, new BasicDBObject(QueryOperators.IN ,new int[]{1,2,3}))).toArray());

//查詢age！=1,2,3

// print(“find: “+coll.find(new BasicDBObject(“age” ,new BasicDBObject(QueryOperators.NIN ,new int[]{1,2,3}))).toArray());

// print(“find: “+coll.find(new BasicDBObject(“age” ,new BasicDBObject(QueryOperators.EXISTS ,true))).toArray());

//查詢age屬性

// print(“find: “+coll.find(null ,new BasicDBObject(“age” ,true)).toArray());

// ListDBObject list=coll.find().toArray();

// for(Object obj:list){

// System.out.println(obj);

// }

// DBObject dbc=new BasicDBObject();

// dbc.put(“name”, 1111);

// ListDBObject list=new ArrayListDBObject();

// list.add(dbc);

// System.out.println(coll.insert(list).getN());

// //查詢部分數據塊

// DBCursor cursor=coll.find().skip(1);

// while(cursor.hasNext()){

// System.out.println(cursor.next());

// }

// DBCursor cur=coll.find(); //DBCursor cur=coll.find().limit(2);

// while(cur.hasNext()){

// System.out.println(cur.next());

// }

//System.out.println(cur.getCursorId()+” “+cur.count()+” “+JSON.serialize(cur));

//條件查詢

BasicDBObject doc5=new BasicDBObject();

doc5.put(“$gt”, 1);

doc5.put(“$lt”, 3);

print(“find 21y23：”+coll.find(new BasicDBObject(“y”, doc5)).toArray());

// BasicDBObject doc5=new BasicDBObject();

// doc5.put(“$gt”, 1);

// doc5.put(“$lt”, 3);

// BasicDBObject doc6=new BasicDBObject();

// doc6.put(“x”, doc5);

// System.out.println(coll.find(doc6));

} catch (Exception e) {

e.printStackTrace();

}

}

}

java中mongodb嵌套json查詢?

fastjson-1.1.2.jar 可以用這個jar包實現 java裡面 json字符串和對象之間的互轉

Java如何讀取json文件並將其存入Mongodb數據庫中

因為Java操作mongodb需要使用相關的ORM驅動，所以你最好是讀取json數據後轉成Java對象然後調用驅動方法存入到數據庫中即可。

原創文章，作者：OBDX，如若轉載，請註明出處：https://www.506064.com/zh-hant/n/136922.html

贊 (0)
打賞 微信掃一掃 微信掃一掃 支付寶掃一掃 支付寶掃一掃
OBDX的頭像OBDX
0 0
上一篇 2024-10-04 00:16
下一篇 2024-10-04 00:16

相關推薦

  • Java JsonPath 效率優化指南

    本篇文章將深入探討Java JsonPath的效率問題，並提供一些優化方案。 一、JsonPath 簡介 JsonPath是一個可用於從JSON數據中獲取信息的庫。它提供了一種DS…

    IGTLV的頭像 IGTLV
    編程 2025-04-29

  • java client.getacsresponse 編譯報錯解決方法

    java client.getacsresponse 編譯報錯是Java編程過程中常見的錯誤，常見的原因是代碼的語法錯誤、類庫依賴問題和編譯環境的配置問題。下面將從多個方面進行分析…

    UBWYH的頭像 UBWYH
    編程 2025-04-29

  • Java騰訊雲音視頻對接

    本文旨在從多個方面詳細闡述Java騰訊雲音視頻對接，提供完整的代碼示例。 一、騰訊雲音視頻介紹 騰訊雲音視頻服務（Cloud Tencent Real-Time Communica…

    YXDEN的頭像 YXDEN
    編程 2025-04-29

  • Java Bean加載過程

    Java Bean加載過程涉及到類加載器、反射機制和Java虛擬機的執行過程。在本文中，將從這三個方面詳細闡述Java Bean加載的過程。 一、類加載器 類加載器是Java虛擬機…

    SUCQN的頭像 SUCQN
    編程 2025-04-29

  • Java Milvus SearchParam withoutFields用法介紹

    本文將詳細介紹Java Milvus SearchParam withoutFields的相關知識和用法。 一、什麼是Java Milvus SearchParam without…

    IQUKH的頭像 IQUKH
    編程 2025-04-29

  • Java 8中某一周的周一

    Java 8是Java語言中的一個版本，於2014年3月18日發布。本文將從多個方面對Java 8中某一周的周一進行詳細的闡述。 一、數組處理 Java 8新特性之一是Stream…

    BYEUI的頭像 BYEUI
    編程 2025-04-29

  • Java判斷字符串是否存在多個

    本文將從以下幾個方面詳細闡述如何使用Java判斷一個字符串中是否存在多個指定字符： 一、字符串遍歷 字符串是Java編程中非常重要的一種數據類型。要判斷字符串中是否存在多個指定字符…

    KJBQQ的頭像 KJBQQ
    編程 2025-04-29

  • VSCode為什麼無法運行Java

    解答：VSCode無法運行Java是因為默認情況下，VSCode並沒有集成Java運行環境，需要手動添加Java運行環境或安裝相關插件才能實現Java代碼的編寫、調試和運行。 一、…

    GSABN的頭像 GSABN
    編程 2025-04-29

  • Java任務下發回滾系統的設計與實現

    本文將介紹一個Java任務下發回滾系統的設計與實現。該系統可以用於執行複雜的任務，包括可回滾的任務，及時恢復任務失敗前的狀態。系統使用Java語言進行開發，可以支持多種類型的任務。…

    BFFRU的頭像 BFFRU
    編程 2025-04-29

  • Java 8 Group By 會影響排序嗎?

    是的，Java 8中的Group By會對排序產生影響。本文將從多個方面探討Group By對排序的影響。 一、Group By的概述 Group By是SQL中的一種常見操作，它…

    AOPSM的頭像 AOPSM
    編程 2025-04-29

發表回復

登錄後才能評論