mongoDB2.6，java使用详解 - 数据库编程

a"); u.setTp(12); String obj2Json = JsonUtils.getSingletonInstance().obj2Json(u); BasicDBObject dbObject1=new BasicDBObject(); dbObject1.put("key", "123131"); dbObject1.put("value", obj2Json); collection2.save(dbObject1);

			BasicDBObject dbObject=new BasicDBObject();
			dbObject.put("key", "123131");
			DBCursor find = collection2.find(dbObject);
			while (find.hasNext()) {
				DBObject next = find.next();
				String key = (String)next.get("key");
				String json = (String)next.get("value");
				System.out.println(key);
				CarPasitionObj formJson = JsonUtils.getSingletonInstance().formJson(json, CarPasitionObj.class);
				System.out.println(formJson.getPn());
			}
} catch (UnknownHostException e) {
?? ??? ??? ?e.printStackTrace();
?? ??? ??? ?
?? ??? ?}

下面贴上我自己的mongodb的工具类：

/**
 * Project Name:main
 * File Name:MongodbCacheManagerUtil.java
 * Package Name:com.hdsx.taxi.driver.cq.cache
 * Date:2014年4月9日下午12:49:55
 * Copyright (c) 2014, sid Jenkins All Rights Reserved.
 * 
 *
*/

package com.hdsx.taxi.driver.cq.mongodb;

import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.List;

import org.apache.log4j.Logger;

import com.hdsx.taxi.driver.cq.module.InitServletModule;
import com.hdsx.taxi.driver.cq.tcp.util.JsonUtils;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoClient;


/**
 * ClassName:MongodbCacheManagerUtil
 * 




Function: TODO ADD FUNCTION. 
 * Reason:	 TODO ADD REASON. 
 * Date:     2014年4月9日 下午12:49:55 
 * @author   sid
 * @see 	 
 */
public class MongodbManagerUtil {
	private static final Logger logger = Logger.getLogger(MongodbManagerUtil.class);

	private Mongo mg = null;
	private DB db = null;
	
	private volatile static MongodbManagerUtil singleton = null;
	
	public static final String KEY = "key";
	
	public static final String VALUE = "value";
	
	public static MongodbManagerUtil getSingletonInstance() {
		if (singleton == null) {
			synchronized (MongodbManagerUtil.class) {
				if (singleton == null) {
					singleton = new MongodbManagerUtil();
				}
			}
			singleton = new MongodbManagerUtil();
		}
		return singleton;
	}

	private MongodbManagerUtil() {
		if (logger.isDebugEnabled()) {
			logger.debug("MongodbCacheManagerUtil() - start "); //$NON-NLS-1$
		}
			try {
				mg = new MongoClient("192.168.186.129", 8888);
				db = mg.getDB("mymongo");
			} catch (UnknownHostException e) {
				e.printStackTrace();
				
			}

		if (logger.isDebugEnabled()) {
			logger.debug("MongodbCacheManagerUtil() - end"); //$NON-NLS-1$
		}
	}

	/**
	 * 
	 * getCache:(获取缓存对象). 
	 *
	 * @author sid
	 * @param name
	 * @return
	 */
	public DBCollection getCache(String name){
		return this.db.getCollection(name);
	}
	/**
	 * 
	 * put:(在指定缓存对象中加入需要缓存的对象). 
	 *
	 * @author sid
	 * @param cacheName
	 * @param key
	 * @param value
	 */
    public void put(String cacheName, String key, Object value) {  
        DBCollection cache = this.db.getCollection(cacheName);
		String obj2Json = JsonUtil

mongoDB2.6，java使用详解(二)