SqlFileStream - функции был передан недопустимый параметр

@AmpiR · Регистрация: 09.05.2015

Author24 — интернет-сервис помощи студентам

Разрабатываю приложение с использованием FILESTREAM на MSSQL 2017.
При создании базы данных включил возможность использования FILESTREAM, создал таблицу по правилам.
Сервер использую локальный.
Запускаю Managment Studio, выполняю следующий скрипт и он работает прекрасно

SQL

1
2
3

INSERT INTO Files(Id, SIZE, FileName, Description, DATA)
SELECT NEWID(), 1254, '1.zip', 'description', BulkColumn
FROM OPENROWSET(BULK 'C:/temp/1.zip', SINGLE_BLOB) AS f;

Пытаюсь напись в приложении следующий код, но вылетает ошибка "функции был передан недопустимый параметр"
Пытаюсь записать тот же файл.
Ошибка вылетает в строке создания var dest = new SqlFileStream(server_path, server_context, FileAccess.Write)
При отладке путь - есть, контекст - 16 байт.
Всё лежит внутри одной транзакции.
Не могу разобраться, в чём может быть проблема...

C#

 
    public Guid add(string file, string description)
    {
            var file_info = new FileInfo(file);
            var entity = new File
            {
                Id = Guid.NewGuid(),
                Description = description,
                FileName = file_info.Name,
                Size = file_info.Length,
            };
 
            _upload(file, entity);
            return entity.Id;
    }
 
    private void _upload(string file, File entity)
        {
            using (TransactionScope ts = new TransactionScope())
            {
                string server_path;
                byte[] server_context;
 
                using (SqlConnection connection = new SqlConnection(MyDbContext.Conn.String()))
                {
                    string sql = @"INSERT INTO Files(Id, Size, FileName, Description) VALUES(@Id, @Size, @FileName, @Description); " +
                        "SELECT Data.PathName(), GET_FILESTREAM_TRANSACTION_CONTEXT() FROM Files WHERE Id = @Id;";
                    using (SqlCommand command = new SqlCommand(sql, connection))
                    {
                        command.Parameters.Add("@Id", SqlDbType.UniqueIdentifier).Value = entity.Id;
                        command.Parameters.Add("@Size", SqlDbType.BigInt).Value = entity.Size;
                        command.Parameters.Add("@FileName", SqlDbType.NVarChar).Value = entity.FileName;
                        command.Parameters.Add("@Description", SqlDbType.NVarChar).Value = entity.Description;
                        connection.Open();
                        using (SqlDataReader reader = command.ExecuteReader())
                        {
                            reader.Read();
                            server_path = reader.GetSqlString(0).Value;
                            server_context = reader.GetSqlBinary(1).Value;
                            reader.Close();
                        }
                    }
 
                    const int BlockSize = 1024 * 4;
 
                    using (var source = new FileStream(file, FileMode.Open, FileAccess.Read))
                    {
                        using (var dest = new SqlFileStream(server_path, server_context, FileAccess.Write))
                        {
                            byte[] buffer = new byte[BlockSize];
                            int bytesRead;
                            while ((bytesRead = source.Read(buffer, 0, buffer.Length)) > 0)
                            {
                                dest.Write(buffer, 0, bytesRead);
                                dest.Flush();
                            }
                            dest.Close();
                        }
                        source.Close();
                    }
                }
                ts.Complete();
            }
        }

@HF · 25.03.2020, 14:47

Честно сказать не понятно что вы творите во второй части.
1) зачем открывается FileStream?

C#

1	using (var source = new FileStream(file, FileMode.Open, FileAccess.Read))

Сам SqlFileStream и есть Stream. Из него читают и пишут.

2) Не понятно что тут вы решили делать

C#

1	using (var dest = new SqlFileStream(server_path, server_context, FileAccess.Write))

Вроде бы вы прочитали из БД файл. Сейчас бы его читать, но нет, вы прямо в прочтённые данные пишите какие-то другие данные. Если вы хотели файл изменить, то зачем сложности с Insert или со чтением какого-то файла?
Вот самый простой пример видимо по работе с этой функцией: читать.

@AmpiR · 04.08.2020, 21:04 **[ТС]**

Как оказалось, проблема была не в коде. Просто надо было настроить в Security в базе данных доступ пользователям. После добавления нужных пользователей, всё заработало как часы.

Правда, до сих пор не знаю как удалить файлы. После удаления записи, они всё равно остаются на диске, хоть в таблице их нет...

@AmpiR 1 / 1 / 0 Регистрация: 09.05.2015 Сообщений: 7
	04.08.2020, 21:04 [ТС]	3
	Как оказалось, проблема была не в коде. Просто надо было настроить в Security в базе данных доступ пользователям. После добавления нужных пользователей, всё заработало как часы. Правда, до сих пор не знаю как удалить файлы. После удаления записи, они всё равно остаются на диске, хоть в таблице их нет... 0