JDBC 연동

package common.DBConnect; 

 

import org.junit.Test; 

 

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 DBconnect { 

 

 

MongoClient mongoClient = null; 

DB db = null; 

 

private void DBconnection(){ 

 

String ip = "localhost"; 

int port = 27017; 

String dbName = "test"; 

 

this.mongoClient = new MongoClient(new ServerAddress(ip, port)); 

this.db = this.mongoClient.getDB(dbName); 

 

} 

 

public void insert(){ 

 

DBconnection(); 

DBCollection userTable = db.getCollection("books"); 

        BasicDBObject doc = new BasicDBObject("name", "MongoDB"). 

        append("type", "database"). 

        append("count", 1). 

        append("info", new BasicDBObject("name", "js")); 

         

        userTable.insert(doc); 

 

} 

 

@Test 

public void find(){ 

 

DBconnection(); 

DBCollection userTable = db.getCollection("books"); 

BasicDBObject query = new BasicDBObject("name" ,"Book3"); 

 

DBCursor cursor = userTable.find(query); 

 

while(cursor.hasNext()){ 

System.out.println(cursor.next()); 

} 

} 

}