使用spring连接及操作mongodb3.0

程序员文章站 2024-02-06 14:43:30

...

前边有一篇记录过不使用spring，直接在java代码中连接和操作mongodb数据库，这里就紧随其后记录一下使用spring的情况下，在java中简单操作mongodb。 maven导包配置：因为涉及了sping以及springmvc，因此也需要导入它们相关的包： project xmlns=http://maven

前边有一篇记录过不使用spring，直接在java代码中连接和操作mongodb数据库，这里就紧随其后记录一下使用spring的情况下，在java中简单操作mongodb。
maven导包配置： 因为涉及了sping以及springmvc，因此也需要导入它们相关的包：

4.0.0spring_mongospring_mongowar0.0.1-SNAPSHOTspring_mongo Maven Webapphttp://maven.apache.orgorg.springframework.dataspring-data-mongodb1.8.0.RELEASEorg.mongodbmongo-java-driver3.0.3commons-loggingcommons-logging1.2org.springframeworkspring-test4.1.6.RELEASEjunitjunit4.11org.springframeworkspring-context4.1.7.RELEASEorg.springframeworkspring-context-support4.0.9.RELEASEmaven-compiler-plugin2.3.21.71.7UTF-8${java.home}/lib/rt.jar;${java.home}/lib/jce.jarspring_mongo

spring基础配置： 主要是开启注解扫描等：

spring连接mongodb以及建立相关工厂的配置：

与数据库对应的实体类： 需要注意的是这里需要实现序列化的接口并设置uid的属性，否则不能在操作中直接把数据库返回结果转换成对象属性：

package spring_mongo.models;

import java.io.Serializable;

public class UserModel implements Serializable {

    private static final long serialVersionUID = 1L;
    private String userName;
    private String password;

    public UserModel(String userName, String password) {
        super();
        this.userName = userName;
        this.password = password;
    }

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

}

根据spring配置获取操作mongodb的MongoTemplete，需要实现ApplicationContextAware接口：

package spring_mogo.dao.daoImp;

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.data.mongodb.core.MongoTemplate;

public abstract class AbstractBaseMongoTemplete implements
        ApplicationContextAware {

    protected MongoTemplate mongoTemplate;

    /**
     * @Description 根据配置文件设置mongoTemplate
     * @param mongoTemplate
     */
    public void setMongoTemplate(MongoTemplate mongoTemplate) {
        this.mongoTemplate = mongoTemplate;
    }

    @Override
    public void setApplicationContext(ApplicationContext applicationContext)
            throws BeansException {
        MongoTemplate mongoTemplate = applicationContext.getBean(
                "mongoTemplate", MongoTemplate.class);
        setMongoTemplate(mongoTemplate);
    }
}

操作数据库的接口以及对应的实现类： 演示了最基础的增删改查，需要注意的地方在于参数的声明以及接收返回数据时和实体类的转换：（1）接口：

package spring_mogo.dao;

import java.util.List;

import spring_mongo.models.UserModel;

public interface UserDao {
    /**
     * 查询数据
     * 
     * @author：tuzongxun
     * @Title: findAll
     * @param @return
     * @return List
     * @date May 13, 2016 3:07:39 PM
     * @throws
     */
    public List findAll();

    /**
     * 新增数据
     * 
     * @author：tuzongxun
     * @Title: insertUser
     * @param @param user
     * @return void
     * @date May 13, 2016 3:09:45 PM
     * @throws
     */
    public void insertUser(UserModel user);

    /**
     * 删除数据
     * 
     * @author：tuzongxun
     * @Title: removeUser
     * @param @param userName
     * @return void
     * @date May 13, 2016 3:09:55 PM
     * @throws
     */
    public void removeUser(String userName);

    /**
     * 修改数据
     * 
     * @author：tuzongxun
     * @Title: updateUser
     * @param @param user
     * @return void
     * @date May 13, 2016 3:10:06 PM
     * @throws
     */
    public void updateUser(UserModel user);

    /**
     * 按条件查询
     * 
     * @author：tuzongxun
     * @Title: findForRequery
     * @param
     * @return void
     * @date May 13, 2016 3:23:37 PM
     * @throws
     */
    public List findForRequery(String userName);

}

（2）实现类，这里要继承AbstractBaseMongoTemplete类，从而获得mongoTemplete进行各种操作：

package spring_mogo.dao.daoImp;

import java.util.List;

import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Component;

import spring_mogo.dao.UserDao;
import spring_mongo.models.UserModel;

import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;

@Component("UserDaoImp")
public class UserDaoImp extends AbstractBaseMongoTemplete implements UserDao {

    /**
     * 查询所有数据
     * 
     * @author：tuzongxun
     * @Title: findAll
     * @Description: TODO
     * @param @return
     * @date May 13, 2016 3:10:29 PM
     * @throws
     */
    @Override
    public List findAll() {
        // 需要设置集合对应的尸体类和相应的集合名，从而查询结果直接映射
        List userList = mongoTemplate.findAll(UserModel.class,
                "user");
        return userList;
    }

    /**
     * 新增数据
     * 
     * @author：tuzongxun
     * @Title: insertUser
     * @Description: TODO
     * @param @param user
     * @date May 13, 2016 3:10:45 PM
     * @throws
     */
    @Override
    public void insertUser(UserModel user) {
        // 设置需要插入到数据库的文档对象
        DBObject object = new BasicDBObject();
        object.put("userName", user.getUserName());
        object.put("password", user.getPassword());
        mongoTemplate.insert(object, "user");
    }

    /**
     * 按条件删除数据
     * 
     * @author：tuzongxun
     * @Title: removeUser
     * @Description: TODO
     * @param @param userName
     * @date May 13, 2016 3:11:01 PM
     * @throws
     */
    @Override
    public void removeUser(String userName) {
        // 设置删除条件，如果条件内容为空则删除所有
        Query query = new Query();
        Criteria criteria = new Criteria("userName");
        criteria.is(userName);
        query.addCriteria(criteria);
        mongoTemplate.remove(query, "user");
    }

    /**
     * 修改数据
     * 
     * @author：tuzongxun
     * @Title: updateUser
     * @Description: TODO
     * @param @param user
     * @date May 13, 2016 3:11:12 PM
     * @throws
     */
    @Override
    public void updateUser(UserModel user) {
        // 设置修改条件
        Query query = new Query();
        Criteria criteria = new Criteria("userName");
        criteria.is(user.getUserName());
        query.addCriteria(criteria);
        // 设置修改内容
        Update update = Update.update("password", user.getPassword());
        // 参数：查询条件，更改结果，集合名
        mongoTemplate.updateFirst(query, update, "user");
    }

    /**
     * 根据条件查询
     * 
     * @author：tuzongxun
     * @Title: findForRequery
     * @Description: TODO
     * @param @param userName
     * @date May 13, 2016 4:08:15 PM
     * @throws
     */
    @Override
    public List findForRequery(String userName) {
        Query query = new Query();
        Criteria criteria = new Criteria("userName");
        criteria.is(userName);
        query.addCriteria(criteria);
        // 查询条件，集合对应的实体类，集合名
        List userList = mongoTemplate.find(query, UserModel.class,
                "user");
        return userList;
    }

}

测试类： 为了验证以上代码和配置的正确性，测试类代码如下：

package spring_mongo.test;

import java.util.List;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import spring_mogo.dao.UserDao;
import spring_mongo.models.UserModel;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "classpath:spring.xml" })
public class mongoTest {

    @Autowired
    private UserDao userDao;

    /**
     * 查询测试
     * 
     * @author：tuzongxun
     * @Title: monFindTest
     * @param
     * @return void
     * @date May 13, 2016 3:27:51 PM
     * @throws
     */
    @Test
    public void monFindTest() {
        List userModels = userDao.findAll();
        if (userModels != null && userModels.size() > 0) {
            for (UserModel user : userModels) {
                System.out.println(user.getUserName() + ":"
                        + user.getPassword());
            }
        }
    }

    /**
     * 插入数据测试
     * 
     * @author：tuzongxun
     * @Title: monInsertTest
     * @param
     * @return void
     * @date May 13, 2016 3:27:38 PM
     * @throws
     */
    @Test
    public void monInsertTest() {
        UserModel user = new UserModel("test111", "123456");
        userDao.insertUser(user);
        this.monFindTest();
    }

    /**
     * 删除测试
     * 
     * @author：tuzongxun
     * @Title: monRemoveTest
     * @param
     * @return void
     * @date May 13, 2016 3:28:06 PM
     * @throws
     */
    @Test
    public void monRemoveTest() {
        String userName = "test111";
        userDao.removeUser(userName);
        this.monFindTest();
    }

    /**
     * 测试修改
     * 
     * @author：tuzongxun
     * @Title: monUpdateTest
     * @param
     * @return void
     * @date May 13, 2016 3:50:08 PM
     * @throws
     */
    @Test
    public void monUpdateTest() {
        UserModel user = new UserModel("test111", "test");
        userDao.updateUser(user);
        this.monFindTest();
    }

    /**
     * 按条件查询
     * 
     * @author：tuzongxun
     * @Title: monFindForRuq
     * @param
     * @return void
     * @date May 13, 2016 4:10:53 PM
     * @throws
     */
    @Test
    public void monFindForRuq() {
        String userName = "test111";
        List userModels = userDao.findForRequery(userName);
        if (userModels != null && userModels.size() > 0) {
            for (UserModel user : userModels) {
                System.out.println(user.getUserName() + ":"
                        + user.getPassword());
            }
        }
    }

}

相关标签：使用 spring 连接操作 mongodb3.0 前边

上一篇：在CentOS/RHEL6.2/5.8,Fedora17/16上安装Nginx/PHP-FPM环境

下一篇： Nginx和PHP-FPM的启动/重启脚本

使用spring连接及操作mongodb3.0

详解Spring Boot实战之Rest接口开发及数据库基本操作

log4j配置及使用博客分类： Spring log4j

php连接oracle及简单操作

Centos7使用yum安装MySQL及实现远程连接的方法

CodeIgniter针对数据库的连接、配置及使用方法，codeigniter数据库_PHP教程

Oracle SQL Developer 连接sqlserver/sybase/mysql/db2驱动安装及使用方法

PHP入门教程之使用Mysqli操作数据库的方法(连接,查询,事务回滚等)

Java使用JDBC连接mysql数据库及测试是否连接成功的方法

CentOS下安装MySQL及Windows下使用Navicat for MySQL连接

Flask框架使用DBUtils模块连接数据库操作示例

使用spring连接及操作mongodb3.0

详解Spring Boot实战之Rest接口开发及数据库基本操作

log4j配置及使用 博客分类： Spring log4j

php连接oracle及简单操作

Centos7使用yum安装MySQL及实现远程连接的方法

CodeIgniter针对数据库的连接、配置及使用方法，codeigniter数据库_PHP教程

Oracle SQL Developer 连接sqlserver/sybase/mysql/db2驱动安装及使用方法

PHP入门教程之使用Mysqli操作数据库的方法(连接,查询,事务回滚等)

Java使用JDBC连接mysql数据库及测试是否连接成功的方法

CentOS下安装MySQL及Windows下使用Navicat for MySQL连接

Flask框架使用DBUtils模块连接数据库操作示例

log4j配置及使用博客分类： Spring log4j