MongoDB(몽고디비) - Java로 몽고디비 연동하기

1. 개요

  안드로이드에서 몽고디비를 연동하기 위해 Java로 구현 및 테스트 해보았습니다. 

2. 라이브러리 설치

  우선 몽고디비 홈페이지의 라이브러리 다운 페이지(https://mongodb.github.io/mongo-java-driver/)로 들어갑니다.

 mongo-java-dirver로 맞춘 다음 왼쪽 다운로드 버튼을 누릅니다. 그리고 새로 나온 페이지에서 mongo-java-driver-버전.jar으로 된 파일을 다운받습니다. 

개발자마다 사용 툴이 다를 것이라고 생각하기에 jar파일 등록하는 것은 따로 설명하지 않겠습니다.

3. 접속 및 DB, Collection 정보 보기

 1. Source Code

import java.util.List; import java.util.Set; import com.mongodb.DB; import com.mongodb.MongoClient; import com.mongodb.ServerAddress; public class Main { public static void main(String args[]){ String MongoDB_IP = "127.0.0.1"; int MongoDB_PORT = 27017; String DB_NAME = "testDB"; //Connect to MongoDB MongoClient mongoClient = new MongoClient(new ServerAddress(MongoDB_IP, MongoDB_PORT)); //View Database List List<String> databases = mongoClient.getDatabaseNames(); System.out.println("=====Database List===== "); int num =1 ; for (String dbName : databases) { System.out.println( num + ". " + dbName); num++; } System.out.println(); //Connect Database and Show Collection List in Database DB db = mongoClient.getDB(DB_NAME); Set<String> collections = db.getCollectionNames(); System.out.println("Database : " + DB_NAME); for (String colName : collections) { System.out.println(" + Collection: " + colName); } } }

 

 2. Result

4. Insert

 똑같은 데이터를 넣어도 여러 오브젝트를 이용하여 넣을 수 있습니다. 총 4개의 경우로 테스트 해보았고 소스는 아래와 같습니다. 

 1. Source Code

import java.util.HashMap; import java.util.Map; import com.mongodb.BasicDBObject; import com.mongodb.BasicDBObjectBuilder; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBCursor; import com.mongodb.DBObject; import com.mongodb.MongoClient; import com.mongodb.ServerAddress; import com.mongodb.util.JSON; public class Main { public static void main(String args[]){ String MongoDB_IP = "127.0.0.1"; int MongoDB_PORT = 27017; String DB_NAME = "testDB"; //Connect to MongoDB MongoClient mongoClient = new MongoClient(new ServerAddress(MongoDB_IP, MongoDB_PORT)); DB db = mongoClient.getDB(DB_NAME); DBCollection collection = db.getCollection("testCollection01"); //=========== Make Data01 by BasicDBObject =========== BasicDBObject document = new BasicDBObject(); document.put("one", "data01"); document.put("two", "BasicDBObject"); BasicDBObject documentDetail = new BasicDBObject(); documentDetail.put("three-one", 99); documentDetail.put("three-two", "BasicDBObject"); documentDetail.put("three-three", "true"); document.put("three", documentDetail); //Insert Data01 collection.insert(document); //=========== Make Data02 by BasicDBObjectBuilder =========== BasicDBObjectBuilder documentBuilder = BasicDBObjectBuilder.start() .add("one", "data02").add("two", "BasicDBObjectBuilder"); BasicDBObjectBuilder documentBuilderDetail = BasicDBObjectBuilder.start() .add("three-one", 98).add("three-two", "BasicDBObjectBuilder").add("three-three", "fasle"); documentBuilder.add("three", documentBuilderDetail.get()); //Insert Data02 collection.insert(documentBuilder.get()); //=========== Make Data03 by BasicDBObjectBuilder =========== Map<String, Object> documentMap = new HashMap<String, Object>(); documentMap.put("one", "data03"); documentMap.put("two", "Map"); Map<String, Object> documentMapDetail = new HashMap<String, Object>(); documentMapDetail.put("three-one", 97); documentMapDetail.put("three-two", "Map"); documentMapDetail.put("three-three", "true"); documentMap.put("three", documentMapDetail); //Insert Data03 collection.insert(new BasicDBObject(documentMap)); //=========== Make Data04 by json =========== String json = "{'one' : 'data04','two' : 'json'," + "'three' : {'three-one' : 96, 'three-two' : 'json', 'three-three' : 'false'}}}"; DBObject dbObject = (DBObject)JSON.parse(json); //Insert Data04 collection.insert(dbObject); //Check Data in Database DBCursor cursorDocBuilder = collection.find(); while (cursorDocBuilder.hasNext()) { System.out.println(cursorDocBuilder.next()); } } }

 

 2. Result

5. update

 1.Source Code

import com.mongodb.BasicDBObject; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBCursor; import com.mongodb.MongoClient; import com.mongodb.ServerAddress; public class Main { static void insertDatas(DBCollection collection){ BasicDBObject document = new BasicDBObject(); document.put("name", "data01"); document.put("type", "String"); document.put("num", 111); BasicDBObject document2 = new BasicDBObject(); document2.put("name", "data02"); document2.put("type", "char"); document2.put("num", 222); BasicDBObject document3 = new BasicDBObject(); document3.put("name", "data03"); document3.put("type", "String"); document3.put("num", 333); collection.insert(document); collection.insert(document2); collection.insert(document3); } static void printAllData(DBCollection collection){ DBCursor cursor = collection.find(); while (cursor.hasNext()) { System.out.println(cursor.next()); } } static void updateData01(DBCollection collection){ BasicDBObject updateQuery = new BasicDBObject(); updateQuery.put("num", 1111); BasicDBObject searchQuery = new BasicDBObject().append("name", "data01"); collection.update(searchQuery, updateQuery); } static void updateData02(DBCollection collection){ BasicDBObject updateQuery = new BasicDBObject().append("$set", new BasicDBObject().append("num", 1111)); BasicDBObject searchQuery = new BasicDBObject().append("name", "data01"); collection.update(searchQuery, updateQuery); } static void updateData03(DBCollection collection){ BasicDBObject updateDocument = new BasicDBObject().append("$inc",new BasicDBObject().append("num", 89)); collection.update(new BasicDBObject().append("name", "data01"), updateDocument); } static void updateData04(DBCollection collection){ BasicDBObject updateQuery = new BasicDBObject().append("$set", new BasicDBObject().append("num",777)); BasicDBObject searchQuery = new BasicDBObject(); searchQuery.append("type", "String"); collection.update(searchQuery, updateQuery); } public static void main(String args[]){ String MongoDB_IP = "127.0.0.1"; int MongoDB_PORT = 27017; String DB_NAME = "testDB"; //Connect to MongoDB MongoClient mongoClient = new MongoClient(new ServerAddress(MongoDB_IP, MongoDB_PORT)); DB db = mongoClient.getDB(DB_NAME); DBCollection collection = db.getCollection("testCollection03"); insertDatas(collection); printAllData(collection); updateData01(collection); //updateData02(collection); //updateData03(collection); //updateData04(collection); } }

 

 2. Result

6. find

  find 함수는 https://www.mkyong.com/mongodb/java-mongodb-query-document/의 소스코드가 정말 잘되어 있어서 가져왔습니다.

 1. Source Code

import java.util.ArrayList; import java.util.Calendar; import java.util.List; import com.mongodb.BasicDBObject; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBCursor; import com.mongodb.DBObject; import com.mongodb.MongoClient; import com.mongodb.ServerAddress; public class Main { public static void main(String args[]){ String MongoDB_IP = "127.0.0.1"; int MongoDB_PORT = 27017; String DB_NAME = "testDB"; //Connect to MongoDB MongoClient mongoClient = new MongoClient(new ServerAddress(MongoDB_IP, MongoDB_PORT)); DB db = mongoClient.getDB(DB_NAME); DBCollection collection = db.getCollection("testCollection02"); //Insert Test Data List<DBObject> datalist = new ArrayList<DBObject>(); Calendar cal = Calendar.getInstance(); for (int i = 1; i <= 5; i++) { BasicDBObject data = new BasicDBObject(); data.append("number", i); data.append("name", "mkyong-" + i); data.append("date", cal.getTime()); datalist.add(data); } collection.insert(datalist ); //Print Data according to conditions. System.out.println("1. Find all matched documents"); DBCursor cursor = collection.find(); while (cursor.hasNext()) { System.out.println(cursor.next()); } System.out.println("\n1-2. Find first matched document"); DBObject dbObject = collection.findOne(); System.out.println(dbObject); System.out.println("\n1-3. Get 'name' field only"); BasicDBObject allQuery = new BasicDBObject(); BasicDBObject fields = new BasicDBObject(); fields.put("name", 1); DBCursor cursor2 = collection.find(allQuery, fields); while (cursor2.hasNext()) { System.out.println(cursor2.next()); } System.out.println("\n2. Find where number = 5"); BasicDBObject whereQuery = new BasicDBObject(); whereQuery.put("number", 5); DBCursor cursor3 = collection.find(whereQuery); while (cursor3.hasNext()) { System.out.println(cursor3.next()); } System.out.println("\n2-2. Find where number in 2,4 and 5"); BasicDBObject inQuery = new BasicDBObject(); List<Integer> list = new ArrayList<Integer>(); list.add(2); list.add(4); list.add(5); inQuery.put("number", new BasicDBObject("$in", list)); DBCursor cursor4 = collection.find(inQuery); while (cursor4.hasNext()) { System.out.println(cursor4.next()); } System.out.println("\n2-3. Find where 5 > number > 2"); BasicDBObject gtQuery = new BasicDBObject(); gtQuery.put("number", new BasicDBObject("$gt", 2).append("$lt", 5)); DBCursor cursor5 = collection.find(gtQuery); while (cursor5.hasNext()) { System.out.println(cursor5.next()); } System.out.println("\n2-4. Find where number != 4"); BasicDBObject neQuery = new BasicDBObject(); neQuery.put("number", new BasicDBObject("$ne", 4)); DBCursor cursor6 = collection.find(neQuery); while (cursor6.hasNext()) { System.out.println(cursor6.next()); } System.out.println("\n3. Find when number = 2 and name = 'mkyong-2' example"); BasicDBObject andQuery = new BasicDBObject(); List<BasicDBObject> obj = new ArrayList<BasicDBObject>(); obj.add(new BasicDBObject("number", 2)); obj.add(new BasicDBObject("name", "mkyong-2")); andQuery.put("$and", obj); System.out.println(andQuery.toString()); DBCursor cursor7 = collection.find(andQuery); while (cursor7.hasNext()) { System.out.println(cursor7.next()); } System.out.println("\n4. Find where name = 'Mky.*-[1-3]', case sensitive example"); BasicDBObject regexQuery = new BasicDBObject(); regexQuery.put("name",new BasicDBObject("$regex", "Mky.*-[1-3]").append("$options", "i")); System.out.println(regexQuery.toString()); DBCursor cursor8 = collection.find(regexQuery); while (cursor8.hasNext()) { System.out.println(cursor8.next()); } } }

 

 2. Result