使用graphql解析器从mongodb数据库中删除/替换文件的问题

如何解决使用graphql解析器从mongodb数据库中删除/替换文件的问题

我有一个模型,该模型从gridfs文件中获取一些数据:

const messageSchema = new Schema({
  content: {
    type: String
  },path: {
    type: String
  },email: {
    type: String
  },fileImage:{
    type: Boolean
  },files_id: {
    type: Schema.Types.ObjectId
  }
});

然后我使用uploadMessage解析器将其上传:

uploadMessage: async (_,args) => {
      const { fileImage,content,email } = args;
      if(fileImage){
        const { file } = args;
        const newFile = await file.then(result => result);
        const fileId = await storeFile(newFile,bucketName).then(result => result);
        
        const { filename } = newFile;
        
        const newMessage = new Message({ 
          content: content,files_id: fileId,email: email,fileImage: fileImage,path: `/${bucketName}/${filename}`
        });
        return newMessage.save();
      }
      else {
        // doesn't matter...
      }

      // Save the record and return it
      
    }

bucketName只是我在使用解析器的文件开头定义的常量。 效果很好,我可以立即添加它而不会出错,但是删除和更新文件存在问题。

在解析器的开头,我初始化了流:

const mongoose = require('mongoose');
const Grid = require('gridfs-stream');
const conn = mongoose.connection;
Grid.mongo = mongoose.mongo;
// Init gfs
let gfs;

const bucketName = 'messages';

conn.once('open',() => {
  // Init stream
  gfs = Grid(conn.db);
  gfs.collection(bucketName)
});

稍后我必须使用解析器,它们都具有相同的问题:

deleteMessage: (parent,args) => {
      console.log(args);
      // Create a new record in the database
      if(!args)
        throw new Error('Error');

      if(args.fileImage){
      return Message.findOneAndDelete({ _id: args._id },(err,user) => {
        gfs.remove({ _id: user.files_id,root: bucketName },gridFSBucket) => {
          if (err) {
            throw new Error(err);
          }
        })
      })
    }
    else return Message.findOneAndDelete({ _id: args._id })
    }

update与delete类似,但是速度不快。 问题是,如果我单击删除文件的速度过快,则会收到错误消息: 在页面上:

Unhandled Rejection (Error): Network error: Unexpected token P in JSON at position 0

在终端上

 TypeError: Cannot read property 'files_id' of null

它位于这里:

 gfs.remove({ _id: user.files_id

这是我的钩子(由codegen生成):

const [deleteMessage] = useDeleteMessageMutation({ refetchQueries: refetchMessages,awaitRefetchQueries: true});

  const [updateMessage] = useUpdateMessageMutation({ refetchQueries: refetchMessages,awaitRefetchQueries: true }   );

DeleteClick功能:

const onDeleteClick = id => {
    return e =>{
      deleteMessage({ variables: { _id: id,fileImage: fileImage   } }); 
    }
  };

DeleteClick函数(带有绑定):

const onDeleteClick = id => {
      deleteMessage({ variables: { _id: id,fileImage: fileImage   } }); 
 };

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com(将#修改为@)

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其他元素将获得点击?
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。)
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbcDriver发生异常。为什么?
这是用Java进行XML解析的最佳库。
Java的PriorityQueue的内置迭代器不会以任何特定顺序遍历数据结构。为什么?
如何在Java中聆听按键时移动图像。
Java“Program to an interface”。这是什么意思?
Java在半透明框架/面板/组件上重新绘画。
Java“ Class.forName()”和“ Class.forName()。newInstance()”之间有什么区别?
在此环境中不提供编译器。也许是在JRE而不是JDK上运行?
Java用相同的方法在一个类中实现两个接口。哪种接口方法被覆盖?
Java 什么是Runtime.getRuntime()。totalMemory()和freeMemory()?
java.library.path中的java.lang.UnsatisfiedLinkError否*****。dll
JavaFX“位置是必需的。” 即使在同一包装中
Java 导入两个具有相同名称的类。怎么处理?
Java 是否应该在HttpServletResponse.getOutputStream()/。getWriter()上调用.close()?
Java RegEx元字符(。)和普通点?