C# 读取和写入oracle的blob字段的方法

//向数据库中写入

private void button1_Click(object sender, EventArgs e)
{
oracleConnection1.Open();

OracleCommand cmd = new OracleCommand("UPDATE TEST SET F2 =:blob where F1=:sn ", oracleConnection1);

cmd.Parameters.Add(new OracleParameter("blob",OracleType.Blob));
cmd.Parameters.Add(new OracleParameter("sn",OracleType.Int32));
FileInfo fi = new FileInfo("c://dos.doc");
FileStream fs = fi.OpenRead();
byte[] MyData = new byte[fs.Length];
fs.Read(MyData, 0, System.Convert.ToInt32(fs.Length));
fs.Close();
cmd.Parameters["blob"].Value = MyData;
cmd.Parameters["sn"].Value = 1;
try
{
int result = cmd.ExecuteNonQuery();
if (result < 1)
{
System.Console.WriteLine("插入数据错误！");
}
else
System.Console.WriteLine("插入数据成功！");
}
catch (Exception e1)
{
System.Console.WriteLine("插入数据错误！"+e1.ToString());
}
finally
{
oracleConnection1.Close();
}

}
//从数据库中读取
private void button2_Click(object sender, EventArgs e)
{
oracleConnection1.Open();
oracleCommand1.CommandText = "select * from TEST where f1=1";
OracleDataReader rs = oracleCommand1.ExecuteReader();
while (rs.Read())//读取数据，如果odr.Read()返回为false的话，就说明到记录集的尾部了
{
byte[] File=(byte[])rs["F2"];
FileInfo fi=new FileInfo("c://new.doc");
FileStream fs=fi.OpenWrite();
fs.Write(File,0,File.Length);
fs.Flush();
fs.Close();

}
rs.Close();
}