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

共10个文件

java：4个

svn-base：4个

all-wcprops：1个

3星 · 超过75%的资源需积分: 50 112 浏览量 2017-11-24 16:17:31 上传评论收藏 13KB RAR 举报

MongoDB是一种流行的开源文档型数据库，它以JSON格式存储数据，非常适合处理半结构化和结构化数据。在Java开发中，我们通常使用MongoDB Java驱动程序来与数据库进行交互，实现DAO（Data Access Object）模式，以便更好地组织数据库操作。在“mongodb_整合java_dao”这个主题中，我们将讨论如何在Java应用中集成MongoDB，创建DAO层来执行CRUD（创建、读取、更新、删除）操作。你需要在项目中添加MongoDB Java驱动的依赖，通常是通过Maven或Gradle。例如，在Maven的pom.xml中，你会看到类似以下的依赖配置： ```xml <dependency> <groupId>org.mongodb</groupId> <artifactId>mongodb-driver-sync</artifactId> <version>4.x.x</version> </dependency> ``` 接着，你需要配置MongoDB连接，创建`MongoClient`实例，然后通过客户端访问数据库和集合： ```java MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017"); MongoDatabase database = mongoClient.getDatabase("your_database_name"); MongoCollection<Document> collection = database.getCollection("your_collection_name"); ``` 在DAO层，你可以定义接口和实现类，比如`MongoUserDao`，用于处理用户数据： ```java public interface MongoUserDao { User save(User user); Optional<User> findByEmail(String email); List<User> findAllNear(double latitude, double longitude, int radius); } ``` 实现类会包含具体的MongoDB操作，如使用`insertOne()`、`findOne()`等方法： ```java @Service public class MongoUserDaoImpl implements MongoUserDao { @Autowired private MongoCollection<Document> usersCollection; @Override public User save(User user) { Document doc = Document.parse(user.toJson()); usersCollection.insertOne(doc); return user; } @Override public Optional<User> findByEmail(String email) { Document query = new Document("email", email); Document result = usersCollection.find(query).first(); if (result != null) { return Optional.of(User.fromJson(result.toJson())); } return Optional.empty(); } @Override public List<User> findAllNear(double latitude, double longitude, int radius) { // 使用GeoSpatial查询找到附近用户 // ... } } ``` “根据经纬度获取附近的商家”或“获取附近的人”涉及到地理空间查询。MongoDB支持2dsphere索引，可以用来存储和查询地理位置数据。在`findAllNear()`方法中，你需要创建一个`GeoJsonPoint`对象，构建查询条件，然后使用`NearQuery`或`GeoNearCommand`执行查询： ```java public List<User> findAllNear(double latitude, double longitude, int radius) { Point center = new Point(new Position(longitude, latitude)); Bson geoNear = new GeoNearFilter() .near(center) .spherical(true) .maxDistance(new Distance(radius, Units.KILOMETERS)) .query(new Document()) .distanceMultiplier(6371); AggregateIterable<Document> iterable = usersCollection.aggregate(Arrays.asList( new AggregationOperation() { @Override public Bson toBsonDocument(Document outputType, Document context) { return geoNear; } }, unwind("$location"), sort(new Sort(Sort.Direction.ASC, "$distance")) )); List<User> users = new ArrayList<>(); for (Document doc : iterable) { User user = User.fromJson(doc.toJson()); users.add(user); } return users; } ``` 以上就是关于“mongodb_整合java_dao”和“根据经纬度获取附近商家”的基本实现。通过这些技术，你可以构建出高效、灵活的应用，利用MongoDB的强大功能处理地理位置数据，同时结合Java的DAO模式优化数据访问逻辑。记得在实际应用中根据项目需求调整和完善这些示例代码。

资源推荐

资源详情

资源评论

收起资源包目录

mongo.rar （10个子文件）

mongo

Point.java 653B

IMongoDao.java 7KB

GeoPO.java 678B

.svn

all-wcprops 627B

prop-base

props

tmp

prop-base

props

text-base

GeoPO.java.svn-base 678B

Point.java.svn-base 653B

MongoDao.java.svn-base 24KB

IMongoDao.java.svn-base 7KB

entries 805B

MongoDao.java 24KB

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

评论收藏

内容反馈