java 操作mongodb

   Person.java

/**
 * Person.java
 * 版权所有(C) 2012 
 * 创建:cuiran 2012-12-12 11:37:16
 */
package com.spring.mongo.domain;

import java.io.Serializable;

public class Person implements Serializable {

	private static final long serialVersionUID = 3617931430808763429L;

	private String id;
	private String name;
	private int age;

	public Person() {
		super();
	}

	public Person(String id, String name, int age) {
		super();
		this.id = id;
		this.name = name;
		this.age = age;
	}

	/**
	 * @return the id
	 */
	public String getId() {
		return id;
	}

	/**
	 * @param id
	 *            the id to set
	 */
	public void setId(String id) {
		this.id = id;
	}

	/**
	 * @return the name
	 */
	public String getName() {
		return name;
	}

	/**
	 * @param name
	 *            the name to set
	 */
	public void setName(String name) {
		this.name = name;
	}

	/**
	 * @return the age
	 */
	public int getAge() {
		return age;
	}

	/**
	 * @param age
	 *            the age to set
	 */
	public void setAge(int age) {
		this.age = age;
	}

	/**
	 * 
	 * @param name
	 * @param age
	 */
	public Person(String name, int age) {
		super();
		this.name = name;
		this.age = age;
	}

	public String toString() {
		return "Person[id=" + id + ",name=" + name + ",age=" + age + "]";
	}

}

 interface RepositoryManager.java 

package com.spring.mongo.services;

import java.util.List;

import com.spring.mongo.domain.Person;

public interface RepositoryManager {

	public void insert(Person person);

	public Person findOne(String id);

	public List<Person> findAll();

	public List<Person> findByRegex(String regex);

	public void removeOne(String id);

	public void removeAll();

	public void findAndModify(String id);

}

 PersonRepositoryImpl.java 

package com.spring.mongo.services.impl;

import java.util.List;
import java.util.regex.Pattern;

import org.springframework.data.document.mongodb.MongoTemplate;
import org.springframework.data.document.mongodb.query.Criteria;
import org.springframework.data.document.mongodb.query.Query;
import org.springframework.data.document.mongodb.query.Update;

import com.spring.mongo.domain.Person;
import com.spring.mongo.services.RepositoryManager;

public class PersonRepositoryImpl implements RepositoryManager {

	  private MongoTemplate mongoTemplate;   

	@Override
	public List<Person> findAll() {
		// TODO Auto-generated method stub
		return getMongoTemplate().find(new Query(), Person.class);   

	}

	@Override
	public void findAndModify(String id) {
		// TODO Auto-generated method stub
		//new Query(Criteria.where("id").is(id)), new Update().inc("age", 3)
		
//		getMongoTemplate().updateFirst(new Query(Criteria.where("id").is(id)), new Update().update("age", 3));
		Query query = new Query();
		query.addCriteria(Criteria.where("id").is(id));
		Person p = getMongoTemplate().findOne(query, Person.class);
		p.setAge(4);
		getMongoTemplate().save(p);
	}

	@Override
	public List<Person> findByRegex(String regex) {
		// TODO Auto-generated method stub
		 Pattern pattern = Pattern.compile(regex,Pattern.CASE_INSENSITIVE);   
	      Criteria criteria = new Criteria("name").regex(pattern.toString());   
	        return getMongoTemplate().find(new Query(criteria), Person.class);   

	}
	@Override
	public Person findOne(String id) {
		// TODO Auto-generated method stub
		 return getMongoTemplate().findOne(new Query(Criteria.where("id").is(id)), Person.class);   

	}

	@Override
	public void insert(Person person) {
		// TODO Auto-generated method stub
		getMongoTemplate().insert(person);   
	}

	@Override
	public void removeAll() {
		// TODO Auto-generated method stub
		List<Person> list = this.findAll();   
        if(list != null){   
            for(Person person : list){   
                getMongoTemplate().remove(person);   
            }   
        }   

	}

	@Override
	public void removeOne(String id) {
		// TODO Auto-generated method stub
		Criteria criteria = Criteria.where("id").in(id);   
        if(criteria != null){   
             Query query = new Query(criteria);   
             if(query != null && getMongoTemplate().findOne(query, Person.class) != null)   
                 getMongoTemplate().remove(getMongoTemplate().findOne(query, Person.class));   
        }   

	}

	public MongoTemplate getMongoTemplate() {
		return mongoTemplate;
	}

	public void setMongoTemplate(MongoTemplate mongoTemplate) {
		this.mongoTemplate = mongoTemplate;
	}

}

 SpringMongoTest.java 

/**
 * MongoTest.java
 * 版权所有(C) 2012 
 * 创建:cuiran 2012-12-12 11:54:30
 */
package com.spring.mongo.main;

import java.util.List;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.spring.mongo.domain.Person;
import com.spring.mongo.services.RepositoryManager;
import com.spring.mongo.services.impl.PersonRepositoryImpl;

public class SpringMongoTest {

	private static Log log = LogFactory.getLog(SpringMongoTest.class.getName());

	private RepositoryManager pr = null;

	public void init() {
		log.debug("开始启动");
		ApplicationContext ctx = new ClassPathXmlApplicationContext(
				"applicationContext.xml");
		pr = (PersonRepositoryImpl) ctx.getBean("personRepository");

	}

	public void insert() {
		for (int i = 1001; i < 10000; i++) {
			Person p = new Person("cuiran" + i, i);
			pr.insert(p);
		}
		log.debug("添加成功");
	}

	public void findOne() {
		String id = "517630b710239ca2d4d828a3";
		Person p = pr.findOne(id);
		log.debug(p);
	}

	public void listAll() {

		List<Person> list = pr.findAll();
		log.debug("查询结果如下:");
		for (Person p : list) {
			log.debug(p.toString());
		}

	}

	public void delete() {
		pr.removeOne("517630b710239ca2d4d828e8");
	}

	public void update() {
		pr.findAndModify("517630b710239ca2d4d828a3");
	}

	public void start() {
		init();
		delete();
		insert();
		listAll();
		update();
		findOne();
	}

	public static void main(String[] args) {
		SpringMongoTest t = new SpringMongoTest();
		t.start();
	}

}

 applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
	xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"
	xmlns:mongo="http://www.springframework.org/schema/data/mongo"
	xsi:schemaLocation="
       http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
       http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd
       http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
       http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd
       http://www.springframework.org/schema/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd">
    
    <context:annotation-config />
       
	<bean id="mongoTemplate" class="org.springframework.data.document.mongodb.MongoTemplate">   
	    <constructor-arg ref="mongo"/>   
	    <constructor-arg name="databaseName" value="db"/>   
	    <constructor-arg name="defaultCollectionName" value="person" />   
	</bean>      
   	
   	<bean id="personRepository" class="com.mongo.dao.impl.PersonRepository">   
        <property name="mongoTemplate" ref="mongoTemplate"></property>   
    </bean>   
    
    <mongo:mongo host="127.0.0.1" port="27017"/>

</beans>

 log4j.properties

log4j.rootLogger=INFO,CONSOLE
log4j.category.com.mongo=DEBUG,messageWeb

log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%d{yyyy-MM-dd HH\:mm\:ss}\:%p %c - %m%n


log4j.appender.messageWeb=org.apache.log4j.DailyRollingFileAppender
log4j.appender.messageWeb.File=D:/logs/mongo.log
log4j.appender.messageWeb.DatePattern = '.'yyyy-MM-dd.'log'
log4j.appender.messageWeb.layout=org.apache.log4j.PatternLayout
log4j.appender.messageWeb.layout.ConversionPattern=%-d{yyyy-MM-dd HH\:mm\:ss} [%c]-[%p] %m%n
log4j.appender.messageWeb.encoding= UTF-8

 

评论

3 楼 zyh_1986 2013-05-14  

文章不错，关键是没有只言片语的讲解，这种博客对于想入门或刚入门的人来说意义不大

2 楼 chenhua_1984 2013-05-08  

DanielHan 写道

什么是mongodb?

NO SQL的一种，现在比较流行的，做大数据用，通常和hadoop结合

1 楼 DanielHan 2013-05-07  

什么是mongodb?