華閱文章網
java直接操作mongodb語句
參考如下public class MongoDBJDBC { public static void main(String[] args) { try { // 實例化Mongo對象，連接27017端口 Mongo mongo = new Mongo("localhost", 27017)； // 連接名為yourdb的數據庫，假如數據庫不存在的話，mongodb會自動建立 DB db = *("test"); // Get collection from MongoDB, database named "yourDB" // 從Mongodb中獲得名為yourColleection的數據集合，如果該數據集合不存在，Mongodb會為其新建立 DBCollection collection = *lection("test1")； // 使用BasicDBObject對象創建一個mongodb的document，并給予賦值。
BasicDBObject document = new BasicDBObject(); //*("id", 1001); //*("msg", "hello world mongoDB in Java")； // 將新建立的document保存到collection中去 //*(document)； // 創建要查詢的document BasicDBObject searchQuery = new BasicDBObject(); *("name", "chen")； // 使用collection的find方法查找document DBCursor cursor = *(searchQuery)； // 循環輸出結果 while (*t()) { *n(*()); } *n("Hello World"); } catch (UnknownHostException e) { *tackTrace(); } catch (MongoException e) { *tackTrace(); } }}。
mongodb 分組的語句怎么寫
/ 首先利$match篩選出where條件 此處看你的查詢范圍條件了BasicDBObject[] array = {new BasicDBObject("startTimeLong", new BasicDBObject("$gte",beginTime)), new BasicDBObject("startTimeLong", new BasicDBObject("$lt",endTime)) }; BasicDBObject cond = new BasicDBObject(); *("$and", array); DBObject match = new BasicDBObject("$match", cond)； // 利用$project拼裝group需要的數據，包含name列、age列 DBObject fields = new BasicDBObject("name", 1); *("age", 1); DBObject project = new BasicDBObject("$project", fields)； // 利用$group進行分組 DBObject _group = new BasicDBObject("name", "$name");_*("age", "$age");DBObject groupFields = new BasicDBObject("_id", _group)； //總數*("count", new BasicDBObject("$sum", 1));DBObject group = new BasicDBObject("$group", groupFields); AggregationOutput output = *InfoCollection().aggregate(match, project, group);。
mongodb語句可以寫成批處理嗎
在MongoDB中，文檔是對數據的抽象，它被使用在Client端和Server端的交互中。所有的Client端（各種語言的Driver）都會使用這種抽象，它的表現形式就是我們常說的BSON(Binary JSON )。
BSON是一個輕量級的二進制數據格式。
MongoDB能夠使用BSON，并將BSON作為數據的存儲存放在磁盤中。
當Client端要將寫入文檔，使用查詢等等操作時，需要將文檔編碼為BSON格式，然后再發送給Server端。同樣，Server端的返回結果也是編碼為BSON格式再放回給Client端的。
java直接操作mongodb語句
參考如下
public class MongoDBJDBC {
public static void main(String[] args) {
try {
// 實例化Mongo對象，連接27017端口
Mongo mongo = new Mongo("localhost", 27017);
// 連接名為yourdb的數據庫，假如數據庫不存在的話，mongodb會自動建立
DB db = *("test");
// Get collection from MongoDB, database named "yourDB"
// 從Mongodb中獲得名為yourColleection的數據集合，如果該數據集合不存在，Mongodb會為其新建立
DBCollection collection = *lection("test1");
// 使用BasicDBObject對象創建一個mongodb的document，并給予賦值。
BasicDBObject document = new BasicDBObject();
//*("id", 1001);
//*("msg", "hello world mongoDB in Java");
// 將新建立的document保存到collection中去
//*(document);
// 創建要查詢的document
BasicDBObject searchQuery = new BasicDBObject();
*("name", "chen");
// 使用collection的find方法查找document
DBCursor cursor = *(searchQuery);
// 循環輸出結果
while (*t()) {
*n(*());
}
*n("Hello World");
} catch (UnknownHostException e) {
*tackTrace();
} catch (MongoException e) {
*tackTrace();
}
}
}
