點滴積累【C#】---C#實現上傳word以流形式保存到數據庫和讀取數據庫中的word文件。

本文修改來源：http://www.cnblogs.com/zmgdpg/archive/2005/03/31/129758.html

效果：

數據庫：

思路：

首先保存word到數據庫：獲取上傳文件字節的大小，然后從流中讀取字節，其次把獲得的流保存到數據庫。

讀取數據庫：根據名稱查找出來數據庫中的流數據，然后用讀取器BinaryWriter讀取流文件保存到指定的目錄下面。

代碼：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.IO;
using System.Data.SqlClient;
using System.Configuration;

namespace WordToDB
{
    public partial class WrodToDB : System.Web.UI.Page
    {
        protected void Page_Load(object sender, EventArgs e)
        {

        }

        protected void btn_Click(object sender, EventArgs e)
        {
            /***************保存word到數據庫**********/
            string name = tb1.Text;
            //接收上傳文件
            Stream fileStream = FileUpload1.PostedFile.InputStream;
            //獲取上傳文件字節的大小
            int length = FileUpload1.PostedFile.ContentLength;
            byte[] wordData = new byte[length];
            //從流中讀取字節並寫入wordData
            fileStream.Read(wordData, 0, length);
            //獲取當前時間
            DateTime time = DateTime.Now;
            //連接數據庫
            SqlConnection conn = new SqlConnection();
            conn.ConnectionString = ConfigurationManager.ConnectionStrings["SQLStr"].ToString();
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.CommandText = "INSERT INTO word (fileName,postTime,fileContent) values (@fileName,@postTime,@fileContent)";
            SqlParameter nameParam = new SqlParameter("@fileName", System.Data.SqlDbType.VarChar, 50);
            nameParam.Value = name;
            cmd.Parameters.Add(nameParam);
            SqlParameter timeParam = new SqlParameter("@postTime", System.Data.SqlDbType.DateTime, 8);
            timeParam.Value = time;
            cmd.Parameters.Add(timeParam);
            //添加word文件
            SqlParameter contentParam = new SqlParameter("@fileContent", System.Data.SqlDbType.Image);
            contentParam.Value = wordData;
            cmd.Parameters.Add(contentParam);
            conn.Open();
            int i = cmd.ExecuteNonQuery();
            if (i > 0)
            {
                Response.Write("<script>alert('上傳成功')</script>");
            }
            else
            {
                Response.Write("<script>alert('上傳失敗')</script>");
            }
            conn.Close();
        }

        protected void btn1_Click(object sender, EventArgs e)
        {
            /****************讀取數據庫中的流文件**********************/
            //連接數據庫
            SqlConnection conn = new SqlConnection();
            conn.ConnectionString = ConfigurationManager.ConnectionStrings["SQLStr"].ToString();
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            //根據TextBox中指定的文件名進行查找讀取
            cmd.CommandText = "select fileContent from word where fileName='" + tb1.Text.ToString() + "'";
            FileStream fs;
            BinaryWriter bw;
            //設定允許讀取到緩沖區的最大長度
            int buffersize = 100;
            //要將字節流讀入的緩沖區
            byte[] outbyte = new byte[buffersize];
            //用於記錄已經讀取的字節數
            long reval;
            //字段中的索引，從這里開始讀取操作
            long startIndex;
            //FileStream對象將封裝的文件的相對路徑或絕對路徑
            string filePath = @"C:\" + tb1.Text + ".doc";
            conn.Open();
            SqlDataReader reader;
            reader = cmd.ExecuteReader();
            while (reader.Read())
            {
                fs = new FileStream(filePath, FileMode.OpenOrCreate, FileAccess.Write);
                bw = new BinaryWriter(fs);
                startIndex = 0;
                //將字節流讀入outbyte緩沖區中並返回讀取的字節數
                reval = reader.GetBytes(0, startIndex, outbyte, 0, buffersize);
                //當讀取的字節流達到緩沖區允許的最大長度時要卸載緩沖區內的數據並將數據寫入文件
                while (reval == buffersize)
                {
                    bw.Write(outbyte);
                    bw.Flush();
                    //重新設定開始讀取的位置，並繼續讀取和寫數據
                    startIndex += buffersize;
                    reval = reader.GetBytes(0, startIndex, outbyte, 0, buffersize);
                }
                //將緩沖區內最后剩余的數據寫入文件
                bw.Write(outbyte, 0, (int)reval - 1);
                bw.Flush();
                bw.Close();
                fs.Close();
            }
            if (reader.Read().ToString() != "")
            {
                Response.Write(@"<script>alert('讀取成功! word的位置在：C:\\" + tb1.Text + ".doc')</script>");
            }
            else
            {
                Response.Write("<script>alert('讀取失敗')</script>");
            }
            reader.Close();
            conn.Close();

        }
    }
}