【MongoDB for Java】Java操作MongoDB
開發環境：
System：Windows
IDE：eclipse、MyEclipse 8
Database：mongoDB
開發依賴庫：
JavaEE5、mongo-2.5.3.jar、junit-4.8.2.jar
Email：[email protected]
一、準備工作
1、 首先，下載mongoDB對Java支援的驅動包
2、 下面建立一個JavaProject工程，匯入下載下來的驅動包。即可在Java中使用mongoDB，目錄如下：
二、Java操作MongoDB示例
在本示例之前你需要啟動mongod.exe的服務，啟動後，下面的程式才能順利執行；
1、 建立SimpleTest.java，完成簡單的mongoDB資料庫操作
Mongo mongo = new Mongo();
這樣就建立了一個MongoDB的資料庫連線物件，它預設連線到當前機器的localhost地址，埠是27017。
DB db = mongo.getDB(“test”);
這樣就獲得了一個test的資料庫，如果mongoDB中沒有建立這個資料庫也是可以正常執行的。如果你讀過上一篇文章就知道，mongoDB可以在沒有建立這個資料庫的情況下，完成資料的新增操作。當新增的時候，沒有這個庫，mongoDB會自動建立當前資料庫。
得到了db，下一步我們要獲取一個“聚集集合DBCollection”，通過db物件的getCollection方法來完成。
DBCollection users = db.getCollection("users");
這樣就獲得了一個DBCollection，它相當於我們資料庫的“表”。
查詢所有資料
DBCursor cur = users.find();
while (cur.hasNext()) {
System.out.println(cur.next());
}
完整原始碼
package com.hoo.test;
import java.net.UnknownHostException;
import com.mongodb.DB;
import com.mongodb.DBCollection;import com.mongodb.DBCursor;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.util.JSON;
/**
* <b>function:</b>MongoDB 簡單示例
* @author hoojo
* @createDate 2011-5-24 下午02:42:29
* @file SimpleTest.java
* @package com.hoo.test
* @project MongoDB
* @blog http://blog.csdn.net/IBM_hoojo
* @email [email protected]
* @version 1.0
*/
public class SimpleTest {
public static void main(String[] args) throws UnknownHostException, MongoException {
Mongo mg = new Mongo();
//查詢所有的Database
for (String name : mg.getDatabaseNames()) {
System.out.println("dbName: " + name);
}
DB db = mg.getDB("test");
//查詢所有的聚集集合
for (String name : db.getCollectionNames()) {
System.out.println("collectionName: " + name);
}
DBCollection users = db.getCollection("users");
//查詢所有的資料
DBCursor cur = users.find();
while (cur.hasNext()) {
System.out.println(cur.next());
}
System.out.println(cur.count());
System.out.println(cur.getCursorId());
System.out.println(JSON.serialize(cur));
}
}
2、 完成CRUD操作，首先建立一個MongoDB4CRUDTest.java，基本測試程式碼如下：
package com.hoo.test;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.List;
import org.bson.types.ObjectId;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import com.mongodb.BasicDBObject;
import com.mongodb.Bytes;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.QueryOperators;
import com.mongodb.util.JSON;
/**
* <b>function:</b>實現MongoDB的CRUD操作
* @author hoojo
* @createDate 2011-6-2 下午03:21:23
* @file MongoDB4CRUDTest.java
* @package com.hoo.test
* @project MongoDB
* @blog http://blog.csdn.net/IBM_hoojo
* @email [email protected]
* @version 1.0
*/
public class MongoDB4CRUDTest {
private Mongo mg = null;
private DB db;
private DBCollection users;
@Before
public void init() {
try {
mg = new Mongo();
//mg = new Mongo("localhost", 27017);
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (MongoException e) {
e.printStackTrace();
}
//獲取temp DB；如果預設沒有建立，mongodb會自動建立
db = mg.getDB("temp");
//獲取users DBCollection；如果預設沒有建立，mongodb會自動建立
users = db.getCollection("users");
}
@After
public void destory() {
if (mg != null)
mg.close();
mg = null;
db = null;
users = null;
System.gc();
}
public void print(Object o) {
System.out.println(o);
}
}
3、 新增操作
在新增操作之前，我們需要寫個查詢方法，來查詢所有的資料。程式碼如下：
/**
* <b>function:</b> 查詢所有資料
* @author hoojo
* @createDate 2011-6-2 下午03:22:40
*/
private void queryAll() {
print("查詢users的所有資料：");
//db遊標
DBCursor cur = users.find();
while (cur.hasNext()) {
print(cur.next());
}
}
@Test
public void add() {
//先查詢所有資料
queryAll();
print("count: " + users.count());
DBObject user = new BasicDBObject();
user.put("name", "hoojo");
user.put("age", 24);
//users.save(user)儲存，getN()獲取影響行數
//print(users.save(user).getN());
//擴充套件欄位，隨意新增欄位，不影響現有資料
user.put("sex", "男");
print(users.save(user).getN());
//新增多條資料，傳遞Array物件
print(users.insert(user, new BasicDBObject("name", "tom")).getN());
//新增List集合
List<DBObject> list = new ArrayList<DBObject>();
list.add(user);
DBObject user2 = new BasicDBObject("name", "lucy");
user.put("age", 22);
list.add(user2);
//新增List集合
print(users.insert(list).getN());
//查詢下資料，看看是否新增成功
print("count: " + users.count());
queryAll();
}
4、 刪除資料
@Test
public void remove() {
queryAll();
print("刪除id = 4de73f7acd812d61b4626a77：" + users.remove(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).getN());
print("remove age >= 24: " + users.remove(new BasicDBObject("age", new BasicDBObject("$gte", 24))).getN());
}
5、 修改資料
@Test
public void modify() {
print("修改：" + users.update(new BasicDBObject("_id", new ObjectId("4dde25d06be7c53ffbd70906")), new BasicDBObject("age", 99)).getN());
print("修改：" + users.update(
new BasicDBObject("_id", new ObjectId("4dde2b06feb038463ff09042")),
new BasicDBObject("age", 121),
true,//如果資料庫不存在，是否新增
false//多條修改
).getN());
print("修改：" + users.update(
new BasicDBObject("name", "haha"),
new BasicDBObject("name", "dingding"),
true,//如果資料庫不存在，是否新增
true//false只修改第一天，true如果有多條就不修改
).getN());
//當資料庫不存在就不修改、不新增資料，當多條資料就不修改
//print("修改多條：" + coll.updateMulti(new BasicDBObject("_id", new ObjectId("4dde23616be7c19df07db42c")), new BasicDBObject("name", "199")));
}
6、 查詢資料
@Test
public void query() {
//查詢所有
//queryAll();
//查詢id = 4de73f7acd812d61b4626a77
print("find id = 4de73f7acd812d61b4626a77: " + users.find(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).toArray());
//查詢age = 24
print("find age = 24: " + users.find(new BasicDBObject("age", 24)).toArray());
//查詢age >= 24
print("find age >= 24: " + users.find(new BasicDBObject("age", new BasicDBObject("$gte", 24))).toArray());
print("find age <= 24: " + users.find(new BasicDBObject("age", new BasicDBObject("$lte", 24))).toArray());
print("查詢age!=25：" + users.find(new BasicDBObject("age", new BasicDBObject("$ne", 25))).toArray());
print("查詢age in 25/26/27：" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.IN, new int[] { 25, 26, 27 }))).toArray());
print("查詢age not in 25/26/27：" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.NIN, new int[] { 25, 26, 27 }))).toArray());
print("查詢age exists 排序：" + users.find(new BasicDBObject("age", new BasicDBObject(QueryOperators.EXISTS, true))).toArray());
print("只查詢age屬性：" + users.find(null, new BasicDBObject("age", true)).toArray());
print("只查屬性：" + users.find(null, new BasicDBObject("age", true), 0, 2).toArray());
print("只查屬性：" + users.find(null, new BasicDBObject("age", true), 0, 2, Bytes.QUERYOPTION_NOTIMEOUT).toArray());
//只查詢一條資料，多條去第一條
print("findOne: " + users.findOne());
print("findOne: " + users.findOne(new BasicDBObject("age", 26)));
print("findOne: " + users.findOne(new BasicDBObject("age", 26), new BasicDBObject("name", true)));
//查詢修改、刪除
print("findAndRemove 查詢age=25的資料，並且刪除: " + users.findAndRemove(new BasicDBObject("age", 25)));
//查詢age=26的資料，並且修改name的值為Abc
print("findAndModify: " + users.findAndModify(new BasicDBObject("age", 26), new BasicDBObject("name", "Abc")));
print("findAndModify: " + users.findAndModify(
new BasicDBObject("age", 28), //查詢age=28的資料
new BasicDBObject("name", true), //查詢name屬性
new BasicDBObject("age", true), //按照age排序
false, //是否刪除，true表示刪除
new BasicDBObject("name", "Abc"), //修改的值，將name修改成Abc
true,
true));
queryAll();
}
mongoDB不支援聯合查詢、子查詢，這需要我們自己在程式中完成。將查詢的結果集在Java查詢中進行需要的過濾即可。
7、 其他操作
public void testOthers() {
相關推薦
【MongoDB for Java】Java操作MongoDB
開發環境：
System：Windows
IDE：eclipse、MyEclipse 8
Database：mongoDB
開發依賴庫：
JavaEE5、mongo-2.5.3.jar、junit-4.8.2.jar
Email：[email p
【redis，1】java操作redis： 將string、list、map、自己定義的對象保存到redis中
n) spa 存儲 div ber sys mil 操作 write
一、操作string 、list 、map 對象
1、引入jar：
jedis-2.1.0.jar
2、代碼
/
java連線並操作mongodb資料庫（增、刪、查、改）
文末附有原始碼下載地址
package com.mongo.controller;
import com.mongodb.*;
import java.net.UnknownHostException;
import java.util.Date;
import java.util.Se
【轉】Python操作MongoDB資料庫
前言
MongoDB GUI 工具
PyMongo（同步）
Motor（非同步）
後記
前言
最近這幾天準備介紹一下 Python 與三大資料庫的使用，這是第一篇，首先來介紹 MongoDB 吧，，走起！！
MongoDB GUI 工具
首先介紹一款 MongoDB 的 GU
不使用spring的情況下用java原生程式碼操作mongodb資料庫的兩種方式
由於更改了mongodb3.0資料庫的密碼，導致這幾天storm組對資料進行處理的時候，一直在報mongodb資料庫連線不上的異常。
主要原因實際上是和mongodb本身無關的，因為他們改的是配
【redis，1】java操作redis： 將string、list、map、自定義的物件儲存到redis中
一、操作string 、list 、map 物件
1、引入jar：
jedis-2.1.0.jar
2、程式碼
/**
* @param args
*/
pub
MongoDB學習筆記(三) java中如何操作MongoDB
1. mongoDB對Java支援的驅動包
驅動包下載地址：http://repo1.maven.org/maven2/org/mongodb/mongo-java-driver/
mongoDB對Java的相關支援、技術：http://www.mongodb.org/di
【SSH進階】java.lang.IllegalArgumentException: id to load is required for loading
最近在做辦公自動化的專案,遇到這樣的問題java.lang.IllegalArgumentException: id to load isrequired for loading
Struts Pro
【Java】Java執行MySQL資料庫的刪除操作
package JavaDatabaseProgramming;
import java.sql.*;
//執行資料庫的刪除操作
public class DeleteData {
//定義MySQL
【MySQL集群】——Java程序連接MySQL集群
manager jdbc rda catch exe 連接 text 個數 trac
上篇簡介了怎樣在Windows環境下建立配置MySQL集群，這裏用一個實現註冊功能的小Demo通過jdbc的方式連接到MySQL集群中。
外部程序想要遠程連接到mys
【字符編碼】Java字符編碼詳細解答及問題探討
很好 cep 我們 簡單 實現 而是 tle 針對 Coding 一、前言
繼上一篇寫完字節編碼內容後，現在分析在Java中各字符編碼的問題，並且由這個問題，也引出了一個更有意思的問題，筆者也還沒有找到這個問題的答案。也希望各位園友指點指點。
二、Java字符編碼
【Java】Java中的數據類型
target java 基本數據類型 item ref cnblogs com 技術分享 aik Java 語言是一種強類型語言。通俗點說就是，在 Java 中存儲的數據都是有類型的，而且必須在編譯時就確定其類型。Java 數據類型分為兩類，如圖：
在 Jav
【java】java自帶的java.util.logging.Logger日誌功能
lena mat logs pre 默認 closed custom err ole 偶然翻閱到一篇文章，註意到Java自帶的Logger日誌功能，特地來細細的看一看，記錄一下。
1.Java自帶的日誌功能，默認的配置
①Logger的默認配置，位置在JRE安裝目錄下l
【java】java反射機制，動態獲取對象的屬性和對應的參數值，並屬性按照字典序排序，Field.setAccessible()方法的說明【可用於微信支付 簽名生成】
modifier 直接 this 字段值 1-1 讓我 toupper ima play 方法1：通過get()方法獲取屬性值
package com.sxd.test.controller;
public class FirstCa{
private
【Debian 8.8】Java 8 安裝以及環境變量配置
ubuntu lan pri 教程 target /usr tle 步驟 tor 事實上可以分為簡單的三個步驟：
下載 JDK 壓縮包
解壓壓縮包
配置環境變量
需要註意的是：
所有命令默認在 root 權限下進行！
演示環境是 Debian 8.8
【java】java反射初探 ——“當類也照起鏡子”
urn win att ofo das 函數 完整 exce ttr 反射的作用
開門見山地說說反射的作用
1.為我們提供了全面的分析類信息的能力
2.動態加載類
我理解的“反射”的意義
（僅個人理解哈）
我理解的
【java】java學習之路-01-Linux基礎（一）
x文件 字母 at命令 超過 用戶登錄 創建刪除 軟連接 nbsp tail linux學習方法：
你的程序要在服務器（linux）上執行，服務器沒有桌面系統，學習linux就是學習命令。
一、Linux介紹
1、芬蘭大學生，名字叫Linux，因為個人興趣，編寫了一個類Un
【tij學習筆記】Java finalize()的使用
依賴 資源釋放 定時 java system 使用 pan 靠譜 col 《Java編程思想》中有提到，Java的垃圾回收器並不是那麽靠譜，垃圾回收會占用很大的資源開銷，垃圾回收器很懶，當變量和對象不再被引用、脫離作用域的時候，垃圾回收器會不定時的進行垃圾回收，也就是說，當
【java】java處理隨機浮點數（小數點後兩位）用RMB的大寫數值規則輸出
pen junit toc get code package 部分 amp print 晚上上床前，拿到這個有意思的問題，就想玩弄一番：
====================================================================
【java】java基本編碼規範
分享 -m cimage down auto bfd imageview ava bbb
【java】java基本編碼規範