当前位置导航:炫浪网>>网络学院>>编程开发>>MsSQL教程

用OleDbCommand更新SQL Server的二进制文件


  利用ADO.NET中的OleDbConnection\OleDbCommand 可以方便的对SQL Server中的二进制文件进行更新操作,下面是详细的代码演示
  
  演示环境:
  数据库机器名 :s_test
  登陆名 :sa
  密码 :7890
  数据库名 db_test
  
  下面建立一个表: 
  create table tb_test(id int identity(1,1),photo image ,constraint pk_tb_test primary key(id)) 
  
  一、将硬盘上的文件保存至数据库(C#)
  //----------------------------------------------------------
  //----------------------------------------------------------
  //下面的示例将c:\1.txt文件保存至数据库的tb_test表中
  //----------------------------------------------------------
  //----------------------------------------------------------
  
  using System;
  using System.IO;?
  using System.Data;
  using System.Data.OleDb;
  
  class image_test
  {
  [STAThread]
  static void Main(string[] args)
  {
  try
  {
  //初始化OleDbConnection和OleDbCommand
  OleDbConnection cn = new OleDbConnection("provider=sqloledb;server=s_test;user id=sa;password=7890;initial catalog=db_test");
  OleDbCommand cmd = new OleDbCommand("INSERT tb_test(photo) VALUES(?)",cn);
  
  //打开文件
  FileStream fs = new FileStream("c:\\1.txt", FileMode.Open, FileAccess.Read);
  Byte[] b = new Byte[fs.Length];
  fs.Read(b, 0, b.Length);
  fs.Close();
  
  //打开连接
  OleDbParameter prm = new OleDbParameter("@photo",OleDbType.VarBinary ,b.Length,?
  ParameterDirection.Input, false, 0, 0, null,DataRowVersion.Current, b);
  cmd.Parameters.Add(prm);
  cn.Open();
  
  //执行
  if (cmd.ExecuteNonQuery() == 1)
  Console.WriteLine("OK");
  else
  Console.WriteLine("Fail");?
  cn.Close();
  }
  catch(Exception ex)
  {
  Console.WriteLine(ex.Message );
  }
  }
  }?
  
  二、更新数据库中保存的文件
  //----------------------------------------------------------
  //----------------------------------------------------------
  //下面的示例用将数据库的tb_test表中ID=1的记录的photo更新为c:\1.txt
  //----------------------------------------------------------
  //----------------------------------------------------------
  
  using System;
  using System.IO;?
  using System.Data;
  using System.Data.OleDb;
  
  class image_test
  {
  [STAThread]
  static void Main(string[] args)
  {
  try
  {
  //初始化OleDbConnection和OleDbCommand
  OleDbConnection cn = new OleDbConnection("provider=sqloledb;server=s_test;user id=sa;password=7890;initial catalog=db_test");
  OleDbCommand cmd = new OleDbCommand("UPDATE tb_test SET photo= ? WHERE ID=1",cn);
  
  //打开文件
  FileStream fs = new FileStream("c:\\1.txt", FileMode.Open, FileAccess.Read);
  Byte[] b = new Byte[fs.Length];
  fs.Read(b, 0, b.Length);
  fs.Close();
  
  //打开连接
  OleDbParameter prm = new OleDbParameter("@photo",OleDbType.VarBinary ,b.Length,?
  ParameterDirection.Input, false, 0, 0, null,DataRowVersion.Current, b);
  cmd.Parameters.Add(prm);
  cn.Open();
  
  //执行
  if (cmd.ExecuteNonQuery() == 1)
  Console.WriteLine("OK");
  else
  Console.WriteLine("Fail");?
  cn.Close();
  }
  catch(Exception ex)
  {
  Console.WriteLine(ex.Message );
  }
  }
  }
相关内容
赞助商链接