docker安裝mongodb及java連接實戰

1.docker部署mongodb
docker run --name mongodb -d -p 27017:27017 -v /data/mongodbdata:/data/db -e MONGO_INITDB_ROOT_USERNAME=testmongo -e MONGO_INITDB_ROOT_PASSWORD=test123456 mongodb:4.0.112.項目實戰
<dependencies><dependency><groupId>org.mongodb</groupId><artifactId>mongo-java-driver</artifactId><version>3.0.4</version></dependency>
</dependencies>import com.mongodb.MongoClient;
import com.mongodb.client.MongoDatabase;//mongodb 連接數據庫工具類
public class MongoDBUtil {//不通過認證獲取連接數據庫對象public static MongoDatabase getConnect(){//連接到 mongodb 服務MongoClient mongoClient = new MongoClient("localhost", 27017);//連接到數據庫MongoDatabase mongoDatabase = mongoClient.getDatabase("test");//返回連接數據庫對象return mongoDatabase;}//需要密碼認證方式連接public static MongoDatabase getConnect2(){List<ServerAddress> adds = new ArrayList<>();//ServerAddress()兩個參數分別為 服務器地址 和 端口ServerAddress serverAddress = new ServerAddress("localhost", 27017);adds.add(serverAddress);List<MongoCredential> credentials = new ArrayList<>();//MongoCredential.createScramSha1Credential()三個參數分別為 用戶名 數據庫名稱 密碼MongoCredential mongoCredential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());credentials.add(mongoCredential);//通過連接認證獲取MongoDB連接MongoClient mongoClient = new MongoClient(adds, credentials);//連接到數據庫MongoDatabase mongoDatabase = mongoClient.getDatabase("test");//返回連接數據庫對象return mongoDatabase;}
}//插入一個文檔
@Test
public void insertOneTest(){//獲取數據庫連接對象MongoDatabase mongoDatabase = MongoDBUtil.getConnect();//獲取集合MongoCollection<Document> collection = mongoDatabase.getCollection("user");//要插入的數據Document document = new Document("name","張三").append("sex", "男").append("age", 18);//插入一個文檔collection.insertOne(document);
}//插入多個文檔
@Test
public void insertManyTest(){//獲取數據庫連接對象MongoDatabase mongoDatabase = MongoDBUtil.getConnect();//獲取集合MongoCollection<Document> collection = mongoDatabase.getCollection("user");//要插入的數據List<Document> list = new ArrayList<>();for(int i = 1; i <= 3; i++) {Document document = new Document("name", "張三").append("sex", "男").append("age", 18);list.add(document);}//插入多個文檔collection.insertMany(list);
}//刪除與篩選器匹配的單個文檔
@Test
public void deleteOneTest(){//獲取數據庫連接對象MongoDatabase mongoDatabase = MongoDBUtil.getConnect();//獲取集合MongoCollection<Document> collection = mongoDatabase.getCollection("user");//申明刪除條件Bson filter = Filters.eq("age",18);//刪除與篩選器匹配的單個文檔collection.deleteOne(filter);
}//刪除與篩選器匹配的所有文檔
@Test
public void deleteManyTest(){//獲取數據庫連接對象MongoDatabase mongoDatabase = MongoDBUtil.getConnect();//獲取集合MongoCollection<Document> collection = mongoDatabase.getCollection("user");//申明刪除條件Bson filter = Filters.eq("age",18);//刪除與篩選器匹配的所有文檔collection.deleteMany(filter);
}//修改單個文檔
@Test
public void updateOneTest(){//獲取數據庫連接對象MongoDatabase mongoDatabase = MongoDBUtil.getConnect();//獲取集合MongoCollection<Document> collection = mongoDatabase.getCollection("user");//修改過濾器Bson filter = Filters.eq("name", "張三");//指定修改的更新文檔Document document = new Document("$set", new Document("age", 100));//修改單個文檔collection.updateOne(filter, document);
}//修改多個文檔
@Test
public void updateManyTest(){//獲取數據庫連接對象MongoDatabase mongoDatabase = MongoDBUtil.getConnect();//獲取集合MongoCollection<Document> collection = mongoDatabase.getCollection("user");//修改過濾器Bson filter = Filters.eq("name", "張三");//指定修改的更新文檔Document document = new Document("$set", new Document("age", 100));//修改多個文檔collection.updateMany(filter, document);
}//查找集合中的所有文檔
@Test
public void findTest(){//獲取數據庫連接對象MongoDatabase mongoDatabase = MongoDBUtil.getConnect();//獲取集合MongoCollection<Document> collection = mongoDatabase.getCollection("user");//查找集合中的所有文檔FindIterable findIterable = collection.find();MongoCursor cursor = findIterable.iterator();while (cursor.hasNext()) {System.out.println(cursor.next());}
}//指定查詢過濾器查詢
@Test
public void FilterfindTest(){//獲取數據庫連接對象MongoDatabase mongoDatabase = MongoDBUtil.getConnect();//獲取集合MongoCollection<Document> collection = mongoDatabase.getCollection("user");//指定查詢過濾器Bson filter = Filters.eq("name", "張三");//指定查詢過濾器查詢FindIterable findIterable = collection.find(filter);MongoCursor cursor = findIterable.iterator();while (cursor.hasNext()) {System.out.println(cursor.next());}
}//取出查詢到的第一個文檔
@Test
public void findTest(){//獲取數據庫連接對象MongoDatabase mongoDatabase = MongoDBUtil.getConnect();//獲取集合MongoCollection<Document> collection = mongoDatabase.getCollection("user");//查找集合中的所有文檔FindIterable findIterable = collection.find();//取出查詢到的第一個文檔Document document = (Document) findIterable.first();//打印輸出System.out.println(document);
}import com.mongodb.client.FindIterable;
import org.bson.Document;
import java.util.List;
import java.util.ArrayList;public class MongoDBPagingExample {public static void main(String[] args) {// 連接到MongoDB（同上）MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");MongoDatabase database = mongoClient.getDatabase("yourDatabaseName");MongoCollection<Document> collection = database.getCollection("yourCollectionName");//或者//獲取數據庫連接對象MongoDatabase mongoDatabase = MongoDBUtil.getConnect();//獲取集合MongoCollection<Document> collection = mongoDatabase.getCollection("user");// 分頁參數int pageNumber = 1; // 頁碼，從1開始int pageSize = 10;  // 每頁大小int skipCount = (pageNumber - 1) * pageSize; // 計算需要跳過的文檔數// 執行分頁查詢FindIterable<Document> findIterable = collection.find().skip(skipCount).limit(pageSize);List<Document> documents = new ArrayList<>();findIterable.forEach(documents::add); // 將結果添加到列表中// 輸出結果documents.forEach(doc -> System.out.println(doc.toJson()));}
}

java獲取MongoDB數據庫的名稱、表名和字段名及相關信息

import com.mongodb.client.*;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import org.bson.BsonDocument;
import org.bson.BsonValue;
import org.bson.Document;import java.util.Map;
import java.util.Objects;public class MongodbDemo {// 1.獲取MongoClient客戶端public static MongoClient getMongoClient(String url) {MongoClientURI mongoClientURI = new MongoClientURI(url);MongoClient mongoClient = new MongoClient(mongoClientURI);return mongoClient;}// 2.獲取數據庫列表public static ListDatabasesIterable<Document> getDataBases(String url) {MongoClient mongoClient = getMongoClient(url);ListDatabasesIterable<Document> listDatabasesIterable = mongoClient.listDatabases();for (Document database: listDatabasesIterable) {System.out.println("DataBase : " + database.get("name"));}close(mongoClient);return listDatabasesIterable;}// 3.獲取數據庫中的集合public static void getCollectionNames(String url) {ListDatabasesIterable<Document> listDatabasesIterable = getDataBases(url);MongoClient mongoClient = getMongoClient(url);for (Document database: listDatabasesIterable) {String databaseName = String.valueOf(database.get("name"));// 跳過系統相關表if ("admin".equals(databaseName)|| "config".equals(databaseName)|| "local".equals(databaseName)) {continue;}MongoDatabase mongoDatabase = mongoClient.getDatabase(databaseName);MongoIterable<String> collectionNames = mongoDatabase.listCollectionNames();System.out.println("DataBase : " + databaseName);for (String collectionName: collectionNames) {System.out.println(" CollectionName : " + collectionName);getField(mongoDatabase, collectionName);getDocument(mongoDatabase, collectionName);}}close(mongoClient);}// 4.獲取集合中的字段及格式public static void getField(MongoDatabase mongoDatabase, String collectionName) {Document doc = mongoDatabase.getCollection(collectionName).find().first();System.out.println("Collection : " + collectionName);if (Objects.nonNull(doc)) {BsonDocument document = BsonDocument.parse(doc.toJson());for(Map.Entry<String, BsonValue> entry : document.entrySet()){BsonValue value = entry.getValue();String type = value.getBsonType().name();System.out.println("Column : " + entry.getKey() + " ==== ColumnType : " + type);}}}// 5.獲取集合中的數據public static void getDocument(MongoDatabase mongoDatabase, String collectionName) {MongoCollection<Document> collection =  mongoDatabase.getCollection(collectionName);// 查詢限制50條FindIterable<Document> findIterable = collection.find().limit(50);System.out.println("CollectionName : " + collectionName);for (Document document : findIterable) {System.out.println(document);}}// 6.關閉客戶端連接public static void close(MongoClient mongoClient) {if (Objects.nonNull(mongoClient)) {mongoClient.close();}}// 測試public static void main(String[] args) {String path = "mongodb://127.0.0.1:27017";MongoClient client = getMongoClient(path);ListDatabasesIterable<Document>  listDatabases = getDataBases(path);getCollectionNames(path);getField(client.getDatabase("testdata"), "account");getDocument(client.getDatabase("testdata"), "account");close(client);}
}

//獲取鏈接對象，參數1為url，參數2為端口號
MongoClient mongoclient=new MongoClient("127.0.0.1",27017);
//獲取所有庫名的迭代器
MongoIterable<String> list= mongoclient.listDatebaseNames();
for(String str:list){System.out.println(str);//查看所有庫名
}

//獲取鏈接對象，參數1為url，參數2為端口號
MongoClient mongoclient=new MongoClient("127.0.0.1",27017);
//獲取庫對象，參數為庫名
MongoDatabase db=mongoclient.getDatabase("school");
//獲取當前庫對象的所有集合名的迭代器
MongoIterable<String> list=db.getlistCollectionNames();
for(String str:list){System.out.println(str);//獲取所有集合名
}
//獲取集合對象，參數為集合名
MongoCollention<Document> collection=db.getCollection("student");

import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import org.bson.Document;
import org.bson.codecs.configuration.CodecRegistries;
import org.bson.codecs.configuration.CodecRegistry;import java.util.HashSet;
import java.util.Set;public class MongoDBFieldRetriever {public static void main(String[] args) {// MongoDB連接字符串String connectionString = "mongodb://localhost:27017";String dbName = "your_database_name";String collectionName = "your_collection_name";// 創建MongoDB客戶端try (MongoClient mongoClient = MongoClients.create(connectionString)) {// 選擇數據庫和集合MongoDatabase database = mongoClient.getDatabase(dbName);MongoCollection<Document> collection = database.getCollection(collectionName);// 獲取集合中的第一個文檔MongoCursor<Document> cursor = collection.find().iterator();if (cursor.hasNext()) {Document firstDocument = cursor.next();// 獲取字段及其類型Set<String> fields = new HashSet<>();for (String key : firstDocument.keySet()) {fields.add(key + " : " + firstDocument.get(key).getClass().getSimpleName());}// 輸出結果System.out.println("Fields and their types in the collection:");for (String field : fields) {System.out.println(field);}}}}
}

1.新增數據//獲取集合對象
MongoCollection<Document> collection = db.getCollection("student");
//新增時創建一個Docuement對象，以鍵值對的形式傳入內容
Document document = new Document();
document.put("name", "黑蛋");
document.put("age", 9);
document.put("sex", "公");
//添加一條數據，沒有返回值
collection.insertOne(document);
//新增多條數據,傳入一個document集合
collection.insertMany(null);
2.修改數據//修改條件
Bson eq = Filters.eq("name","黑蛋");
//修改匹配到的第一條
UpdateResult updateOne = collection.updateOne(eq, new Document("$set",new Document("age",20)));
//修改匹配的多條
collection.updateMany(eq, null);
修改的返回值內容
AcknowledgedUpdateResult{matchedCount=0, modifiedCount=0, upsertedId=null}
matchedCount:代表匹配到的文檔數modifiedCount:代表被修改的文檔數upsertedId:代表修改的文檔id(主鍵)3.數據刪除//條件
Bson eq = Filters.eq("name","黑蛋");
//刪除一條符合的
DeleteResult deleteOne = collection.deleteOne(eq);
//刪除 所有符合條件的
DeleteResult deleteMany = collection.deleteMany(eq);
刪除的返回值內容
AcknowledgedDeleteResult{deletedCount=0}
deletedCount:被刪除的文檔數4.查詢數據//無條件全查
FindIterable<Document> find = collection.find();
//帶條件查詢
Bson eq = Filters.regex("name", "蛋");
FindIterable<Document> find = collection.find(eq);
查詢的結果集映射這種解析方式我們必須知道文檔中的各個字段名//全查
FindIterable<Document> find = collection.find();//創建一個實體類集合準備接收結果
List<Student>  slist = new ArrayList<Student>();
//獲取結果集迭代器對象    
MongoCursor<Document> iterator = find.iterator();while(iterator.hasNext()) {Student s =  new Student();Document next = iterator.next();s.setSname(next.getString("name"));s.setSsex(next.getString("sex"));s.setSid(next.getInteger("sid"));    //將結果添加至實體類集合slist.add(s);}