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