使用springdata操作mongodb
近期装了个mongodb，试试。发现很多网上找来的列子不对自己。首先工程以来的jar包
<dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-mongodb</artifactId> <version>1.0.3.RELEASE</version> </dependency>简单的配置文件
<?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:context="http://www.springframework.org/schema/context" xmlns:mongo="http://www.springframework.org/schema/data/mongo" xsi:schemaLocation= "http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"> <mongo:mongo host="10.211.55.10" port="27017"/> <bean id="mongoOps" class="org.springframework.data.mongodb.core.MongoTemplate"> <constructor-arg ref="mongo"/> <constructor-arg name="databaseName" value="test"/> </bean></beans> 因为倒入了他自己的xsd文件，所以可以看下mongo的内容实际上是MongoFactoryBean
<xsd:element name="mongo" type="mongoType"><xsd:annotation><xsd:documentation source="org.springframework.data.mongodb.core.core.MongoFactoryBean"><!]></xsd:documentation><xsd:appinfo><tool:annotation><tool:exports type="com.mongodb.Mongo"/></tool:annotation></xsd:appinfo></xsd:annotation></xsd:element>然后看下MongoTemplate类的构造函数，就清楚了。
public MongoTemplate(Mongo mongo, String databaseName) {this(new SimpleMongoDbFactory(mongo, databaseName), null);}
测试类的基类;
import org.apache.log4j.Logger;import org.junit.AfterClass;import org.junit.Before;import org.junit.BeforeClass;import org.springframework.beans.factory.support.DefaultListableBeanFactory;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;/** * User: zhangtan * Date: 2012-07-28 * Time: 11：14 */publicclass BaseTestCase { protected Logger log = Logger.getLogger(this.getClass()); protected static ApplicationContext appContext; @BeforeClass public staticvoid setUp() throws Exception { try { long start = System.currentTimeMillis(); System.out.println("开始加载配置文件"); appContext =new ClassPathXmlApplicationContext(new String[]{"spring-config.xml"}); System.out.println("配置文件加载结束" + (System.currentTimeMillis() - start)); } catch (Exception e) { e.printStackTrace(); } } protected boolean setProtected() { return false; } @Before public void autoSetBean() { appContext.getAutowireCapableBeanFactory().autowireBeanProperties(this, DefaultListableBeanFactory.AUTOWIRE_BY_NAME, false); } @AfterClass public staticvoid tearDown() throws Exception { }}增删改查基本操作
package dao;import com.mongodb.DBCollection;import com.mongodb.WriteResult;import com.zt.todo.log.UserLog;import org.junit.Test;import org.springframework.data.mongodb.core.MongoTemplate;import org.springframework.data.mongodb.core.query.Query;import org.springframework.data.mongodb.core.query.Update;import java.net.UnknownHostException;import static org.springframework.data.mongodb.core.query.Criteria.where;/** * Created by IntelliJ IDEA. * User: zhangtan * Date: 12-7-28 * Time: 11：19 */public class MongoTest extends BaseTestCase { private MongoTemplate mongoOps; @Test public void insertLog() throws UnknownHostException { UserLog userLog = new UserLog("zt", "吃饭"); mongoOps.insert(new UserLog("zt", "我今天吃饭了"));// mongoOps.dropCollection("person"); //save mongoOps.save(userLog,"userLog"); //find UserLog savedLog =mongoOps.findOne(new Query(where("operater").is("zt")), UserLog.class); System.out.println("savedLog : " + savedLog); //update WriteResult updateResult =mongoOps.updateFirst(new Query(where("operater").is("zt")), Update.update("operater", "qs"), UserLog.class); System.out.println("updateResult : " + updateResult.getN()); //delete mongoOps.remove(new Query(where("operater").is("zt")),"userLog"); //List DBCollection dBCollection = mongoOps.getCollection("userLog"); System.out.println("Number of user = " + dBCollection.getCount()); } public MongoTemplate getMongoOps() { return mongoOps; } public void setMongoOps(MongoTemplate mongoOps) { this.mongoOps = mongoOps; }}
页:
[1]