zoukankan      html  css  js  c++  java
  • 使用ADO.NET 和C# 处理BLOB 数据


      使用Microsoft SQL Server 存储和检索数据是一项与大多数应用程序相关的任务。在最近的一个项目中,我提出了一个新的交互手段——大数据类型或者 BLOB。项目必须存储和检索Microsoft Word 文档和图像文件。本文覆盖了使用 ADO.NET 所完成任务的后台部分,后面将会有一期专栏讨论使用 ASP.NET 的前台表现。
      
      什么是 BLOB?
      BLOB 是二进制大对象(binary large object)的首字母缩写,是在 SQL Server 中作为一个单一实体存储的二进制数据集合。BLOB 主要用于保存多媒体对象,比如图像、视频和声音,但是它们还可以存储程序,甚至是代码片断。虽然 SQL Server 支持 BLOB,但不是所有数据都支持。
      
      访问 BLOB 数据
      有几种方法可以用来从 SQL Server 数据库读取数据。首先,你可以逐行读取数据;或者,你可以选择从特定列中读取数据。最简单的方法是访问特定的列,下面我们先讨论这种方法。
      
      读取 BLOB 数据要求工作在字节级。幸运的是,SqlDataReader 对象有一个 GetBytes 方法用于以字节方式访问一个列的数据。一旦字节被读取,它们就可以与一个 FileStream 对象组合,以将 BLOB 对象保存到一个文件中。下面的 C# 代码给出了这个例子:
      
      Byte[] blob = null;
      FileStream fs = null;
      const string sConn = "server=(local);Initial
      Catalog=Northwind;UID=ctester;PWD=password";
      try {
      SqlConnection conn = new SqlConnection(sConn);
      SqlCommand cmd = new SqlCommand("SELECT Picture FROM Categories WHERE
      CategoryName='Builder'", conn);
      cn.Open();
      SqlDataReader sdr = cmd.ExecuteReader();
      sdr.Read();
      
      blob = new Byte[(sdr.GetBytes(0, 0, null, 0, int.MaxValue))];
      sdr.GetBytes[0, 0, blob, 0, blob.Length);
      sdr.Close();
      conn.Close();
      fs = new FileStream("c:\\Builder.doc", FileMode.Create, FileAccess.Write);
      
      fs.Write(blob, 0, blob.Length);
      fs.Close();
      } catch (SqlException e){
      Console.WriteLine("SQL Exception: " + e.Message);
      } catch (Exception e) {
      Console.WriteLine("Exception: "+ e.Message);
      }
      
      这段代码从一个特定的数据单元(行和列的交叉点)中读取一个 BLOB 对象。注意:它(通过 Using 语句)使用了System.Data.SqlClient 和System.IO 命名空间。FileStream 类的 Write 方法被用于将 BLOB 存储到一个本地驱动器中。在这种情况下,我们知道正在处理的是文档和图像文件,所以存储它们有意义。
      
      另外一种场景涉及到读取一个数据库记录行,这条记录中一个列是 BLOB 类型而其它列不是。SqlDataReader 对象的默认行为是,只要可以得到整行数据,就将传入数据以一行记录装载。BLOB 对象的大小使这个方法不兼容,所以它们很难对待。这可以通过SqlCommand 类的ExecuteReader 方法来完成。你可以将CommandBehavior.SequentialAccess 传递给ExecuteReader 方法去修改SqlDataReader 的默认行为,以取代装载成行的数据,它将按其接收数据的顺序装载数据。
      
      使用SequentialAccess 的主要方面是知道字段被访问的顺序。SqlDataReader 的默认行为是允许你访问你想要访问的任何字段,但是SequentialAccess 使你以SqlDataReader 对象返回的顺序访问字段。数据被顺序读取,所以数据在被读取之后,它将不再可用。
      
      在访问 BLOB 字段的数据时,SqlDataReader 类的GetBytes、GetString 和 GetChars 方法可以用来检索数据。GetBytes 和 GetChars 允许你使用 BLOB 字段的数据填充一个数组(它们都返回 long 型数值)。下面的代码展示了它们的使用方法。
      
      SqlConnection conn = null;
      SqlCommand cmd = null;
      SqlDataReader sdr = null;
      FileStream fs = null;
      BinaryWriter bw = null;
      long blob;
      byte[] outBuffer = new byte[255];
      const string sConn = "server=(local);Initial
      Catalog=Northwind;UID=ctester;PWD=password";
      try {
      conn = new SqlConnection(sConn);
      cmd = new SqlCommand("SELECT CategoryID, Picture FROM Categories WHERE
      CategoryName='Builder'",conn);
      conn.Open();
      sdr = cmd.ExecuteReader(CommandBehavior.SequentialAccess);
      while (sdr.Read()) {
      id = sdr.getString(0);
      fs = new FileStream("c:\\Builder.doc", FileMode.OpenOrCreate,
      FileAccess.Write);
      bw = new BinaryWriter(fs);
      blob = sdr.GetBytes(1, startIndex, outBuffer, 0, 255);
      while (blob == 255) {
      bw.Write(outBuffer);
      bw.Flush();
      startIndex += 255;
      bw.Flush();
      bw.Close();
      fs.Close();
      }
      sdr.Close();
      conn.Close();
      } }
      
      存储 BLOB 数据
      检索和保存 BLOB 对象是一个很简单的过程;相反的过程,在 SQL Server 中存储 BLOB 对象,也一样简单。这里我要指出的是,前面的例子中使用了由这个例子中的代码存储到表中的 BLOB 数据(Builder.doc)。
      
      SqlConnection conn =null;
      SqlCommand cmd = null;
      SqlParameter param = null;
      FileStream fs = null;
      const string sConn = "server=(local);Initial
      Catalog=Northwind;UID=ctester;PWD=password";
      try {
      conn = new SqlConnection(sConn);
      cmd = new SqlCommand("UPDATE Categories SET Picture = @Picture WHERE
      CategoryName = 'Seafood'", conn);
      fs = new FileStream("c:\\Builder.doc", FileMode.Open, FileAccess.Read);
      Byte[] blob = new Byte[fs.Length];
      fs.Read(blob, 0, blob.Length);
      fs.Close();
      param = new SqlParameter("@Picture", SqlDbType.VarBinary, blob.Length,
      ParameterDirection.Input, false, 0, 0, null, DataRowVersion.Current, blob);
      cmd.Parameters.Add(param);
      conn.Open();
      cmd.ExecuteNonQuery();
      } catch (SqlException e){
      Console.Write("SQL Exception: " + e.Message());
      } catch (Exception e) {
      Console.Write("Exception: " e.Message());
      }
      
      示例代码从本地文件系统插入一个 Word 文档到数据库中。它与常规的数据库更新操作类似,然而,FileStream 和 Bytes 对象用于处理将 Word 文档插入到数据库中。另外一个变化是使用SqlParameter 对象将 BLOB 插入到数据库字段中。这就允许数据可以直接从内存写出到数据库中。
      
      不是所有的数据都是相等的
      虽然字符串值是开发人员与数据库交互时最常用的数据类型,但是其它数据类型也经常使用,比如数字和 BLOB。在编程时,将将这些对象视为二进制流对待。

  • 相关阅读:
    Python内置函数(14)——delattr
    Python内置函数(13)——complex
    Python内置函数(12)——compile
    Python内置函数(11)——classmethod
    Python内置函数(10)——chr
    Python内置函数(9)——callable
    Python内置函数(8)——bytes
    Python内置函数(7)——bytearray
    Python内置函数(6)——bool
    Python内置函数(4)——ascii
  • 原文地址:https://www.cnblogs.com/88223100/p/1016221.html
Copyright © 2011-2022 走看看