1.引入pom

    <dependency>
      <groupId>org.mongodb.morphia</groupId>
      <artifactId>morphia</artifactId>
      <version>1.3.2</version>
    </dependency>

2.創建Entity類

@Entity()
public class Commodity {

    @Id
    private ObjectId id;

    @Indexed
    
 
private String cmdtyCode;

    private String cmdtyName;

    @Embedded
    private List<Attribute> attributes;

    @Reference
    private CommodityInfo commodityInfo;

    public ObjectId getId() {
        return id;
    }

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

    
 
public String getCmdtyCode() {
        return cmdtyCode;
    }

    public void setCmdtyCode(String cmdtyCode) {
        this.cmdtyCode = cmdtyCode;
    }

    public String getCmdtyName() {
        return cmdtyName;
    }

    public void setCmdtyName(String cmdtyName) {
        this.cmdtyName = cmdtyName;
    }

    
 
public List<Attribute> getAttributes() {
        return attributes;
    }

    public void setAttributes(List<Attribute> attributes) {
        this.attributes = attributes;
    }

    public CommodityInfo getCommodityInfo() {
        return commodityInfo;
    }

    public void setCommodityInfo(CommodityInfo commodityInfo) {
        this.commodityInfo = commodityInfo;
    }
}

@Entity()
public class CommodityInfo {

    @Id
    private ObjectId id;

    private String color;

    private String style;

    public String getColor() {
        return color;
    }

    public void setColor(String color) {
        this.color = color;
    }

    public String getStyle() {
        return style;
    }

    public void setStyle(String style) {
        this.style = style;
    }

    public ObjectId getId() {
        return id;
    }

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

public class Attribute {

    private String key;

    private String value;

    public String getKey() {
        return key;
    }

    public void setKey(String key) {
        this.key = key;
    }

    public String getValue() {
        return value;
    }

    public void setValue(String value) {
        this.value = value;
    }
}

　　註意： @Entity：聲明該類作為文檔將持久保存。在默認情況下，Morphia使用類名稱來命名集合

　　　　　@Embedded：成員對象將被視為嵌入的（embedded）。它會顯示為集合中父文檔的子集

　　　　　@Reference：說明對象是對另外一個集合中的文檔的引用

　　　　　@Indexed：表明為此屬性增加索引

3.通過Datastore使用

　　a.創建Datastore對象

        Morphia morphia = new Morphia();
        morphia.mapPackage("com.wode.entity"); // entity所在包路徑
        MongoClient mongoClient = new MongoClient(new MongoClientURI("mongodb://localhost:27017"));
        Datastore datastore = morphia.createDatastore(mongoClient, "morphia");

　　b.添加

        //先添加@Reference引用的對象
        CommodityInfo cmdtyInfo = new CommodityInfo();
        cmdtyInfo.setColor("silver");
        cmdtyInfo.setStyle("12");
        datastore.save(cmdtyInfo);

        //再添加商品
        Commodity cmdty = new Commodity();
        cmdty.setCommodityInfo(cmdtyInfo);
        cmdty.setCmdtyCode("Ag");
        cmdty.setCmdtyName("銀");

        List<Attribute> attributes = new ArrayList<>();
        Attribute attribute = new Attribute();
        attribute.setKey("品質");
        attribute.setValue("優");
        attributes.add(attribute);
        cmdty.setAttributes(attributes);

        datastore.save(cmdty);

　　c.修改

        Query<Commodity> query = datastore.createQuery(Commodity.class).filter("cmdtyCode = ", "Ag");
        UpdateOperations<Commodity> updateOperations = datastore.createUpdateOperations(Commodity.class).set("cmdtyName", "銀00").set("cmdtyCode", "Ag00");
        UpdateResults result = datastore.update(query, updateOperations);
        System.out.println(result.getUpdatedCount());

　　d.刪除

        Query<Commodity> query = datastore.createQuery(Commodity.class).filter("cmdtyCode = ", "Ag00");
        datastore.delete(query);

　　e.查詢

        List<String> list = new ArrayList<>();
        list.add("Ag11");
        list.add("Ag12");
        List<Commodity> resultList = datastore.createQuery(Commodity.class).filter("cmdtyCode in ", list).order("-cmdtyCode").asList();
        for(Commodity cmdty : resultList){
            System.out.println("cmdtyCode[" + cmdty.getCmdtyCode() + "], cmdtyName[" + cmdty.getCmdtyName() + "]");
        }

　　註意：分頁查詢可用：.offset( (pageIndex - 1) * pageSize ).limit( pageSize )

4.通過BasicDAO使用

　　a.創建BasicDAO的實現類

public class CmdtyDAO extends BasicDAO<Commodity, ObjectId> {

    public CmdtyDAO(MongoClient mongoClient, Morphia morphia, String dbName){
        super(mongoClient, morphia, dbName);
    }

}

　　b.初始化DAO

        Morphia morphia = new Morphia();
        morphia.mapPackage("com.wode.entity"); // entity所在包路徑
        MongoClient mongoClient = new MongoClient(new MongoClientURI("mongodb://localhost:27017"));
        CmdtyDAO dao = new CmdtyDAO(mongoClient, morphia, "morphia");

　　c.使用基本同Datastore

MongoDB的ORM框架——Morphia