一聚教程网:一个值得你收藏的教程网站

热门教程

Java mongodb保存/读取应用实例详解

时间:2022-06-29 03:14:50 编辑:袖梨 来源:一聚教程网

下面的例子是把User对象插入到Mongodb中,并读出来

 代码如下 复制代码
User.java:
package com.mongo;
 
public class User {
 String name;
 int age;
 Oid _id;
 public String getName() {
  return name;
 }
 public void setName(String name) {
  this.name = name;
 }
 public int getAge() {
  return age;
 }
 public void setAge(int age) {
  this.age = age;
 }
 /**
  * Mongodb会自动生成ObjectId
  * @author fhp
  *
  */
 public class Oid{
  String $oid;
  public String get$oid() {
   return $oid;
  }
 
  public void set$oid(String $oid) {
   this.$oid = $oid;
  }
 
 }
}

Main.java:

 代码如下 复制代码
 package com.mongo;
 
import java.net.UnknownHostException;
 
import com.google.gson.Gson;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
import com.mongodb.util.JSON;
 
public class Main {
 
 /**
  * @param args
  * @throws UnknownHostException
  */
 public static void main(String[] args) throws UnknownHostException {
  // TODO Auto-generated method stub
     MongoClient mongoClient = new MongoClient();
 
     DB psdoc = mongoClient.getDB("psdoc");
     DBCollection user=psdoc.getCollection("user");
 
     User u1=new User();
     u1.setAge(20);
     u1.setName("ssss");
     Gson gson=new Gson();
     //转换成json字符串,再转换成DBObject对象
     DBObject dbObject = (DBObject) JSON.parse(gson.toJson(u1));
     //插入数据库
     user.insert(dbObject);
 
     DBCursor cursor=user.find();
     while(cursor.hasNext())
     {
      DBObject obj=cursor.next();
      //反转
      User u=gson.fromJson(obj.toString(), User.class);
      System.out.println(u.name);
     }
 }
 
}

为了方便,可以直接把Gson整合进驱动里,直接修改驱动的源代码
com.mongodb.DBCollection.java:
新增方法:

 代码如下 复制代码
/**
  * 把普通的对象写入数据库
  *
  * @param obj
  * @return
  */
 public WriteResult insert(Object obj) {
  Gson gson = new Gson();
  DBObject dbObject = (DBObject) JSON.parse(gson.toJson(obj));
  gson=null;
  return insert(dbObject);
 }
com.mongodb.DBCursor.java:

新增方法

 代码如下 复制代码
/**
     * 从数据库读出对象
     * @param obj
     * @param clazz
     * @return
     */
    public T nextObj(Class clazz) {
        _checkType( CursorType.ITERATOR );
        Gson gson=new Gson();
        T u=gson.fromJson(_next().toString(), clazz);
gson=null;
        return u;
    }

修改后的调用方法:

 代码如下 复制代码

Main.java:

package com.mongo;
 
import java.net.UnknownHostException;
 
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.MongoClient;
 
public class Main {
 
 /**
  * @param args
  * @throws UnknownHostException
  */
 public static void main(String[] args) throws UnknownHostException {
  // TODO Auto-generated method stub
     MongoClient mongoClient = new MongoClient();
 
     DB psdoc = mongoClient.getDB("psdoc");
     DBCollection user=psdoc.getCollection("user");
 
     User u1=new User();
     u1.setAge(20);
     u1.setName("ssss");
     //直接插入对象
     user.insert(u1);
     DBCursor cursor=user.find();
     while(cursor.hasNext())
     {
      //传入类参数,反回该类对象
      User u=cursor.nextObj(User.class);
      System.out.println(u.name);
     }
 }
 
}

热门栏目