출처: http://bcho.tistory.com/742
초간단 Mongo DB Quick Start Guide
조대협 (http://bcho.tistory.com)
Mongo DB는 NoSQL 중에서 가장 널리 사용되는 인기있는 제품이다.
사용과 운영이 다른 시스템에 비해서 매우 쉽고, JSON 기반의 Document를 제공하기 때문에,
데이타 구조에 대한 이해 및 사용이 쉽다. 또한 index나 search와 같은 feature를 제공하고 있고,
근래에는 Text Search와 GridFS를 이용한 파일 저장 그리고, 위치 정보 저장 및 쿼리등
다양한 기능을 제공하고 있다.
Mongo DB는 10gen이라는 회사에서 개발되어서, 현재 오픈소스로와 상용 버전으로 공급되고 있다.
이 글에서는 Mongo DB에 대한 이해를 돕기 위해서 간단한 설치에서부터, 자바 기반의 프로그래밍
샘플까지 소개하도록 한다.
1.설치
1) 다운로드 하기
mongodb는 http://www.mongodb.org/downloads 에서 다운로드 받을 수 있다.
여기서는 Windows 64-bit Production Release 버전을 기준으로 한다.
zip 파일을 다운로드 받은 후에 C:\dev\mongodb-win32-x86_64-2.4.3 디렉토리에 압축을 풀었다.
2) Mongodb 구동
C:\dev\mongodb-win32-x86_64-2.4.3 에서 다음과 같은 명령어를 이용하여 구동한다.
.\bin\mongod --dbpath C:\dev\mongodb-win32-x86_64-2.4.3\data |
3) 콘솔 확인
구동후에, http://localhost:28017 을 접속하면 아래와 같이 mongodb의 기본 관리 화면을 접속할 수
있다.
2.간단한 테스팅
인스톨이 끝났으면 간단한 테스트를 해보자, ./bin/mongo.exe를 수행하면 Java Script 기반의 쉘이
수행된다. 이해를 돕기 위해서 하나의 테이블에 Insert , select, delete, update를 수행하는 명령을
SQL 문장과 비교해서 소개한다.
Insert
SQL : insert into users ("name","city") values("terry","seoul")
Mongo DB : db.users.insert({_id:"terry",city:"seoul"})
Select
SQL : select * from users where id="terry"
Mongo DB : db.users.find({_id:"terry"})
Update
SQL : update users set city="busan" where _id="terry"
Mongo DB : db.users.update( {_id:"terry"}, {$set :{ city:"Busan" } } )
Delete
SQL : delete from users where _id="terry"
Mongo DB : db.users.remove({_id:"terry"})
간단하게 나마, mongodb query에 대해서 설명하였다.
조금 더 자세한 쿼리에 대한 설명은 http://docs.mongodb.org/manual/crud/ 를 참고하기 바란다.
3. 자바로 간단한 프로그램 작성하기
지금까지 설치와 간단한 쿼리 수행을 해봤다. 그러면 이번에는 다음 단계로 간단한 자바 클라이언트를
구현해보자, RDBMS를 이용하기 위해서 JDBC 드라이버를 사용한다면, mongodb는 전용 드라이버 mongo-java-driver 를 제공한다.
이 예제에서는 별도로 설치하기 보다는 아래와 같이 maven 빌드 스크립트에 dependency를 추가하여,
빌드시에 자동으로 라이브러리가 로딩 되도록 한다.
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion>
<groupId>mongodb</groupId> <artifactId>simplemongo</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging>
<name>simplemongo</name> <url>http://maven.apache.org</url>
<properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> </properties>
<dependencies> <dependency> <groupId>org.mongodb</groupId> <artifactId>mongo-java-driver</artifactId> <version>2.10.1</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>2.3.1</version> <configuration> <source>1.6</source> <target>1.6</target> </configuration> </plugin> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-eclipse-plugin</artifactId> <configuration> <downloadSources>true</downloadSources> <downloadJavadocs>true</downloadJavadocs> </configuration> </plugin>
</plugins> </build> </project>
|
다음은 localhost에 있는 mongodb instance에 하나의 document(RDBMS로 치면 row)를 insert 하는
클라이언트 프로그램 예제이다.
package com.terry;
import com.mongodb.BasicDBObject; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.MongoClient; import com.mongodb.ServerAddress;
public class SimpleMongo {
MongoClient mongoClient = null; DB db=null;
public void mongoTest(String ip,int port,String dbname) throws Exception{
mongoClient = new MongoClient(new ServerAddress(ip,port)); db = mongoClient.getDB(dbname);
DBCollection userTable = db.getCollection("userTable"); BasicDBObject doc = new BasicDBObject("name", "MongoDB"). append("type", "database"). append("count", 1). append("info", new BasicDBObject("x", 203).append("y", 102));
userTable.insert(doc); }
public static void main(String args[]) throws Exception{ SimpleMongo testRunner = new SimpleMongo(); testRunner.mongoTest("localhost", 27017, "testdb"); } }
|
간단한 예제이기 때문에 몇가지만 설명을 하면 com.mongodb.DB는 mySQL의 DB등과 같이,
RDBMS의 DB의 개념을 표현한다. 그래서 mongoDB에 연결한후에, db를 getDB를 통해서 연결한다.
mongoDB에서 테이블은 collection이라는 개념으로 존재한다.
Table에 insert를 하기 위해서는 getCollection 메서드를 사용해서 해당 테이블 객체를 가지고 온 후, Json Object를 만들어서 Table (Collection)에 insert를 하면 된다.