mongodb 创建LBS位置索引
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了mongodb 创建LBS位置索引，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4510字，纯文字阅读大概需要7分钟。
内容图文
com.teewoo.mongodb;
import com.mongodb.BasicDBObject;
import com.mongodb.BasicDBObjectBuilder;
import com.mongodb.MongoClient;
import com.mongodb.ServerAddress;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import org.apache.commons.lang3.StringUtils;
import org.bson.Document;
import org.bson.types.ObjectId;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
/**
* mongoDB 基本操作
*
* @author xiaojf 2016-6-24 15:55:56
*/
public class MongoBaseOps {
private static MongoClient client; //mongo客户端
static {
client = new MongoClient(Arrays.asList(new ServerAddress("localhost", 27017)));
}
/**
* 根据db名称获取db对象
*
* @param name db名称
* @return db对象
* @author xiaojf 2016-6-24 16:27:56
*/
public static MongoDatabase getDbByName(String name) {
MongoDatabase mongoDatabase = client.getDatabase(name);
return mongoDatabase;
}
/**
* 根据mongo db名称和mongo collection 名称获取mongo collection对象
*
* @param dbName mongo db名称
* @param collectionName mongo collection 名称
* @return mongo collection对象
* @author xiaojf 2016-6-24 16:36:39
*/
public static MongoCollection getCollectionByName(String dbName,String collectionName){
MongoCollection<Document> mongoCollection = getDbByName(dbName).getCollection(collectionName);
return mongoCollection;
}
/**
* 新增文档
*
* @param dbName mongo db 名称
* @param collectionName mongo collection 名称
* @param document 文档
* @author xiaojf 2016-6-24 16:36:39
*/
public static void insertDoc(String dbName,String collectionName,Document document){
MongoCollection mongoCollection = getCollectionByName(dbName, collectionName);
mongoCollection.insertOne(document);
}
/**
* 批量新增文档
*
* @param dbName mongo db 名称
* @param collectionName mongo collection 名称
* @param documents 文档集合
* @author xiaojf 2016-6-24 16:36:39
*/
public static void batchInsertDoc(String dbName, String collectionName, List documents){
MongoCollection mongoCollection = getCollectionByName(dbName, collectionName);
mongoCollection.insertMany(documents);
}
/**
* 根据id删除文档
*
* @param dbName mongo db 名称
* @param collectionName mongo collection 名称
* @param id mongo document _id
* @author xiaojf 2016-6-24 17:07:16
*/
public static void deleteById(String dbName, String collectionName,String id){
if (StringUtils.isBlank(dbName) || StringUtils.isBlank(collectionName) || StringUtils.isBlank(id)) {
return ;
}
MongoCollection mongoCollection = getCollectionByName(dbName, collectionName);
mongoCollection.deleteOne(new BasicDBObject("_id", new ObjectId(id)));
}
/**
* 根据id获取文档
*
* @param dbName mongo db 名称
* @param collectionName mongo collection 名称
* @param id mongo document _id
* @author xiaojf 2016-6-24 17:07:16
*/
public static Object getById(String dbName, String collectionName,String id){
if (StringUtils.isBlank(dbName) || StringUtils.isBlank(collectionName) || StringUtils.isBlank(id)) {
return null;
}
MongoCollection mongoCollection = getCollectionByName(dbName, collectionName);
FindIterable findIterable = mongoCollection.find(new BasicDBObject("_id", new ObjectId(id)));
MongoCursor cursor = findIterable.iterator();
while (cursor.hasNext()) {
return cursor.next();
}
return null;
}
/**
* 创建索引
*
* @param dbName mongo db 名称
* @param collectionName mongo collection 名称
* @param fieldName 字段名称
* @param indexType 索引类型
* @author xiaojf 2016-6-27 13:43:02
*/
public static void createIndex(String dbName, String collectionName,String fieldName,String indexType){
MongoCollection mongoCollection = getCollectionByName(dbName, collectionName);
mongoCollection.createIndex(new BasicDBObject(fieldName, indexType));
}
public static void main(String[] args) {
//获取 mongodb db对象
MongoDatabase mongoDatabase = MongoBaseOps.getDbByName("db_test");
//删除旧mongodb collection
mongoDatabase.getCollection("collect_gps").drop();
List<Document> documentList = new ArrayList<Document>();
for (int i = 0 ;i<100;i++) {
//构建2d索引的LBS document
Document doc = new Document();
doc.put("gps", BasicDBObjectBuilder.start().add("lon", 33+i).add("lat", i-33).get());
documentList.add(doc);
}
//批量新增文档给
MongoBaseOps.batchInsertDoc("db_test","collect_gps",documentList);
//创建2d索引
MongoBaseOps.createIndex("db_test","collect_gps","gps","2d");
}
}
mongodb 创建LBS位置索引
标签：color ring for 基本 base blog insert com art
本文系统来源：http://www.cnblogs.com/xiaojf/p/6561288.html
内容总结
以上是互联网集市为您收集整理的mongodb 创建LBS位置索引全部内容，希望文章能够帮你解决mongodb 创建LBS位置索引所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】