ConversationMemoryStore.java 文件源码

@Override
public String storeConversationMemorySnapshot(ConversationMemorySnapshot snapshot) throws IResourceStore.ResourceStoreException {
    try {
        String json = documentBuilder.toString(snapshot);
        Document document = Document.parse(json);

        document.remove("id");

        if (snapshot.getId() != null) {
            document.put("_id", new ObjectId(snapshot.getId()));
            conversationCollection.updateOne(new Document("_id", new ObjectId(snapshot.getId())),
                    new Document("$set", document),
                    new UpdateOptions().upsert(true));
        } else {
            conversationCollection.insertOne(document);
        }

        return document.get("_id").toString();
    } catch (IOException e) {
        throw new IResourceStore.ResourceStoreException(e.getLocalizedMessage(), e);
    }
}