c# 操作文件存入數據庫（以二進制形式存入）

　　在開發的過程中，經常會遇到將文件存入數據庫的形式，一般常用方法是將文件上傳至服務器，數據庫只需保存文件路徑地址即可，但是很多內部window應用並不鏈接網絡都是本地運行服務，那么此時我們存儲文件就需要用到另一種形式，即將文件 FileStream 操作文件流的形式將文件轉為字節存入數據庫，下載時，在對應轉換下載即可。

 

　　本次，我們將提供兩種數據庫的操作方式，PostgresSql 和 Sqlite 兩種數據庫的存儲方式。

 

　　PostgresSql

　　Psql 數據庫提供了存儲字節的類型，即 bytea，所以創建數據庫時，要將對應的字段設置為 bytea

CREATE TABLE tb_flypath 
(  
    ID SERIAL PRIMARY KEY ,
    FileName TEXT NOT NULL,
    FileContent bytea NOT NULL,
    CreateTime timestamp(6) NOT NULL DEFAULT CURRENT_TIMESTAMP
)

　　那么，設置為 bytea 后就可以將文件轉為字節進行存儲了，使用以下代碼

        /// <summary>
        /// 將文件轉為字節
        /// </summary>
        /// <param name="path">文件路徑</param>
        /// <returns></returns>
        public byte[] getContent(string path)
        {
            System.IO.FileStream fs = new System.IO.FileStream(@path, System.IO.FileMode.Open);
            fs.Position = 0;
            byte[] content = new byte[fs.Length];
            fs.Read(content, 0, (int)fs.Length);
            fs.Close();
            return content;
        }

　　我們直接使用 SQL 語句，將字節轉為字符串存入數據庫

        /// <summary>
        /// 字節轉字符串
        /// </summary>
        /// <param name="inputBytes">字節</param>
        /// <returns></returns>
        public string ByteToString(byte[] inputBytes)
        {
            StringBuilder temp = new StringBuilder(2048);
            foreach (byte tempByte in inputBytes)
            {
                temp.Append(tempByte > 15 ?
                Convert.ToString(tempByte, 2) : '0' + Convert.ToString(tempByte, 2));
            }
            return temp.ToString();
        }

        string bstr = ByteToString(buffer);
        string insertSql = string.Format(@"INSERT INTO tb_flyPath (FileContent) VALUES ('{0}')", bstr);

　　以上就是將文件寫入數據庫的操作，但是，如果采用此方法的話，就會有問題，因為 INSERT SQL 無法識別字節的類型，所以我們是將字符串存入了對應字節類型的字段里。

　　那么后續遇到的問題是，下載文件時，無論如何轉換 FileContent 都無法將下載的文件打開，如果是文本的話，則出現的內容為已轉換的二進制數據。

　　至於為什么會出現這樣，還沒研究透，歡迎留言。

　　所以，我又采取了以下的方式進行數據存儲，使用數據庫 Parameter 參數執行SQL，這種方法可以將你傳入的數據直接轉為對應的類型  DbType.Bytea ，此類型可以傳入字節類型數據進行存儲，使用這種方式后，存入的數據就可以下載后進行轉換使用並打開各種文件了。

        /// <summary>
        /// 文件存儲入表
        /// </summary>
        /// <param name="filePath">文件路徑</param>
        /// <param name="id">節點ID</param>
        /// <returns></returns>
        public bool FileInsert(string filePath, string id)
        {
            string strErrMsg = "";
            //讀取文件 
            FileStream fs = File.OpenRead(filePath);
            byte[] buffer = new byte[fs.Length];
            fs.Read(buffer, 0, buffer.Length);

            if (!CreateCommand(out strErrMsg))
                return false;

            NpgsqlParameter paramFileContent = _Command.CreateParameter();
            paramFileContent.NpgsqlDbType = NpgsqlTypes.NpgsqlDbType.Bytea;
            paramFileContent.ParameterName = "FileContent";
            paramFileContent.Direction = ParameterDirection.Input;
            paramFileContent.Value = buffer;
            _Command.Parameters.Add(paramFileContent);

            NpgsqlParameter paramFileName = _Command.CreateParameter();
            paramFileName.NpgsqlDbType = NpgsqlTypes.NpgsqlDbType.Varchar;
            paramFileName.ParameterName = "FileName";
            paramFileName.Direction = ParameterDirection.Input;
            paramFileName.Value = id;
            _Command.Parameters.Add(paramFileName);

            string sqlInsert = "INSERT INTO tb_flypath (filename,filecontent) VALUES (:FileName, :FileContent)";
            _Command.CommandText = sqlInsert;
            _Command.CommandType = CommandType.Text;

            _Connection.Open();
            int result = _Command.ExecuteNonQuery();
            _Connection.Close();

            return result > 0 ? true : false;
        }

        /// <summary> 
        /// 根據文件名從數據庫中獲取文件 
        /// </summary> 
        /// <param name="fileName">數據庫中的文件名</param> 
        /// <param name="savePath">文件的保存路徑，包括文件名，如D:\test.fly</param> 
        public bool DownloadFile(string fileName, string savePath)
        {
            string strErrMsg = "";

            if (!CreateCommand(out strErrMsg))
                return false;70 
            string sqlSelect = "select filename, filecontent from tb_flypath where filename=:FileName";
            _Command.CommandText = sqlSelect;
            _Command.CommandType = CommandType.Text;

            NpgsqlParameter paramFileName = _Command.CreateParameter();
            paramFileName.NpgsqlDbType = NpgsqlTypes.NpgsqlDbType.Varchar;
            paramFileName.ParameterName = "FileName";
            paramFileName.Direction = ParameterDirection.Input;
            paramFileName.Value = fileName;
            _Command.Parameters.Add(paramFileName);

            _Connection.Open();
            NpgsqlDataReader dr = _Command.ExecuteReader();
            dr.Read();
            byte[] buffer = (byte[])dr["filecontent"];
            dr.Close();
            _Connection.Close();

            //把文件保存到指定路徑 
            File.WriteAllBytes(savePath, buffer);

            return true;
        }

 

　　Sqlite

　　我們在講下 Sqlite 數據庫的操作方式，其實方法都一樣，沒什么太大區別，只是各個數據庫的存儲數據類型不太一樣。

　　Sqlite 提供了 BLOB 類型進行存儲字節數據，所以創建表。

CREATE TABLE tb_flyPath
(
    ID INTEGER primary key autoincrement , 
    FileName VARCHAR not null ,
    FileContent BLOB not null ,
    CreateTime timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP
)

　　那么存取文件的方法大致無區別，PostgresSql 用的是 bytea 類型，那么 Sqlite 這里需要設置為 DbType.Binary 類型。

        /// <summary>
        /// 文件存儲入表
        /// </summary>
        /// <param name="filePath">文件路徑</param>
        /// <param name="id">節點ID</param>
        /// <returns></returns>
        public bool FileInsert(string filePath, string id)
        {
            string strErrMsg = "";
            //讀取文件 
            FileStream fs = File.OpenRead(filePath);
            byte[] buffer = new byte[fs.Length];
            fs.Read(buffer, 0, buffer.Length);

            if (!CreateCommand(out strErrMsg))
                return false;

            SQLiteParameter paramFileContent = _Command.CreateParameter();
            paramFileContent.DbType = DbType.Binary;
            paramFileContent.ParameterName = "FileContent";
            paramFileContent.Direction = ParameterDirection.Input;
            paramFileContent.Value = buffer;
            _Command.Parameters.Add(paramFileContent);

            SQLiteParameter paramFileName = _Command.CreateParameter();
            paramFileName.DbType = DbType.String;
            paramFileName.ParameterName = "FileName";
            paramFileName.Direction = ParameterDirection.Input;
            paramFileName.Value = id;
            _Command.Parameters.Add(paramFileName);

            string sqlInsert = "INSERT INTO tb_flyPath (filename,filecontent) VALUES (:FileName, :FileContent)";
            _Command.CommandText = sqlInsert;
            _Command.CommandType = CommandType.Text;

            _Connection.Open();
            int result = _Command.ExecuteNonQuery();
            _Connection.Close();

            return result > 0 ? true : false;
        }

        /// <summary> 
        /// 根據文件名從數據庫中獲取文件 
        /// </summary> 
        /// <param name="fileName">數據庫中的文件名</param> 
        /// <param name="savePath">文件的保存路徑，包括文件名，如D:\test.fly</param> 
        public bool DownloadFile(string fileName, string savePath)
        {
            string strErrMsg = "";

            if (!CreateCommand(out strErrMsg))
                return false;

            string sqlSelect = "select filename, filecontent from tb_flyPath where filename=:FileName";
            _Command.CommandText = sqlSelect;
            _Command.CommandType = CommandType.Text;

            SQLiteParameter paramFileName = _Command.CreateParameter();
            paramFileName.DbType = DbType.String;
            paramFileName.ParameterName = "FileName";
            paramFileName.Direction = ParameterDirection.Input;
            paramFileName.Value = fileName;
            _Command.Parameters.Add(paramFileName);

            _Connection.Open();
            SQLiteDataReader dr = _Command.ExecuteReader();
            dr.Read();
            byte[] buffer = (byte[])dr["filecontent"];
            dr.Close();
            _Connection.Close();

            //把文件保存到指定路徑 
            File.WriteAllBytes(savePath, buffer);

            return true;
        }

 

　　如有講的不對，歡迎評論留言。