标签归档:数据库

使用Java操作MongoDB

HelloWorld程序

  学习任何程序的第一步,都是编写HelloWorld程序,我们也不例外,看下如何通过Java编写一个HelloWorld的程序。

  首先,要通过Java操作Mongodb,必须先下载Mongodb的Java驱动程序,可以在这里下载

  新建立一个Java工程,将下载的驱动程序放在库文件路径下,程序代码如下:

package com.mkyong.core;

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;



/**

* 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

 
继续阅读