- 浏览: 420702 次
- 性别:
- 来自: 杭州
文章分类
- 全部博客 (269)
- 原创 (7)
- Java (51)
- Java Concurrency (2)
- IDE (16)
- Linux (46)
- Database (23)
- NoSQL (35)
- Web服务器 (23)
- Log日志 (11)
- HTTP (11)
- HTML (2)
- XML (1)
- Test (7)
- Mina (0)
- Amoeba (4)
- Cobar (1)
- 序列化 (2)
- Python (5)
- PHP (1)
- Socket通信 (1)
- Network (3)
- Struts (2)
- Web前端 (10)
- Maven (6)
- SVN (15)
- Json (1)
- XMPP (2)
- Go (1)
- Other (4)
- 未整理 (5)
最新评论
-
u012374672:
[color=darkred][/color][flash=2 ...
Mongo的ORM框架的学习Morphia(annotations) -
b_l_east:
很有问题啊
利用redis的transaction功能,实现分布式下加锁
转自: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); } }
发表评论
-
mongodb 地理位置处理
2016-05-16 13:39 1387我只记录我用到的部分,没有完整分析mongodb对地理位置 ... -
Redis配置文件redis.conf
2014-11-14 14:10 1839# Redis configuration file ex ... -
Redis高可用部署及监控
2014-11-12 13:25 1076一、 Re ... -
JCS官方文档的简单笔记,仅供自己参考
2014-09-26 20:08 7491. 基本配置 jcs.default=DCjcs.de ... -
JCS基本配置
2014-09-26 19:39 9171、默认的内存缓存 ... -
NoSQL解决方案比较(MongoDB vs Redis, Tokyo Cabinet, and Berkeley DB)
2013-09-30 14:20 1312NoSQL解决方案比较 NoSQL Solution: E ... -
morphia与spring的整合
2012-12-07 15:06 1459转自: http://www.blogjava.net/wat ... -
Mongo的ORM框架的学习Morphia(十五)Morphia+spring整合
2012-12-07 15:06 1627转自:http://topmanopensource.itey ... -
Mongo的ORM框架的学习Morphia(十二) morphia的Query和Update
2012-12-07 15:06 1838转自:http://topmanopensource.itey ... -
Mongo的ORM框架的学习Morphia(九) morphia简单使用
2012-12-05 14:44 1344转自 http://topmanopensource.itey ... -
Mongo的ORM框架的学习Morphia(八) morphia数据库访问接口
2012-12-05 14:35 1991转自:http://topmanopensource.itey ... -
Mongo的ORM框架的学习Morphia(annotations)
2012-12-05 14:33 2503一:@Entity的使用 @Entity ... -
Instagram的Redis实践(内存占用优化)
2012-11-30 10:43 1171转自:http://blog.nosqlfan.com/htm ... -
SQL 和Mongo 对比图表
2012-11-28 14:54 2180参看官方说明: http://www.mongodb ... -
MongoDB 入门指南、示例
2012-11-23 10:38 828转自:http://www.cnblogs.com/hoojo ... -
mongodb中使用MapReduce
2012-11-23 10:12 1189MapReduce函数的用法如下: db.users.ma ... -
python的redis用法
2012-11-22 15:48 1140#! /usr/bin/env python #coding ... -
Python连接redis
2012-11-22 15:46 5581一、Redis是流行的NOSQL内存数据库,以Key-Valu ... -
【pipeline】【分布式的id生成器】【分布式锁【watch】【multi】】【redis分布式】
2012-08-29 10:42 1345转自 http://www.bwkeji.com/a/wang ... -
利用redis的transaction功能,实现分布式下加锁
2012-08-29 09:57 2346package memcached; import ja ...
相关推荐
Mongo的ORM框架的学习Morphia
mongo-2.7.3.jar和morphia-0.99.jar
spring MVC morphia mongo 整合的例子 网上下载的例子 自己调试保证绝对能运行
java mongodb orm 实现-基于mongodb-driver开发的ORM
这个压缩文件包含mongo-2.7.3.jar和morphia-0.99.jar是morphia框架必须的jar
spring-mongodb-morphia springdata-mongo morphia mongodb 学习
MongoModel - Ruby ODM用于与MongoDB数据库交互
Play 被选为开发此应用程序的主要框架,因为它具有惊人的生态系统、插件和其他好处,例如 Akka、CoffeeScript 支持 Web Sockets 等等。 这个应用程序的起点是它是一个可配置的框架,使工作变得简单和可定制。 Next...
总结了mongo数据库的映射框架morphia的基本用法。包括查询,更新等,是一份不错的mongodb操作入门文档。
讲解mongo中使用框架实现模糊查找,Mongo的高级查询功能
morphia mongo db OR-mapping mongo db再带的CRUD 太麻烦了, 一个不错的框架 类似 Hibernate
bugu-mongo1.12 mongo开源框架
lucid-mongo, 面向adonis框架的Mongodb ODM 清晰 Mongolucid是mongo查询生成器和 ORM 。 它还支持数据库迁移,种子和工厂作为 @adonis/lucid.
在线文档WORD版详细文档(完整)请见:docs /睿智平台SqlToy4.17使用手册.doc范例演示项目快速上手主要功能项目阅读其readme.md学习POJO和DTO严格分层演示项目分片分库分表演示nosql演示(mongo和elasticsearch) ...
详细介绍 Web项目Mongo数据库连接 内加驱动包 超值下载
Mongo是一个高性能,开源,无模式的文档型数据库,它在许多场景下可用于替代传统的关系型数据库或键/值存储方式。Mongo使用C++开发,提供了以下功能:
使用TF和ycsb构建mongo测试框架 准备 配置AWS凭证 安装terraform(0.14.9+) Visual Studio代码(首选) 设置 签出源代码后,在根目录中运行terraform init命令。 计划 初始化成功后,运行计划与terraform plan 。...
CI框架的mongo_db数据库扩展链接文件,有了它,CI框架链接mongo_db不在烦恼!
芒果板 mongo-orm项目的管理面板。
MongoModel MongoModel是用于与MongoDB数据库接口的Ruby ORM。 安装MongoModel作为gem分发。 使用以下命令安装:gem install mongomodel为了提高性能,您可能还应该安装MongoModel MongoModel是用于与MongoDB数据库...