DBObject object = new BasicDBObject()
object.put("name", "aaa")
object.put("age", 11)
collection.save(object)
System.out.println(object.get("_id"))
HelloWorld程序
学习任何程序的第一步，都是编写HelloWorld程序，我们也不例外，看下如何通过Java编写一个HelloWorld的程序。
首先，要通过Java *** 作Mongodb，必须先下载Mongodb的Java驱动程序，可以在这里下载。
新建立一个Java工程，将下载的驱动程序放在库文件路径下，程序代码如下：
package com.mkyong.coreimport 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.coreimport 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")
Set<String> 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()
}
}
}
一、安装mongoDB
1、解压mongodb-win32-i386-1.8.2至E:\MyProgram\mongodb-win32-i386-1.8.2（你可以按照自己的路径来，路径中最好不要有空格，要不然麻烦）
2、新建文件夹C:\DATA\DB，这是mongoDB的默认数据文件夹，你也可以在文件夹E:\MyProgram\mongodb-win32-i386-1.8.2新建一个文件夹data作为mongoDB的数据库文件存储目录
3、进入CMD，运行命令E:\MyProgram\mongodb-win32-i386-1.8.2\bin\mongod.exe -dbpath E:\MyProgram\mongodb-win32-i386-1.8.2\data，OK，mongoDB已经安装成功并已经在运行中了，你将会看到如下：
此时是mongoDB的运行状态，你可以按Ctrl+C结束运行状态或者直接关掉CMD结束运行。
二、运行mongoDB时的错误与处理
完成安装后，结束掉所有CMD窗口，然后进行如下 *** 作：
1、运行E:\MyProgram\mongodb-win32-i386-1.8.2\bin\mongo，可能会报错误：couldn't connect to server 127.0.0.1 shell/mongo.js，原因是mongod.exe没有启动，
2、既然没启动，那咱就启动呗，运行E:\MyProgram\mongodb-win32-i386-1.8.2\bin\mongod，可能会报错误：dbpath (/data/db/) does not exist, terminating，看这样子，本人觉得还得在data文件夹下再建一个db文件夹啊，如此即新建一db文件夹，再运行mongod命令，结果提示一样，不知道怎么搞啦，咱google吧
找到文章http://www.mongodb.org/display/DOCS/Starting+and+Stopping+Mongo
说“To start Mongo in default mode, where data will be stored in the /data/db directory (or c:\data\db on Windows), and listening on port 27017”，哦，原来默认的文档路径在c:\data\db，啥也不说，直接按这个建文件夹，再次运行命令mongod，OK了，启动成功，这个命令窗口不能关闭，否则mongoDB就退出了
三，使用mongo命令
保持mongod命令窗口的运行状态，再新开一命令窗口
输入E:\MyProgram\mongodb-win32-i386-1.8.2\bin\mongo，出现
MongoDB shell version:1.8.2
connecting to:test
>
OK，连接成功。
1，show dbs 显示数据库列表
2，use Northwind 进入Northwind数据库,大小写敏感
3，show collections 显示数据库中的集合
4，db 用于查看当前所在的数据库
5，db.Customer.count() 查看集合Customer的记录总数
6，db.Customer.findOne({"_id":"1"}) 查看CustomerId=1的记录
新增数据
1，use MyTest，这个数据库不存在，无所谓，mongo会创建，
MongoDB在使用前，并不要求您事先创建好相应的数据库，设计数据表结构！
在MongoDB中，没有【表】的概念，取而代之的是【集合】，也没有【数据记录】的概念，取而代之的是【文档】，我们可以把【文档】理解成一个【对象】，任意的对象，甚至可以有复杂的嵌套层次。
因此，我们不用再写代码从【数据表字段】到C#类的【属性，字段】的转换了，现在直接就可以读写整个对象了。
而且MongoDB不支持Join *** 作，所以，如果有【关联】 *** 作，就需要你自己来处理
2，item={"Key":"1","text":"wokao","number":3}
3，db.table1.insert(item)，mongo将建立集合table1，并将item插入，完成了新增加数据库的工作
4，db.table1.find()显示table1中的数据，MongoDB的文档使用的是一种称为BSON格式的对象，与Javascript中的JSON类似
5，额外的，输入item1={"Id":5,"str":"asdfasdf"}，再插入db.table1.insert(item1)，再用find()命令看，也插入成功了~，注意到结构和item不一样！但不建议这样做。
注意到：【每个文档有一个名为 "_id" 的成员】，我可没有定义啊。
其实，MongoDB会为每个文档都创建这样一个文档成员，我们指定的 "key", "id" 对于MongoDB来说：它们并不是【文档的主键】，MongoDB只认 "_id"，你可以指定，但如果不指定，MongoDB就自动添加。
修改数据
1，var t=db.table1.findOne({"Id":5})，获取一条记录
2，t.str="wokao"
3，db.table1.update({"Id":5},t)
删除数据
db.table1.remove({"Id":5})
查找数据
上面已经有find和findOne命令，即用于查询
db.table1.find()
MongoDB的查询条件中，并没有 >, <, >= , <= 这些运算符，而是使用 "$lt", "$lte", "$gt", "$gte"
新建表
db.MyTest.table2.save({})
删除表
db.table1.drop()或db.runCommand({"drop","table1"})
删除数据库
db.runCommand({"dropDatabase": 1})，此命令只能删除当前数据库
获取服务端状态信息
db.runCommand({"serverStatus" : 1})
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）