#region 解压ACCESS文件并插入数据到SQL数据库 protected void Button1_Click(object sender, EventArgs e) { if (File1.PostedFile != null) { System.Web.HttpFileCollection oFiles; oFiles = System.Web.HttpContext.Current.Request.Files; if (oFiles.Count < 1) { Response.Write("请选择文件。"); Response.End(); } string FilePath = oFiles[0].FileName; if (FilePath == "" || FilePath == null) { Response.Write("请选择一个文件。"); Response.End(); } //// 获取文件名： //string fileName = File1.PostedFile.FileName.Substring(File1.PostedFile.FileName.LastIndexOf("\\") + 1); ////取后缀： //string suffix = fileName.SubString(fileName.LastIndexOf(".") + 1); string strzipPath = "" + File1.PostedFile.FileName.Substring(File1.PostedFile.FileName.LastIndexOf(" \\ ") + 1) + ""; string strtxtPath = ""; System.Diagnostics.Process Process1 = new System.Diagnostics.Process(); Process1.StartInfo.FileName = "Winrar.exe"; Process1.StartInfo.CreateNoWindow = true; strtxtPath = "g:\\freezip\\"; Process1.StartInfo.Arguments = " x " + strzipPath + " " + strtxtPath; Process1.Start(); if (Process1.HasExited) { Response.Write("完成"); //Winrar = true; } Process1.Dispose(); //if (Winrar) //{ try { string sql = "SELECT DM,BH,MC,GG,DW,DJ,PBSL,KCSL,QKSL,QKJE,CPSL,CPJE,XXDM,ND FROM OPENROWSET" + "('Microsoft.Jet.OLEDB.4.0', 'G:\\freezip\\UpData.mdb'; 'admin'; '',YQQKTJ)"; string constr = "server=192.168.10.22;uid=sa;pwd=;database=jcjyzbxj"; SqlConnection con = new SqlConnection(constr); SqlDataAdapter da = new SqlDataAdapter(sql, con); DataSet ds = new DataSet(); da.Fill(ds, "DM_ZCFL"); if (ds.Tables[0].Rows.Count > 0) { InsertData2(ds); Response.Write("<script language='javascript'>alert('成功')</script>"); } else { Response.Write("<script language='javascript'>alert('没有找到文件!')</script>"); } } catch (Exception ex) { throw ex; } //} } } protected void InsertData2(DataSet Set) { try { DataSet dataSet = Set; string conditions = String.Empty; SqlConnection con = new SqlConnection("server=YWG;uid=sa;pwd=;database=jcjyzbxj"); SqlCommand com = new SqlCommand("DELETE FROM YQQKTJ WHERE XXDM='" + dataSet.Tables[0].Rows[0][12].ToString() + "' AND ND='" + dataSet.Tables[0].Rows[0][13].ToString() + "'", con); con.Open(); com.ExecuteNonQuery(); con.Close(); DataSet ds = new DataSet(); SqlDataAdapter da = new SqlDataAdapter("SELECT top 1 DM,BH,MC,GG,DW,DJ,PBSL,KCSL,QKSL,QKJE,CPSL,CPJE,XXDM,ND FROM YQQKTJ",con); //WHERE XXDM='" + dataSet.Tables[0].Rows[0][12].ToString() + "' AND ND='" + dataSet.Tables[0].Rows[0][13].ToString() + "'", con); da.Fill(ds, "DSYQQKTJ"); for (int i = 0; i < dataSet.Tables[0].Rows.Count; i++) { DataRow dr = ds.Tables[0].NewRow(); dr[0] = dataSet.Tables[0].Rows[i][0].ToString(); dr[1] = dataSet.Tables[0].Rows[i][1].ToString(); dr[2] = dataSet.Tables[0].Rows[i][2].ToString(); dr[3] = dataSet.Tables[0].Rows[i][3].ToString(); dr[4] = dataSet.Tables[0].Rows[i][4].ToString(); dr[5] = float.Parse(dataSet.Tables[0].Rows[i][5].ToString()); dr[6] = dataSet.Tables[0].Rows[i][6].ToString(); dr[7] = int.Parse(dataSet.Tables[0].Rows[i][7].ToString()); dr[8] = dataSet.Tables[0].Rows[i][8].ToString(); dr[9] = float.Parse(dataSet.Tables[0].Rows[i][9].ToString()); dr[10] = int.Parse(dataSet.Tables[0].Rows[i][10].ToString()); dr[11] = float.Parse(dataSet.Tables[0].Rows[i][11].ToString()); dr[12] = dataSet.Tables[0].Rows[i][12].ToString(); dr[13] = dataSet.Tables[0].Rows[i][13].ToString(); ds.Tables[0].Rows.Add(dr); } SqlCommandBuilder builder = new SqlCommandBuilder(da); da.Update(ds, "DSYQQKTJ"); } catch (Exception ex) { throw ex; } }#endregion
评论