JDBC连接MongoDB

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了JDBC连接MongoDB，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3092字，纯文字阅读大概需要5分钟。

内容图文

pom文件中导入驱动

<!-- MongoDB驱动 -->
<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongo-java-driver</artifactId>
    <version>3.12.7</version>
</dependency>

示例代码

import com.mongodb.*;
 
import java.net.UnknownHostException;
import java.util.Date;
import java.util.Set;

public class TestController {
 
	private static final String MONGO_HOST = "localhost";
	private static final Integer MONGO_PORT = 27017;
	private static final String MONGO_USERNAME = "test";
	private static final String MONGO_PASSWORD = "1234";
	private static final String MONGO_DB_NAME = "mongo-db-test";
	private static final String MONGO_COLLECTION_NAME = "mongo-collection-test";
 
 
	public static void main(String[] args) throws UnknownHostException {
 
		// 获取Mongo客户端
		MongoClient mongoClient = new MongoClient(MONGO_HOST, MONGO_PORT);
		/**
		 * 1.获取所有db名称并打印（mongodb未开启auth认证下可用）
		 */
		/*List<String> databaseNames = mongoClient.getDatabaseNames();
		System.out.println(MONGO_HOST + ":" + MONGO_PORT.toString() + "包含如下数据库：");
		for (String databaseName : databaseNames) {
			System.out.println(databaseName);
		}*/
 
		/**
		 * 2.获取到指定db（若不存在，则mongo会创建该db）
		 */
		DB db = mongoClient.getDB(MONGO_DB_NAME);
		// 2.1用户名&密码校验
		boolean auth = db.authenticate(MONGO_USERNAME, MONGO_PASSWORD.toCharArray());
		if (!auth) {
			System.out.println(MONGO_DB_NAME + " connection failed！");
			return;
		}
		System.out.println(MONGO_DB_NAME + " connection success！");
 
		// 2.2获取该db下所有集合名称并打印
		Set<String> collectionNames = db.getCollectionNames();
		System.out.println(db.getName() + "包含如下集合：");
		for (String collectionName : collectionNames) {
			System.out.println(collectionName);
		}
 
		// 2.3获取指定集合(若不存在，则mongo会创建该集合)
		DBCollection collection = db.getCollection(MONGO_COLLECTION_NAME);
 
		/**
		 * 3.增删查改
		 */
		// 3.1插入一条文档
		BasicDBObject document = new BasicDBObject();
		document.put("name", "Cheung");
		document.put("age", 24);
		document.put("address", "Beijing");
		document.put("date", new Date());
		collection.insert(document);
 
		// 3.2查询一条文档
		BasicDBObject searchObj = new BasicDBObject();
		searchObj.put("name", "Cheung");
		DBCursor cursor = collection.find(searchObj);
		if (cursor.hasNext()) {
			System.out.println("查询到的文档为：");
			while (cursor.hasNext()) {
				System.out.println(cursor.next());
			}
		} else {
			System.out.println("该文档不存在！");
		}
 
		// 3.3修改一条文档
		BasicDBObject newDocument = new BasicDBObject();
		newDocument.put("name", "Cheung-updated");// 新文档
		BasicDBObject updateObj = new BasicDBObject();
		updateObj.put("$set", newDocument);
		collection.update(searchObj, updateObj);// 更新
 
		// 3.4查询修改后的文档（修改确认）
		DBCursor cursor2 = collection.find(newDocument);
		if (cursor2.hasNext()) {
			System.out.println("修改后的文档为：");
			while (cursor2.hasNext()) {
				System.out.println(cursor2.next());
			}
		} else {
			System.out.println("该文档不存在！");
		}
 
		// 3.5删除该文档
		collection.remove(newDocument);
 
		// 3.6查询该文档是否存在（删除确认）
		DBCursor cursor3 = collection.find(newDocument);
		if (cursor3.hasNext()) {
			System.out.println("查询到的文档为：");
			while (cursor3.hasNext()) {
				System.out.println(cursor3.next());
			}
		} else {
			System.out.println("该文档不存在！");
		}
 
	}
 
}

内容总结

以上是互联网集市为您收集整理的JDBC连接MongoDB全部内容，希望文章能够帮你解决JDBC连接MongoDB所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端