mongodb_整合java_dao,以及用mongodb做附近人,或者是根据经纬多获取附近商家

package com.home.core.dao.mongo; import java.lang.reflect.Field; import java.lang.reflect.Method; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.List; import java.util.Map; import org.bson.types.ObjectId; import com.home.core.config.CustomizedPropertyPlaceholderConfigurer; import com.home.system.config.ConfigConstants; 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.MongoException; import com.mongodb.WriteResult; /** * * 作者：zhouyp * 创建时间：2016-1-19 */ public class MongoDao implements IMongoDao{ /** * Mongo是非线程安全的,采用恶汉生成方式保证线程安全 */ private Mongo mongo = null; private MongoDao(){ if(mongo == null){ try { String host = (String) CustomizedPropertyPlaceholderConfigurer.getContextProperty(ConfigConstants.MONGO_HOST); mongo = new Mongo(host,43576); } catch (UnknownHostException e) { e.printStackTrace(); } catch (MongoException e) { e.printStackTrace(); } } } /********单例模式声明开始，采用饿汉式方式生成，保证线程安全********************/ private static final MongoDao mongoDao = new MongoDao(); public static MongoDao getMongoDaoInstance(){ return mongoDao; } /************************单例模式声明结束*************************************/ @Override public boolean delete(String dbName, String collectionName, String[] keys, Object[] values) { DB db = null; DBCollection dbCollection = null; if(keys!=null && values!=null){ if(keys.length != values.length){ //如果keys和values不对等，直接返回false return false; }else{ try { db = mongo.getDB(dbName); //获取指定的数据库 dbCollection = db.getCollection(collectionName); //获取指定的collectionName集合 BasicDBObject doc = new BasicDBObject(); //构建删除条件 WriteResult result = null; //删除返回结果 String resultString = null; for(int i=0; i<keys.length; i++){ doc.put(keys[i], values[i]); //添加删除的条件 } result = dbCollection.remove(doc); //执行删除操作 resultString = result.getError(); if(null != db){ try { db.requestDone(); //请求结束后关闭db db = null; } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } } return (resultString!=null) ? false : true; //根据删除执行结果进行判断后返回结果 } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } finally{ if(null != db){ db.requestDone(); //关闭db db = null; } } } } return false; } @Override public boolean deleteById(String dbName, String collectionName,String id) { DB db = null; DBCollection dbCollection = null; try { db = mongo.getDB(dbName); //获取指定的数据库 dbCollection = db.getCollection(collectionName); //获取指定的collectionName集合 //根据id查询 BasicDBObject query = new BasicDBObject(); query.put("_id", new ObjectId(id)); DBObject dbObj = dbCollection.findOne(query); dbCollection.remove(dbObj); //执行删除操作 if(null != db){ try { db.requestDone(); //请求结束后关闭db db = null; } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } } return true; //根据删除执行结果进行判断后返回结果 } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } finally{ if(null != db){ db.requestDone(); //关闭db db = null; } } return false; } @Override public ArrayList<DBObject> find(String dbName, String collectionName, String[] keys, Object[] values, int num) { ArrayList<DBObject> resultList = new ArrayList<DBObject>(); //创建返回的结果集 DB db = null; DBCollection dbCollection = null; DBCursor cursor = null; if(keys!=null && values!=null){ if(keys.length != values.length){ return resultList; //如果传来的查询参数不对，直接返回空的结果集 }else{ try { db = mongo.getDB(dbName); //获取数据库实例 dbCollection = db.getCollection(collectionName); //获取数据库中指定的collection集合 BasicDBObject queryObj = new BasicDBObject(); //构建查询条件 for(int i=0; i<keys.length; i++){ //填充查询条件 queryObj.put(keys[i], values[i]); } cursor = dbCollection.find(queryObj); //查询获取数据 int count = 0; if(num != -1){ //判断是否是返回全部数据，num=-1返回查询全部数据，num!=-1则返回指定的num数据 while(count<num && cursor.hasNext()){ resultList.add(cursor.next()); count++; } return resultList; }else{ while(cursor.hasNext()){ resultList.add(cursor.next()); } return resultList; } } catch (Exception e) { // TODO: handle exception } finally{ if(null != cursor){ cursor.close(); } if(null != db){ db.requestDone(); //关闭数据库请求 } } } } return resultList; } @Override public DBCursor findAllByCollection(String dbName, String collectionName) { DB db = null; DBCollection dbCollection = null; DBCursor cursor = null; try { db = mongo.getDB(dbName); // 获取数据库实例 dbC