MongoDB

package com.xbwen.po;

import com.bugull.mongo.BuguEntity;
import com.bugull.mongo.annotations.Entity;
import com.bugull.mongo.annotations.Id;

@Entity
public class Foo implements BuguEntity{
    @Id
    private String id;
    private String name;

    @Override
    public String getId() {
        return id;
    }

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

	public String getName() {
		return name;
	}

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

 

package com.xbwen.dao.impl;

import com.bugull.mongo.BuguDao;
import com.xbwen.po.Foo;

public class FooDaoImpl extends BuguDao<Foo> {
    public FooDaoImpl(){
        super(Foo.class);
    }
    
}

 

package com.xbwen.dao;

import com.xbwen.po.Foo;

public interface FooDao extends BuguBase<Foo> {
   
}

 

package com.xbwen.context;
import com.bugull.mongo.BuguConnection;  
import javax.servlet.ServletContextEvent;  
import javax.servlet.ServletContextListener;  
  
public class MySystemListener implements ServletContextListener{  
    @Override  
    public void contextInitialized(ServletContextEvent event) {  
        //连接数据库  
        BuguConnection conn = BuguConnection.getInstance();  
        conn.connect("127.0.0.1", 27017, "test");
    }  
   
    @Override  
    public void contextDestroyed(ServletContextEvent event) {
        //关闭数据库连接
        BuguConnection.getInstance().close();  
    } 
}  

 

package com.xbwen.dao;


import java.util.List;

import com.bugull.mongo.BuguQuery;
import com.bugull.mongo.BuguUpdater;
import com.mongodb.DBCollection;
import com.mongodb.WriteResult;

public interface BuguBase<T> {

	/***插入数据***/
	/**添加一个对象*/
	public WriteResult insert(T t);
	/**添加多个对象*/
	public WriteResult insert(List<T> list); //批量插入
	/**添加或更新一个对象*/
	public WriteResult save(T t);//如果t中没有ID值，则为插入，若有ID值，则为修改。用户自定义ID除外。
	
	/***删除数据***/
	/**删除整个Collection*/
	public void drop();
	/**根据对象删除*/
	public WriteResult remove(T t);
	/**根据id删除*/
	public WriteResult remove(String id);
	/**批量删除*/
	public WriteResult remove(List<String> idList);
	/**按条件删除*/
	public WriteResult remove(String key, Object value);
	/**按条件删除*/
	public WriteResult remove(@SuppressWarnings("rawtypes") BuguQuery query);
	
	/***基本查询***/
	/** 根据id查询一个对象 */
	public T findOne(String id);
	/** 根据key-value查询一个对象 */
	public T findOne(String key, Object value);
	/** 查询全部 */
	public List<T> findAll();
	/** 查询全部，并排序，排序格式为orderBy-->{name:-1},其中1是升序，－1是降序*/
	public List<T> findAll(String orderBy);
	/** 分页查询全部，pageNum为页码，起始页为1，pageSize页容量大小 */
	public List<T> findAll(int pageNum, int pageSize);
	/** 分页查询全部并排序，orderBy格式{name:-1},其中1是升序，－1是降序,pageNum起始页，pageSize页容量大小  */
	public List<T> findAll(String orderBy, int pageNum, int pageSize);
	/** 根据id查询是否存在 */
	public boolean exists(String id);
	/** 根据key-value查询是否存在 */
	public boolean exists(String key, Object value);
	/** 查询总数目 */
	public long count();
	/** 根据key-value查询总数目 */
	public long count(String key, Object value);
	/** 查询某一字段的不重复值 */
	@SuppressWarnings("rawtypes")
	public List distinct(String key);
	/**
	 * 高级查询
	 * <br>-------------------------------------------
	 * <br>生成查询条件：is、notEquals、greaterThan、greaterThanEquals、
	 * lessThan、lessThanEquals、in、notIn、all、size、mod、existsField、
	 * notExistsField、regex、where、or、and
	 * <br>地理空间数据查询：near、withinCenter、withinBox
	 * <br>设置查询参数：slice、returnFields、notReturnFields、sort、
	 * pageNumber、pageSize
	 * <br>返回查询结果：result、results、count、exists、distinct
	 * <br>-------------------------------------------
	 * <br>注：支持连缀书写形式、支持分页、支持指定返回或不返回某些字段、支持
	 * Entity对象作为查询条件、支持字符串形式的排序：
	 * @return
	 */
	public BuguQuery<T> query();
	/**
	 * 修改数据
	 * <br>-------------------------------------------
	 * <br>修改属性值：set
	 * <br>删除属性列：unset
	 * <br>增加、减少数值：inc
	 * <br>乘以某个数值：mul
	 * <br>数组操作：push、pushEach、pull、popFirst、popLast
	 * <br>设置成较小值：min
	 * <br>设置成较大值：max
	 * <br>按位操作：bitwise
	 */
	public BuguUpdater<T> update();
	/** 获取数据集合，提供自定义服务 */
	public DBCollection getCollection();
}

 

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" id="WebApp_ID" version="3.0">
  <display-name>Forum</display-name>
  <listener>  
    <listener-class>com.xbwen.context.MySystemListener</listener-class>  
</listener> 
  <welcome-file-list>
    <welcome-file>index.html</welcome-file>
    <welcome-file>index.htm</welcome-file>
    <welcome-file>index.jsp</welcome-file>
    <welcome-file>default.html</welcome-file>
    <welcome-file>default.htm</welcome-file>
    <welcome-file>default.jsp</welcome-file>
  </welcome-file-list>
</web-app>

 

评论

1 楼 石头茨 2015-01-23  

在maven （http://search.maven.org）项目中，找不到bugu-mongo-1.14.zip包。能将此项目上传打maven吗？