有做模仿易企秀网站吗,专业制作网站的基本步骤,数据分析师培训机构,网站查询站长工具Mongodb的数据库简介、docker部署、操作语句以及java应用
本文主要介绍了mongodb的基础概念和特点#xff0c;以及基于docker的mongodb部署方法#xff0c;最后介绍了mongodb的常用数据库操作语句#xff08;增删改查等#xff09;以及java下的常用语句。
一、基础概念
… Mongodb的数据库简介、docker部署、操作语句以及java应用
本文主要介绍了mongodb的基础概念和特点以及基于docker的mongodb部署方法最后介绍了mongodb的常用数据库操作语句增删改查等以及java下的常用语句。
一、基础概念
1、Mongodb简要介绍
MongoDB是一个基于分布式文件存储的数据库。MongoDB是一个介于关系数据库和非关系数据库之间的产品是非关系数据库当中功能最丰富最像关系数据库的。
2、基础概念
1文档field记录
“类似json的bson格式同一张表的数据结构可以不固定MongoDB中的记录是一个文档它是由字段和值对组成的数据结构。
2集合Collection表
集合就是一组文档类似于关系数据库中的表。
可以使用“.”按照命名空间将集合划分为子集合。
3数据库DataBase 中多个文档组成集合多个集合组成数据库。在磁盘上不同的数据库存放在不同的文件中.
MongoDB 中存在以下系统数据库。
Admin 数据库、Local 数据库、Config 数据库。 3、与关系型数据库类比
DataBase Document field(key/value) 二、特性和应用场景
1、特性
1大数据量
2高并发(虚拟内存)
3数据结构可扩展性:(数据结构不固定)表结构灵活可变字段类型可以随时修改。
4应用不需要事务以及复杂的 join 支持,价值较低的数据对事务性要求不高
2、应用场景
游戏场景使用MongoDB存储游戏用户信息用户的装备、积分等直接以内嵌文档的形式存储方便查询、更新。
物流场景使用MongoDB存储订单信息订单状态在运送过程中会不断更新以MongoDB内嵌数组的形式来存储一次查询就能将订单所有的变更读取出来。
社交场景使用MongoDB存储存储用户信息以及用户发表的朋友圈信息通过地理位置索引实现附近的人、地点等功能。
物联网场景使用MongoDB存储所有接入的智能设备信息以及设备汇报的日志信息并对这些信息进行多维度的分析。
视频直播使用MongoDB存储用户信息、礼物信息等。 三、docker下的mongodb部署
1、部署mongodb
docker search mongodocker pull mongo:latestcd /datamkdir mongo_local_datadocker run --name my_mongo -v /data/mongo_local_data:/data/db --rm -d -p 27017:27017 mongodocker ps
2、进入mongodb数据库
docker exec -it my_mongo /bin/bashcd /bin
可见有mongosh
mongosh admin
附:
docker exec -it 容器id mongo admin 报错如下解决办法
[rootiZ2zehrk49wgv86b2hqvncZ ~]# docker exec -it 67c3f3893ce8 mongo admin
OCI runtime exec failed: exec failed: unable to start container process: exec: mongo: executable file not found in $PATH: unknown
按如上先进入容器再mongosh admin
四、Mongodb的主要操作
1、创建账户
db.createUser({ user:root,pwd:123456,roles:[ { role:userAdminAnyDatabase, db: admin},readWriteAnyDatabase]});
2、连接数据库
db.auth(root, 123456)
3、创建数据库
use my_mongodb
4、创建集合
db.createCollection(shucai_record)
5、插入数据
db.集合名.insert(JSON数据) mongodb会给每条数据增加一个全球唯一的_id键
db.getCollection(shucai_record).insert( { _id: ObjectId(638e8e739320275867030e4c), readTimestamp: NumberLong(1670286944653), address: DB14.2, value: NumberInt(0), DeviceId: NumberInt(1368)
} );
db.getCollection(shucai_record).insert( { _id: ObjectId(638e8e739320275867030e4d), readTimestamp: NumberLong(1670286944653), address: DB14.4, value: NumberInt(0), DeviceId: NumberInt(1368)
} );
db.getCollection(shucai_record).insert( { _id: ObjectId(638e8e739320275867030e4e), readTimestamp: NumberLong(1670286944653), address: DB14.6, value: NumberInt(0), DeviceId: NumberInt(1368)
} );
db.getCollection(shucai_record).insert( { _id: ObjectId(638e8e739320275867030e4f), readTimestamp: NumberLong(1670286944653), address: DB14.8, value: NumberInt(0), DeviceId: NumberInt(1368)
} );
db.getCollection(shucai_record).insert( { _id: ObjectId(638e8e739320275867030e50), readTimestamp: NumberLong(1670286944653), address: DB14.10, value: NumberInt(0), DeviceId: NumberInt(1368)
} ); 6、查找数据
db.集合名.find({键:{运算符值}})
Eg: 查找设备点位地址为DB14.10和DB14.8的数据
db.getCollection(shucai_record).find({address:{$in:[DB14.10,DB14.8]}})
7、修改数据
db.集合名.update(条件,新数据[是否新增,是否修改多条,])
inc递增rename重命名列set修改列值unset删除列
Eg:
1设备点位地址为DB14.8的数据,value值加上4
db.shucai_record.update({address:{$in:[DB14.8]}},{$inc:{value:4}})db.getCollection(shucai_record).find({address:{$in:[DB14.10,DB14.8]}})
2设备点位地址为DB14.8的数据,value值改为30第一个true: 如果没找到DB14.8的数据则新增value值为30第二个true: 如果找到多条多条进行更新value值改为30
db.shucai_record.update({address:{$in:[DB14.10]}},{$set:{value:30}},true,true) db.getCollection(shucai_record).find({address:{$in:[DB14.10,DB14.8]}}) 8、删除数据
db.集合名.remove(条件[,是否删除一条])
Eg:删除设备点位地址为DB14.10的数据,false: 如果找到多条就删除多条)
db.shucai_record.remove({address:{$in:[DB14.10]}},false) db.getCollection(shucai_record).find({address:{$in:[DB14.10,DB14.8]}}) 9、删除集合
db.集合名.drop()
10、删除数据库
db.dropDataBase()
11、索引的建立和查看
# 索引建立
db.集合名.ensureIndex({字段名:11:升序-1降序},{name:索引名})
# 索引查看
db.集合名.getIndexes()
#索引删除
db.集合名.dropIndex(索引名) Eg:
db.shucai_record.ensureIndex({readTimestamp:1},{name:timeIndex})
db.shucai_record.getIndexes()
db.shucai_record.dropIndex(timeIndex) Bson filter Filters.and(Filters.eq(DeviceId, device.getId()), Filters.eq(address, factoryIndexAddress.getParamAddress()), Filters.gte(readTimestamp, beginTimeStamp), Filters.lte(readTimestamp, endTimeStamp)); 五、java中的mongodb操作【主要介绍 查询操作】
1、数据库连接及集合选定
String mongoCollection “shucai_record”MongoCollectionDocument collection mongoTemplate.getCollection(mongoCollection);
2、筛选条件
Bson filter Filters.and(Filters.eq(DeviceId, device.getId()), Filters.eq(address, factoryIndexAddress.getParamAddress()), Filters.gte(readTimestamp, beginTimeStamp), Filters.lte(readTimestamp, endTimeStamp));
3、查找
FindIterableDocument projection null;projection collection.find(filter).sort(Sorts.descending(readTimestamp));
4、查找结果的条数
long projectionTotal collection.countDocuments(filter);
5、查找结果遍历 和 获取查找结果的值
MongoCursorDocument cursor projection.iterator();
Document lastData cursor.next();String address lastData.get(address).toString(); while (cursor.hasNext()) {documentData cursor.next();if ((Boolean) documentData.get(value) false) {//其他逻辑处理eg:continueFlag false;}}
