一友樱槐、MongoDB数据库参数配置
1、推荐使用mongodb.cfg.properties配置，则在构造MongoDBService对象的时候只需调用无参构造方法即可自动完成配置。
2、如果没有通过mongodb.cfg.properties，会采用程序指定的默认配置。
// 定义默认配置，1、IP地址 2、端口号 3、用户名 4、密码 5、配置文件位置名 6、数据库名 private static final String MONGODB_ADDRESS = "127.0.0.1" private static final int MONGODB_PORT = 27017 private static final String MONGODB_USERNAME = "root" private static final String MONGODB_PASSWORD = "" private static final String MONGODB_RESOURCE_FILE = "mongodb.cfg.properties" private static final String MONGODB_DBNAME = "test" 颂氏 private static final String MONGODB_COLLECTIONNAME = "test"3、通过有参构造方法构造MongoDBService对象或通过get/set方法，指定数据库好友及集合，优先级最高。
//有参构造方法，指定数据库名与集合名 public MongoDBServiceImpl(String dbName, String collName) { this.dbName = dbName this.collName = collName try { db = getDb() } catch (Throwable e) { e.printStackTrace() } } //无参构造方法，返回配置文件配置的数据库对象引用，如果配置文件中没有设置则返回默认数据库对象引用 public MongoDBServiceImpl() { getDb() } /* * 获取数据库对象，3种情况（优先级从高到低）：<span style="white-space: pre"></span>*1、构造方法指定2、配置文件指定3、默认数据库<span style="white-space: pre"></span>*（情况2、3在MongoDButil中设置） */ public DB getDb() { if (this.db == null) { if (this.dbName == null) { this.db = MongoDBUtil.getDB() } else { this.db = MongoDBUtil.getDBByName(this.dbName) } } return this.db } /* * 获取集合对象，3种情况（优先级从高到低）： *1、构造方法指定2、配置文件指定3、默认数据库 *（情况2、3在MongoDButil中设置） */ public DBCollection getCollection() { if(this.collName != null){ return db.getCollection(this.collName) } else { return MongoDBUtil.getDBCollection() } }二、方法简介（具体实现参看MongoDBServiceImpl接口实现类）
1、获取基本信息或对象:
(1)、获取数据库名： getDbName()
(2)、设置数据库名（指定数据库）： setDbName(String dbName)
(3)、获取集合名： getCollName()
(4)、设置集合名（指定集合）： setCollName(String collName)
(5)、获取数据库对象： getDb()
2、数据插入方式：
(1)、插入单条数据： insert(DBObject obj)
(2)、插入多条数据： insertBatch(List list)void
3、数据删除方式：
(1)、删除单条数据： delete(DBObject obj)
(2)、删除多条数据： deleteBatch(List list)
4、数量统计方式：
(1)、获取集合中数据数量： getCollectionCount()
(2)、获取符合条件的数据数量： getCount(DBObject obj)
5、查找数据：
(1)、查找所有数据： findAll()
(2)、查找符合条件的数据： find(DBObject obj)
(3)、查找符合条件的数据并排序： find(DBObject query, DBObject sort)
(4)、查找符合条件的指定数量的数据并排序：find(DBObject query, DBObject sort, int start, int limit)
(5)、由ID查找数据： getById(String id)
6、更新数据 ：update(DBObject setFields, DBObject whereFields) void
7、打印List： printListDBObj(List list)
测试代码：（@Test）
public class testMongoService { //使用mongodb.cfg.properties中配置的数据库与集合，如未指定，使用MongoDBUtil中默认的数据库与集合 MongoDBService mongoDBService1 = new MongoDBServiceImpl() //测试插入数据 @Test public void testInsert(){ //数据一，包括用户名、密码，地址信息（省份、城市），爱好[…] BasicDBList dbList1 = new BasicDBList() dbList1.add("basketball") dbList1.add("music") dbList1.add("web") DBObject dbObject1 = new BasicDBObject("username","insert1") .append("age", 18) .append("address", new BasicDBObject("province","广东").append("city", "广州")) .append("favourite", dbList1) //数据二 BasicDBList dbList2 = new BasicDBList() dbList2.add("football") dbList2.add("music") DBObject dbObject2 = new BasicDBObject("username","insert2") .append("age", 18) .append("address", new BasicDBObject("province","陕西").append("city", "西安")) .append("favourite", dbList2) //数据三 BasicDBList dbList3 = new BasicDBList() dbList3.add("Linux") DBObject dbObject3 = new BasicDBObject("username","insert3") .append("age", 18) .append("address", new BasicDBObject("province","河北").append("city", "保定")) .append("favourite", dbList3) //数据四 BasicDBList dbList4 = new BasicDBList() dbList4.add("swim") dbList4.add("android") DBObject dbObject4 = new BasicDBObject("username","insert4") .append("age", 18) .append("address", new BasicDBObject("province","四川").append("city", "成都")) .append("favourite", dbList4) //数据五 DBObject dbObject5 = new BasicDBObject("username", "insert5") .append("age", 28) .append("address", new BasicDBObject("city", "杭州")) mongoDBService1.printListDBObj(mongoDBService1.findAll()) System.out.println("——————————————————insert collection——————————————————") List<dbobject>list = new ArrayList<dbobject>() list.add(dbObject1) list.add(dbObject2) list.add(dbObject3) list.add(dbObject5) mongoDBService1.insertBatch(list) System.out.println("——————————————————insert one——————————————————") mongoDBService1.insert(dbObject4) mongoDBService1.printListDBObj(mongoDBService1.findAll()) } //测试查询数据 @Test public void testFind(){ DBObject dbObject = new BasicDBObject("username","insert1") System.out.println("数量：" + mongoDBService1.getCollectionCount()) System.out.println("username=java的数据数量：" + mongoDBService1.getCount(dbObject)) System.out.println("——————————————————find all——————————————————") mongoDBService1.printListDBObj(mongoDBService1.findAll()) System.out.println("——————————————————find obj——————————————————") mongoDBService1.printListDBObj(mongoDBService1.find(dbObject)) System.out.println("——————————————————find sort——————————————————") mongoDBService1.printListDBObj(mongoDBService1.find(new BasicDBObject(), new BasicDBObject("age", 1))) System.out.println("——————————————————find sort limit——————————————————") mongoDBService1.printListDBObj(mongoDBService1.find(new BasicDBObject(), new BasicDBObject("age", 1), 1, 2)) } //测试数据更新 @Test public void testUpdate(){ BasicDBObject newDocument = new BasicDBObject("$set",new BasicDBObject("age",11)) BasicDBObject searchQuery = new BasicDBObject().append("username", "insert2") mongoDBService1.printListDBObj(mongoDBService1.find(searchQuery)) System.out.println("——————————————————update——————————————————") mongoDBService1.update(newDocument, searchQuery) mongoDBService1.printListDBObj(mongoDBService1.find(searchQuery)) } //测试数据删除 @Test public void testDelete(){ DBObject dbObject1 = new BasicDBObject("username", "insert1") DBObject dbObject2 = new BasicDBObject("username", "insert2") DBObject dbObject3 = new BasicDBObject("username", "insert3") DBObject dbObject4 = new BasicDBObject("username", "insert4") DBObject dbObject5 = new BasicDBObject("username", "insert5") List<dbobject>list = new ArrayList<dbobject>() list.add(dbObject1) list.add(dbObject2) list.add(dbObject3) list.add(dbObject4) mongoDBService1.printListDBObj(mongoDBService1.findAll()) System.out.println("——————————————————delete list——————————————————") mongoDBService1.deleteBatch(list) System.out.println("——————————————————delete one——————————————————") mongoDBService1.delete(dbObject5) //System.out.println("——————————————————delete all——————————————————") //mongoDBService1.delete(new BasicDBObject()) mongoDBService1.printListDBObj(mongoDBService1.findAll()) }}</dbobject></dbobject></dbobject></dbobject>测试结果：
源代码：（完整项目文件下载链接：点击打开链接）
MongoDBServiceImpl.java
public class MongoDBServiceImpl implements MongoDBService { private String dbName private String collName private DB db //有参构造方法，指定数据库名与集合名 public MongoDBServiceImpl(String dbName, String collName) { this.dbName = dbName this.collName = collName try { db = getDb() } catch (Throwable e) { e.printStackTrace() } } //无参构造方法，返回配置文件配置的数据库对象引用，如果配置文件中没有设置则返回默认数据库对象引用 public MongoDBServiceImpl() { getDb() } /* * 获取数据库对象，3种情况（优先级从高到低）： *1、构造方法指定2、配置文件指定3、默认数据库 *（情况2、3在MongoDButil中设置） */ public DB getDb() { if (this.db == null) { if (this.dbName == null) { this.db = MongoDBUtil.getDB() } else { this.db = MongoDBUtil.getDBByName(this.dbName) } } return this.db } /* * 获取集合对象，3种情况（优先级从高到低）： *1、构造方法指定2、配置文件指定3、默认数据库 *（情况2、3在MongoDButil中设置） */ public DBCollection getCollection() { if(this.collName != null){ return db.getCollection(this.collName) } else { return MongoDBUtil.getDBCollection() } } public DBObject map2Obj(Map<string, object="">map) { DBObject obj = new BasicDBObject() if (map.containsKey("class") &&map.get("class") instanceof Class) map.remove("class") obj.putAll(map) return obj } //插入数据 public void insert(DBObject obj) { getCollection().insert(obj) } //插入多条数据 public void insertBatch(List<dbobject>list) { if (list == null || list.isEmpty()) { return } List<dbobject>listDB = new ArrayList<dbobject>() for (int i = 0i <list.size()i++) { listDB.add(list.get(i)) } getCollection().insert(listDB) } //删除数据 public void delete(DBObject obj) { getCollection().remove(obj) } //删除多条数据 public void deleteBatch(List<dbobject>list) { if (list == null || list.isEmpty()) { return } for (int i = 0i <list.size()i++) { getCollection().remove(list.get(i)) } } //获取集合中的数据数量 public long getCollectionCount() { return getCollection().getCount() } //查找符合条件的数据数量 public long getCount(DBObject obj) { if (obj != null) return getCollection().getCount(obj) return getCollectionCount() } //查找符合条件的数据 public List<dbobject>find(DBObject obj) { DBCursor cur = getCollection().find(obj) return DBCursor2list(cur) } //查找符合条件的数据并排序 @Override public List<dbobject>find(DBObject query, DBObject sort) { DBCursor cur if (query != null) { cur = getCollection().find(query) } else { cur = getCollection().find() } if (sort != null) { cur.sort(sort) } return DBCursor2list(cur) } //查找符合条件的数据并排序，规定数据个数 @Override public List<dbobject>find(DBObject query, DBObject sort, int start, int limit) { DBCursor cur if (query != null) { cur = getCollection().find(query) } else { cur = getCollection().find() } if (sort != null) { cur.sort(sort) } if (start == 0) { cur.batchSize(limit) } else { cur.skip(start).limit(limit) } return DBCursor2list(cur) } //将DBCursor转化为list<dbobject> private List<dbobject>DBCursor2list(DBCursor cur) { List<dbobject>list = new ArrayList<dbobject>() if (cur != null) { list = cur.toArray() } return list } //更新数据 public void update(DBObject setFields, DBObject whereFields) { getCollection().updateMulti(whereFields, setFields) } //查询集合中所有数据 public List<dbobject>findAll() { DBCursor cur = getCollection().find() List<dbobject>list = new ArrayList<dbobject>() if (cur != null) { list = cur.toArray() } return list } //由ID获取数据 public DBObject getById(String id) { DBObject obj = new BasicDBObject() obj.put("_id", new ObjectId(id)) DBObject result = getCollection().findOne(obj) return result } public String getDbName() { return dbName } public void setDbName(String dbName) { this.dbName = dbName this.db = MongoDBUtil.getDBByName(this.dbName) } public String getCollName() { return collName } public void setCollName(String collName) { this.collName = collName } @Override public void printListDBObj(List<dbobject>list) { // TODO Auto-generated method stub for(DBObject dbObject: list){ System.out.println(dbObject) } } }</dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></string,>MongoDBUtil.java
public class MongoDBUtil { // 定义默认配置，1、IP地址 2、端口号 3、用户名 4、密码 5、配置文件位置名 6、数据库名 private static final String MONGODB_ADDRESS = "127.0.0.1" private static final int MONGODB_PORT = 27017 private static final String MONGODB_USERNAME = "root" private static final String MONGODB_PASSWORD = "" private static final String MONGODB_RESOURCE_FILE = "mongodb.cfg.properties" private static final String MONGODB_DBNAME = "test" private static final String MONGODB_COLLECTIONNAME = "test" // 定义静态变量，1、Mongo对象（代表数据库连接）2、DB对象（代表数据库）3、集合名4、数据库相关配置映射集合5、已获取的数据库连接 private static Mongo mongo private static DB db private static DBCollection collection private static Map<string, string="">cfgMap = new HashMap<string, string="">() private static Hashtable<string, db="">mongoDBs = new Hashtable<string, db="">() /** * 初始化Mongo的数据库 */ static { init() } /** * 获取配置文件中配置的DB对象 */ public static DB getDB() { return db } /** * 获取配置文件中配置的DBCollection对象 */ public static DBCollection getDBCollection() { return collection } /** * 根据数据库名称,得到数据库 如果不存在,则创建一个该名称的数据库,并设置用户名和密码为配置文件中的参数值 * * @param dbName * @return DB */ @SuppressWarnings("deprecation") public static DB getDBByName(String dbName) { DB db = mongo.getDB(dbName) if (!mongoDBs.contains(db)) { System.out.println("add") db.addUser(cfgMap.get("mongo.db.username"), cfgMap.get("mongo.db.password").toCharArray()) mongoDBs.put(dbName, db) } return db } // ————————————————————————————————————初始化过程———————————————————————————————————— /** * 获取配置文件mongedb.cfg.properties的文件对象 */ public static File getConfigFile() { String path = MongoDBUtil.class.getResource("/").getPath() String fileName = path + MONGODB_RESOURCE_FILE System.out.println(fileName) File file = new File(fileName) if (file.exists()) { return file } return null } /** * 通过mongedb.cfg.properties配置文件初始化配置映射集合，如果没有编写配置文件，则加载程序指定的默认配置 */ @SuppressWarnings("unchecked") private static void initCfgMap() { File file = getConfigFile() if (file != null) { Properties p = new Properties() try { p.load(new FileInputStream(file)) for (Enumeration enu = p.propertyNames()enu.hasMoreElements()) { String key = (String) enu.nextElement() String value = (String) p.getProperty(key) cfgMap.put(key, value) } } catch (IOException e) { System.out.println("加载Mongo配置文件失败!") e.printStackTrace() } } else { // 如果没有编写配置文件，则加载默认配置 cfgMap.put("mongo.db.address", MONGODB_ADDRESS) cfgMap.put("mongo.db.port", String.valueOf(MONGODB_PORT)) cfgMap.put("mongo.db.username", MONGODB_USERNAME) cfgMap.put("mongo.db.password", MONGODB_PASSWORD) cfgMap.put("mongo.db.dbname", MONGODB_DBNAME) cfgMap.put("mongo.db.collectionname", MONGODB_COLLECTIONNAME) } } /** * 初始化Mongo的数据库（将db指向相应对象引用，将collection指向相应对象引用，通过mongoDBs记录现有数据库对象） */ @SuppressWarnings("deprecation") private static void init() { initCfgMap() try { String address = cfgMap.get("mongo.db.address") int port = Integer.parseInt(cfgMap.get("mongo.db.port").toString()) String dbName = cfgMap.get("mongo.db.dbname") String username = cfgMap.get("mongo.db.username") String password = cfgMap.get("mongo.db.password") String collectionName = cfgMap.get("mongo.db.collectionname") mongo = new Mongo(address, port) if (dbName != null &&!"".equals(dbName)) { db = mongo.getDB(dbName) if (username != null &&!"".equals(username)) { db.addUser(username, password.toCharArray()) if (collectionName != null &&!"".equals(collectionName)) { collection = db.getCollection(collectionName) } } mongoDBs.put(dbName, db) } } catch (Exception e) { e.printStackTrace() } } }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()
}
}
}
java *** 作mongodb插入、读取、修改以及删除基础
本文主要讲述如何使用Java *** 作MongoDB以及了解MongoDB如何进行日常的数据库 *** 作。文章内容如下：第一步：安装MongoDB无需太多的繁杂步骤，你只要在MongoDB官方网站查看安装说明，根据自己的 *** 作系统进行选择适应的版本即可。第二步：启动MongoDB服务器这一步也很简单。运行mongod.exe文件里的bin文件夹（我使用的是Windows OS系统），并启动MongoDB服务器。在默认的情况下服务器将启动端口27017，你需要在安装过程中创建将数据存储在/data/db目录里。第三步：启动MongoDB shell指令你可以通过运行mongo.exe文件来启动MongoBD shell。第四步：利用MongoDB创建数据库利用MongoDB在MongoDB shell中输入以下内容建立一个名为“company”的数据库。use company 记住，除非你在MangoDB里保存了一些东西，否则它不会自动为你保存。使用下面的命令帮你查看可用的数据库，茄手它会显示“company”尚未被创建。show dbs第五步：在MongoDB中保存数据使用下面的命令来保存employee 数据代表一个collection，将其命名为employees。employee = {name : "A", no : 1} db.employees.save(employee) 通过使用下面的命令来查看collection里的数据。db.users.find()如何使用Java *** 作MongoDB？下面是是一段简单的Java代码，你可以在这里获得mongo-java驱动。很简单，只需要盯纳雹使用下面的代码，重复上面的 *** 作即可。package com.eviac.blog.mongoimport java.net.UnknownHostExceptionimport com.mongodb.BasicDBObjectimport com.mongodb.DBimport com.mongodb.DBCollectionimport com.mongodb.DBCursorimport com.mongodb.Mongoimport com.mongodb.MongoExceptionpublic class MongoDBClient { public static void main(String[] args) { try { Mongo mongo = new Mongo("localhost", 27017)DB db = mongo.getDB("company")DBCollection collection = db.getCollection("employees")BasicDBObject employee = new BasicDBObject()employee.put("name", "Hannah")employee.put("no", 2)collection.insert(employee)BasicDBObject searchEmployee = new BasicDBObject()searchEmployee.put("no", 2)DBCursor cursor = collection.find(searchEmployee)while (cursor.hasNext()) { System.out.println(cursor.next())} System.out.println("凯帆The Search Query has Executed!")} catch (UnknownHostException e) { e.printStackTrace()} catch (MongoException e) { e.printStackTrace()} } } 结果如下：{ "_id" : { "$oid" : "4fec74dc907cbe9445fd2d70"} , "name" : "Hannah" , "no" : 2} The Search Query has Executed! 小结：随着互联网Web2.0网站的兴起，非关系型的数据库现在成了一个极其热门的新领域，非关系数据库产品的发展也非常迅速。本文浅显的谈及了如何使用Java *** 作MongoDB以及了解MongoDB如何进行日常的数据库 *** 作的问题。如果您是这方面的专家不妨与我们分享下。本文为CSDN编译整理，未经允许不得转载。
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）