Зачем нужен Stream в C#?

Question

[beduin01]

Потребовалось мне тут на C# написать крохотное приложение. Задача -- прочитать блоб из одной БД и записать в другую (тоже в блоб).

C# знаю лишь поверхностно. Мне не понятен такой момент. Почему во всех примерах используются какие-то Streams?

byte[] userBlob;

                myCommand.CommandText = "SELECT id, userblob FROM USERS";
                myCommand.Connection = myFBConnection;
                myCommand.Transaction = myTransaction;

                FbDataReader reader = myCommand.ExecuteReader();
                
                try
                {
                    while(reader.Read())
                    {
                        Console.WriteLine(reader.GetString(0));
                        userBlob = // Вот тут что должно быть? Читать как биты или поток

                    }
                }

                catch (Exception e)
                {
                    Console.WriteLine(e.Message);
                    Console.WriteLine("Can't read data from DB");
                }

БД. FireBird.

Вроде бы мне метод `reader.GetBytes` нужен, так?

Попробовал так:

userBlob = reader.GetBytes(0,0,userBlob,0,userBlob.Length);

Но не могу понять зачем в параметры метода нужно передавать еще раз userBlob если в него читаются данные.
И оно кстати ругается: Cannot convert type long to byte[]

тут еще как я понимаю размерность буфера предполагается указывать -- вопрос, а как узнать то сколько данных будет в самом блобе?

Comments

[VZVZ]

В языке D, видимо, нет потоков Stream, вот на нем пиши, он луДший.

И еще зачем тебе база данных? Что это за изврат? Что за зоопарк - SQL и C# в одном флаконе? Может тебе еще и redis добавить для разнообразия? Ты уж определись или работать с базой данных и писать всё только на SQL, или на C# и никаких баз данных, вали всё тупо в файлы.

[beduin01]

VZVZ: Мне именно БД нужна. К сожалению без вариантов.

[VZVZ]

beduin01: а я говорю что тебе D нужен он луДший и он луДше чем SQL так что выкень свой SELECT в корзину.

[beduin01]

VZVZ: тебе по существу нечего сказать? На чем надо на том и пишу.

[VZVZ]

beduin01: Мне есть что сказать по существу то что я не знаю эти BLOB и не хочу знать потому что они ненужны.
MySQL с PostgreSL гемора много. А плюсов внятных лично для себя не нашел.
И во обще с реляционными БД лучше не связываться -- неудобно будет хранить информацию разношерстую.
Как вариант смотрите на arangodb.com и https://www.rethinkdb.com/
А еще в свое время на D был написан самый быстрый парсер XML.

Answer 1

[Станислав Макаров]

GetBytes возвращает long, не знаю где вы нашли, что он возвращает массив байт:
https://msdn.microsoft.com/ru-ru/library/system.da...

Так что передача буфера третьим параметром более чем логична.

И оно кстати ругается: Cannot convert type long to byte[]

Да ладно вам?) А это не навело вас... на мысли относительно типа возвращаемого значения?) Вы сами придумали, что он возвращает массив байт?

тут еще как я понимаю размерность буфера предполагается указывать -- вопрос, а как узнать то сколько данных будет в самом блобе?

Ну вот если все таки пройдете в документацию, то ниже вы увидите следующее:

GetBytes возвращает количество доступных байтов в поле.Часто это значение равно точной длине поля.Однако возвращенное число может быть меньше фактической длины поля, если GetBytes уже использовался для получения байтов из поля.

При передаче буфера, значение которого равно null, метод GetBytes возвращает длину строки в байтах.

Поэтому, если вы не знаете длину буфера - вызовите метод с null для получения этой длины, создайте буфер и поместите туда значение вторым вызовом GetBytes.
В .net и C# нормальная документация, ее полезно читать.

Почему во всех примерах используются какие-то Streams?

Потому что BLOB они на то и BLOB, что Large Object. Блоб может быть килобайтовый, а может быть и гигабайтового размера. Гигабайт читать в массив целиком далеко не всегда целесообразно, как правило - вообще не целесообразно.

Стримы - это абстракция в стандартной библиотеке, реализующая концепцию потоковой обработки. Файловый поток не будет загружать 10-гиговый файл в память целиком, если вы прочтете только первый килобайт. С блобами из базы аналогичная ситуация. Даже если конкретно ваш драйвер БД не поддерживает загрузку блоба по частям, в принципе такая практика существует.

Comments

[beduin01]

А вот так прочитать можно? Encoding.ASCII.GetBytes(reader.GetString(0)); ?

[beduin01]

И еще вопрос, что может приводить вот к этой ошибке img.ctrlv.in/img/16/04/14/570fa106de789.png

[Станислав Макаров]

beduin01 зачем пытаться читать как строку то, что не предназначено для чтения в виде строки?

byte[] userBlob = new byte[reader.GetBytes(0, 0, null, 0, 0)];
reader.GetBytes(0, 0, userBlob, 0, userBlob.length);

[Станислав Макаров]

beduin01 вы пытаетесь выполнить одну update-транзакцию параллельно с другой. С FB не работал, не знаю насколько гранулярны там блокировки, возможно что блокируется вся таблица. Что с этим делать, вам лучше почитать в доках по Firebird (я имею в виду, как правильно осуществлять параллельные транзакции). Но сначала сделайте Dispose транзакции - коммита, возможно, только закрепляет транзакцию, но не снимает блокировки, или, например, автоматом начинает новую транзакцию, из-за чего у вас эта новая транзакция остается открытой и держит таблицу/запись в базе заблокированной. Всему, что реализует IDisposable, в том числе через базовые классы, нужно делать Dispose. Чтобы не забыть это делать, и дополнительно структурировать код, ознакомьтесь с оператором using: https://msdn.microsoft.com/ru-ru/library/yh598w02.aspx

[Станислав Макаров]

beduin01 *коммита -> коммит

Answer 2

[MADm]

Cудя по всему вы используете Firebird. Я не могу понять какая именно библиотека используется.
Вот тут смотрели? codeproject могу предположить что нужно получать данные вот так userBlob = reader[номер столбца];
Но советую лучше прочитать документацию по конкретной библиотеке что используете, или использовать другую библиотеку для вашей бд.

Comments

[beduin01]

Да, именно его

[beduin01]

`userBlob = (byte [])reader[1];`

Ошибка: Не удалось привести тип объекта "System.DBNull" к типу "System.Byte[]".

[MADm]

userblob в базе is null? есть там строки с null?

[beduin01]

MADm: да в этом косяк оказывается.

[MADm]

Ну значит проверять на dbnull и забирать что нужно. Вот кстати нашел примеры
www.firebirdsql.org/en/net-examples-of-use