【MongoDB】5.MongoDB与java的简单结合

1.首先 你的清楚你的MongoDB的版本是多少  就下载对应的架包

下载地址如下：

http://mongodb.github.io/mongo-java-driver/  

2.新建一个项目  把架包扔进去，并Build path到你的项目下【如果用于测试，请如下 多用一个架包】

3.新建一个MongoConnection类 用来获取MongoDB的连接对象：

package com.mongo.util;

import java.util.ArrayList;
import java.util.List;

import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoDatabase;

public class MongoConnection {

/**
* 需要验证用户名 密码的 MongoDB的连接方式 com.mongodb.MongoClient.getDatabase("数据库名")
* @return
*/
public MongoDatabase getConnection() {
try {
//连接到MongoDB服务 如果是远程连接可以替换“localhost”为服务器所在IP地址
//ServerAddress()两个参数分别为 服务器地址 和 端口
ServerAddress serverAddress = new ServerAddress("localhost",27017);
List<ServerAddress> addrs = new ArrayList<ServerAddress>();
addrs.add(serverAddress);

//MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码
MongoCredential credential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());
List<MongoCredential> credentials = new ArrayList<MongoCredential>();
credentials.add(credential);

//通过连接认证获取MongoDB连接
MongoClient mongoClient = new MongoClient(addrs,credentials);

//连接到数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName");
System.out.println("连接成功");
return mongoDatabase;
} catch (Exception e) {
System.err.println( e.getClass().getName() + ": " + e.getMessage() );
}
return null;
}

/**
* 不需要验证 用户名+密码 的获取连接的方式 com.mongodb.MongoClient.getDatabase("数据库名")
* @return
*/
public MongoDatabase getConnectionBasis(){
try {
//连接到mongodb服务
MongoClient mongoClient = new MongoClient("localhost",27017);
MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName");
System.out.println("连接成功");
return mongoDatabase;
} catch (Exception e) {
System.out.println(e.getClass().getName()+":"+e.getMessage());
}
return null;
}

}

 1 package com.mongo.util;
 2 
 3 import java.util.ArrayList;
 4 import java.util.List;
 5 
 6 import com.mongodb.MongoClient;
 7 import com.mongodb.MongoCredential;
 8 import com.mongodb.ServerAddress;
 9 import com.mongodb.client.MongoDatabase;
10 
11 public class MongoConnection {
12      
13     /**
14      * 需要验证用户名  密码的 MongoDB的连接方式   com.mongodb.MongoClient.getDatabase("数据库名")
15      * @return
16      */
17     public MongoDatabase getConnection() {
18          try {  
19                 //连接到MongoDB服务 如果是远程连接可以替换“localhost”为服务器所在IP地址  
20                 //ServerAddress()两个参数分别为 服务器地址 和 端口  
21                 ServerAddress serverAddress = new ServerAddress("localhost",27017);  
22                 List<ServerAddress> addrs = new ArrayList<ServerAddress>();  
23                 addrs.add(serverAddress);  
24                   
25                 //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码  
26                 MongoCredential credential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());  
27                 List<MongoCredential> credentials = new ArrayList<MongoCredential>();  
28                 credentials.add(credential);  
29                   
30                 //通过连接认证获取MongoDB连接  
31                 MongoClient mongoClient = new MongoClient(addrs,credentials);  
32                   
33                 //连接到数据库  
34                 MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName");  
35                 System.out.println("连接成功");  
36                 return mongoDatabase;
37             } catch (Exception e) {  
38                 System.err.println( e.getClass().getName() + ": " + e.getMessage() );  
39             }  
40          return null;
41     }
42     
43     /**
44      * 不需要验证  用户名+密码  的获取连接的方式 com.mongodb.MongoClient.getDatabase("数据库名")
45      * @return
46      */
47     public MongoDatabase getConnectionBasis(){
48         try {
49             //连接到mongodb服务
50             MongoClient mongoClient = new MongoClient("localhost",27017);
51             MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName");
52             System.out.println("连接成功");
53             return mongoDatabase;
54         } catch (Exception e) {
55             System.out.println(e.getClass().getName()+":"+e.getMessage());
56         }
57         return null;
58     }
59     
60 }

4.再建一个类 用来测试 你的增删改查

package com.mongo.test;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;

import org.bson.Document;
import org.junit.Test;

import com.mongo.util.MongoConnection;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;

public class MongoTest {

MongoConnection connection = new MongoConnection();
//连接到数据库
MongoDatabase mongoDatabase = connection.getConnectionBasis();


@Test
public void test(){
//createCollection();//创建 集合 一次就好
MongoCollection<Document> collection = getCollection();
insertDomcument(collection);
findAll(collection);
//delete(collection);
}

/**
* 创建 集合【对应RDBMS 中的数据表】 com.mongodb.client.MongoDatabase.createCollection("集合名")
*/
public void createCollection(){
mongoDatabase.createCollection("testConllection");
System.out.println("创建集合成功");
}

/**
* 获取 集合【对应RDBMS 中的数据表】com.mongodb.client.MongoDatabase.getCollection("集合名")
*/
public MongoCollection<Document> getCollection(){
MongoCollection<Document> collection = mongoDatabase.getCollection("testConllection");
System.out.println("转换到指定集合");
return collection;
}

/**
* 插入 文档【对应RDBMS 中的一条数据】com.mongodb.client.MongoCollection<Document>.insertOne()/insertMany()
*/
public void insertDomcument(MongoCollection<Document> collection){
/**
* 1. 创建文档 org.bson.Document 参数为key-value的格式
* 2. 创建文档集合List<Document>
* 3. 将文档集合插入数据库集合中 mongoCollection.insertMany(List<Document>) 插入单个文档可以用 mongoCollection.insertOne(Document)
* */
Document document = new Document();
document.append("name", "走四方");
document.append("age", 23);
document.append("url", "www.baidu.com");

List<Document> list = new ArrayList<Document>();
list.add(document);

collection.insertMany(list);
System.out.println("插入文档成功");

//插入 单条数据
Document t = new Document();
t.append("name", "走什么");
t.append("age", 26);
t.append("url", "www.agen.cn");

collection.insertOne(t);
System.out.println("插入单条数据成功");
}

/**
* 查询 所有文档【表内 数据】com.mongodb.client.MongoCollection<Document>.find()
* 查询 本条数据的时间节点 _id采用ObjectId格式
*
* ObjectId 是一个12字节 BSON 类型数据，有以下格式：
前4个字节表示时间戳
接下来的3个字节是机器标识码
紧接的两个字节由进程id组成（PID）
最后三个字节是随机数。
*/
public void findAll(MongoCollection<Document> collection){
/**
* 1. 获取迭代器FindIterable<Document>
* 2. 获取游标MongoCursor<Document>
* 3. 通过游标遍历检索出的文档集合
* */
FindIterable<Document> findIterable = collection.find();
MongoCursor<Document> mongoCursor = findIterable.iterator();
while(mongoCursor.hasNext()){
Document document = mongoCursor.next();
System.out.println("MongoDB数据："+document);
System.out.println("本地时间："+new SimpleDateFormat().format(document.getObjectId("_id").getDate()));
}
}

/**
* 更新 所有文档【表内 数据】com.mongodb.client.MongoCollection<Document>.updateMany()
*/
public void update(MongoCollection<Document> collection){

collection.updateMany(Filters.eq("age", 26), new Document("$set",new Document("age",100)));

FindIterable<Document> findIterable = collection.find();
MongoCursor<Document> cursor = findIterable.iterator();
while (cursor.hasNext()) {
System.out.println("更新后的MongoDB数据："+cursor.next());
}
}


/**
* 删除 文档 com.mongodb.client.MongoCollection<Document>.deleteMany()/deleteOne()
*/
public void delete(MongoCollection<Document> collection){
// 删除符合条件的 第一个文档
collection.findOneAndDelete(Filters.eq("age", 26));
//删除符合条件的 所有文档
collection.deleteMany(Filters.gte("age", 20));

FindIterable<Document> findIterable = collection.find();
MongoCursor<Document> cursor = findIterable.iterator();
while(cursor.hasNext()){
System.out.println("删除后的MongoDB数据："+cursor.next());
}
}
}

  1 package com.mongo.test;
  2 
  3 
  4 import java.text.SimpleDateFormat;
  5 import java.util.ArrayList;
  6 import java.util.List;
  7 
  8 import org.bson.Document;
  9 import org.junit.Test;
 10 
 11 import com.mongo.util.MongoConnection;
 12 import com.mongodb.client.FindIterable;
 13 import com.mongodb.client.MongoCollection;
 14 import com.mongodb.client.MongoCursor;
 15 import com.mongodb.client.MongoDatabase;
 16 import com.mongodb.client.model.Filters;
 17 
 18 public class MongoTest {
 19     
 20     MongoConnection connection = new MongoConnection();
 21     //连接到数据库
 22     MongoDatabase mongoDatabase = connection.getConnectionBasis();
 23     
 24     
 25     @Test
 26     public void test(){
 27         //createCollection();//创建   集合 一次就好
 28         MongoCollection<Document> collection = getCollection();
 29         insertDomcument(collection);
 30         findAll(collection);
 31         //delete(collection);
 32     }
 33     
 34     /**
 35      * 创建  集合【对应RDBMS 中的数据表】 com.mongodb.client.MongoDatabase.createCollection("集合名")
 36      */
 37     public void createCollection(){
 38         mongoDatabase.createCollection("testConllection");
 39         System.out.println("创建集合成功");
 40     }
 41     
 42     /**
 43      * 获取  集合【对应RDBMS 中的数据表】com.mongodb.client.MongoDatabase.getCollection("集合名")
 44      */
 45     public MongoCollection<Document> getCollection(){
 46         MongoCollection<Document>  collection = mongoDatabase.getCollection("testConllection");
 47         System.out.println("转换到指定集合");
 48         return collection;
 49     }
 50     
 51     /**
 52      * 插入  文档【对应RDBMS 中的一条数据】com.mongodb.client.MongoCollection<Document>.insertOne()/insertMany()
 53      */
 54     public void insertDomcument(MongoCollection<Document> collection){
 55         /** 
 56         * 1. 创建文档 org.bson.Document 参数为key-value的格式 
 57         * 2. 创建文档集合List<Document> 
 58         * 3. 将文档集合插入数据库集合中 mongoCollection.insertMany(List<Document>) 插入单个文档可以用 mongoCollection.insertOne(Document) 
 59         * */
 60         Document document = new Document();
 61         document.append("name", "走四方");
 62         document.append("age", 23);
 63         document.append("url", "www.baidu.com");
 64         
 65         List<Document> list = new ArrayList<Document>();
 66         list.add(document);
 67         
 68         collection.insertMany(list);
 69         System.out.println("插入文档成功");
 70         
 71         //插入 单条数据
 72         Document  t = new Document();
 73         t.append("name", "走什么");
 74         t.append("age", 26);
 75         t.append("url", "www.agen.cn");
 76         
 77         collection.insertOne(t);
 78         System.out.println("插入单条数据成功");
 79     }
 80     
 81     /**
 82      * 查询  所有文档【表内 数据】com.mongodb.client.MongoCollection<Document>.find()
 83      * 查询  本条数据的时间节点   _id采用ObjectId格式
 84      * 
 85      * ObjectId 是一个12字节 BSON 类型数据，有以下格式：
 86             前4个字节表示时间戳
 87             接下来的3个字节是机器标识码
 88             紧接的两个字节由进程id组成（PID）
 89             最后三个字节是随机数。
 90      */
 91     public void findAll(MongoCollection<Document> collection){
 92         /** 
 93         * 1. 获取迭代器FindIterable<Document> 
 94         * 2. 获取游标MongoCursor<Document> 
 95         * 3. 通过游标遍历检索出的文档集合 
 96         * */
 97          FindIterable<Document> findIterable = collection.find();
 98          MongoCursor<Document> mongoCursor = findIterable.iterator();
 99          while(mongoCursor.hasNext()){
100              Document document = mongoCursor.next();
101              System.out.println("MongoDB数据："+document);
102              System.out.println("本地时间："+new SimpleDateFormat().format(document.getObjectId("_id").getDate()));
103          }
104     }
105     
106     /**
107      * 更新   所有文档【表内  数据】com.mongodb.client.MongoCollection<Document>.updateMany()
108      */
109     public void update(MongoCollection<Document> collection){
110         
111         collection.updateMany(Filters.eq("age", 26), new Document("$set",new Document("age",100)));
112         
113         FindIterable<Document> findIterable = collection.find();
114         MongoCursor<Document> cursor = findIterable.iterator();
115         while (cursor.hasNext()) {
116             System.out.println("更新后的MongoDB数据："+cursor.next());
117         }
118     }
119     
120     
121     /**
122      * 删除  文档 com.mongodb.client.MongoCollection<Document>.deleteMany()/deleteOne()
123      */
124     public void delete(MongoCollection<Document> collection){
125         // 删除符合条件的 第一个文档
126         collection.findOneAndDelete(Filters.eq("age", 26));
127         //删除符合条件的  所有文档
128         collection.deleteMany(Filters.gte("age", 20));
129         
130         FindIterable<Document> findIterable = collection.find();
131         MongoCursor<Document> cursor = findIterable.iterator();
132         while(cursor.hasNext()){
133             System.out.println("删除后的MongoDB数据："+cursor.next());
134         }
135     }
136     
137     
138     
139     
140     
141 }