C# 從Excel 批量導入數據庫

最近遇到了關於 C# MVC 批量添加數據的問題，解決后就自己寫了一個未完成的小Demo 

 

 

不管什么編程語言都會提供操作Excel文件的方式，C#操作Excel主要有以下幾種方式：

 

1.Excel   

 

說明：利用Office 的Excel組件來操作excel文件

 

優點：能夠完全操作Excel文件，生成豐富文件內容

 

缺點：需要電腦安裝Excel,會啟動Excel進程這在web上很不方便

 

2.OpenXML

 

說明：一個操作字處理文檔的組件包括Excel

 

優點：能夠操作操作Excel2007版本文件

 

缺點：只能夠操作Excel2007文件

 

3.NPOI

 

說明：一個開源的Excel讀寫庫

 

優點：不需要安裝Excel

 

缺點：只能夠操作Excel2003文檔，對文檔內容控制不完全

 

4.OleDb

 

說明：使用Microsoft Jet 提供程序用於連接到 Excel 工作簿,將Excel文件作為數據源來讀寫

 

優點：簡單快速,能夠操作高版本Excel

 

缺點：只能夠進行有限的操作(讀、寫)

 

 

今天學習使用OleDb操作Excel文件

連接字符串：Provider=Microsoft.Jet.OLEDB.4.0;Data Source=d:\test.xls;Extended Properties='Excel 8.0;HDR=Yes;IMEX=1;'

provider：表示提供程序名稱

Data Source：這里填寫Excel文件的路徑

Extended Properties：設置Excel的特殊屬性

Extended Properties 取值：

Excel 8.0   針對Excel2000及以上版本，Excel5.0 針對Excel97。

HDR=Yes 表示第一行包含列名,在計算行數時就不包含第一行

IMEX   0:導入模式,1:導出模式:2混合模式

 

1.讀取Excel

if (openFileDialog1.ShowDialog() == DialogResult.OK)  
            {  
                String sConnectionString = "Provider=Microsoft.Jet.OLEDB.4.0;" +  
     "Data Source="+openFileDialog1.FileName+";"+  
     "Extended Properties='Excel 8.0;HDR=Yes;IMEX=2'";  
  
                //實例化一個Oledbconnection類(實現了IDisposable,要using)  
                using (OleDbConnection ole_conn = new OleDbConnection(sConnectionString))  
                {  
                    ole_conn.Open();  
                    using (OleDbCommand ole_cmd = ole_conn.CreateCommand())  
                    {  
                        //類似SQL的查詢語句這個[Sheet1$對應Excel文件中的一個工作表]  
                        ole_cmd.CommandText = "select * from [Sheet1$]";  
                        OleDbDataAdapter adapter = new OleDbDataAdapter(ole_cmd);  
                        DataSet ds = new DataSet();  
                        adapter.Fill(ds, "Sheet1");  
                       for (int i = 0; i < ds.Tables[0].Rows.Count; i++)  
                        {  
                            MessageBox.Show(ds.Tables[0].Rows[i]["商家名稱"].ToString());  
                        }  
                    }  
                }  
            }  

 

 

2.獲取工作簿中所有的工作表

if (openFileDialog1.ShowDialog() == DialogResult.OK)  
            {  
                String sConnectionString = "Provider=Microsoft.Jet.OLEDB.4.0;" +  
     "Data Source="+openFileDialog1.FileName+";"+  
     "Extended Properties='Excel 8.0;HDR=Yes;IMEX=2'";  
  
                //實例化一個Oledbconnection類(實現了IDisposable,要using)  
                using (OleDbConnection ole_conn = new OleDbConnection(sConnectionString))  
                {  
                    ole_conn.Open();  
                    using (OleDbCommand ole_cmd = ole_conn.CreateCommand())  
                    {  
                        DataTable tb = ole_conn.GetOleDbSchemaTable(OleDbSchemaGuid.Tables, null);  
                        foreach (DataRow row in tb.Rows)  
                        {  
                            MessageBox.Show(row["TABLE_NAME"].ToString());  
                        }  
                    }  
                }  
            }  

 

3.寫入數據到Excel表

if (openFileDialog1.ShowDialog() == DialogResult.OK)  
            {  
                String sConnectionString = "Provider=Microsoft.Jet.OLEDB.4.0;" +  
     "Data Source="+openFileDialog1.FileName+";"+  
     "Extended Properties=Excel 8.0;";  
  
                //實例化一個Oledbconnection類(實現了IDisposable,要using)  
                using (OleDbConnection ole_conn = new OleDbConnection(sConnectionString))  
                {  
                    ole_conn.Open();  
                    using (OleDbCommand ole_cmd = ole_conn.CreateCommand())  
                    {  
                        ole_cmd.CommandText = "insert into [Sheet1$](商戶ID,商家名稱)values('DJ001','點擊科技')";  
                        ole_cmd.ExecuteNonQuery();  
                        MessageBox.Show("數據插入成功......");  
                    }  
                }  
            }  

 

4.創建Excel文件並寫入數據

String sConnectionString = "Provider=Microsoft.Jet.OLEDB.4.0;" +  
     "Data Source=d:\\excel1.xls;" +  
     "Extended Properties=Excel 8.0;";  
            //實例化一個Oledbconnection類(實現了IDisposable,要using)  
                using (OleDbConnection ole_conn = new OleDbConnection(sConnectionString))  
                {  
                    ole_conn.Open();  
                    using (OleDbCommand ole_cmd = ole_conn.CreateCommand())  
                    {  
                        ole_cmd.CommandText = "CREATE TABLE CustomerInfo ([CustomerID] VarChar,[Customer] VarChar)";  
                        ole_cmd.ExecuteNonQuery();  
                        ole_cmd.CommandText = "insert into CustomerInfo(CustomerID,Customer)values('DJ001','點擊科技')";  
                        ole_cmd.ExecuteNonQuery();  
                        MessageBox.Show("生成Excel文件成功並寫入一條數據......");  
                    }  
                }  

 

 

　　　　1 首先 我們 在前台進行文件的上傳

 

　　　　　　

<div id="bulkDlg" >
    <div class="col-xs-12">
        <form class="form-horizontal" id="bulkForm" enctype="multipart/form-data">

            <div class="form-group">

            </div>

            <div class="form-group">
                <label class="col-sm-3 control-label no-padding-right" for=""> 上傳文件 </label>
                <div class="col-sm-9">
                    <input type="file" id="BulkXls" name="BulkXls" />
                </div>
                <div>
                    <input type="button" id="sub" value="提交" />
                </div>
            </div>

        </form>
    </div>
</div>

 

<script>
    $("#sub").click(function () {
        var formData = new FormData();
        formData.append("BulkXls", document.getElementById("BulkXls").files[0]);

        $.ajax({
            url: "/Home/UploadXls",
            type: "POST",
            data: formData,
            /**
            *必須false才會自動加上正確的Content-Type
            */
            contentType: false,
            /**
            * 必須false才會避開jQuery對 formdata 的默認處理
            * XMLHttpRequest會對 formdata 進行正確的處理
            */
            processData: false,
            success: function (data) {
                //執行成功回調函數
            },
            error: function () {

            }
        });
    }) 
</script>

　　注意：在我們用ajax提交的時候，這里一定得用$.ajax, 不能用$.post（本人試過，post提交為成功！）contentType 和  processData 一定要有 並且必須為false 還有就是 FormData支持高版本瀏覽器 低版本瀏覽器（IE8以上）

 

　　2 后台代碼

　　　　定義一個 方法來接受 前台傳過來的文件，以及解析Excel文件中的內容，並轉換為Dataset

　　        [HttpPost]

public string UploadXls()
        {
            try
            {
                HttpPostedFileBase file = HttpContext.Request.Files["BulkXls"];
                if (file == null)
                {
                    return  "請選擇文件";
                }
                var ext = Path.GetExtension(file.FileName);
                var exts = ",.xls,.xlsx,";
                if (!exts.Contains("," + ext + ","))
                {
                    return "請上傳.xls,.xlsx文件";
                }
                //上傳文件
                var path = HttpContext.Request.MapPath("~/");
                var dir = "/Upload_Files/xls/";
                if (!Directory.Exists(path + dir))
                {
                    Directory.CreateDirectory(path + dir);
                }
                //保存文件
                var fullPath = path + dir + "hotels" + Path.GetExtension(file.FileName);
                file.SaveAs(fullPath);

                var filePath = Server.MapPath("~/Upload_Files/xls/" + "hotels" + Path.GetExtension(file.FileName));
                // 讀取Excel文件到DataSet中
                string connStr = "";
                string fileType = System.IO.Path.GetExtension(filePath);
                if (!string.IsNullOrEmpty(fileType))
                {
　　　　　　　　　　　　//支持文件格式不一樣，Excel有 97-2003及2007格式  分別為 .xls和.xlsx
                    if (fileType == ".xls")
                    { connStr = "Provider=Microsoft.Jet.OLEDB.4.0;" + "Data Source=" + filePath + ";" + ";Extended Properties=\"Excel 8.0;HDR=YES;IMEX=1\""; }
                    else
                    { connStr = "Provider=Microsoft.ACE.OLEDB.12.0;" + "Data Source=" + filePath + ";" + ";Extended Properties=\"Excel 12.0;HDR=YES;IMEX=1\""; }
                    string sql_F = "Select * FROM [{0}]";

                    OleDbConnection conn = null;
                    OleDbDataAdapter da = null;

                    DataSet ds = new DataSet();
                    try
                    {
                        // 初始化連接，並打開
                        conn = new OleDbConnection(connStr);
                        conn.Open();
                        // 初始化適配器
                        da = new OleDbDataAdapter();
                        da.SelectCommand = new OleDbCommand(String.Format(sql_F, "Sheet1$"), conn);
                        DataSet dsItem = new DataSet();
                        da.Fill(dsItem, "t");
                        ds.Tables.Add(dsItem.Tables[0].Copy());
　　　　　　　　　　　　　　//這里的for是循環DataSet中的值並向數據庫中插入
                        for (int i = 0; i < dsItem.Tables[0].Rows.Count; i++)
                        {
　　　　　　　　　　　　　　　　　　
                            var hotelName = dsItem.Tables[0];
　　　　　　　　　　　　　　　　　　//比如我們導入的 Excel表中有 四列
                            if (!_HotelRepository.IsExist(u => u.HotelName == hotelName))
                            { 
　　　　　　　　　　　　　　　　　　　//實例化一個User對象並賦值
                                User model= new User();
　　　　　　　　　　　　　　　　　　  //這里是Excel表格中對應的列
                                model.UserName= dsItem.Tables[0].Rows[i]["用戶名"].ToString();//
                                model.Account= dsItem.Tables[0].Rows[i]["賬號"].ToString();
                                model.Password= dsItem.Tables[0].Rows[i]["密碼"].ToString();
　　　　　　　　　　　　　　　　　　　//執行插入的方法    _UserRepository.Add(model);
                            }
                        }
                    }
                    catch (Exception ex)
                    {

                    }
                    finally
                    {
                        // 關閉連接
                        if (conn.State == ConnectionState.Open)
                        {
                            conn.Close();
                            da.Dispose();
                            conn.Dispose();
                        }
                    }
                }


            }
            catch (Exception ex)
            {

            }
            return "";
        }

 

　　具體的像數據庫插入數據，這里就不多說了，方法有很多

 

注意：在后台讀取解析Excel文件的時候如果遇到  “未在本地計算機上注冊“Microsoft.Ace.OleDb.12.0”提供程序。”  遇到這個問題的時候，請自行百度下載一個 名為 AccessDatabaseEngine.exe的插件     百度直接搜索  “未在本地計算機上注冊“Microsoft.Ace.OleDb.12.0”提供程序。”  也行