步入工作,项目需要,使用的是c#编写的办公OA系统,要实现一个从固定文件夹下读取Excel表格,将表中数据插入生产SQL语句,调用接口将生成的SQL语句插入的Oracle数据库中。
本身不懂c#,有之前已经大致写好的例子,我只是拿来理解并测试修改,最终实现列子可用,并仿照例子,实现多个相似Excel导入功能。
开始正题。
1.读取本地Excel文件数据
- 首先获取文件地址
这里地址是项目实现设置好的,拼接而成,Settings["Download"]是config里设置的地址string file_Path = ConfigurationManager.AppSettings["Download"].ToString().Trim() + "Excel\\" + fileName;
<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();//列表里取数据