日期:2014-05-16 浏览次数:20456 次
package com.mongo.ulit;
import 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;
public class MonConnection {
??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();??
???????? }??
??}
}
?
?
下面是mongodb的java驱动jar文件
?
mongodb? 包,使用的时间将mongodb.z01.zip改为mongodb.z01然后解压即可