数据库

Spring Data MongoDB基础实例代码

1.以下从官方下载示例，下载地址如下所示：

http://www.springsource.org/samples

2.排错，

   刚下载下来的SpringExample有错误，首先它不是一个maven项目，单击右键使其转换成maven项目，添加一些依赖，比如spring-aop,spring-context,spring-core,log4j等依赖。同时更新你的依赖包，依赖配置，最终运行成功后，运行下一步。

3.代码讲解。

3.1  方式一（注解方式开启mongo.exe,同时创建数据库yourdb，文档yourCollection），代码如下所示：

package com.mkyong.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.document.mongodb.MongoTemplate;
import org.springframework.data.document.mongodb.config.AbstractMongoConfiguration;
import com.mongodb.Mongo;
/**
 * Spring MongoDB configuration file
 *
 */
@Configuration
public class SpringMongoConfig extends AbstractMongoConfiguration {
        @Override
        public @Bean Mongo mongo() throws Exception {
                return new Mongo("localhost");
        }
        @Override
        public @Bean MongoTemplate mongoTemplate() throws Exception {
                return new MongoTemplate(mongo(),"yourdb","yourCollection");
        }
}

3.2方式二（配置文件的方式）,代码如下所示：

        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">
        
        
        
                
                
                
        
        
        

3.3 实体类的编写

package com.mkyong.user;
public class User {
        private String id;
        private String firstname;
        private String lastname;
        private int age;
        public User(){};
        public User(String id, String firstname, String lastname, int age) {
                super();
                this.id = id;
                this.firstname = firstname;
                this.lastname = lastname;
                this.age = age;
        }
        public String getId() {
                return id;
        }
        public void setId(String id) {
                this.id = id;
        }
        public String getFirstname() {
                return firstname;
        }
        public void setFirstname(String firstname) {
                this.firstname = firstname;
        }
        public String getLastname() {
                return lastname;
        }
        public void setLastname(String lastname) {
                this.lastname = lastname;
        }
        public int getAge() {
                return age;
        }
        public void setAge(int age) {
                this.age = age;
        }
        @Override
        public String toString() {
                return "User [id=" + id + ", firstname=" + firstname + ", lastname="
                                + lastname + ", age=" + age + "]";
        }
}

最后书写main类，如下所示：

package com.mkyong.core;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.support.GenericXmlApplicationContext;
import org.springframework.data.document.mongodb.MongoOperations;
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.mkyong.config.SpringMongoConfig;
import com.mkyong.user.User;
public class App
{
    public static void main( String[] args )
    {
        //For Annotation 注解方式
        ApplicationContext ctx = new AnnotationConfigApplicationContext(SpringMongoConfig.class);
        //For XML XML配置文件方式
        //ApplicationContext ctx = new GenericXmlApplicationContext("mongo-config.xml");
        MongoOperations mongoOperation = (MongoOperations)ctx.getBean("mongoTemplate");
        User user = new User("1001", "yong", "mook kim", 30);
        //save
        mongoOperation.save("userprofile",user);
        //find
        User savedUser = mongoOperation.findOne("userprofile",
                        new Query(Criteria.where("id").is("1001")),
                                User.class);
        System.out.println("savedUser : " + savedUser);
        //update
        mongoOperation.updateFirst("userprofile",
                        new Query(Criteria.where("firstname").is("yong")),
                        Update.update("lastname", "new lastname"));
        //find
        User updatedUser = mongoOperation.findOne(
                        "userprofile",
                        new Query(Criteria.where("id").is("1001")),
                                User.class);
        System.out.println("updatedUser : " + updatedUser);
        //delete
        mongoOperation.remove("userprofile",
                        new Query(Criteria.where("id").is("1001")),
                        User.class);
        //List
        List listUser =
                mongoOperation.getCollection("userprofile", User.class);
        System.out.println("Number of user = " + listUser.size());
    }
}

 由于只是一些CURD的操作，比较简单，直接看代码就明白了，我就不多讲了。

4.运行效果

Spring Data MongoDB基础实例代码

• 收藏(9)
• 赞(67)
• 举报

分享到：