程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> SqlServer數據庫 >> 關於SqlServer >> 用OleDbCommand更新SQLServer的二進制文件

用OleDbCommand更新SQLServer的二進制文件

編輯:關於SqlServer
利用ADO.Net中的OleDbConnectionOleDbCommand 可以方便的對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 );
  }
  }
  }

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved