本文使用的是最新的3.0版本驱动包。maven地址

<dependency>
	<groupId>org.mongodb</groupId>
	<artifactId>mongo-java-driver</artifactId>
	<version>3.0.0</version>
</dependency>

说明，2.6以后的版本的java驱动和旧的版本有很大区别，本文是基于3.0版本的驱动

无需认证连接mongdb服务器

import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoCredential;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;

import java.net.InetAddress;
import java.net.InterfaceAddress;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

import org.bson.Document;

//不需要认证
public class Auth_no {
	
	/**
	 * 获得无密码验证的client
	 * @param ip
	 * @param port
	 * @return
	 */
	public static MongoClient getClient(String ip,int port){
		MongoClient client=null;
		try {
		MongoClientOptions.Builder build = new MongoClientOptions.Builder();
		// 与数据最大连接数50
		build.connectionsPerHost(50);
		// 如果当前所有的connection都在使用中，则每个connection上可以有50个线程排队等待
		build.threadsAllowedToBlockForConnectionMultiplier(50);
		build.connectTimeout(1 * 60 * 1000);
		build.maxWaitTime(2 * 60 * 1000);
		MongoClientOptions options = build.build();
		InetAddress inetAddress;
	
			inetAddress = InetAddress.getByName(ip);
		
		ServerAddress addr=new ServerAddress(inetAddress, port);//设置地址
		client = new MongoClient(addr, options);
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return client;
	}
	
	
	public static void main(String args[]) throws UnknownHostException {
		MongoClientOptions.Builder build = new MongoClientOptions.Builder();
		// 与数据最大连接数50
		build.connectionsPerHost(50);
		// 如果当前所有的connection都在使用中，则每个connection上可以有50个线程排队等待
		build.threadsAllowedToBlockForConnectionMultiplier(50);
		build.connectTimeout(1 * 60 * 1000);
		build.maxWaitTime(2 * 60 * 1000);
		MongoClientOptions options = build.build();
		InetAddress inetAddress=InetAddress.getByName("127.0.0.1");
		ServerAddress addr=new ServerAddress(inetAddress, 2222);//设置地址
		MongoClient client = new MongoClient(addr, options);

		// 获取数据库test,不存在的话，会自动建立该数据库
		MongoDatabase db = client.getDatabase("lhy");

		// 获取data集合，不存在的话，会自动建立该集合（相当于关系数据库中的数据表）
		MongoCollection<Document> users = db.getCollection("lhy");
		Document document = new Document();
		document.append("firstName", "lei");
		document.append("address", "sichuan chengdu");
		users.insertOne(document);
		// MongoClient使用完后必须要close释放资源
		client.close();
	}
}

需要认证

import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoClientURI;
import com.mongodb.MongoCredential;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;

import java.net.InetAddress;
import java.net.InterfaceAddress;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

import org.bson.Document;

/**
 * 需要认证
 * @author Administrator
 *
 */
public class Auth_ok {
	
	
	
	/**
	 * 第一种认证方式
	 */
	public static void auth1(){
		
		String sURI = String.format("mongodb://%s:%s@%s:%d/%s", "lhy1", "123", "localhost", 27017, "lhy"); 
		MongoClientURI uri = new MongoClientURI(sURI); 
		MongoClient mongoClient = new MongoClient(uri); 
		MongoDatabase db = mongoClient.getDatabase("lhy");
		MongoCollection<Document> users = db.getCollection("lhy");
		Document document = new Document();
		document.append("aaa", "lei");
		document.append("bbb", "sichuan chengdu");
		users.insertOne(document);
		mongoClient.close();
	}
	/**
	 * 第二种认证方式
	 * @throws UnknownHostException
	 */
	public static void auth2() throws UnknownHostException{
		
		MongoClientOptions.Builder build = new MongoClientOptions.Builder();
		// 与数据最大连接数50
		build.connectionsPerHost(50);
		// 如果当前所有的connection都在使用中，则每个connection上可以有50个线程排队等待
		build.threadsAllowedToBlockForConnectionMultiplier(50);
		build.connectTimeout(1 * 60 * 1000);
		build.maxWaitTime(2 * 60 * 1000);

		MongoClientOptions options = build.build();
		MongoCredential crclientedentials = MongoCredential
				.createScramSha1Credential("lhy1", "lhy", "123".toCharArray());
		List<MongoCredential> credentialsList = new ArrayList<MongoCredential>();
		credentialsList.add(crclientedentials);//凭证列表，英文一个数据库中可能有多个账号密码
		InetAddress inetAddress=InetAddress.getByName("127.0.0.1");
		ServerAddress addr=new ServerAddress(inetAddress, 27017);//设置地址
		MongoClient client = new MongoClient(addr, credentialsList, options);

		// 获取数据库test,不存在的话，会自动建立该数据库
		MongoDatabase db = client.getDatabase("lhy");

		// 获取data集合，不存在的话，会自动建立该集合（相当于关系数据库中的数据表）
		MongoCollection<Document> users = db.getCollection("lhy");
		Document document = new Document();
		document.append("firstName", "lei");
		document.append("address", "sichuan chengdu");
		users.insertOne(document);
		// MongoClient使用完后必须要close释放资源
		client.close();
	}
	public static void main(String args[]) throws UnknownHostException {
		auth1();
	}
}

增加

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

import org.bson.Document;

import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;


public class M_Insert {
	
	/**
	 * 单个插入
	 */
	public static void insert_1(){
		
		MongoClient client=Auth_no.getClient("127.0.0.1", 2222);
		// 获取data集合，不存在的话，会自动建立该集合（相当于关系数据库中的数据表）
		MongoDatabase db = client.getDatabase("lhy");
		MongoCollection<Document> collection = db.getCollection("lhy");
		Document document = new Document();
		document.append("name", "ddd  aaa");
		document.append("age", "lhy gggg");
		collection.insertOne(document);
		
		

		// MongoClient使用完后必须要close释放资源
		client.close();
	}
	
	/**
	 * 批量插入
	 */
	public static void insert_2(){
		
		MongoClient client=Auth_no.getClient("127.0.0.1", 2222);
		// 获取data集合，不存在的话，会自动建立该集合（相当于关系数据库中的数据表）
		MongoDatabase db = client.getDatabase("lhy");
		MongoCollection<Document> collection = db.getCollection("lhy");
		//创建一个包含多个文档的列表
		 List<Document> documents = new ArrayList<Document>();
		 for (int i = 0; i < 100; i++) {
		 documents.add(new Document("i", i));
		 }
		//  向文档中插入列表
		 collection.insertMany(documents);

	}
	public static void main(String[] args) {
		insert_1();
	}

}

删除

import static com.mongodb.client.model.Filters.eq;
import static com.mongodb.client.model.Filters.gte;

import org.bson.Document;

import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.result.DeleteResult;


public class M_Delete {

	
	public static void delete_1(){
		MongoClient client=Auth_no.getClient("127.0.0.1", 2222);
		// 获取data集合，不存在的话，会自动建立该集合（相当于关系数据库中的数据表）
		MongoDatabase db = client.getDatabase("lhy");
		MongoCollection<Document> collection = db.getCollection("lhy");
		// 删除第一个符合条件的数据
		 collection.deleteOne(eq("name", "lhy"));
		//  获取全部文档,可以看到没有110这个数了
		 for (Document cur : collection.find()) {
		 System.out.println(cur.toJson());
		 }

		// 删除所有符合条件的数据，并且返回结果
		 DeleteResult deleteResult = collection.deleteMany(gte("i", 100));
		//  输出删除的行数
		 System.out.println(deleteResult.getDeletedCount());
		//  获取全部文档,所有i>=100的数据都没了
		 for (Document cur : collection.find()) {
		 System.out.println(cur.toJson());
		 }
	}
	
	
	public static void main(String[] args) {
		MongoClient client=Auth_no.getClient("127.0.0.1", 2222);
		// 获取data集合，不存在的话，会自动建立该集合（相当于关系数据库中的数据表）
		MongoDatabase db = client.getDatabase("lhy");
		MongoCollection<Document> collection = db.getCollection("lhy");
		collection.drop();
	}
}

修改

import static com.mongodb.client.model.Filters.eq;
import static com.mongodb.client.model.Filters.gte;
import static com.mongodb.client.model.Filters.lt;

import org.bson.Document;

import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.result.DeleteResult;
import com.mongodb.client.result.UpdateResult;


public class M_Update {
	/* 修改时的参数：
	 $inc 对指定的元素加
	 $mul 乘
	 $rename 修改元素名称
	 $setOnInsert 如果以前没有这个元素则增加这个元素，否则不作任何更改
	 $set 修改制定元素的值
	 $unset 移除特定的元素
	 $min 如果原始数据更大则不修改，否则修改为指定的值
	 $max 与$min相反
	 $currentDate 修改为目前的时间*/
	public static void update_1()
	{
		MongoClient client=Auth_no.getClient("127.0.0.1", 2222);
		// 获取data集合，不存在的话，会自动建立该集合（相当于关系数据库中的数据表）
		MongoDatabase db = client.getDatabase("lhy");
		MongoCollection<Document> collection = db.getCollection("lhy");
		// 修改第一个符合条件的数据
		// $set 为修改
		 collection.updateOne(eq("i", 10), new Document("$set", new
		 Document("i", 110)));
		//  获取全部文档,可以看到以前10的地方变成了110
		 for (Document cur : collection.find()) {
		 System.out.println(cur.toJson());
		 }

		// 批量修改数据并且返回修改的结果，讲所有小于100的结果都加100
		 UpdateResult updateResult = collection.updateMany(lt("i", 100),
		 new Document("$inc", new Document("i", 100)));
		//  显示发生变化的行数
		 System.out.println(updateResult.getModifiedCount());
		//  获取全部文档,可以看到除了刚才修改的110其他的全为了100
		 for (Document cur : collection.find()) {
		 System.out.println(cur.toJson());
		 }

		
	}
	public static void main(String[] args) {
		
	}
}

查询

import static com.mongodb.client.model.Filters.and;
import static com.mongodb.client.model.Filters.eq;
import static com.mongodb.client.model.Filters.exists;
import static com.mongodb.client.model.Filters.gt;
import static com.mongodb.client.model.Filters.lte;

import org.bson.Document;

import com.mongodb.BasicDBObject;
import com.mongodb.Block;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;


public class M_Query {

	public static void query_1(){
		MongoClient client=Auth_no.getClient("127.0.0.1", 2222);
		// 获取data集合，不存在的话，会自动建立该集合（相当于关系数据库中的数据表）
		MongoDatabase db = client.getDatabase("lhy");
		MongoCollection<Document> collection = db.getCollection("lhy");
		 // 显示集合中的文档的数量
		 System.out.println(collection.count());
		
		//  查询集合中的第一个文档
		 Document myDoc = collection.find().first();
		 System.out.println(myDoc.toJson());
		
		 //遍历文档   1 
		 for (Document cur : collection.find()) {
			 System.out.println(cur.toJson());
			 }
		 
		// 遍历文档  2
		 MongoCursor<Document> cursor = collection.find().iterator();
		 try {
		 while (cursor.hasNext()) {
		 System.out.println(cursor.next().toJson());
		 }
		 } finally {
		 cursor.close();
		 }
	}
	
	/**
	 * 条件查询
	 */
	public static void query_2(){
		MongoClient client=Auth_no.getClient("127.0.0.1", 2222);
		// 获取data集合，不存在的话，会自动建立该集合（相当于关系数据库中的数据表）
		MongoDatabase db = client.getDatabase("lhy");
		MongoCollection<Document> collection = db.getCollection("lhy");

			//  根据条件获取某分文档 eq:==
			 Document myDoc = collection.find(eq("i", 71)).first();
			 System.out.println(myDoc.toJson());

			// 通过查询语句一次性获取多个数据
			 Block<Document> printBlock = new Block<Document>() {
			 @Override
			 public void apply(final Document document) {
			 System.out.println(document.toJson());
			 }
			 };
			// 获得所有大于50的
			 collection.find(gt("i", 50)).forEach(printBlock);
			// 大于50 小于 100
			 collection.find(and(gt("i", 50), lte("i", 100))).forEach(printBlock);

			 //对输出文档进行排序,-1为递减，1为递增
			// 官方文档的例子有误：http:mongodb.github.io/mongo-java-driver/3.0/driver/getting-started/quick-tour/#sorting-documents
			 Document myDoc1 = collection.find(exists("i"))
			 .sort(new BasicDBObject("i", -1)).first();
			 System.out.println(myDoc1.toJson());

			// 选择性输出结果中的元素，0为不显示，1为显示
			// 官方文档中的例子又不能用：http:mongodb.github.io/mongo-java-driver/3.0/driver/getting-started/quick-tour/#projecting-fields
			 BasicDBObject exclude = new BasicDBObject();
			 exclude.append("_id", 0);
			  exclude.append("count", 0);
			 exclude.append("name", 1);
			 exclude.append("info", 1);
			 Document myDoc2 = collection.find().projection(exclude).first();
			 System.out.println(myDoc2.toJson());
		
	}
	public static void main(String[] args) {
	
		
	}
}

多语句执行

import static com.mongodb.client.model.Filters.eq;
import static com.mongodb.client.model.Filters.gte;

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

import org.bson.Document;

import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.BulkWriteOptions;
import com.mongodb.client.model.DeleteOneModel;
import com.mongodb.client.model.InsertOneModel;
import com.mongodb.client.model.ReplaceOneModel;
import com.mongodb.client.model.UpdateOneModel;
import com.mongodb.client.model.WriteModel;
import com.mongodb.client.result.DeleteResult;


public class M_builk {

	/**
	 * 按顺序执行
	 */
	public static void builk_1(){
		MongoClient client=Auth_no.getClient("127.0.0.1", 2222);
		// 获取data集合，不存在的话，会自动建立该集合（相当于关系数据库中的数据表）
		MongoDatabase db = client.getDatabase("lhy");
		MongoCollection<Document> collection = db.getCollection("lhy");
	
		// 按照语句先后顺序执行
		List list=new ArrayList();
		list.add(new InsertOneModel(new Document("name", 4)));
		list.add(new InsertOneModel(new Document("name", 5)));
		list.add(new UpdateOneModel(new Document("name", 4),new Document("$set", new Document("x", 2))));
		list.add(new DeleteOneModel(new Document("name", 5)));
	
		 collection.bulkWrite(list);
		 // 获取全部文档
		 for (Document cur : collection.find()) {
		 System.out.println(cur.toJson());
		 }

		
	}
	
	/**
	 * 不按顺序执行
	 */
	public static void builk_2(){
		MongoClient client=Auth_no.getClient("127.0.0.1", 2222);
		// 获取data集合，不存在的话，会自动建立该集合（相当于关系数据库中的数据表）
		MongoDatabase db = client.getDatabase("lhy");
		MongoCollection<Document> collection = db.getCollection("lhy");

		/**
		 * 不按先手顺序执行
		 */
		List list=new ArrayList();
		list.add(new InsertOneModel(new Document("name", 4)));
		list.add(new InsertOneModel(new Document("name", 5)));
		list.add(new UpdateOneModel(new Document("name", 4),new Document("$set", new Document("x", 2))));
		list.add(new DeleteOneModel(new Document("name", 5)));
	
		 collection.bulkWrite(list, new BulkWriteOptions().ordered(false));
		// 获取全部文档
		 for (Document cur : collection.find()) {
		 System.out.println(cur.toJson());
		 }
	}
	
	
	public static void main(String[] args) {
		builk_1();
	}
}

mongdb drivar for java 3.0版本之mongo-java-driver-3.0.0.jar 使用

无需认证连接mongdb服务器

需要认证

增加

删除

修改

查询

多语句执行

热门文章

最新文章

相关课程

相关电子书

相关实验场景

探索云世界

热门

云计算

大数据

云原生

人工智能

数据库

开发与运维

活动广场

任务中心

训练营

直播

乘风者计划

下载

镜像站

技术资料

mongdb drivar for java 3.0版本之mongo-java-driver-3.0.0.jar 使用

无需认证连接mongdb服务器

需要认证

增加

删除

修改

查询

多语句执行

热门文章

最新文章

相关课程

相关电子书

相关实验场景