public class TestMongoDB {
/**
* @param args
*/
public static void main(String[] args) {
TestMongoDB t = new TestMongoDB();
DB db = t.conn();
t.insert(db);
// t.findFirst(db);
// t.loopInsert(db);
// t.count(db);
// t.getIterateColl(db);
// t.getData(db);
// t.update(db);
// t.delete(db);
}
//连接mongo db
public DB conn(){
DB db = null;
try {
Mongo m = new Mongo("192.168.1.129",27017);
db = m.getDB("test");
return db;
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (MongoException e) {
e.printStackTrace();
}
return db;
}
//获取所有collections名字,类似于获取所有table名字。
public void getCollections(DB db){
Set<String> result = db.getCollectionNames();
for(String s:result){
System.out.println(s);
}
}
//插入数据
public void insert(DB db){
DBCollection coll = db.getCollection("MonTest");
BasicDBObject doc = new BasicDBObject();
doc.put("name", "郑家豪");
doc.put("sno", 1001);
doc.put("school", "广东商学院");
BasicDBObject friends = new BasicDBObject();
BasicDBObject f1 = new BasicDBObject();
f1.put("name", "苗露");
f1.put("id", 1);
f1.put("hobbit", "football");
BasicDBObject f2 = new BasicDBObject();
f2.put("name", "詹婷婷");
f2.put("id", 2);
f2.put("hobbit", "football");
friends.put("f1",f1);
friends.put("f2",f2);
// friends.put("f1","苗露");
// friends.put("f2","詹婷婷");
// doc.put("friends", friends);
// BasicDBObject[] fs = new BasicDBObject[]{f1,f2};
// doc.put("friends", fs);
ArrayList<BasicDBObject> fl = new ArrayList<BasicDBObject>();
fl.add(f1);
fl.add(f2);
doc.put("friends", fl);
coll.insert(doc);
}
//找到第一条数据
public void findFirst(DB db){
DBCollection coll = db.getCollection("MonTest");
DBObject doc = coll.findOne();
System.out.println(doc);
}
//循环插入数据
public void loopInsert(DB db){
DBCollection coll = db.getCollection("MonTest");
for(int i=0;i<101;i++){
coll.insert(new BasicDBObject().append("i", i));
}
}
//统计一个collection的条数
public void count(DB db){
DBCollection coll = db.getCollection("MonTest");
System.out.println(coll.getCount());
}
//遍历一个collection
public void getIterateColl(DB db){
DBCollection coll = db.getCollection("MonTest");
DBCursor cursor = coll.find();
while(cursor.hasNext()){
DBObject doc = cursor.next();
System.out.println(doc);
}
}
//查找一个collection的一条数据
public void getData(DB db){
DBCollection coll = db.getCollection("MonTest");
BasicDBObject query = new BasicDBObject().append("name", "郑家豪");
query.put("friends.f1.name","苗露");
BasicDBObject keys = new BasicDBObject();
keys.put("friends.f1", 1); //1表示显示 0表示不显示
DBCursor cursor = coll.find(query,keys);
while(cursor.hasNext()){
DBObject doc = cursor.next();
DBObject friends = (DBObject) doc.get("friends");
DBObject f1 = (DBObject) friends.get("f1");
System.out.println(f1.get("name"));
// System.out.println(doc.get("friends"));
}
}
//修改多条数据 (updateMulti 修改一条用update)
public void update(DB db){
DBCollection coll = db.getCollection("MonTest");
BasicDBObject query = new BasicDBObject().append("friends.f1.id", 1);
BasicDBObject update = new BasicDBObject();
update.put("friends.f1.name", "simon");
coll.updateMulti(query, new BasicDBObject().append("$set", update));
DBCursor cursor = coll.find(query);
while(cursor.hasNext()){
DBObject doc = cursor.next();
System.out.println(doc);
}
}
//删除
public void delete(DB db){
DBCollection coll = db.getCollection("MonTest");
BasicDBObject doc = new BasicDBObject().append("friends.f1.id", 1);
coll.remove(doc);
getIterateColl(db);
}
//优化查找 optimization
public void optiGetData(DB db){
DBCollection coll = db.getCollection("MonTest");
}
}
如果想像ORM
public class Friends extends BasicDBObject {
private String name;
private String password;
private int sex;
public Friends(String name, String password, int sex) {
super();
this.name = name;
this.password = password;
this.sex = sex;
}
public Friends(){
super();
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public int getSex() {
return sex;
}
public void setSex(int sex) {
this.sex = sex;
}
//插入
public void insert(DB db){
Friends f = new Friends();
DBCollection coll = db.getCollection("friends");
f.put("name", "郑家豪");
f.put("sno", "123456");
f.put("sex", 0);
coll.setObjectClass(Friends.class);
coll.insert(f);
ObjectId id = (ObjectId)f.get( "_id" );
System.out.println(id);
}
分享到:
相关推荐
亲测可用, NoSQL Manager for MongoDB 2.7.x, 支持MongoDB 3.0, 下载运行 破解.bat即可
studio3T无限试用,mongodb图形化管理工具,运行脚本就可以试用30天,到期后再运行,可以无限试用,脚本可以放到自启动里面,这样就可以自动运行
mongodb drive mongodb 驱动 试用idea等 用于mongodb数据连接 dbeaver数据库链接。开放资源
mongodb 客户端,经试用完胜mongo VUE,推荐
免积分 #nosql manager for mongodb无限30天使用#
在MongoDB的官网上下载比较慢,这个自己亲自试用,可以在电脑上安装,一些配置MongoDB数据库的可以在网上当一下,或者去看一下崔庆才老师的博客。
下一节开始试用。 到此这篇关于Pycharm连接MongoDB数据库安装教程的文章就介绍到这了,更多相关Pycharm连接MongoDB内容请搜索软件开发网以前的文章或继续浏览下面的相关文章希望大家以后多多支持软件开发网!
破解步骤: 1、hosts添加127.0.0.1 nosqlbooster.com、127.0.0.1 www.nosqlbooster.com 2、覆盖resources文件 3、输入License
可以试用30天,到期之后运行bat再次试用。注意保存配置
绿色破解版的MongoDB客户端工具.免安装,不是经常看到的13天试用版,是破解的哟
Studio 3T 无限30天试用,到期运行一下此文件即可,建议加到开机自动启动,就不用担心过期了
MongoDB的可视化工具studio,Windows 64位版的,可试用30天
koa-graphql-mongodb由以下工具赞助; 请通过查看并注册免费试用来帮助支持我们。 koa-graphql-mongodb
MongoDB可视化工具Studio 3T V2018.2.5, 可30天免费试用,功能强大
此工具用于重置Studio 3T的试用日期,每次过期时运行此bat文件即可重新获取30天试用
3.对于4.X及以下版本,可每30天清理一次,重置试用期限,对于5.X以上版本,官方开始增加了网络验证,每次运行后,会同步服务端记录的试用日期回本地,需要每次试用完毕后运行清理一次,或者选择端外网试用;...
适用于MongoDB的Flexmonster连接器 网站: Flexmonster数据透视表和图表 Flexmonster Pivot是用于交互式Web报表的功能... 我们有30天免费试用! 用于MongoDB的Flexmonster连接器模块作为Flexmonster Pivot的MIT许可
输入mongod命令,回车,你会发现,data\db\文件夹找不到,因为MongoDB在每次试用都时候需要以后data目录下都db目录来存放数据库数据等,所以我们需要在安装mongoDB目录下创建一个data文件夹,data目录下再创建一个db...
官网太慢。 文件名:mongodbmanagerpro_inst.exe 官网下载的mongoDB Professional 5.7.2 windows安装包。 下载地址: ...注意此版本不是免费版,但是有14天试用期。
#Mongo测试创建该存储库是为了试用MongoDB的一些功能,并同时完成我需要解决的小测试。 随意看一下,叉子,或任何您想做的。 都是你的,冠军。