Java實現對MongoDB的AND、OR和IN操做 ，大於、小於等判斷
本文轉自http://blog.csdn.net/mydeman/article/details/6652387java
在MongoDB的官方文檔中關於Java操做的介紹，只給出了很簡單的幾個例子。這些例子雖然能夠知足必定的需求，可是還並非太徹底。下面是我根據網頁中的提示寫的幾個例子。mongodb
1.背景。用JUnit4.8.2實現的單元測試的形式。測試數據：數據庫
[plain] view plaincopyprint?單元測試
{uid:10,username:"Jim",age:23,agender:"male"}測試
{uid:27,username:"tom",age:13,agender:"male"}ui
{uid:12,username:"Jane",age:31,agender:"female"}spa
{uid:23,username:"Alex",age:47,agender:"male"}.net
{uid:109,username:"Lily",age:24,agender:"female"}code
{uid:10,username:"Jim",age:23,agender:"male"}
{uid:27,username:"tom",age:13,agender:"male"}
{uid:12,username:"Jane",age:31,agender:"female"}
{uid:23,username:"Alex",age:47,agender:"male"}
{uid:109,username:"Lily",age:24,agender:"female"}
單元測試的初始化和清理工做，主要是創建數據庫鏈接、寫入測試數據、清理測試數據：blog
[java] view plaincopyprint?
private static List<BasicDBObject> documents = new ArrayList<BasicDBObject>();
private static DBCollection coll;
@BeforeClass
public static void init(){
try {
initConnection();
loadData();
} catch (Exception e) {
e.printStackTrace();
}
}
private static void initConnection() throws UnknownHostException, MongoException{
//Create a connection to Collection 'user'
Mongo mongo = new Mongo("localhost", 27017);
DB db = mongo.getDB("test");
coll = db.getCollection("user");
}
private static void loadData() throws Exception{
BufferedReader br = new BufferedReader(new InputStreamReader(MongoTest.class.getResourceAsStream("data")));
String line = null;
while((line = br.readLine()) != null){
JSONObject jo = new JSONObject(line);
//Convert JSONObject into BasicDBObject
BasicDBObject dbObject = new BasicDBObject();
Iterator<String> joKeys = jo.keys();
while(joKeys.hasNext()){
String key = joKeys.next();
dbObject.put(key, jo.get(key));
}
documents.add(dbObject);
}
}
@Before
public void setUp(){
//Insert all data into MongoDB
for(BasicDBObject bdo : documents){
coll.insert(bdo);
}
}
public void cleanUp(){
//Drop the collection to remove all data.
//Note: it's not recommended.
coll.drop();
}
private static List<BasicDBObject> documents = new ArrayList<BasicDBObject>();
private static DBCollection coll;
@BeforeClass
public static void init(){
try {
initConnection();
loadData();
} catch (Exception e) {
e.printStackTrace();
}
}
private static void initConnection() throws UnknownHostException, MongoException{
//Create a connection to Collection 'user'
Mongo mongo = new Mongo("localhost", 27017);
DB db = mongo.getDB("test");
coll = db.getCollection("user");
}
private static void loadData() throws Exception{
BufferedReader br = new BufferedReader(new InputStreamReader(MongoTest.class.getResourceAsStream("data")));
String line = null;
while((line = br.readLine()) != null){
JSONObject jo = new JSONObject(line);
//Convert JSONObject into BasicDBObject
BasicDBObject dbObject = new BasicDBObject();
Iterator<String> joKeys = jo.keys();
while(joKeys.hasNext()){
String key = joKeys.next();
dbObject.put(key, jo.get(key));
}
documents.add(dbObject);
}
}
@Before
public void setUp(){
//Insert all data into MongoDB
for(BasicDBObject bdo : documents){
coll.insert(bdo);
}
}
@After
public void cleanUp(){
//Drop the collection to remove all data.
//Note: it's not recommended.
coll.drop();
}
2. AND是比較簡單的。
[java] view plaincopyprint?
public void testAnd(){
//agender='female' AND age > 27
DBObject queryCondition = new BasicDBObject();
queryCondition.put("agender", "female");
queryCondition.put("age", new BasicDBObject("$gt", 27));
DBCursor dbCursor = coll.find(queryCondition);
assertEquals(1, dbCursor.size());
assertEquals("Jane", dbCursor.next().get("username"));
}
@Test
public void testAnd(){
//agender='female' AND age > 27
DBObject queryCondition = new BasicDBObject();
queryCondition.put("agender", "female");
queryCondition.put("age", new BasicDBObject("$gt", 27));
DBCursor dbCursor = coll.find(queryCondition);
assertEquals(1, dbCursor.size());
assertEquals("Jane", dbCursor.next().get("username"));
}
3.單個字段的OR操做。
[java] view plaincopyprint?
public void testOrSingleField(){
DBObject queryCondition = new BasicDBObject();
//age<15 OR age>27
queryCondition = new BasicDBObject();
BasicDBList values = new BasicDBList();
values.add(new BasicDBObject("age", new BasicDBObject("$gt", 27)));
values.add(new BasicDBObject("age", new BasicDBObject("$lt", 15)));
queryCondition.put("$or", values);
DBCursor dbCursor = coll.find(queryCondition);
assertEquals(3, dbCursor.size());
assertEquals("tom", dbCursor.next().get("username"));
}
@Test
public void testOrSingleField(){
DBObject queryCondition = new BasicDBObject();
//age<15 OR age>27
queryCondition = new BasicDBObject();
BasicDBList values = new BasicDBList();
values.add(new BasicDBObject("age", new BasicDBObject("$gt", 27)));
values.add(new BasicDBObject("age", new BasicDBObject("$lt", 15)));
queryCondition.put("$or", values);
DBCursor dbCursor = coll.find(queryCondition);
assertEquals(3, dbCursor.size());
assertEquals("tom", dbCursor.next().get("username"));
}
4. 多個字段之間的OR操做
[java] view plaincopyprint?
@Test
public void testOrMultiFields(){
DBObject queryCondition = new BasicDBObject();
//agender=female OR age<=23
queryCondition = new BasicDBObject();
BasicDBList values = new BasicDBList();
values.add(new BasicDBObject("agender", "female"));
values.add(new BasicDBObject("age", new BasicDBObject("$lte", 23)));
queryCondition.put("$or", values);
DBCursor dbCursor = coll.find(queryCondition);
assertEquals(4, dbCursor.size());
assertEquals("Jim", dbCursor.next().get("username"));
}
@Test
public void testOrMultiFields(){
DBObject queryCondition = new BasicDBObject();
//agender=female OR age<=23
queryCondition = new BasicDBObject();
BasicDBList values = new BasicDBList();
values.add(new BasicDBObject("agender", "female"));
values.add(new BasicDBObject("age", new BasicDBObject("$lte", 23)));
queryCondition.put("$or", values);
DBCursor dbCursor = coll.find(queryCondition);
assertEquals(4, dbCursor.size());
assertEquals("Jim", dbCursor.next().get("username"));
}
5. 單個字段的IN操做。對於相似 where age=13 OR age=47的查詢條件，就能夠考慮使用IN代替
[java] view plaincopyprint?
@Test
public void testIn(){
DBObject queryCondition = new BasicDBObject();
//age in [13, 47]
queryCondition = new BasicDBObject();
BasicDBList values = new BasicDBList();
values.add(13);
values.add(47);
queryCondition.put("age", new BasicDBObject("$in", values));
DBCursor dbCursor = coll.find(queryCondition);
assertEquals(2, dbCursor.size());
assertEquals("tom", dbCursor.next().get("username"));
}
@Test
public void testIn(){
DBObject queryCondition = new BasicDBObject();
//age in [13, 47]
queryCondition = new BasicDBObject();
BasicDBList values = new BasicDBList();
values.add(13);
values.add(47);
queryCondition.put("age", new BasicDBObject("$in", values));
DBCursor dbCursor = coll.find(queryCondition);
assertEquals(2, dbCursor.size());
assertEquals("tom", dbCursor.next().get("username"));
}
從以上幾個例子能夠看出，經過BasicDBList與BasicDBObject的相結合能夠得出比較複雜的查詢條件。
- 1. Calendar 日期判斷 等於 。小於。大於
- 2. smarty 操做符 大於，小於，大於等於……
- 3. mongodb查詢的語法（大於，小於，大於或等於，小於或等於等等）
- 4. 關於javascrip ==(等號) 和===(恆等)判斷
- 5. 關於大小端的判斷函數
- 6. sql server 判斷 不等於
- 7. MyBatis 處理sql中的 大於，小於，大於等於，小於等於
- 8. MyBatis mapper.xml處理sql中的 大於，小於，大於等於，小於等於
- 9. MongoDB中的日期查詢命令的記錄：大於、小於、等於、範圍內、(mongoVUE 操做記錄)
- 10. mysql中between and 和大於等於、小於等於測試
- 更多相關文章...
- • C# 判斷 - C#教程
- • R 判斷語句 - R 語言教程
- • ☆基於Java Instrument的Agent實現
- • 適用於PHP初學者的學習線路和建議
-
每一个你不满意的现在，都有一个你没有努力的曾经。
- 1. 融合阿里雲，牛客助您找到心儀好工作
- 2. 解決jdbc(jdbctemplate)在測試類時不報錯在TomCatb部署後報錯
- 3. 解決PyCharm GoLand IntelliJ 等 JetBrains 系列 IDE無法輸入中文
- 4. vue+ant design中關於圖片請求不顯示的問題。
- 5. insufficient memory && Native memory allocation (malloc) failed
- 6. 解決IDEA用Maven創建的Web工程不能創建Java Class文件的問題
- 7. [已解決] Error: Cannot download ‘https://start.spring.io/starter.zip?
- 8. 在idea讓java文件夾正常使用
- 9. Eclipse啓動提示「subversive connector discovery」
- 10. 帥某-技巧-快速轉帖博主文章（article_content）
- 1. Calendar 日期判斷 等於 。小於。大於
- 2. smarty 操做符 大於，小於，大於等於……
- 3. mongodb查詢的語法（大於，小於，大於或等於，小於或等於等等）
- 4. 關於javascrip ==(等號) 和===(恆等)判斷
- 5. 關於大小端的判斷函數
- 6. sql server 判斷 不等於
- 7. MyBatis 處理sql中的 大於，小於，大於等於，小於等於
- 8. MyBatis mapper.xml處理sql中的 大於，小於，大於等於，小於等於
- 9. MongoDB中的日期查詢命令的記錄：大於、小於、等於、範圍內、(mongoVUE 操做記錄)
- 10. mysql中between and 和大於等於、小於等於測試