使用MySQL将文件上传到DataHandler

Question

目前，我很难使用.mp3将一个非常小的文件上传到MySQL数据库。我正在本地尝试代码，之后它将被翻译成一个webservice。下面的“粗”代码试图上载该文件。现在我不知道上传部分是搞砸了还是下载部分不是working.Because，我用一个非常简单的文本文件测试了代码，当我下载它(从DB)时，它充满了垃圾data.Here，这是我为这两个部分使用的代码。

上传部分

public void uploadFile(FileUploader Dfile)
{

        DataHandler handler = Dfile.getDfile();
        InputStream is = handler.getInputStream();

        //Move input stream to byteArray
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        byte[] tmp = new byte[4096];
        int ret = 0;

        while((ret = is.read(tmp)) > 0)
        {
            bos.write(tmp, 0, ret);
        }

        byte[] myArray = bos.toByteArray();

        MySQL s = new MySQL();

        s.InsertFile(Dfile.getName(), myArray);
        is.close();
}//End method

这就是将数组转储到DB中的地方。

public void InsertFile(String Fname , byte[] myArray )
{
   String sql = "INSERT INTO `uploadtest`.`File` (`Filename`,`Data`) VALUES ( \"" + Fname + "\",\"" + myArray + "\");" ;
   try 
   {
       //Insert it into the Db
       int a = stat.executeUpdate (sql);
   } 
   catch (IOException e)
   {
       e.printStackTrace();
   }
   catch (SQLException e) 
   {
    e.printStackTrace();
   }
}//end method

下载部分

这是我用来测试上传是否成功的代码。

     String sql = "SELECT Data FROM uploadtest.File where filename=\"" + name + "\"";
    try 
       {
           ResultSet rs = stat.executeQuery(sql);
           Blob blob = null;
           InputStream inputStream = null;

           if(rs.next())
           {
            inputStream = rs.getBinaryStream("Data");
           }


            OutputStream out = new FileOutputStream(new File("d:\\somefile.mp3")); // Just to test if file retrieved from DB(blob type) was correct

            int read = 0;
            byte[] bytes = new byte[1024];

            while ((read = inputStream.read(bytes)) != -1)
            {
                out.write(bytes, 0, read);
            }

            inputStream.close();
            out.flush();
            out.close();

对我可能出错的地方有什么建议吗？

Answer 1

这就是你要犯错的地方：

String sql = "INSERT INTO `uploadtest`.`File` (`Filename`,`Data`) VALUES ( \"" + Fname + "\",\"" + myArray + "\");" ;

就像在下载部分使用流获取方法一样，需要使用流方法将数据插入数据库。您现在所做的只是连接对象myArray的字符串表示。为了获得一个想法，尝试在变量sql中记录或打印值，以查看它包含了什么，并查看将执行什么语句。

至于如何解决这个问题，您可以使用一个PreparedStatement，然后使用setBinaryStream()或setBlob()，然后直接从数据处理程序中提交您的流，而不需要字节流。下面是一个例子：使用JDBC将文件数据插入MySQL数据库

最后一个注意事项是:整个数据将在内存中传递，当文件变大时，您可能会从java或mysql获得与内存相关的问题。如果插入大文件，可以考虑将文件存储在块中。还可以考虑不将文件插入数据库。将文件保存在文件系统上，并将它们组织到目录和子目录中。并且只将文件的路径存储在数据库中。