mongodb使用实践---mongodb+mongo-java-driver+morphia

packagecom.lolaage.dals.dbfactory.mongodb;

importjava.net.UnknownHostException;
importjava.util.ArrayList;
importjava.util.List;

import com.mongodb.*;
importorg.apache.log4j.Logger;

importcom.lolaage.config.Configure;
importcom.lolaage.config.IConfigure;
importcom.lolaage.entity.newdata.TLogin;
importorg.mongodb.morphia.Datastore;
importorg.mongodb.morphia.Morphia;
importorg.mongodb.morphia.mapping.Mapper;

/*** 
 * @ClassName: MongoFactory
 * @Description: MongoFactory
 * @date 2018
 * 
 */
public classMongoFactory {
   private static final Logger logger = Logger.getLogger(MongoFactory.class);
   private static Datastore ds = null;

   privateMongoFactory() {

   }

   /*** 根据名称获取DB，相当于是连接
    * 
    * @param* @return
    */
   public staticDatastore getDatastore() {
      if (ds == null) {      
         init();//初始化
}
      returnds;

   }
   

   /*** 初始化连接池，设置参数。
    */
   private static voidinit() {
      IConfigure config =Configure.getInstance();
      String host = config.readString("mongodb", "ip");
      short port = config.readShort("mongodb", "port");
      String uname = config.readString("mongodb", "uname");
      String pwd = config.readString("mongodb", "pwd");
      int poolSize = config.readInt("mongodb", "pool_size"); //连接数量
      int minpoolsize = config.readInt("mongodb", "min_pool_size"); //最小连接数量
      minpoolsize = minpoolsize>0 ? minpoolsize : 20;
      int maxidletimems = config.readInt("mongodb", "maxidletimems"); //最大空闲时间
      maxidletimems = maxidletimems>0 ? maxidletimems : 1000*10;
      int maxWaitTime = config.readInt("mongodb", "maxWaitTime"); //最大等待时间
      maxWaitTime = maxWaitTime>0 ? maxWaitTime : 1000*15;
      int socketTimeout = config.readInt("mongodb", "socketTimeout");//连接超时时间
      socketTimeout = socketTimeout>0 ? socketTimeout : 1000*15;
      int connectTimeout = config.readInt("mongodb", "connectTimeout"); //超时
      connectTimeout = connectTimeout>0 ? connectTimeout : 1000*15;

      int blockSize = config.readInt("mongodb", "block_size"); //等待队列长度
      String databaseName = config.readString("mongodb", "database_name");
      Morphia morphia = newMorphia();
      Mapper mapper =morphia.getMapper();
      mapper.addMappedClass(TLogin.class);
      mapper.createEntityCache();

      //其他参数根据实际情况进行添加
      try{     
         //1.连接池相关选项配置
            MongoClientOptions options=MongoClientOptions.builder()
                    .connectionsPerHost(poolSize)
                    .minConnectionsPerHost(minpoolsize)
                    .maxConnectionIdleTime(maxidletimems)
                    .threadsAllowedToBlockForConnectionMultiplier(blockSize)
                    .maxWaitTime(maxWaitTime)
                    .socketTimeout(socketTimeout)
                    .connectTimeout(connectTimeout)
                    .build();
            //2.鉴权配置
            MongoCredential credential = MongoCredential.createScramSha1Credential(uname, "admin", pwd.toCharArray());
            List<MongoCredential> credentials = new ArrayList<MongoCredential>();
            credentials.add(credential);

            //3.mongodb服务器相关配置
            List<ServerAddress> addresses=new ArrayList<ServerAddress>();
            addresses.add(newServerAddress(host, port));

            //4.创建客户实例，获取数据库存储对象。
            MongoClient mongoClient =  newMongoClient(addresses,credentials, options);
         morphia.mapPackage("com.lolaage");//告诉morphia到哪个包下面去找实体类
         logger.warn("获取数据库连接对象>>>>>>>>>>>>>>>>>");
         ds = morphia.createDatastore(mongoClient, databaseName);//构建Datastore对象，其中`databaseName`是数据库名称
            ds.ensureIndexes();//确保索引生效
      //} catch (UnknownHostException e) {
      //logger.error(e.getMessage());
      } catch(MongoException e) {
         logger.error(e.getMessage());
      }
   }
}
--------------------------------------------使用样例-------------------------------------------------------

1.对象配置

@Entity
public class TLogin extends LongPKMongoEO {
private int sessionId;
private long userId;
public int getSessionId() {
return sessionId;
}
public void setSessionId(int sessionId) {
this.sessionId = sessionId;
}
public long getUserId() {
return userId;
}
public void setUserId(long userId) {
this.userId = userId;
}
}

public abstract class LongPKMongoEO {
@Id
Long _id;
@Transient
protected Datastore ds;
public void setDs(Datastore ds) {
this.ds = ds;
}
@PrePersist
void prePersist() {
//自增性主键的处理
if (_id == null) {
String collName = ds.getCollection(getClass()).getName();
Query<StoredSeqence> q = ds.find(StoredSeqence.class, "_id", collName);
StoredSeqence ss = ds.findAndModify(q, ds.createUpdateOperations(StoredSeqence.class).inc("value"));
if(ss == null) {
ss = new StoredSeqence(collName);
ss.setValue(1l);
ds.save(ss);
}
_id = ss.getValue();
}
}
public Long getId() {
return _id;
}
}

@Entity(noClassnameStored = true)
public class StoredSeqence implements Serializable {
private static final long serialVersionUID = 1L;
@Id
String collName;
Long value;
public StoredSeqence() {
}
public StoredSeqence(String collName) {
this.collName = collName;
}
public Long getValue() {
return value;
}
public void setValue(Long value) {
this.value = value;
}
public String getCollName() {
return collName;
}
public void setCollName(String collName) {
this.collName = collName;
}
}

2.对象存储：
Datastore datastore =MongoFactory.getDatastore();
Datastore ds =getDatastore();
ds.save(loginVO);
3.对象查询：
Datastore ds =getDatastore();
Query<TLogin> q = ds.createQuery(TLogin.class);
q.filter("userId", ((Long)userId));
TLogin login = q.get();