Mongo的ORM框架的学习Morphia(十) morphia应用

转自：http://topmanopensource.iteye.com/blog/1439688

 

package com.easyway.mongodb.model;

import com.google.code.morphia.annotations.Embedded;
import com.google.code.morphia.annotations.Property;
/**
 * 
 * @Title: mongo的框架morphia的学习
 * @Description: 
 * @Copyright:Copyright (c) 2011
 * @Company:易程科技股份有限公司
 * @Date:2012-2-29
 * @author longgangbai
 * @version 1.0
 */
@Embedded
public class Address {

    @Property("address_street")
    private String street;

    @Property
    private String postCode;

    public Address() {
        super();
    }

    public String getStreet() {
        return street;
    }

    public void setStreet(String street) {
        this.street = street;
    }

    public String getPostCode() {
        return postCode;
    }

    public void setPostCode(String postCode) {
        this.postCode = postCode;
    }
}

 

package com.easyway.mongodb.model;

import java.util.Date;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.Vector;

import com.google.code.morphia.annotations.Embedded;
import com.google.code.morphia.annotations.Entity;
import com.google.code.morphia.annotations.Transient;
/**
 * 
 * @Title: mongo的框架morphia的学习
 * @Description: 
 * @Copyright:Copyright (c) 2011
 * @Company:易程科技股份有限公司
 * @Date:2012-2-29
 * @author longgangbai
 * @version 1.0
 */
@Entity("hotels")
public class Hotel extends BasicEntry {
	private static final long serialVersionUID = 1L;

	
    public enum Type { BUSINESS, LEISURE }
    private String name;
    private Date startDate;
    private Date endDate;


	private int stars;
    private boolean takesCreditCards;
    private Type type;
    private Set<String> tags;

    public static Hotel createHotel(){
    	return new Hotel();
    }
    @Transient
    private String temp;

    @Embedded
    private Address address;

    @Embedded(concreteClass = Vector.class)
    private List<PhoneNumber> phoneNumbers;

    private Hotel() {
        super();
        tags = new HashSet<String>();
        phoneNumbers = new Vector<PhoneNumber>();
    }
    public Date getEndDate() {
		return endDate;
	}


	public void setEndDate(Date endDate) {
		this.endDate = endDate;
	}
    
    public Address getAddress() {
        return address;
    }

    public void setAddress(Address address) {
        this.address = address;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getStars() {
        return stars;
    }

    public void setStars(int stars) {
        this.stars = stars;
    }

    public Date getStartDate() {
        return startDate;
    }

    public void setStartDate(Date startDate) {
        this.startDate = startDate;
    }

    public boolean isTakesCreditCards() {
        return takesCreditCards;
    }

    public void setTakesCreditCards(boolean takesCreditCards) {
        this.takesCreditCards = takesCreditCards;
    }

    public Type getType() {
        return type;
    }

    public void setType(Type type) {
        this.type = type;
    }

    public Set<String> getTags() {
        return tags;
    }

    public void setTags(Set<String> tags) {
        this.tags = tags;
    }

    public List<PhoneNumber> getPhoneNumbers() {
        return phoneNumbers;
    }

    public void setPhoneNumbers(List<PhoneNumber> phoneNumbers) {
        this.phoneNumbers = phoneNumbers;
    }

    public String getTemp() {
        return temp;
    }

    public void setTemp(String temp) {
        this.temp = temp;
    }
}

 

package com.easyway.mongodb.model;

import com.google.code.morphia.annotations.Embedded;
import com.google.code.morphia.annotations.Property;

/**
 * 
 * @Title: mongo的框架morphia的学习
 * @Description: 
 * @Copyright:Copyright (c) 2011
 * @Company:易程科技股份有限公司
 * @Date:2012-2-29
 * @author longgangbai
 * @version 1.0
 */
@Embedded
public class PhoneNumber {

    public enum Type { PHONE, FAX }

    @Property
    private int countryCode;
    @Property
    private int localExtension;
    @Property
    private Type type;

    public PhoneNumber() {
        this.type = Type.PHONE;
    }

    public PhoneNumber( int countryCode, int localExtension, Type type ) {
        this.countryCode = countryCode;
        this.localExtension = localExtension;
        this.type = type;
    }

    public int getCountryCode() {
        return countryCode;
    }

    public void setCountryCode(int countryCode) {
        this.countryCode = countryCode;
    }

    public int getLocalExtension() {
        return localExtension;
    }

    public void setLocalExtension(int localExtension) {
        this.localExtension = localExtension;
    }

    public Type getType() {
        return type;
    }

    public void setType(Type type) {
        this.type = type;
    }

    @Override
    public boolean equals(Object obj) {
        if (obj == null) {
            return false;
        }
        if (getClass() != obj.getClass()) {
            return false;
        }
        final PhoneNumber other = (PhoneNumber) obj;
        if (this.countryCode != other.countryCode) {
            return false;
        }
        if (this.localExtension != other.localExtension) {
            return false;
        }
        if (this.type != other.type) {
            return false;
        }
        return true;
    }

    @Override
    public int hashCode() {
        int hash = 5;
        hash = 43 * hash + this.countryCode;
        hash = 43 * hash + this.localExtension;
        hash = 43 * hash + this.type.hashCode();
        return hash;
    }

}

 

package com.easyway.mongodb.model;

import java.io.Serializable;

import org.bson.types.ObjectId;

import com.google.code.morphia.annotations.Id;
/**
 * 
 * @Title: mongo的框架morphia的学习
 * @Description: 
 * @Copyright:Copyright (c) 2011
 * @Company:易程科技股份有限公司
 * @Date:2012-2-29
 * @author longgangbai
 * @version 1.0
 */
public abstract class BasicEntry implements Serializable {
	private static final long serialVersionUID = 1L;

	/** The id for this instance */
	@Id 
	protected String id = new ObjectId().toString();

    public BasicEntry() {
    }

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }
}

 

数据访问层：

package com.easyway.mongodb.dao;

import java.io.IOException;
import java.net.UnknownHostException;
import java.util.Properties;

import com.google.code.morphia.AdvancedDatastore;
import com.google.code.morphia.Datastore;
import com.google.code.morphia.Morphia;
import com.google.code.morphia.dao.BasicDAO;
import com.mongodb.DB;
import com.mongodb.Mongo;
import com.mongodb.MongoOptions;
import com.mongodb.ServerAddress;
/**
 * 针对morphia的封装的DAO层 
 * @Title: 
 * @Description: 实现TODO
 * @Copyright:Copyright (c) 2011
 * @Company:易程科技股份有限公司
 * @Date:2012-3-2
 * @author 
 * @version 1.0
 */
public class BaseDAO<BasicEntry, String> extends BasicDAO<BasicEntry, String> {
  

	protected static Datastore ds=null;
    protected static AdvancedDatastore ads;
    private static final Properties properties=new Properties();
    /**
     * 静态语句用于加载mongo 相关的配置文件
     */
    static {
    	try {
    		properties.load(BaseDAO.class.getResourceAsStream("/Mongo-db.properties"));
    		initDAO();
		} catch (IOException e) {
			e.printStackTrace();
		}
    }
    public BaseDAO() {
		super(ds);
	}
   /**
   * 用于初始化Mongodb 数据库的数据访问层的方法
   * @throws UnknownHostException 
   * @throws NumberFormatException 
   * 
   */
	protected static void initDAO() throws NumberFormatException, UnknownHostException {
		ServerAddress sa=new ServerAddress(properties.getProperty("mongo.db.host"),Integer.parseInt(properties.getProperty("mongo.db.port")));
		MongoOptions options=new MongoOptions();
		options.connectionsPerHost=Integer.parseInt(properties.getProperty("mongo.db.connectionsPerHost"));//pool size(驱动的链接池大小).  /* mongod --dbpath ..\db --maxConns 20(并发数) */  默认都为10
		Mongo mongo=new Mongo(sa, options);
		DB db=mongo.getDB(properties.getProperty("mongo.db.databaseName"));
		Morphia morphia = new Morphia();
		ds =   morphia.createDatastore(mongo, db.getName());
	    ads = (AdvancedDatastore) ds;
	}
}

 

package com.easyway.mongodb.dao;

import java.util.Date;
import java.util.List;

import com.easyway.mongodb.model.Hotel;
import com.easyway.mongodb.model.Hotel.Type;
import com.google.code.morphia.query.Query;
import com.google.code.morphia.query.UpdateOperations;

/**
 * 
 * @Title: mongo的框架morphia的学习
 * @Description: 
 * @Copyright:Copyright (c) 2011
 * @Company:易程科技股份有限公司
 * @Date:2012-2-29
 * @author longgangbai
 * @version 1.0
 */
public class HotelDAO extends BaseDAO<Hotel, String> {

    public HotelDAO() {
    }
    /**
     * 
     */
    public void batchUpdate(int stars){
    	 Query<Hotel> query=createQuery().filter("stars", stars);
    	 UpdateOperations<Hotel> mods = createUpdateOperations().inc("stars", 1);
         update(query, mods);
    }
    /**
     * 条件查询
     * @param hotel
     */
    public List<Hotel> findHotelByCondition(int stars){
    	Query<Hotel> query=createQuery().filter("stars", stars).order("stars");
    	return find(query).asList();
    }
    /**
     * 保存的方法
     * @param hotel
     */
    public void updateHotel(Hotel hotel){
    }
    /**
     * 统计小于 stars<5 的hotel
     * @return
     */
    public Long countHotel(){
    	 Query<Hotel> query=this.createQuery().field("stars").lessThan(5);
    	 return this.count(query);
    }
    /**
     * 删除Hotel
     * @param hotelId
     */
    public void deleteHotelById(String hotelId){
    	this.deleteById(hotelId);
    }
    /**
     * 根据id查询Hotel
     * @param hotelId
     * @return
     */
    public Hotel getHotelById(String hotelId){
    	return this.get(hotelId);
    }
    
    /**
     * 批量删除hotel对象
     */
    public void deleteByQuery() {
    	Query<Hotel> query=createQuery();
    	query.filter("stars in", new Integer[]{3,4});
		this.deleteByQuery(query);
	}
    
    
    
    /**
     * 保存的方法
     * @param hotel
     */
    public void saveHotel(Hotel hotel){
    	super.save(hotel);
    }
    /**
     * 分页的方法
     * @param offset
     * @param limit
     * @param order
     * @return
     */
    public List<Hotel> pageQuery(int offset,int limit,String order){
    	return this.createQuery().limit(limit).offset(offset).order(order).asList();
    }
    
    /**
     * 查询是否存在特定类型的酒店
     * @param type
     * @return
     */
    public boolean queryBusinessHotelType(Type type){
    	return this.exists("type", type);
    }
    
    /**
     * 根据特定字段查询相关的Hotel
     * @param fieldName
     * @param fieldValue
     * @return
     */
    public Hotel findHotel(String fieldName,Object fieldValue){
    	return this.findOne(fieldName, fieldValue);
    }
	
    /**
	 * <p>Create a filter based on the specified condition and value.
	 * </p><p>
	 * <b>Note</b>: Property is in the form of "name op" ("age >").
	 * </p><p>
	 * Valid operators are ["=", "==","!=", "<>", ">", "<", ">=", "<=", "in", "nin", "all", "size", "exists"]
	 * </p>
	 * <p>Examples:</p>
	 * 
	 * <ul>
	 * <li>{@code filter("yearsOfOperation >", 5)}</li>
	 * <li>{@code filter("rooms.maxBeds >=", 2)}</li>
	 * <li>{@code filter("rooms.bathrooms exists", 1)}</li>
	 * <li>{@code filter("stars in", new Long[]{3,4}) //3 and 4 stars (midrange?)}</li>
	 * <li>{@code filter("age >=", age)}</li>
	 * <li>{@code filter("age =", age)}</li>
	 * <li>{@code filter("age", age)} (if no operator, = is assumed)</li>
	 * <li>{@code filter("age !=", age)}</li>
	 * <li>{@code filter("age in", ageList)}</li>
	 * <li>{@code filter("customers.loyaltyYears in", yearsList)}</li>
	 * </ul>
	 * 
	 * <p>You can filter on id properties <strong>if</strong> this query is
	 * restricted to a Class<T>.
	 * 时间重叠规律：
	 *     酒店入住时间的开始时间小于等于查询条件的结束时间，并且酒店入住时间的结束时间大于等于查询条件的开始时间
	 */
    public boolean queryHotelHasPerson(Date startDate,Date endDate,String name){
    	return this.createQuery()
    	       .filter("name=", name)
    	       .filter("startDate >=",endDate)
    	       .filter("endDate <=", startDate)
    	       .countAll()>0;
    }
    
}

 

测试类：

package com.easyway.mongodb.app;

import java.util.Date;

import com.easyway.mongodb.dao.HotelDAO;
import com.easyway.mongodb.model.Address;
import com.easyway.mongodb.model.Hotel;
/**
 * 
 * @Title: TODO
 * @Description: 实现TODO
 * @Copyright:Copyright (c) 2011
 * @Company:易程科技股份有限公司
 * @Date:2012-3-2
 * @author 
 * @version 1.0
 */
public class HotelApp {
	public static void main(String[] args) {
		HotelDAO  hotelDAO=new HotelDAO();

        Hotel borg =Hotel.createHotel();
        borg.setName("Hotel Borg");
        borg.setStars(4);
        borg.setTakesCreditCards(true);
        borg.setStartDate(new Date());
        borg.setType(Hotel.Type.LEISURE);
        Address borgAddr = new Address();
        borgAddr.setStreet("Posthusstraeti 11");
        borgAddr.setPostCode("101");
        borg.setAddress(borgAddr);
        hotelDAO.save(borg);
		
        long count=hotelDAO.countHotel();
        System.out.println("count="+count);
        
	}

}