MongoDB数据库建立连接

chunjihong

<span style=&quot;font-size:14px;&quot;>package com.eduaks.luck.test;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.colasoft.wcs.common.AppCf;
import com.colasoft.wcs.utils.MongoUtil;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoOptions;
import com.mongodb.ServerAddress;
import com.mongodb.WriteConcern;
import com.mongodb.WriteResult;
public class Test {
private static Log log = LogFactory.getLog(MongoUtil.class);
private static Mongo mongo;
private static DB db;//要连接的数据库
protected DBCollection _coll;
protected String _ns;//数据库中插入信息的表的名字
static {
try {
ServerAddress address = new ServerAddress(&quot;127.0.0.1&quot;,
27017);
MongoOptions option = new MongoOptions();
option.connectionsPerHost = 1000;
option.threadsAllowedToBlockForConnectionMultiplier = 100;
option.maxWaitTime = 5000;
option.autoConnectRetry = true;
option.socketKeepAlive = true;
mongo = new Mongo(address, option);
db =  mongo.getDB(AppCf.mongo_dbname);//要连接的数据库
_coll = _db.getCollection(_ns);//建立连接
//boolean auth = db.authenticate(AppCf.mongo_username, AppCf.mongo_password.toCharArray());
//if(!auth){
//log.error(&quot;数据库用户名和密码错误！&quot;);
//}
} catch (Exception e) {
log.error(&quot;mongo数据库初始化失败,失败原因:&quot; + e.getMessage(), e);
}
}
public static DB getDB() {
return db;
}
/**
* 插入
*
* @Title: insert
* @Description: TODO
* @param @param basicDBObject
* @param @return
* @return WriteResult
* @throws
*/
public WriteResult insert(DBObject basicDBObject) {
try {
return _coll.insert(basicDBObject, WriteConcern.SAFE);
} catch (Exception e) {
log.error(&quot;插入失败!&quot; + e.getMessage(), e);
}
return null;
}
}
</span>
　　


　　


　　


　　package com.luck.mongdb;



import java.net.UnknownHostException;



import com.mongodb.BasicDBObject;

import com.mongodb.DB;

import com.mongodb.DBCollection;

import com.mongodb.DBCursor;

import com.mongodb.DBObject;

import com.mongodb.Mongo;

import com.mongodb.MongoException;



public class MongDBTest {

    public static void main(String[] args) {

         Mongo mongo;

            try {

                    mongo = new Mongo(&quot;192.168.9.60&quot;, 27017);

                    DB db = mongo.getDB(&quot;myText&quot;);

                    //创建表

                   // DBObject obj =  (BasicDBObject)JSON.parse(&quot;{'name':'zouguijin','age':'25'}&quot;);

                    //db.createCollection(&quot;test&quot;,obj);

                    

                    

                   DBCollection table = db.getCollection(&quot;test&quot;);

                   //增加

                  /* BasicDBObject beanOne = new BasicDBObject();

                    beanOne.put(&quot;name&quot;, &quot;kakakaka&quot;);

                    beanOne.put(&quot;sex&quot;, &quot;男&quot;);

                    beanOne.put(&quot;age&quot;, 20);

                    table.save(beanOne);*/

                  

                   //查询

                   DBCursor dbCursor= table.find();

                   BasicDBObject oldObject = new BasicDBObject();

                   System.out.println(dbCursor.toArray());

                   for(DBObject i : dbCursor){

                       oldObject = (BasicDBObject) i;

                        System.out.println(i.get(&quot;name&quot;));

                        System.out.println(i.get(&quot;sex&quot;));

                        System.out.println(i.get(&quot;age&quot;)&#43;&quot;:&quot;&#43;i.get(&quot;_id&quot;));

                    }

                   //修改

                   BasicDBObject   newObject = new BasicDBObject();

                   newObject.put(&quot;name&quot;, &quot;第三方&quot;);

                   newObject.put(&quot;sex&quot;, &quot;女&quot;);

                   newObject.put(&quot;age&quot;, 30);

                  // table.update(oldObject,newObject);

                   //删除

                   table.findAndRemove(newObject);

                  

                  

                  

            } catch (UnknownHostException e) {

                e.printStackTrace();

            } catch (MongoException e) {

                e.printStackTrace();

            }

    }

}







版权声明：本文为博主原创文章，未经博主允许不得转载。