C#实现Excel表格导入数据库

2018-10-30 本文已影响14人依旧丶森

步入工作，项目需要，使用的是c#编写的办公OA系统，要实现一个从固定文件夹下读取Excel表格，将表中数据插入生产SQL语句，调用接口将生成的SQL语句插入的Oracle数据库中。

本身不懂c#,有之前已经大致写好的例子，我只是拿来理解并测试修改，最终实现列子可用，并仿照例子，实现多个相似Excel导入功能。
开始正题。

1.读取本地Excel文件数据

首先获取文件地址
```
string file_Path = ConfigurationManager.AppSettings["Download"].ToString().Trim() + "Excel\\" + fileName;
```
这里地址是项目实现设置好的，拼接而成，Settings["Download"]是config里设置的地址
<add key="Download" value="D:\Upload\"/>

设置变量，设置读取文件的属性

//设置变量为下一步准备
//自定义的数据结构DataStruct，存放插入数据返回信息(项目设定的)
DataStruct ds = new DataStruct();
//DataSet数据集，可存放多个数据表
DataSet dataSet = new DataSet();
//DataTable数据表
DataTable dt = new DataTable();
DataTable _dt = new DataTable();
//设置读入Excel的属性，设置错误则无法连接获取数据
string ConnectionString = string.Format("Provider=Microsoft.ACE.OLEDB.12.0; Data Source='{0}';Extended Properties='Excel 12.0;IMEX=1;HDR=NO;'", file_Path);

获取数据

 using (OleDbConnection conn = new OleDbConnection(ConnectionString))
 {
       string tableName = null;
       try{
              conn.Open();
              //获取第一个表名字，如果要第二个直接rows[1][2]即可
              DataTable sheet_name = conn.GetOleDbSchemaTable(OleDbSchemaGuid.Tables, null);
              tableName = sheet_name.Rows[0][2].ToString().Trim();
              //判断表名字末尾是否有$符号，有的话去掉。
              //当表名为汉字，没有$，当为默认的sheet时，获取时有$
              if (tableName.Contains("$")) {
                   tableName = tableName.Substring(0, tableName.Length - 1);
              }

              //读取所有行和列，如果读取选定列，可以修改Select语句
              string cmdText = string.Format("SELECT * FROM [{0}$]", tableName);
              OleDbCommand command = new OleDbCommand(cmdText, conn);
              OleDbDataAdapter adpt = new OleDbDataAdapter();

              adpt.SelectCommand = command;
              adpt.Fill(dataSet, tableName);

              if (dataSet.Tables.Count > 0) {
                   //读取Excel成功,处理数据,去掉头尾,筛选
                   dt = dataSet.Tables[0];
                   conn.Close();
              }
       }
       catch (Exception e){
            //e.Message;
       }
 }

处理筛选数据

    //复制表，清除数据，只得到表结构
    _dt = dt.Copy();
    _dt.Rows.Clear();
    //for循环遍历，筛选数据
    foreach (DataRow dr in dt.Rows)
    {
           //前置条件判定
           var num = dr[2];//处罚编号
           if (num.ToString().Trim().Length > 0) {
                string pattern = @"^[A-Za-z0-9]+$";
                string ck_num = num.ToString().Trim();
                //正则判断处罚编号是否为数字或字母，除去表头汉字
                if (Regex.IsMatch(ck_num, pattern)) {
                    //将数据存到之前清理的表中
                    DataRow _dr = _dt.NewRow();
                    _dr.ItemArray = dr.ItemArray;
                    _dt.Rows.Add(_dr);
                }
           }
    }

生成插入的Oracle SQL语句

   //构建Insert语句，多条插入，使用begin  end；
   string sqlString = "begin ";
   //遍历生成完整SQL语句，注意Oracle数据库数据格式要求
   foreach (DataRow dr in _dt.Rows)
   {
         sqlString += String.Format("insert into 简易 " +
         "(序号,部门ID,时间,来源,来源编号,当事人,身份证件 " +
         " values  (SEQ_SIMPLE_ID.Nextval," +
         "(select dptid from TB_DEPT where name like'%{0}%')," +
         " to_date('{1}','yyyy/mm/dd hh24:mi:ss')," +
         " '{2}', '{3}', '{4}','{5}');",
           dr[1].ToString().Trim(),
           dr[2].ToString().Trim(),
           dr[3].ToString().Trim(),
           dr[4].ToString().Trim(),
           dr[5].ToString().Trim(),
           dr[6].ToString().Trim(),
           dr[7].ToString().Trim() );
   }
   sqlString += " end;";
   //这里是写好的方法实现提交SQL语句到Oracle库中
   ds = CommandSQLs(sqlString);

提交SQL的函数

   public DataStruct CommandSQLs(string sqls)
   {
        DataStruct data = new DataStruct();
        if (string.IsNullOrEmpty(sqls)) {
             data.IsSuc = false;
             data.Message = "添加失败,要执行的SQL为空...";
             return data;
         }

          string plsql = "begin " + sqls + " end;";
          using (DalBase dataBaseInteractDAL = new DalBase())
          {
              int count = dataBaseInteractDAL.Update(plsql);
              if (count > 0){
                  data.IsSuc = true;
                  data.AllReturnCount = data.CurrentReturnCount = count;
                  data.Message = "添加成功...";
                  return data;
              }
              else {
                  data.IsSuc = false;
                  data.Message = "添加失败...";
                  return data;
              }
          }
   }

注意：有些模块使用需要引入对应的库

使用过程中用到的其他小方法：

1.检测数据是否为数字(包括小数和负数)

    private string CheckNumber(string str) 
    {
          String pattern = "-[0-9]+(.[0-9]+)?|[0-9]+(.[0-9]+)?";
          //正则筛选的到数字列表，当只有一个时，整体才是数字。
          MatchCollection results = Regex.Matches(str, pattern);
          if (str == null) {
              return str;
          }
          //当筛选得到大于1和小于1时，不是纯数字。
          else if (results.Count<1 || results.Count>1){
              str = null;
              return str;
          }
          else {
              return str;
          }
    }

2.判断字符最后一个是否为固定字符

     string dw = dr[9].ToString().Trim();
     string k = dw.Substring(dw.Length - 1, 1);
     if (k == "所") {
           dw = dw.Substring(0, dw.Length - 1);
     }

3.提取数字

    decimal result = 0;
    string str = dr[12].ToString().Trim(); //将￥50.00提取出数字
    str = Regex.Replace(str, @"[^\d.\d]", "");
     // 如果是数字，则转换为decimal类型
    if (Regex.IsMatch(str, @"^[+-]?\d*[.]?\d*$")) {
           result = decimal.Parse(str);
     }

4.获取DataSet格式的数据

    //项目中的方法，得到DataSet数据
    var bm = QueryData(sql);
    //新建DataTable，获取DataSet中数据(Set里是Table列表)
    DataTable bm_ta = new DataTable();
    bm_ta = bm.Tables[0];
    //新建DataRow，获取行数据(Table里是Row列表)
    DataRow myDr = bm_ta.Rows[0];
    string myId = myDr[0].ToString();//列表里取数据

C#实现Excel表格导入数据库

1.读取本地Excel文件数据

使用过程中用到的其他小方法：

猜你喜欢

热点阅读