Mongo的ORM框架的学习Morphia(十五)Morphia+spring整合

使用Morphia和Spring的整合如下：

package com.easyway.morphia.mongodb.services;import org.bson.types.ObjectId;import com.easyway.morphia.mongodb.dao.IHotelDAO;import com.easyway.morphia.mongodb.model.Hotel;/** *  * @Title: TODO * @Description: 实现TODO * @Copyright:Copyright (c) 2011 * @Company:易程科技股份有限公司 * @Date:2012-3-10 * @author  * @version 1.0 */public class HotelServiceImpl extends MongoBaseServiceImpl<Hotel, ObjectId> implements IHotelService{private IHotelDAO hotelDAO;public IHotelDAO getHotelDAO() {return hotelDAO;}public void setHotelDAO(IHotelDAO hotelDAO) {this.hotelDAO = hotelDAO;super.setBaseDao(hotelDAO);}}

?

package com.easyway.morphia.mongodb.services;import org.bson.types.ObjectId;import com.easyway.morphia.mongodb.model.Hotel;/** *  * @Title: TODO * @Description: 实现TODO * @Copyright:Copyright (c) 2011 * @Company:易程科技股份有限公司 * @Date:2012-3-10 * @author  * @version 1.0 */public interface IHotelService extends IMongoBaseService<Hotel, ObjectId>{}

?

package com.easyway.morphia.mongodb.services;import com.google.code.morphia.Datastore;import com.google.code.morphia.Key;import com.google.code.morphia.query.Query;import com.google.code.morphia.query.QueryResults;/** *  * @Title: TODO * @Description: 实现TODO * @Copyright:Copyright (c) 2011 * @Company:易程科技股份有限公司 * @Date:2012-3-10 * @author  * @version 1.0 */public interface IMongoBaseService<T, K>{public long count();public long count(Query<T> q);public longcount(String key, Object value) ; public  voiddelete(T entity) ;public  voiddeleteById(K id);public  voiddeleteByQuery(Query<T> q) ;public  booleanexists(Query<T> q);public  booleanexists(String key, Object value) ;public  QueryResults<T>find() ;public  QueryResults<T>find(Query<T> q) ;public  T findOne(Query<T> q) ;public  TfindOne(String key, Object value) ;public  Key<T>save(T entity) ;  public DatastoregetDatastore();    public Tget(K id) ;  public Query<T> createQuery() ;}

?

package com.easyway.morphia.mongodb.services;import com.google.code.morphia.Datastore;import com.google.code.morphia.Key;import com.google.code.morphia.dao.DAO;import com.google.code.morphia.query.Query;import com.google.code.morphia.query.QueryResults;/** *  * @Title: TODO * @Description: 实现TODO * @Copyright:Copyright (c) 2011 * @Company:易程科技股份有限公司 * @Date:2012-3-10 * @author  * @version 1.0 */public class MongoBaseServiceImpl<T, K> implements IMongoBaseService<T, K>{private DAO<T, K>  baseDao;public long count(){return baseDao.count();}public long count(Query<T> q){return baseDao.count(q);}public long count(String key, Object value){return baseDao.count(key, value);}public void delete(T entity){baseDao.delete(entity);}public void deleteById(K id){baseDao.deleteById(id);}public void deleteByQuery(Query<T> q){baseDao.deleteByQuery(q);}public boolean exists(Query<T> q){return baseDao.exists(q);}public boolean exists(String key, Object value){return baseDao.exists(key, value);}public QueryResults<T> find(){return baseDao.find();}public QueryResults<T> find(Query<T> q){return baseDao.find(q);}public T findOne(Query<T> q){return (T) baseDao.findOne(q);}public T findOne(String key, Object value){return (T) baseDao.findOne(key, value);}public Key<T> save(T entity){return baseDao.save(entity);}public DAO getBaseDao(){return baseDao;}public void setBaseDao(DAO baseDao){this.baseDao = baseDao;}public Datastore getDatastore(){return baseDao.getDatastore();}public T get(K id){return (T) baseDao.get(id);}public Query<T> createQuery(){return baseDao.createQuery();}}

??

?MOdel：

package com.easyway.morphia.mongodb.model;import org.bson.types.ObjectId;import com.google.code.morphia.annotations.*;/** *  * @Title: TODO * @Description: 实现TODO * @Copyright:Copyright (c) 2011 * @Company:易程科技股份有限公司 * @Date:2012-3-10 * @author  * @version 1.0 */@Entitypublic class Hotel{@Id private ObjectId oid;private String trackName;private String address;public ObjectId getOid() {return oid;}public void setOid(ObjectId oid) {this.oid = oid;}public String getTrackName() {return trackName;}public void setTrackName(String trackName) {this.trackName = trackName;}public String getAddress() {return address;}public void setAddress(String address) {this.address = address;}}

?

DAO层：

package com.easyway.morphia.mongodb.dao;import org.bson.types.ObjectId;import com.easyway.morphia.mongodb.model.Hotel;import com.google.code.morphia.dao.DAO;/** *  * @Title: TODO * @Description: 实现TODO * @Copyright:Copyright (c) 2011 * @Company:易程科技股份有限公司 * @Date:2012-3-10 * @author  * @version 1.0 */public interface IHotelDAO extends DAO<Hotel, ObjectId>{}

?

package com.easyway.morphia.mongodb.dao;import org.bson.types.ObjectId;import com.easyway.morphia.mongodb.model.Hotel;import com.google.code.morphia.Datastore;import com.google.code.morphia.dao.BasicDAO;/** *  * @Title: TODO * @Description: 实现TODO * @Copyright:Copyright (c) 2011 * @Company:易程科技股份有限公司 * @Date:2012-3-10 * @author  * @version 1.0 */public class HotelDAOImpl extends BasicDAO<Hotel, ObjectId> implements IHotelDAO{protected HotelDAOImpl(Datastore ds){super(ds);}}

?

?

sping和morphia的扩展类：

package com.easyway.morphia.mongodb.ext;import org.springframework.beans.factory.config.AbstractFactoryBean;import org.springframework.util.StringUtils;import com.google.code.morphia.Datastore;import com.google.code.morphia.Morphia;import com.mongodb.Mongo;/** *  * @Title: 通过扩展AbstractFactoryBean创建  DataStore的FactoryBean类 * @Description: 实现TODO * @Copyright:Copyright (c) 2011 * @Company:易程科技股份有限公司 * @Date:2012-3-3 * @author  * @version 1.0 */public class DataStoreFactoryBean extends AbstractFactoryBean<Datastore> {private Morphia morphia;private Mongo mongo;private String dbName;private String user;private String password;@Overridepublic Class<?> getObjectType() {return Datastore.class;}@Overrideprotected Datastore createInstance() throws Exception {if (StringUtils.hasText(user)) {return morphia.createDatastore(mongo, dbName, user, password.toCharArray());}return morphia.createDatastore(mongo, dbName);}@Overridepublic void afterPropertiesSet() throws Exception {super.afterPropertiesSet();if (mongo == null) {throw new IllegalStateException("mongo is not set");}if (morphia == null) {throw new IllegalStateException("morphia is not set");}}public void setMorphia(Morphia morphia) {this.morphia = morphia;}public void setMongo(Mongo mongo) {this.mongo = mongo;}public void setDbName(String dbName) {this.dbName = dbName;}public void setUser(String user) {this.user = user;}public void setPassword(String password) {this.password = password;}}

?

?

package com.easyway.morphia.mongodb.ext;import java.util.ArrayList;import java.util.List;import org.springframework.beans.factory.BeanCreationException;import org.springframework.beans.factory.config.AbstractFactoryBean;import com.mongodb.Mongo;import com.mongodb.MongoOptions;import com.mongodb.ServerAddress;/** *  * @Title: 通过扩展AbstractFactoryBean创建  Mongo的FactoryBean类 * @Description: 实现TODO * @Copyright:Copyright (c) 2011 * @Company:易程科技股份有限公司 * @Date:2012-3-10 * @author  * @version 1.0 */public class MongoFactoryBean extends AbstractFactoryBean<Mongo> {private List<ServerAddress> replicaSetSeeds = new ArrayList<ServerAddress>();private MongoOptions mongoOptions;@Overridepublic Class<?> getObjectType() {return Mongo.class;}@Overrideprotected Mongo createInstance() throws Exception {if (replicaSetSeeds.size() > 0) {if (mongoOptions != null) {return new Mongo(replicaSetSeeds, mongoOptions);}return new Mongo(replicaSetSeeds);}return new Mongo();}public void setMultiAddress(String[] serverAddresses) {replSeeds(serverAddresses);}private void replSeeds(String... serverAddresses) {try {replicaSetSeeds.clear();for (String addr : serverAddresses) {String[] a = addr.split(":");String host = a[0];if (a.length > 2) {throw new IllegalArgumentException("Invalid Server Address : " + addr);}else if(a.length == 2) {replicaSetSeeds.add(new ServerAddress(host, Integer.parseInt(a[1])));}else{replicaSetSeeds.add(new ServerAddress(host));}}} catch (Exception e) {throw new BeanCreationException("Error while creating replicaSetAddresses",e);}}public void setAddress(String serverAddress) {replSeeds(serverAddress);}}

?

?

?

package com.easyway.morphia.mongodb.ext;import org.springframework.beans.factory.config.AbstractFactoryBean;import com.google.code.morphia.Morphia;/** *  * @Title: 通过继承  AbstractFactoryBean<Morphia> 用来创建 Morphia的工厂bean *  * @Description: 实现TODO * @Copyright:Copyright (c) 2011 * @Company:易程科技股份有限公司 * @Date:2012-3-3 * @author  * @version 1.0 */public class MorphiaFactoryBean extends AbstractFactoryBean<Morphia> {private String[] mapPackages;private String[] mapClasses;private boolean ignoreInvalidClasses;@Overridepublic Class<?> getObjectType() {return Morphia.class;}@Overrideprotected Morphia createInstance() throws Exception {Morphia m = new Morphia();if (mapPackages != null) {for (String packageName : mapPackages) {m.mapPackage(packageName, ignoreInvalidClasses);}}if (mapClasses != null) {for (String entityClass : mapClasses) {m.map(Class.forName(entityClass));}}return m;}public void setMapPackages(String[] mapPackages) {this.mapPackages = mapPackages;}public void setMapClasses(String[] mapClasses) {this.mapClasses = mapClasses;}public void setIgnoreInvalidClasses(boolean ignoreInvalidClasses) {this.ignoreInvalidClasses = ignoreInvalidClasses;}}

?

?

?

spring的配置如下：

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"xmlns:tx="http://www.springframework.org/schema/tx" xmlns:jdbc="http://www.springframework.org/schema/jdbc"xmlns:context="http://www.springframework.org/schema/context"xsi:schemaLocation="             http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd             http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd             http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.0.xsd             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd             http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd"default-autowire="byName"><context:annotation-config /><!-- 导入属性配置文件 --><bean    >    <property name="morphia">      <ref bean="morphia"/>    </property>     <property name="mongo">      <ref bean="mongo"/>    </property>     <property name="dbName">    <value>           ${mongo.db.databaseName}       </value>    </property></bean><bean  id="hotelDAO" >     <constructor-arg index="0" >        <ref  bean="mongo"/>      </constructor-arg>         <constructor-arg index="1" >        <ref  bean="morphia"/>      </constructor-arg>      <constructor-arg index="2" >          <value>           ${mongo.db.databaseName}       </value>      </constructor-arg></bean></beans>

?

?

?

测试类如下：

package com.easyway.morphia.mongodb.app;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import com.easyway.morphia.mongodb.model.Hotel;import com.easyway.morphia.mongodb.services.IHotelService;/** *  * @Title: TODO * @Description: 实现TODO * @Copyright:Copyright (c) 2011 * @Company:易程科技股份有限公司 * @Date:2012-3-10 * @author  * @version 1.0 */public class HotelApp {public static void main(String[] args) {ApplicationContext  ctx=new ClassPathXmlApplicationContext("classpath:applicationContext-resource.xml");IHotelService  hotelSrv=(IHotelService)ctx.getBean("trackService");Hotel  hotel=new Hotel();hotel.setAddress("Model 168地址 ");hotel.setTrackName("跟踪地址");hotelSrv.save(hotel);}}

?