關于文件保存到Oracle中BLOB字段的方法及例子

-------------------------------------------

public class FileOpClass

{

public static byte[] GetFileStream(string filepath)

{

byte[] byteArray = null;

FileStream fs = null;

try

{

fs = new FileStream(filepath, FileMode.Open);

long filelength = fs.Length;

byteArray = new byte[filelength];

fs.Read(byteArray, 0, byteArray.Length);

}

catch (Exception ee)

{

}

finally

{

if (fs != null)

{

fs.Close();

fs.Dispose();

fs = null;

}

}

return byteArray;

}

public static void WriteToFile(byte[] byteArray, string filepath)

{

if (System.IO.File.Exists(filepath) == true)

{

try

{

System.IO.File.Delete(filepath);

}

catch { }

}

FileStream fs = null;

try

{

fs = new FileStream(filepath, FileMode.OpenOrCreate);

fs.Write(byteArray, 0, byteArray.Length);

fs.Flush();

}

catch (Exception ee)

{

}

finally

{

if (fs != null)

{

fs.Close();

fs.Dispose();

fs = null;

}

}

}

}

//------------------------------------------

先插入一條objblob字段為空的記錄，用insert into tablename(objid,objname) values('xxx','yyyy');

然后對objblog字段作update方式操作

//------------------------------------------

byte[] byteArray =FileOpClass.GetFileStream(path);

object UpdateBLOBFdValue=byteArray;

//------------------------------------------

//更新BLOB字段值的方法

//------------------------------------------

public bool UpdateBLOBFieldValue(string UpdateTableName, string UpdateBLOBFieldName, object UpdateBLOBFdValue, string WhereEqFieldName, string WhereEqFdValue)

{

bool rbc = false;

DatabaseHelperClass dbh = new DatabaseHelperClass(m_Database);

DbConnection dbconn = null;

DbTransaction dbtrans = null; //Provider=OraOleDb.Oracle;

DbCommand dbCmd1 = null;

try

{

dbconn = dbh.db.CreateConnection();

if (dbconn.State != ConnectionState.Open)

{

dbconn.Open();

}

dbtrans = dbconn.BeginTransaction();

string PrixChar = dbh.PrixChar;

string x = "update " + UpdateTableName + " set " + UpdateBLOBFieldName + "=" + PrixChar + "Img where " + WhereEqFieldName + "=" + PrixChar + "tmpguid ";

byte[] byteArray = UpdateBLOBFdValue as byte[];

//

dbCmd1 = dbconn.CreateCommand();

dbCmd1.CommandText = x;

dbCmd1.CommandType = CommandType.Text;

dbCmd1.Connection = dbconn;

dbCmd1.Transaction = dbtrans;

//

DbParameter dbparam = dbh.CreateParameter("" + PrixChar + "Img", byteArray);

dbparam.Direction = ParameterDirection.Input;

dbparam.DbType = System.Data.DbType.Binary;

dbparam.Value = byteArray;

dbCmd1.Parameters.Add(dbparam);

dbCmd1.Parameters.Add(dbh.CreateParameter("" + PrixChar + "tmpguid", WhereEqFdValue));

if (dbCmd1.ExecuteNonQuery() > 0)

{

rbc = true;

dbtrans.Commit();

}

}

catch (Exception ee)

{

if (dbtrans != null)

{

dbtrans.Rollback();

}

rbc = false;

}

finally

{

if (dbCmd1 != null)

{

dbCmd1.Dispose();

dbCmd1 = null;

}

//----

if (dbtrans != null)

{

dbtrans.Dispose();

dbtrans = null;

}

if (dbconn != null)

{

dbconn.Dispose();

dbconn = null;

}

}

return rbc;

}

----the---end-------