MongoDB 테이블 구조 설계 코드 실현 및 연결 실현

1. 보기 위해
테이블 구조 설계 코드:

package cn.uestc.warningTest.warningTest;
import org.bson.Document;
public class TableDesign {
	private String time;//  
    
	private String phoneNum;//   
    private String type;//  
    private String local;//   
    private String out;//  
    private String in;//  
    private String context;//  
    public TableDesign(String phoneNum,String type,String context){
    	super();
    	
    	this.phoneNum = phoneNum;
    	this.type = type;
    	this.context = context;
    }
     public Document getDoc(){
    	  return new Document("   ",phoneNum).
    			  append("    ",type).
    			  append("    ", context);
      }
     public String getTime() {
 		return time;
 	}
 	public void setTime(String time) {
 		this.time = time;
 	}
 	public String getPhoneNum() {
 		return phoneNum;
 	}
 	public void setPhoneNum(String phoneNum) {
 		this.phoneNum = phoneNum;
 	}
 	public String getType() {
 		return type;
 	}
 	public void setType(String type) {
 		this.type = type;
 	}
 	public String getLocal() {
 		return local;
 	}
 	public void setLocal(String local) {
 		this.local = local;
 	}
 	public String getOut() {
 		return out;
 	}
 	public void setOut(String out) {
 		this.out = out;
 	}
 	public String getIn() {
 		return in;
 	}
 	public void setIn(String in) {
 		this.in = in;
 	}
 	public String getContext() {
 		return context;
 	}
 	public void setContext(String context) {
 		this.context = context;
 	}
}

2. MongodB 연결:

package cn.uestc.warningTest.warningTest;

import java.util.ArrayList;
import java.util.List;

import org.bson.Document;

import com.mongodb.BasicDBObject;
import com.mongodb.MongoClient;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import com.mongodb.connection.Connection;

public class mongodbConnection {
	//mongodb     
	String url ;
	String dbase;
	String collect;
	Connection connection;
	String number;
	String IMSI;
	MongoCollection col;
	public mongodbConnection(String url,String dbase){
		this.url= url;
		this.dbase = dbase;
	
	}
	public MongoCollection getConnection(String collect){
		MongoClient client = new MongoClient(url,27019);	
		MongoDatabase db = client.getDatabase(dbase);
		col =db.getCollection(collect) ;
		System.out.println("  ");
		return col;
		
	}
	public  MongoCursor query(String number, String simi,MongoCollection col){
	    BasicDBObject query = new BasicDBObject();
		query.put("   ", number);
		BasicDBObject query1 = new BasicDBObject();
		query1.put("SIMI ", simi);
		List orQueryList = new ArrayList();  
        orQueryList.add(query);  
        orQueryList.add(query1);  
        BasicDBObject orQuery = new BasicDBObject("$or", orQueryList);  
		FindIterable findIterable = col.find(orQuery);
		MongoCursor mongoCursor = findIterable.iterator();
		return mongoCursor;
	}
	/*public static void main(String args[]){
		mongodbConnection a = new mongodbConnection("192.168.0.75","warning","warn");
	    a.getConnection();
	}*/
	
}

3. 상기 2의 연결을 최적화하고 연결 탱크로 실현한다. (단일 모드)

package cn.uestc.warningTest.warningTest;

import java.rmi.UnknownHostException;
import java.util.ArrayList;
import java.util.List;

import org.bson.Document;

import com.mongodb.BasicDBObject;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.ServerAddress;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;

public class ConnectionPool {

	private static MongoClient mongoClient = null;
	private static final ConnectionPool pool = new ConnectionPool();
	private ConnectionPool(){
		if(mongoClient == null){
			MongoClientOptions.Builder buide = new MongoClientOptions.Builder();
			buide.connectionsPerHost(100);//                 
            buide.connectTimeout(1000 * 60 * 20);//              
            buide.maxWaitTime(100 * 60 * 5);//                          
            buide.threadsAllowedToBlockForConnectionMultiplier(100);
            buide.maxConnectionIdleTime(0);
            buide.maxConnectionLifeTime(0);
            buide.socketTimeout(0);
            MongoClientOptions myOptions = buide.build();
            try{
            	mongoClient = new MongoClient(new ServerAddress("192.168.0.75",27019),myOptions);
            }catch(Exception e){
            	e.printStackTrace();
            }
		}
	}
	public static ConnectionPool getConnectionPool(){
		return pool;
	}
	public MongoDatabase getDB(String dbName){
		return mongoClient.getDatabase(dbName);
	}
	public static MongoCollection getCollection(String dbName,String collectionName){
		MongoDatabase db = mongoClient.getDatabase(dbName);
		return db.getCollection(collectionName);
	}
	
    public static MongoCursor query(String number, String simi,String dbName,String collectName){
    	MongoDatabase db = mongoClient.getDatabase(dbName);
    	MongoCollection col =db.getCollection(collectName) ;
    	BasicDBObject query = new BasicDBObject();
		query.put("   ", number);
		BasicDBObject query1 = new BasicDBObject();
		query1.put("SIMI ", simi);
		List orQueryList = new ArrayList();  
        orQueryList.add(query);  
        orQueryList.add(query1);  
        BasicDBObject orQuery = new BasicDBObject("$or", orQueryList);  
		FindIterable findIterable = col.find(orQuery);
		MongoCursor mongoCursor = findIterable.iterator();
		return mongoCursor;
	}

}