3

我在我的项目中使用 CSVReader 来读取 Windows 服务中的 .csv 文件。我们将 .csv 文件传递​​给 CSVReader 以处理文件，它工作正常。但最近我们决定将 csv 文件保存到数据库表并从那里读取。当用户提交 csv 文件进行处理时，我们的 aspx 页面将读取 csv 文件并将其转换为字节数组并保存到数据库中。服务将读取表并获取字节数组并将其转换为 Filestream。此流被传递给 CSVReader 以进行进一步的工作。现在它为最后一行最后一列抛出错误。它仅在保存并从数据库中读取后才会发生。我收到以下错误。不知道如何解决这个问题。

“CSV 在位置 '494' 的记录 '9' 字段 '3 附近似乎已损坏。当前原始数据：'

听到的是代码将文件转换为字节数组.....

try
{
     fs = new FileStream(filepath, FileMode.Open);
     fsbuffer = new byte[fs.Length];
     fs.Read(fsbuffer, 0, (int)fs.Length);
}

从 DB 读取到字节数组......

myobject.FileByteArray = ObjectToByteArray(row);

public byte[] ObjectToByteArray(DataRow row)
        {
            if (row["fileBytearray"] == null)
                return null;
            try
            {
                BinaryFormatter bf = new BinaryFormatter();
                System.IO.MemoryStream ms = new System.IO.MemoryStream();

                bf.Serialize(ms, row["fileBytearray"]);
                return ms.ToArray();
            }
    }

Stream fileStream = new MemoryStream(myobject.FileByteArray)
using (CsvReader csv = 
                        new CsvReader(new StreamReader(fileStream, System.Text.Encoding.UTF7), hasHeader, ','))
4

1 回答 1

2

我无法重新创建您的问题，因此，由于从头到尾没有看到保存和加载，我建议尝试以下方法进行检索：

public MemoryStream LoadReportData(int rowId)
{

  MemoryStream stream = new MemoryStream();

  using (BinaryWriter writer = new BinaryWriter(stream))
  {

    using (DbConnection connection = db.CreateConnection())
    {
      DbCommand selectCommand = "SELECT CSVData FROM YourTable WHERE Id = @rowId";

      selectCommand.Connection = connection;

      db.AddInParameter(selectCommand, "@rowId", DbType.Int32, rowId);
      connection.Open();

      using (IDataReader reader = selectCommand.ExecuteReader(CommandBehavior.SequentialAccess))
      {

        while (reader.Read())
        {

          int startIndex = 0;
          int bufferSize = 8192;

          byte[] buffer = new byte[bufferSize];

          long retVal = reader.GetBytes(0, startIndex, buffer, 0, bufferSize);

          while (retVal == bufferSize)
          {

            writer.Write(buffer);
            writer.Flush();

            startIndex += bufferSize;
            retVal = reader.GetBytes(0, startIndex, buffer, 0, bufferSize);

          }

          writer.Write(buffer, 0, (int)retVal);
        }

      }

    }
  }

  return stream;

}

您需要将 selectCommand sql 和参数替换为您用于返回数据的任何 sql。

此方法使用 aSqlDataReader从适当的行（在我的示例中由 rowId 标识）和列（CSVData在我的示例中调用）顺序读取字节，这应该避免在退出时出现任何截断问题（可能是您的 DataTable 对象仅返回第一个n字节）。MemoryStream 对象可用于将 CSV 文件重新保存到文件系统以进行测试，或直接馈送到您的 CSVReader。

如果您可以发布您的Save方法（您实际上将数据保存到数据库中），那么我们也可以检查它以确保那里也不会发生截断。

我现在可以提出的另一个建议是将文件加载到byte数组中。如果您要一次性加载文件，那么您可以简单地替换：

try
{
     fs = new FileStream(filepath, FileMode.Open);
     fsbuffer = new byte[fs.Length];
     fs.Read(fsbuffer, 0, (int)fs.Length);
}

和

byte[] fileBytes = File.ReadAllBytes(filepath);
于 2012-10-15T08:48:49.010 回答