РЕДАКТИРОВАТЬ: После еще нескольких испытаний эта ошибка напрямую связана с СЧАСТЛИВОЙ. Когда я вынул его из стека, он работал как положено.
Я боролся с этой проблемой в течение нескольких дней. Этот код работает для файлов CSV меньшего размера (25 КБ), но как только вы попытаетесь сделать файлы большего размера (5000 КБ), он выдает исключение.
Мой стек - это приведенный ниже код из ядра asp. net 3.0, NPG SQL 4.1.1, для СЧАСТЛИВОГО, к экземпляру PostgreSQL 12.
Вот код:
string query = "COPY " + seedingDataApi.tableName + " FROM STDIN CSV ENCODING 'UTF8' QUOTE '\"'; ";
using (var conn = postgresContext.GetDBConnectionPG())
{
conn.Open();
using (var writer = conn.BeginTextImport(query))
{
_logger.LogInformation("Text import started");
using (StreamReader sr = new StreamReader(seedingDataApi.tableName + ".csv"))
{
_logger.LogInformation("Read stream started.");
while (!sr.EndOfStream)
{
string testString = "";
testString = sr.ReadLine();
while ("<EOL>" != testString.Substring(Math.Max(0, testString.Length - 5)))
{
testString += sr.ReadLine();
}
testString = testString.Remove(testString.Length - 5);
writer.WriteLine(testString);
}
}
}
}
Исключение, выданное приложением:
System.Exception: Npgsql.NpgsqlException (0x80004005): Exception while reading from stream
---> System.IO.EndOfStreamException: Attempted to read past the end of the stream.
at Npgsql.NpgsqlReadBuffer.<>c__DisplayClass34_0.<<Ensure>g__EnsureLong|0>d.MoveNext()
at Npgsql.NpgsqlReadBuffer.<>c__DisplayClass34_0.<<Ensure>g__EnsureLong|0>d.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
at Npgsql.NpgsqlConnector.<>c__DisplayClass160_0.<<DoReadMessage>g__ReadMessageLong|0>d.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
at Npgsql.NpgsqlConnector.<>c__DisplayClass160_0.<<DoReadMessage>g__ReadMessageLong|0>d.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
at Npgsql.NpgsqlConnector.ReadMessage(DataRowLoadingMode dataRowLoadingMode)
at Npgsql.NpgsqlRawCopyStream..ctor(NpgsqlConnector connector, String copyCommand)
at Npgsql.NpgsqlConnection.BeginTextImport(String copyFromCommand)
at MiniAppApiServer.Repositories.TableSeedRepo.TableSeedRepository.SeedTableDataAsync(TableSeedDataParams seedingDataApi, CancellationToken ct) in /source/MiniAppApiServer/Repositories/TableSeedRepo/TableSeedRepository.cs:line 306System.IO.EndOfStreamException: Attempted to read past the end of the stream.
at Npgsql.NpgsqlReadBuffer.<>c__DisplayClass34_0.<<Ensure>g__EnsureLong|0>d.MoveNext()
at MiniAppApiServer.Repositories.TableSeedRepo.TableSeedRepository.SeedTableDataAsync(TableSeedDataParams seedingDataApi, CancellationToken ct) in /source/MiniAppApiServer/Repositories/TableSeedRepo/TableSeedRepository.cs:line 339
at MiniAppApiServer.Supervisors.TableSeedSupervisor.TableSeedSupervisor.SeedTableDataAsync(Stream data, String tablename, CancellationToken ct) in /source/MiniAppApiServer/Supervisors/TableSeedSupervisor/TableSeedSupervisor.cs:line 86
at MiniAppApiServer.Controllers.TableSeedingController.PostTableDataSeed(IFormFile file, CancellationToken ct) in /source/MiniAppApiServer/Controllers/TableSeedingController.cs:line 114
Большое спасибо!