①范例：连接数据库

package cn.mldn.demo;

import com.mongodb.DB;

import com.mongodb.MongoClient;

public class MongoDemoA {

public static void main(String[] args) throws Exception {

// 设置要连接的数据库的主机名称与端口号

MongoClient client = new MongoClient("localhost", 27001);

MongoClient内部实现了一个连接池，默认初始化10个连接，MongoClient对象是线程安全的，因此可以只创建一个，在多线程环境下安全使用。

另外要注意，close方法将关闭当前所有活跃的连接，所以应该在确定不再使用MongoDB的时候才应该关闭。

DB db = client.getDB("mldn");  // 连接数据库

1：数据库名区分大小写，另外如果数据库不存在，不会报错，而是新建一个

2： DB对象代表了和数据库的一个连接。默认情况下，当执行完数据库的查询或者更新操作后，连接将自动回到连接池中。不需要我们手动调用代码放回池中。

// 进行数据库的用户名与密码验证

if (db.authenticate("hello", "happy".toCharArray())) {

for (String name : db.getCollectionNames()) {

System.out.println("集合名字：" + name);

}

}

client.close();     // 关闭数据库连接

}

}

②范例：保存数据

package cn.mldn.demo;

import com.mongodb.BasicDBObject;

import com.mongodb.DB;

import com.mongodb.DBCollection;

import com.mongodb.MongoClient;

public class MongoDemoB {

public static void main(String[] args) throws Exception {

// 设置要连接的数据库的主机名称与端口号

MongoClient client = new MongoClient("localhost", 27001);

DB db = client.getDB("mldn");  // 连接数据库

// 进行数据库的用户名与密码验证

if (db.authenticate("hello", "happy".toCharArray())) {

DBCollection col = db.getCollection("deptcol") ;    // 要操作的集合名字

for (int x = 0 ; x < 100 ; x ++) {    // 循环保存数据

BasicDBObject obj = new BasicDBObject() ;

obj.append("deptno" , 1000 + x) ;   // 设置部门编号信息

obj.append("dname" , "技术部 - " + x) ;

obj.append("loc" , "北京 - " + x) ;

col.insert(obj) ;   // 保存数据

}

}

client.close();     // 关闭数据库连接

}

}

新增

1：第一种方式，示例：

BasicDBObjectdata1 = new BasicDBObject();

data1.put("userId", "u1234");

data1.put("name", "name123");

或者data1.append("userId", "u1234").append("name", "name123");

users.insert(data1);

//或者users.save(data1);

2：第二种方式，示例：

BasicDBObjectBuilder data1=BasicDBObjectBuilder.start().add("userId","u234").add("name","name234");

users.insert(data1.get());

3：第三种方式，示例：

Map<String, Object> data1 = new HashMap<String, Object>();

data1.put("userId","u345");

users.insert(new BasicDBObject(data1));

4：第四种方式，示例：

String json = "{'userId': 'u456','name' : 'name456'}";

DBObject data1 = (DBObject)JSON.parse(json);

users.insert(data1);

③范例：数据读取

package cn.mldn.demo;

import com.mongodb.*;

public class MongoDemoC {

public static void main(String[] args) throws Exception {

// 设置要连接的数据库的主机名称与端口号

MongoClient client = new MongoClient("localhost", 27001);

DB db = client.getDB("mldn");  // 连接数据库

// 进行数据库的用户名与密码验证

if (db.authenticate("hello", "happy".toCharArray())) {

DBCollection col = db.getCollection("deptcol") ;    // 要操作的集合名字

DBCursor cursor = col.find() ;  // 得到全部内容

while (cursor.hasNext()) {

DBObject obj = cursor.next() ;  // 得到每一个内容

System.out.println("部门编号：" + obj.get("deptno") + "，名称：" + obj.get("dname"));

}

}

client.close();     // 关闭数据库连接

}

}

④范例：使用分页处理

package cn.mldn.demo;

import com.mongodb.*;

public class MongoDemoD {

public static void main(String[] args) throws Exception {

// 设置要连接的数据库的主机名称与端口号

MongoClient client = new MongoClient("localhost", 27001);

DB db = client.getDB("mldn");  // 连接数据库

// 进行数据库的用户名与密码验证

if (db.authenticate("hello", "happy".toCharArray())) {

DBCollection col = db.getCollection("deptcol") ;    // 要操作的集合名字

DBCursor cursor = col.find().skip(0).limit(10) ;  // 得到全部内容

while (cursor.hasNext()) {

DBObject obj = cursor.next() ;  // 得到每一个内容

System.out.println("部门编号：" + obj.get("deptno") + "，名称：" + obj.get("dname"));

}

}

client.close();     // 关闭数据库连接

}

}

⑤范例：设置查询条件

package cn.mldn.demo;

import com.mongodb.*;

public class MongoDemoE {

public static void main(String[] args) throws Exception {

// 设置要连接的数据库的主机名称与端口号

MongoClient client = new MongoClient("localhost", 27001);

DB db = client.getDB("mldn");  // 连接数据库

// 进行数据库的用户名与密码验证

if (db.authenticate("hello", "happy".toCharArray())) {

DBCollection col = db.getCollection("deptcol") ;    // 要操作的集合名字

DBObject cond = new BasicDBObject() ;   // 准备设置查询过滤条件

// 设置deptno的数据范围在1000 ~ 1020之间

cond.put("deptno",new BasicDBObject("$gte",1000).append("$lte",1020)) ;

// 设置之前所定义的查询条件

DBCursor cursor = col.find(cond).skip(0).limit(50) ;  // 得到全部内容

while (cursor.hasNext()) {

DBObject obj = cursor.next() ;  // 得到每一个内容

System.out.println("部门编号：" + obj.get("deptno") + "，名称：" + obj.get("dname"));

}

}

client.close();     // 关闭数据库连接

}

}

⑥范例：设置范围查询—— in

package cn.mldn.demo;

import com.mongodb.*;

public class MongoDemoF {

public static void main(String[] args) throws Exception {

// 设置要连接的数据库的主机名称与端口号

MongoClient client = new MongoClient("localhost", 27001);

DB db = client.getDB("mldn");  // 连接数据库

// 进行数据库的用户名与密码验证

if (db.authenticate("hello", "happy".toCharArray())) {

DBCollection col = db.getCollection("deptcol");    // 要操作的集合名字

DBObject cond = new BasicDBObject();   // 准备设置查询过滤条件

// 设置deptno的数据范围在1000 ~ 1020之间

cond.put("deptno", new BasicDBObject("$in", new int[]{1001, 1003, 1005}));

// 设置之前所定义的查询条件

DBCursor cursor = col.find(cond).skip(0).limit(50);  // 得到全部内容

while (cursor.hasNext()) {

DBObject obj = cursor.next();  // 得到每一个内容

System.out.println("部门编号：" + obj.get("deptno") + "，名称：" + obj.get("dname"));

}

}

client.close();     // 关闭数据库连接

}

}

⑦范例：执行模糊查询

package cn.mldn.demo;

import com.mongodb.*;

import java.util.regex.Pattern;

public class MongoDemoG {

public static void main(String[] args) throws Exception {

// 设置要连接的数据库的主机名称与端口号

MongoClient client = new MongoClient("localhost", 27001);

DB db = client.getDB("mldn");  // 连接数据库

// 进行数据库的用户名与密码验证

if (db.authenticate("hello", "happy".toCharArray())) {

DBCollection col = db.getCollection("deptcol");    // 要操作的集合名字

Pattern pattern = Pattern.compile("5") ;    // 设置过滤条件

DBObject cond = new BasicDBObject();   // 准备设置查询过滤条件

// 设置deptno的数据范围在1000 ~ 1020之间

cond.put("dname", new BasicDBObject("$regex", pattern));

// 设置之前所定义的查询条件

DBCursor cursor = col.find(cond).skip(0).limit(50);  // 得到全部内容

while (cursor.hasNext()) {

DBObject obj = cursor.next();  // 得到每一个内容

System.out.println("部门编号：" + obj.get("deptno") + "，名称：" + obj.get("dname"));

}

}

client.close();     // 关闭数据库连接

}

}

⑧范例：数据修改

package cn.mldn.demo;

import com.mongodb.*;

import java.util.regex.Pattern;

public class MongoDemoH {

public static void main(String[] args) throws Exception {

// 设置要连接的数据库的主机名称与端口号

MongoClient client = new MongoClient("localhost", 27001);

DB db = client.getDB("mldn");  // 连接数据库

// 进行数据库的用户名与密码验证

if (db.authenticate("hello", "happy".toCharArray())) {

DBCollection col = db.getCollection("deptcol");    // 要操作的集合名字

DBObject condA = new BasicDBObject();   // 准备设置要修改的过滤条件

condA.put("deptno" , 1000) ;    // 设置修改的内容

DBObject condB = new BasicDBObject() ;  // 修改器的设置

condB.put("$set", new BasicDBObject("dname", "修改后的部门名称")) ;

WriteResult result = col.update(condA, condB) ;

System.out.println(result.getN());

}

client.close();     // 关闭数据库连接

}

}

DBObject condition = new BasicDBObject("userId","u234");

users.update(condition, new BasicDBObject("userId","cc").append("name","cc"));

当然也可以使用修改器

users.update(condition, new BasicDBObject("$set",new

BasicDBObject("name","ccNew")));

⑨范例：多行数据的修改

package cn.mldn.demo;

import com.mongodb.*;

public class MongoDemoI {

public static void main(String[] args) throws Exception {

// 设置要连接的数据库的主机名称与端口号

MongoClient client = new MongoClient("localhost", 27001);

DB db = client.getDB("mldn");  // 连接数据库

// 进行数据库的用户名与密码验证

if (db.authenticate("hello", "happy".toCharArray())) {

DBCollection col = db.getCollection("deptcol");    // 要操作的集合名字

DBObject condA = new BasicDBObject();   // 准备设置要修改的过滤条件

condA.put("deptno",new BasicDBObject("$gte",1000).append("$lte",1020)) ;

DBObject condB = new BasicDBObject() ;  // 修改器的设置

condB.put("$set", new BasicDBObject("dname", "修改后的部门名称")) ;

WriteResult result = col.updateMulti(condA, condB) ;

System.out.println(result.getN());

}

client.close();     // 关闭数据库连接

}

}

DBObject condition = new BasicDBObject("userId","u234");

users.update(condition, new BasicDBObject("userId","cc").append("name","cc"));

当然也可以使用修改器

users.update(condition, new BasicDBObject("$set",new

BasicDBObject("name","ccNew")));

⑩范例：删除数据

package cn.mldn.demo;

import com.mongodb.*;

public class MongoDemoJ {

public static void main(String[] args) throws Exception {

// 设置要连接的数据库的主机名称与端口号

MongoClient client = new MongoClient("localhost", 27001);

DB db = client.getDB("mldn");  // 连接数据库

// 进行数据库的用户名与密码验证

if (db.authenticate("hello", "happy".toCharArray())) {

DBCollection col = db.getCollection("deptcol");    // 要操作的集合名字

DBObject cond = new BasicDBObject();   // 准备设置要修改的过滤条件

cond.put("deptno",new BasicDBObject("$gte",1000).append("$lte",1020)) ;

WriteResult result = col.remove(cond) ;

System.out.println(result.getN());

}

client.close();     // 关闭数据库连接

}

}

users.remove(new BasicDBObject("userId","u1"));

⑪
 
⑫
 
⑬
 
⑭
 
⑮
 
⑯
 
⑰
 
⑱
 
⑲
 
⑳
 

最新文章

  1. （转载）如何借助KeePassX在Linux上管理多个密码
  2. UVa OJ 140 - Bandwidth (带宽)
  3. 【大数比较】NYOJ-73
  4. 为ListView添加头和脚
  5. Chapter 15_4 子模块和包
  6. String中的两种实例化方式的区别
  7. Topshelf 一个简化Windows服务开发的宿主服务框架
  8. input密码框输入后设置显示为星号或其他样式
  9. org.apache.ibatis.builder.IncompleteElementException: Could not find result map com.hp.entity.Emp
  10. Unity 3D中不得不说的yield协程与消息传递
  11. 学习笔记之Data analysis
  12. kubernetes下安装mysql
  13. 【BZOJ1487】[HNOI2009]无归岛（动态规划）
  14. 【CF771A】Bear and Friendship Condition
  15. [DEFCON全球黑客大会] 针对CTF，大家都是怎么训练的？
  16. selenium2.0关于python的常用函数
  17. CLR如何控制类型中的字段排序
  18. 利用kage把msf变成可视化远控平台
  19. print、println的区别
  20. Java-Runoob：Java Stream、File、IO

热门文章

  1. pop() 删除掉数组的最后一个元素
  2. PHP5.5.38版本Zend Guard loader for 5.5安装（详细）
  3. HTTP协议中request和response常用方法
  4. IIS的UrlRewrite模块
  5. ADDED、ADDED_TO_STAGE、REMOVED、REMOVED_FROM_STAGE这几个事件的区别
  6. echarts简单的折线图
  7. canel的网络策略
  8. 大数据学习笔记5 - Spark
  9. HDU - 1695 GDU
  10. Win10系统下安装Gradle-3.5