C#操作Oracle中大數據（Blob）

之前在網上搜索C#操作Oracle中大數據的源代碼，找到的文章基本都是一篇，都是沒有提供引用庫的，還是得自己寫一個 - -

代碼如下：

using System;
using System.Data.OracleClient;
using System.Data;
using System.IO;
using System.Windows.Forms;


namespace OraclePDF
{
    public class OracleBlobControl
    {
        private string constr = "data source=xxxx;password=xxxx;persist security info=True;user id=xxxx";
        private string tempFilePath = @"\";
        OracleConnection Conn = null;
        OracleCommand cmd = null;
        /// <summary>
        /// 數據庫連接串
        /// </summary>
        public string Constr
        {
            get { return constr; }
            set { constr = value; }
        }
        /// <summary>
        /// 臨時文件目錄
        /// </summary>
        public string TempFilePath
        {
            get { return tempFilePath; }
            set { tempFilePath = value;}
        }


        /// <summary>
        /// 將文件用blob格式保存在數據庫中 blobName：sql語句中的blobs列名
        /// </summary>
        /// <param name="FilePath"></param>
        /// <param name="sql"></param>
        /// <param name="blobName"></param>
        /// <returns></returns>
        public string SaveBlob(string FilePath,string sql,string  blobName)
        {
           // string sql = "insert into CHY_BLOB_TEST(id,big) values('" + System.DateTime.Now.ToShortTimeString() + "',:a)";
            try
            {
                //文件流
                Byte[] blob = GetblobByFilePath(FilePath);
                //初始化數據庫連接
                init(sql);
                //綁定數據
                OracleParameter param = new OracleParameter(blobName, OracleType.Blob, blob.Length, ParameterDirection.Input, false, 0, 0, null, DataRowVersion.Current, blob);
                cmd.Parameters.Add(param);
                //執行
                cmd.ExecuteNonQuery();

                return "1";

            }
            catch (Exception ex)
            {
                return "err;" + ex.Message;
            }
            finally
            {
                if (Conn != null)
                {
                    Conn.Close();
                }
            }
        }


        /// <summary>
        /// 將數據庫中的blob文件以FileType的格式讀出 sql語句返回的第一個列是blob 返回文件的臨時位置
        /// </summary>
        /// <param name="FileType"></param>
        /// <param name="sql"></param>
        /// <param name="blobName"></param>
        /// <returns></returns>
        public string ReaderBlob(string FileType,string sql)
        {
            //string sql = "SELECT a.big FROM CHY_BLOB_TEST a where a.id = '17:39'";
            try
            {
                //初始化數據庫連接
                init(sql);
                //從數據庫中讀取blob
                Byte[] blob = GetBlobByReader();
                //文件臨時位置
                string filePath = tempFilePath + "OraclePDF_Temp." + FileType;
                SaveTempFile(blob, filePath);
                return filePath;
            }
            catch (Exception e)
            {
                return "SQL Exception: " + e.Message;
            }
            finally
            {
                if (Conn != null)
                {
                    Conn.Close();
                }
            }
        }

        public string ExceSqlReturnOne(string sql)
        {
            try
            {
                //初始化數據庫連接
                init(sql);
                return cmd.ExecuteOracleScalar().ToString();
            }
            catch (Exception e)
            {
                return "-1";
            }
            finally
            {
                if (Conn != null)
                {
                    Conn.Close();
                }
            }
        }


        /// <summary>
        /// 將blob存到臨時文件
        /// </summary>
        /// <param name="blob"></param>
        /// <param name="filePath"></param>
        private static void SaveTempFile(Byte[] blob, string filePath)
        {
            FileStream fs = null;
            //如果存在臨時文件 先刪除
            if (System.IO.File.Exists(filePath))  //打開文件
            {
                System.IO.File.Delete(filePath);
            }
            fs = new FileStream(filePath, FileMode.Create, FileAccess.Write);
            fs.Write(blob, 0, blob.Length);
            fs.Close();
        }

        /// <summary>
        /// 從OracleDataReader獲取blob二進制流
        /// </summary>
        /// <returns></returns>
        private Byte[] GetBlobByReader()
        {
            OracleDataReader odr = cmd.ExecuteReader();
            odr.Read();
            Byte[] blob = null;
            //GetBytes 返回字段中的可用字節數
            //列號 讀取開始位置 要寫入的緩沖區 寫入位置 要讀取的字節數
            blob = new Byte[(odr.GetBytes(0, 0, null, 0, int.MaxValue))];
            odr.GetBytes(0, 0, blob, 0, blob.Length);
            odr.Close();
            return blob;
        }

        /// <summary>
        /// 根據文件地址獲取二進制blob
        /// </summary>
        /// <param name="FilePath"></param>
        /// <returns></returns>
        private static Byte[] GetblobByFilePath(string FilePath)
        {
            System.IO.FileStream fs = new System.IO.FileStream(FilePath, FileMode.Open, FileAccess.Read);
            Byte[] blob = new Byte[fs.Length];
            fs.Read(blob, 0, blob.Length);
            fs.Close();
            return blob;
        }

        /// <summary>
        /// 初始化數據庫連接
        /// </summary>
        private void init(string sql)
        {
            Conn = new OracleConnection(constr);
            Conn.Open();
            cmd = new OracleCommand();
            cmd.Connection = Conn;
            cmd.CommandText = sql;
        }



    }
}

 

好像通用性還是不夠，果然還是新手做給自己用的東西。