MongoDB的ORM框架——Morphia
阿新 • • 發佈:2019-04-02
ring updater lte 命名 一個 xtend code ret setvalue
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; @Indexedprivate 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