java MongoDB模型的序列化类

ef1yzkbh  于 2023-05-12  发布在  Java
关注(0)|答案(8)|浏览(184)

当我在mongodb中插入一个List时,有一个问题:

Exception in thread "main" java.lang.IllegalArgumentException: can't serialize class mongodb.Person
    at org.bson.BasicBSONEncoder._putObjectField(BasicBSONEncoder.java:234)
    at org.bson.BasicBSONEncoder.putIterable(BasicBSONEncoder.java:259)
    at org.bson.BasicBSONEncoder._putObjectField(BasicBSONEncoder.java:198)
    at org.bson.BasicBSONEncoder.putObject(BasicBSONEncoder.java:140)
    at org.bson.BasicBSONEncoder.putObject(BasicBSONEncoder.java:86)
    at com.mongodb.DefaultDBEncoder.writeObject(DefaultDBEncoder.java:27)
    at com.mongodb.OutMessage.putObject(OutMessage.java:142)
    at com.mongodb.DBApiLayer$MyCollection.insert(DBApiLayer.java:252)
    at com.mongodb.DBApiLayer$MyCollection.insert(DBApiLayer.java:211)
    at com.mongodb.DBCollection.insert(DBCollection.java:57)
    at com.mongodb.DBCollection.insert(DBCollection.java:87)
    at com.mongodb.DBCollection.save(DBCollection.java:716)
    at com.mongodb.DBCollection.save(DBCollection.java:691)
    at mongodb.MongoDB.main(MongoDB.java:45)

Person类的定义如下:

class Person{
    private String name;
    public Person(String name){
        this.name = name;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
}

该方案是:

DBCollection coll = db.getCollection("test");
        DBObject record = new BasicDBObject();
        List<Person> persons= new ArrayList<Person>();
        persons.add(new Person("Jack"));
        record.put("person", persons);
        coll.save(record);

我在google上找不到答案,请帮帮我。

bkhjykvo

bkhjykvo1#

只需在Person类中实现Serializable接口。
在你的类中定义一个serialVersionUID也是很好的。
AFAIK,在java中创建POJO类时,类应该是可序列化的,如果它要通过一些流传输,有一个默认的构造函数,并允许使用getter和setter方法访问属性/字段。
你可能有兴趣阅读这个:Discover the secrets of the Java Serialization API

3j86kqsm

3j86kqsm2#

我在使用mongodb时也遇到了同样的异常。我试着让这个有问题的类序列化,但这并没有解决我的问题。
以下是为我工作的。将类扩展为BasicDBObject的子级。当然,只有当问题是由MongoDB引起的时候,这才有效。

extends BasicDBObject

原始来源
http://techidiocy.com/cant-serialize-class-mongodb-illegal-argument-exception/#comment-1298

uurv41yg

uurv41yg3#

类Person应该实现java.io.Serializable接口。
class Person implements Serializable

dldeef67

dldeef674#

你的Person类定义需要有implements Serializable才能序列化,例如:

class Person implements Serializable {
   //Rest here
}

以下是一些关于Java对象序列化的有用链接:链接,Link

6yjfywim

6yjfywim5#

这里的问题不在于“实现可序列化”。问题是该对象未在DBObject中转换。
可能的解决方案:

import com.fasterxml.jackson.databind.ObjectMapper;
import com.mongodb.*;

....

ObjectMapper mapper = new ObjectMapper();
DBObject dboJack = mapper.convertValue(new Person("Jack"), BasicDBObject.class);
...
gjmwrych

gjmwrych6#

你可以通过使用以下代码来实现这一点:

import com.google.gson.annotations.Expose;
import com.mongodb.ReflectionDBObject;

class PersonList extends ReflectionDBObject {
    // person property
    @Expose public java.util.List<Person> person;
}

现在,在mongodb代码中,可以序列化Person列表,如下所示

....
PersonList personList = new PersonList();
personList.person = new ArrayList<>();
// add persons to the list
....
....
record.put("personsList", personList);
....
// rest of your code
3vpjnl9f

3vpjnl9f7#

下面是使Employee对象序列化的代码示例:

public class Employee implements Serializable {

    private int empId;
    private String name;

    public int getEmpId() {
        return empId;
    }

    public String getName() {
        return name;
    }

    public void setEmpId(int empId) {
        this.empId = empId;
    }

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public String toString() {
        return "EMployee id : " + empId + "  \nEmployee Name : " + name;
    }
}

//Another Main Class
public class Main{
    public static void main(String[] args) 
        throws FileNotFoundException, IOException, ClassNotFoundException {

        String filename = "data.txt";
        Employee e = new Employee();
        e.setEmpId(101);
        e.setName("Yasir Shabbir");

        FileOutputStream fos = null;
        ObjectOutputStream out = null;

        fos = new FileOutputStream(filename);
        out = new ObjectOutputStream(fos);
        out.writeObject(e);

        out.close();

        // Now to read the object from file
        // save the object to file
        FileInputStream fis = null;
        ObjectInputStream in = null;

        fis = new FileInputStream(filename);
        in = new ObjectInputStream(fis);
        e = (Employee) in.readObject();
        in.close();

        System.out.println(e.toString());
    }
}
pprl5pva

pprl5pva8#

首先,你应该知道为什么要使类可序列化?每当你想把网络上的对象移动到文件、数据库、网络、进程或任何其他系统。在java中简单实现。只需实现可串行化接口。

相关问题