java—从mysql数据库读取文本文件并写入项目文件夹时,会额外写入一行

imzjd6km  于 2021-06-19  发布在  Mysql
关注(0)|答案(2)|浏览(431)

我将文本文件存储在mysql中,并将其从java读取到项目文件中。我在这方面面临一个问题。我正在保存3个文件,每个文件包含992行。但是,当我读取并将其保存回java项目文件夹时,两个文件被写为993行,每行最后一行是一个空字符串。
如何解决?
这里是我的代码读写到项目文件夹。
我附加的文件可以访问的链接。文件1文件2文件3
在这些文件中,file1和file2正在写入额外的行。
这是密码

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();
      }
   }
 }
y53ybaqx

y53ybaqx1#

由于忽略了流返回的实际读取字节数,因此读取流的方式不正确 read 方法。这会导致您写入的字节数出现“一对一”错误,从而导致重复先前读取的字节,从而损坏您写入的文件。
您需要将代码更改为:

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

请注意,我还增加了缓冲区大小,因为这将比每两个字节读取更有效。
通过使用try with资源关闭流,可以进一步简化代码。
或者更简洁地说,不要创建输出流,而是使用:

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

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

lf3rwulv

lf3rwulv2#

文件1的长度为20579字节,文件2的长度为20585字节,文件3的长度为20612字节。工作文件长度均匀。在你的代码中你读写字节2乘2。我的猜测是,当您写入文件1和2的最后一个字节时,您会在数组中添加一个额外的字节并将其写入文件。
试着一个接一个地读取字节,看看它是否工作得更好。

相关问题