Mongodb 基本操作指令集合

db -> collection(集合) -> document(json文档)

db.help();

show dbs ; 显示所有db

show collections; 显示db下面所有集合

db.createCollection("yourCollection");  创建普通集合

db.createCollection("cappedCollection",{capped:true,size:16332,max:100})   创建就盖子集合，盖子集合只用于保存日志文件  不允许删除和修改大小值

db.users.stats(); 查询集合中存储大小等信息

db.serverStatus(); 查看服务器一些信息，如存储引擎等

db.version(); 查看版本

db.users.find({$where:"this.age != 40"}) ; 查询age不等于40的记录 不建议使用 $where

db.users.find().skip(2).sort({age:1}).limit(2);  skip加limit可以用于分页操作   skip(pageSize*pageNum)

db.users.find({age:{$gte:30,$lte:40}}) ; 成绩大于等于30且小于等于40的数据 

db.users.find({$or:[{name:'lanwx'},{name:"alex"}]});

db.users.find({},{name:1,by:1}); 只查询对应的字段  相当于select name from users ;

db.users.insert({name:"lanwx"});

db.users.find({name:"lanwx"});

db.users.find({age:{$ne:80}})  ; 查找age不等于80

db.users.find({age:{$in:[80,35]}}) ; 查找age等于80和35的记录

db.users.find({name:"lanwx"}).sort({age:1});  按照age从小到大排序（升序）   -1 则从大到小排序（降序）

db.users.find({name:"lanwx",age:24});

db.users.update({name:"lanwx"},{$set:{age:30}})

db.users.update({name:"lanwx",age:30},{$set:{age:31}})   更新age列的值为31

db.users.update({address:"厦门市"},{addresses:"厦门市"})  把原来的一列更改成新的一列

db.users.update({name:"lanwx"},{$unset:{address:1}})  name值对应的address字段

db.users.count()

db.users.remove({age:24});   删除所有age等于24的文档

db.users.drop();   删除集合并且对应的索引

db.users.getIndexes();   查询集合中所有的索引

db.users.createIndex({name:1},{unique:true}) ;   在name字段上创建索引 1表示升序索引 -1表示降序 ,是否创建唯一索引



db.cityServiceArea.find({geo:{$geoIntersects:{$geometry:{"type" : "Point","coordinates" : [116.429630,39.79417899999] }}}});  通过坐标查询所在的区域












// 原生java操作mongodb  通过坐标获取区域ID
public List<Long> doGetAreaIdsByLngAndLat(Double lng, Double lat){
    Preconditions.checkNotNull(lng,"经度不能为空");
    Preconditions.checkNotNull(lat,"纬度不能为空");
    Preconditions.checkState(lng != 0,"经度不能为0");
    Preconditions.checkState(lat != 0,"纬度不能为0");
    Stopwatch stopwatch = Stopwatch.createStarted();
    List<Long> areaIds = Lists.newArrayList();
    MongoDatabase database = this.mongodbClient.getDatabase(this.dbName);
    try{
        if(database != null){
            MongoCollection mongoCollection = database.getCollection("cityServiceArea");
            if(mongoCollection != null){
                FindIterable findIterable = mongoCollection.find(Filters.geoIntersects("geo",new Point(new Position(lng,lat))));
                Document document = (Document)findIterable.first();
                if(document != null){
                    areaIds.add((long)document.get("_id"));
                }
            }
        }
        logger.info("【SBS】通过经纬度获取区域ID耗时：{}",stopwatch.stop());
        return areaIds;
    }catch (Exception e){
        logger.info("【SBS】通过经纬度获取区域ID出错，{}",e);
        throw new BusinessException(ErrorCodeConstants.BUSINESS_ERROR, "通过经纬度获取区域异常");
    }
}