Excel导入导出数据库01

主要分为两部份

1.Excel操作类

引入
using System.Data.OleDb;
using System.IO;
using System.Collections;

    /// <summary>
    /// Excel导入导出
    /// </summary>
    public class ExcelToData
    {
        /// <summary>
        /// 无参构造函数
        /// </summary>
        public ExcelToData()
        {
            //
        }
        /// <summary>
        /// 带参构造函数,初始化连接Excel字符串
        /// </summary>
        /// <param name="fileName">文件绝对路径</param>
        public ExcelToData(string fileName)
        {
            this.connStr = "Provider=Microsoft.Jet.OLEDB.4.0;" +
                  "Data Source=" + fileName + ";" +
                  "Extended Properties='Excel 8.0;HDR=No;IMEX=1'";//HDR第一行是否为列名；IMEX=1互混数据列作为文本数据读取。
        }

        private string connStr;
        /// <summary>
        /// 连接Excel字符串
        /// </summary>
        public string ConnStr
        {
            get { return this.connStr; }
            set { this.connStr = value; }
        }
        private List<string> sheets;
        /// <summary>
        /// 得到Excel文件所有Sheets(工作表),使用前请先调用FillSheets（）方法
        /// </summary>
        public List<string> Sheets
        {
            //set {this.sheets =value ;}
            get { return this.sheets; }
        }

        /// <summary>
        /// 得到Excel文件所有Sheets(工作表)
        /// </summary>
        /// <returns>void</returns>
        public List<string> FillSheets()
        {
            sheets = new List<string>();
            OleDbConnection conn = new OleDbConnection(connStr);
            conn.Open();
            DataTable schemaTable = conn.GetOleDbSchemaTable(OleDbSchemaGuid.Tables, new object[] { null, null, null, "TABLE" });
            conn.Close();
            if (schemaTable.Rows.Count > 0)
            {
                foreach (DataRow dr in schemaTable.Rows)
                {
                    if (dr[2].ToString().Substring(0, 1) == "'")
                    {
                        sheets.Add(dr[2].ToString().Substring(1, dr[2].ToString().Length - 2));
                    }
                    else
                    {
                        sheets.Add(dr[2].ToString());
                    }
                }
            }
            return sheets;

        }
        /// <summary>
        /// 根据指定Excel工作表名的指定单元区域读取数据
        /// </summary>
        /// <param name="sheetName">工作表名</param>
        /// <param name="region">单元区域</param>
        /// <returns>DataTable</returns>
        public DataTable GetExcelData(string sheetName, string region)
        {
            string sqlStr = "select * from [" + sheetName + region + "]";
            OleDbDataAdapter ExcelDA = new OleDbDataAdapter(sqlStr, connStr);
            DataSet ds = new DataSet();
            try
            {
                ExcelDA.Fill(ds);
            }
            catch (OleDbException ex)
            {
                throw ex;
            }
            return ds.Tables[0];
        }
        /// <summary>
        /// 根据指定Excel工作表名读取数据
        /// </summary>
        /// <param name="sheetName">工作表名</param>
        /// <returns></returns>
        public DataTable GetExcelData(string sheetName)
        {
            string sqlStr = "select * from [" + sheetName + "]";
            OleDbDataAdapter ExcelDA = new OleDbDataAdapter(sqlStr, connStr);
            DataSet ds = new DataSet();
            try
            {
                ExcelDA.Fill(ds);
            }
            catch (OleDbException ex)
            {
                throw ex;
            }
            return ds.Tables[0];
        }
        /// <summary>
        /// 读取Excel文件所有的sheet工作表中数据到DataSet
        /// </summary>
        /// <returns></returns>
        public DataSet GetAllExcelData()
        {
            if (sheets == null)
            {
                FillSheets();
            }
            string sql = "";
            DataSet ds = new DataSet();
            for (int i = 0; i < sheets.Count; i++)
            {
                sql = "select * from [" + sheets[i].ToString() + "]";
                OleDbDataAdapter ExcelDA = new OleDbDataAdapter(sql, connStr);
                ExcelDA.Fill(ds, sheets[i].ToString());
            }
            return ds;

        }

        /// <summary>
        /// 往Excel文件中批插入数据行,插入时确保该Excel文件存在，且工作表（sheetName)存在。
        /// </summary>
        /// <param name="Htable">键表示插入的列,注意必须用(F1，F2，..)；值表示插入列值，注意与参数dt中的列要一一对应</param>
        /// <param name="dt">要向Excel中插入的datatable</param>
        /// <param name="sheetName">工作表名</param>
        ///   /// <param name="Flag">true,参数Htable键值为参数dt列的索引号;false,为dt列名</param>
        /// <param name="BeginRow">Excel插入开始行,如(A1:C1);无表示从工作表（sheetName)末尾行开始插入</param>
        /// <returns>void</returns>
        public void InsertExcelData(Hashtable Htable, DataTable dt, string sheetName, bool Flag, params string[] BeginRow)
        {
            if (Htable.Count > 0)
            {
                if (dt.Rows.Count > 0)
                {
                    string connStr1 = this.connStr.Replace(";IMEX=1", "");
                    OleDbConnection conn = new OleDbConnection(connStr1);
                    conn.Open();
                    OleDbCommand comm = conn.CreateCommand();
                    StringBuilder sb1 = new StringBuilder(256);
                    StringBuilder sb2 = null;
                    foreach (DictionaryEntry de in Htable)
                    {
                        sb1.Append(de.Key.ToString() + ",");

                    }
                    sb1.Remove(sb1.Length - 1, 1);

                    int colStartID = 0;

                    string[] splitStr = null;
                    if (BeginRow.Length > 0)
                    {
                        splitStr = BeginRow[0].ToString().Split(':');
                        if (Char.IsNumber(splitStr[1].ToString(), 1))
                        {
                            colStartID = int.Parse(splitStr[1].ToString().Substring(1));
                        }
                        else
                        {
                            colStartID = int.Parse(splitStr[1].ToString().Substring(2));
                            splitStr[1] = splitStr[1].Substring(0, 2);
                        }

                    }

                    for (int i = 0; i < dt.Rows.Count; i++)
                    {
                        sb2 = new StringBuilder(256);
                        foreach (DictionaryEntry de in Htable)
                        {
                            if (Flag)
                            {
                                sb2.Append("'" + dt.Rows[i][int.Parse(de.Value.ToString())].ToString() + "',");
                            }
                            else
                            {
                                sb2.Append("'" + dt.Rows[i][de.Value.ToString()].ToString() + "',");
                            }

                        }
                        if (BeginRow.Length > 0)
                        {


                            comm.CommandText = "insert into [" + sheetName + splitStr[0].Substring(0, 1) + colStartID.ToString() + ":" + splitStr[1].Substring(0, 1) + colStartID.ToString() + "] (" + sb1.ToString() + ") values(" + sb2.Remove(sb2.Length - 1, 1).ToString() + ")";

                            colStartID++;

                        }
                        else
                        {
                            comm.CommandText = "insert into [" + sheetName + "] (" + sb1.ToString() + ") values(" + sb2.Remove(sb2.Length - 1, 1).ToString() + ")";
                        }
                        comm.ExecuteNonQuery();
                    }
                    conn.Close();

                }
            }

        }
        /// <summary>
        /// 插入一条数据
        /// </summary>
        /// <param name="Htable">键表示插入的列,注意必须用(F1，F2，..)；值表示插入列值</param>
        /// <param name="sheetName">工作表名</param>
        /// <param name="BeginRow">Excel插入开始行,如(A1,C1);无表示从工作表（sheetName)末尾行开始插入</param>
        public void InsertExcelData(Hashtable Htable, string sheetName, params string[] BeginRow)
        {

            if (Htable.Count > 0)
            {
                string connStr1 = this.connStr.Replace(";IMEX=1", "");
                OleDbConnection conn = new OleDbConnection(connStr1);

                StringBuilder sb1 = new StringBuilder(256);
                StringBuilder sb2 = new StringBuilder(256);
                foreach (DictionaryEntry de in Htable)
                {
                    sb1.Append(de.Key.ToString() + ",");
                    sb2.Append("'" + de.Value.ToString() + "',");

                }

                conn.Open();
                OleDbCommand comm = conn.CreateCommand();
                if (BeginRow.Length > 0)
                {
                    comm.CommandText = "insert into [" + sheetName + BeginRow[0].ToString() + "] (" + sb1.Remove(sb1.Length - 1, 1).ToString() + ") values(" + sb2.Remove(sb2.Length - 1, 1).ToString() + ")";

                }
                else
                {
                    comm.CommandText = "insert into [" + sheetName + "] (" + sb1.Remove(sb1.Length - 1, 1).ToString() + ") values(" + sb2.Remove(sb2.Length - 1, 1).ToString() + ")";
                }
                comm.ExecuteNonQuery();
                conn.Close();
            }
        }

        /// <summary>
        /// 更新一行数据
        /// </summary>
        /// <param name="sheetName">工作表名</param>
        /// <param name="Htable">要更新的字段，键表示列名，键值表示要更新列值</param>
        /// <param name="whereStr">更新条件如（F1=?);无，null</param>
        /// <param name="updateRow">sheetName中要更新的行如（A1:C1)</param>
        public void UpdateExcelData(string sheetName, Hashtable Htable, string whereStr, params string[] updateRow)
        {
            if (Htable.Count > 0)
            {
                string connStr1 = this.connStr.Replace(";IMEX=1", "");
                OleDbConnection conn = new OleDbConnection(connStr1);
                conn.Open();
                OleDbCommand comm = conn.CreateCommand();

                StringBuilder sb1 = new StringBuilder(256);
                sb1.Append("set ");
                foreach (DictionaryEntry de in Htable)
                {
                    sb1.Append(de.Key.ToString() + "='" + de.Value.ToString() + "',");

                }

                if (whereStr != null)
                {
                    if (updateRow.Length > 0)
                    {
                        comm.CommandText = "UPDATE [" + sheetName + updateRow[0].ToString() + "]  " + sb1.Remove(sb1.Length - 1, 1).ToString() + " where " + whereStr;
                    }
                    else
                    {
                        comm.CommandText = "UPDATE [" + sheetName + "]  " + sb1.Remove(sb1.Length - 1, 1).ToString() + " where " + whereStr;

                    }
                }
                else
                {
                    if (updateRow.Length > 0)
                    {
                        comm.CommandText = "UPDATE [" + sheetName + updateRow[0].ToString() + "]  " + sb1.Remove(sb1.Length - 1, 1).ToString();
                    }
                    else
                    {
                        comm.CommandText = "UPDATE [" + sheetName + "]  " + sb1.Remove(sb1.Length - 1, 1).ToString();

                    }
                }
                comm.ExecuteNonQuery();
                conn.Close();


            }
        }

    }

2.操作页面，添加一个button控件用来确定上传，一个FileUpload控件，一个TextArea控件来显示导入产生的信息

后台代码：

  protected void btnSubmit_Click(object sender, EventArgs e)
        {
            if (!fileExcel.HasFile)
            {
                ExtAspNet.Alert.ShowInTop("请您选择Excel文件！");
                return;//当无文件时,返回
            }
            string fileName = fileExcel.FileName;
            string IsXls = System.IO.Path.GetExtension(fileName).ToString().ToLower();//获得文件的扩展名

            if (IsXls != ".xls" && IsXls != ".xlsx")
            {
                ExtAspNet.Alert.ShowInTop("只可以选择Excel文件！");
                return;//当选择的不是Excel文件时,返回
            }

            ExcelToData readExcel = new ExcelToData(fileName);
            readExcel.FillSheets();
            DataTable dtExcel = readExcel.GetExcelData(readExcel.Sheets[0].ToString());
            DataRow[] dr = dtExcel.Select();            //定义一个DataRow数组
            int rowsnum = dtExcel.Rows.Count;

            if (rowsnum < 2)
            {//第一行为标题，所以从2开始
                ExtAspNet.Alert.ShowInTop("Excel表为空表,无数据！");
                return;
            }
            else
            {
                string User_No = String.Empty;
                DateTime ScheduleDate;
                string ShiftName = String.Empty;
                StringBuilder sb;
                string strCheckSQL;
                StringBuilder sbInfo = new StringBuilder();
                for (int i = 1; i < dr.Length; i++)
                {
                    sb = new StringBuilder();
                    User_No = dr[i][0].ToString().Trim();
                    ShiftName = dr[i][2].ToString().Trim();

                    try
                    {
                        ScheduleDate = DateTime.Parse(dr[i][1].ToString().Trim ());
                        
                    }
                    catch (Exception ex)
                    {
                        sbInfo.AppendLine("人员【" + User_No + "】日期【" + dr[i][1].ToString() + "】格式不正确!");
                        continue;
                    }

                    try
                    {

                        sb.Append("INSERT INTO [dbo].[KQ_Schedule]([EmpID],[ScheduleDate],[ShiftID])");
                        sb.Append(String.Format(" VALUES ('{0}','{1}','{2}') END;", User_No ,ScheduleDate, ShiftName));
                        int result=dbacess.ExecuteNonQuery(sql, null);
                        if (result > 0)
                        {
                            sbInfo.AppendLine("人员【" + User_No + "】导入成功!");
                        }
                        else {
                            sbInfo.AppendLine("人员【" + User_No + "】导入失败!");
                        }
                    }
                    catch (Exception ex)       //捕捉异常
                    {
                        sbInfo.AppendLine("人员【" + User_No + "】导入出错：" + ex.Message);
                        continue;
                    }
                    
                }//for i
                txtInfo.Text = sbInfo.ToString();
            }
            
        }