Работа с объектами большого объема в MS SQL и ADO
stream.Read(b, 0, CInt(stream.Length))
'Создание и подготовка к вызову хранимой процедуры
Dim cmd As New SqlClient.SqlCommand("AddBlob", conn)
With cmd
.CommandType = CommandType.StoredProcedure
.Parameters.Add("@img", SqlDbType.Image)
With .Parameters("@img")
.Direction = ParameterDirection.Input
.Value = b
End With
'Вызов хранимой процедуры
.ExecuteNonQuery()
End With
sb.Text = "Ready"
End If
Все выглядит достаточно просто, и если учитывать, что весь мусор уберет GC, жизнь становится совсем легкой.
А что, если у вас уже есть изображение (скажем, в объекте PictureBox) и вам нужно сохранить его в базу? В этом случае нужно использовать другой поток – MemoryStream. Вот как это может быть сделано:
|
sb.Text = "connecting to database..." sb.Refresh() 'Если соединение не открыто, открываем If conn.State <> ConnectionState.Open Then conn.Open() End If sb.Text = "loading image..." sb.Refresh() 'Создание и подготовка к вызову хранимой процедуры Dim cmd As New SqlClient.SqlCommand("AddBlob", conn) cmd.CommandType = CommandType.StoredProcedure 'Сохранение изображения в поток в памяти в формате BMP Dim stream As New MemoryStream() img1.Image.Save(stream, Imaging.ImageFormat.Bmp) stream.Seek(0, SeekOrigin.Begin) 'Подготовка параметров cmd.Parameters.Add("@img", SqlDbType.Image) With cmd.Parameters("@img") .Direction = ParameterDirection.Input 'Воспользуемся удобным методом ToArray. Жалко что его нет у FileStream-a .Value = stream.ToArray() End With 'Вызов хранимой процедуры cmd.ExecuteNonQuery() sb.Text = "Ready" |
Теперь рассмотрим случай, когда нужно извлекать изображение из базы с помощью ADO.NET. Последовательность действий может быть такой:
Открыть соединение.
Подготовить команду (SqlCommand).
Заполнить SqlDataReader – аналог ADO Recordset в очень урезанном варианте.
Считать данные в MemoryStream.
Загрузить Image из потока.
Перед чтением данных из DataReader-а необходимо вызвать метод Read. Вот реализация:
|
sb.Text = "connecting to database..." sb.Refresh() 'Установка соединения If conn.State <> ConnectionState.Open Then conn.Open() End If sb.Text = "Loading image..." sb.Refresh() 'Подготовка запроса на выборку данных Dim cmd As New SqlClient.SqlCommand("select img from blob_test where id = 3", conn) 'Создание и заполнение объекта DataReader Dim reader As SqlDataReader = cmd.ExecuteReader() Dim ms As New MemoryStream() 'Переход на первую строку reader.Read() Dim bb() As Byte bb = reader.Item("img") 'Запись данных в поток в памяти ms.Write(bb, 0, CInt(bb.Length)) ms.Seek(0, SeekOrigin.Begin) 'Загружаем графическое изображение в Image pb.Image = Image.FromStream(ms) sb.Text = "Ready" |
Если нужно читать данные порциями, а не целиком, как это сделано в примере, воспользуйтесь методом GetBytes, который аналогичен ADO-методу GetChunk. Однако если объем данных очень велик, это не сильно поможет, так как они передаются клиенту все сразу в момент вызова метода Read. Для того чтобы данные передавались на клиента только по запросу, необходимо передать в качестве параметра метода ExecuteReader флаг CommandBehavior.SequentialAccess. В этом случае данные будут считываться непосредственно в момент вызова GetBytes.
|
ПРИМЕЧАНИЕ Для этого флага есть одно замечание. Если вы выбираете несколько полей, считывать их значения вы должны в той последовательности, в которой они возвращаются из базы. Видимо поэтому флаг называется «Последовательный доступ». |
Я знаю, что многие не любят хранимые процедуры.
Действительно, для использования хранимых процедур вы должны быть более-менее
знакомы с T-SQL и знать общие принципы работы с реляционными БД. Кроме этого,
считается, что архитектура, в которой слишком большой упор сделан на вынесение
логики на уровень SQL Server-а, имеет ряд недостатков: плохое масштабирование,
сложное сопровождение и отладка. Отчасти все это правда, однако лично я все же
стараюсь использовать хранимые процедуры везде, где возможно, и лишь в тех
случаях, когда бизнес-логика действительно сложна и требует взаимодействия
нескольких бизнес-компонентов, отказываюсь от их использования. Тем, кто не
хочет использовать хранимые процедуры для обновления больших объектов, я
советую прочитать статью 
support.microsoft/default.aspx?scid=kb;en-us;Q309158&ID=kb;en-us;Q309158,
в которой излагается метод чтения и записи больших объектов с помощью DataSet.
Последнее, на чем я бы хотел остановиться, и что вызывает наибольшее количество проблем у начинающих программистов это работа с большими объектами в Oracle. Традиционно этот вопрос довольно сложен: в про-дотнетовскую эру доступ к СУБД Oracle с помощью OLEDB-провайдеров в основном обеспечивали две библиотеки: MSDAORA и OraOLEDB.
Провайдер MSDAORA – предоставлял слабый сервис (нельзя было, например, узнать количество строк в выборке) и не позволял работать с большими объектами в принципе. Единственным достоинством данного провайдера является то, что он входит в стандартный пакет MDAC – Microsoft Data Access Components.
Провайдер OraOLEDB – родной провайдер, который предоставлял большую функциональность, чем MSDAORA, и позволял работать с большими объектами.
|
ПРИМЕЧАНИЕ В Oracle, как и в MS SQL, большие текстовые данные отличаются от больших бинарных данных. Первые называются CLOB и NCLOB – Character Large OBjects, вторые – BLOB – Binary Large OBjects. Аналогию с типами MS SQL провести несложно. |
Получать и изменять данные с помощью объекта Recordset можно точно так же, как и в случае MS SQL Server-а. Пример я приводил выше. Единственная проблема связана с передачей больших объектов в качестве параметров хранимых процедур. Для того чтобы это работало, необходимо в объекте Command установить динамический параметр SPPrmsLOB в TRUE.
Я не буду подробно и с примерами останавливаться на работе с этими провайдерами, вместо этого сосредоточившись на управляемом ADO.NET провайдере. Если у вас будут вопросы, обратитесь к документации или, если совсем плохо будет, задайте вопрос в нашем форуме по базам данных.
Провайдер для ADO.NET не поставляется с .NET Framework
1.0, его нужно устанавливать вручную. Скачать последнюю версию можно по адресу microsoft/downloads/details.aspx?familyid=4f55d429-17dc-45ea-bfb3-076d1c052524&languageid=f49e8428-7071-4979-8a67-3cffcb0c2524&displaylang=en.
Вводную информацию об использовании этого провайдера в
ASP.NET-приложениях можно получить из статьи msdn.microsoft/vstudio/using/building/default.aspx?pull=/library/en-us/dndotnet/html/manprooracperf.asp.
Следующий пример демонстрирует методы работы с большими объектами с помощью управляемого провайдера. Для его правильной работы вам необходимо подключить сборку System.Data.OracleClient.dll.
|
Sub FillDBFromStream(stream as Stream, UserName as String) 'Открываем соединение Dim con As New OracleClient.OracleConnection("server=srv;Uid=u;pwd=p") 'Создаем запрос с одним параметром username Dim da As New OracleClient.OracleDataAdapter("select * from USERS_STATE where USERNAME = :username", con) 'Добавляем параметр и устанавливаем его значение da.SelectCommand.Parameters.Add("username", Data.OracleClient.OracleType.VarChar).Value = UserName Dim ds As New DataSet() 'Объект CommandBuilder необходим для обновления данных Dim cb As New OracleClient.OracleCommandBuilder(da) 'Производим выборку da.Fill(ds, "UState") 'Считываем данные из потока во внутренний массив Dim b() as Byte ReDim b(CInt(ms.Length)) stream.Read(b, 0, CInt(stream.Length)) 'Если выборка пуста, создаем новую запись If ds.Tables("UState").Rows.Count = 0 Then 'Создание записи Dim dr As DataRow = ds.Tables("UState").NewRow() dr("username") = UserName dr("b_state") = b 'Добавление записи ds.Tables("UState").Rows.Add(dr) Else 'Обновление записи Dim dr As DataRow = ds.Tables("UState").Rows(0) dr("b_state") = b End If 'Изменения записываем в базу da.Update(ds, "UState") End Sub |
Надо сказать, что этот способ будет работать, только если в таблице имеется первичный ключ. В моем случае, логичнее всего он смотрится на поле username. При отсутствии ключа в момент выполнения команды Update вы получите следующую ошибку:
| Dynamic SQL generation for the UpdateCommand is not supported against a SelectCommand that does not return any key column information. |
В документации по Oracle утверждается, что обновление данных лучше производить в явных транзакциях.
|
ПРИМЕЧАНИЕ По умолчанию соединение открывается в режиме неявной транзакции, в котором транзакция начинается в момент выполнения первой команды после окончания предыдущей транзакции. Этот режим аналогичен установке SET IMPLICIT_TRANSACTIONS ON в MS SQL Server. |
Это связано с тем, что транзакция, в контексте которой
производится обновление, автоматически подтверждается в момент выполнения
команды Update. Так что если вы затем захотите отменить изменения – это вам так
просто не удастся сделать. Проблема решается с помощью объекта Transaction,
пример использования которого, как и пример сохранения больших данных с помощью
хранимых процедур, можно найти по адресу support.microsoft/default.aspx?scid=kb;EN-US;Q322796.
Ну вот, пожалуй, и все. Буду рад, если эта статья помогла вам в работе с большими объектами.