从MySQL数据库读取文本文件并写入project文件夹时额外写入一行

Question

我正在MySQL中存储文本文件，并将其从Java读入项目文件。我在这方面面临一个问题。我正在保存3个文件，每个文件包含992行。但当我读取并将其保存回java项目文件夹时，两个文件被写成每行993行，最后一行是空字符串。

对此如何化解？

这里是我的代码读取和写入项目文件夹。

我正在附上可以访问这些文件的链接。文件1文件2文件3

这是密码

import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class ReadBlob 
{

    public static void main(String[] args) throws Exception 
    {

       Connection myConn = null;
       Statement myStmt = null;
       ResultSet myRs = null;

       InputStream input = null;
       FileOutputStream output = null;

         try {
        // 1. Get a connection to database
         myConn = DriverManager.getConnection(
                "jdbc:mysql://localhost:3306/database", "username", "password");

        // 2. Execute statement
        myStmt = myConn.createStatement();
        String sql = "select file from tablename where id='1'";//I am mention the ID related to the files
        myRs = myStmt.executeQuery(sql);

        // 3. Set up a handle to the file
        File theFile = new File("data2.txt");
        output = new FileOutputStream(theFile);

        if (myRs.next()) 
                    {

            input = myRs.getBinaryStream("file"); 

            System.out.println("Reading data from database...");
            System.out.println(sql);

            byte[] buffer = new byte[2];
            while (input.read(buffer) > 0) {
                output.write(buffer);
            }

            System.out.println("\nSaved to file: " + theFile.getAbsolutePath());

            System.out.println("\nCompleted successfully!");                
              }

         } 
            catch (Exception exc) 
            {
          exc.printStackTrace();
         } 
            finally 
            {
        if (input != null) 
                    {
            input.close();
        }

        if (output != null) 
                    {
            output.close();
        }

        close(myConn, myStmt);
       }
     }

       private static void close(Connection myConn, Statement myStmt)
        throws SQLException {

    if (myStmt != null) {
        myStmt.close();
        }

        if (myConn != null) {
        myConn.close();
      }
   }
 }

Answer 1

通过忽略read方法返回的实际读取字节数，您将错误地读取流。这会导致写入的字节数出现偏离一的错误，这会导致重复先前读取的字节数，从而损坏写入的文件。

您需要将代码更改为：

byte[] buffer = new byte[4096];
int bytesRead;
while ((bytesRead = input.read(buffer)) != -1) {
    output.write(buffer, 0, bytesRead);
}

注意，我还增加了缓冲区大小，因为这将比每两个字节读取的效率更高。

或者更简洁,不要创建输出流,而是使用：

Files.copy(input, file.toPath());

文件可能仍然是不正确的，因为有可能您在编写文件时犯了类似的错误。