您的位置:首页 > 数据库

Excel导入SQL数据库代码

2012-02-28 16:11 393 查看


Excel导入SQL数据库完整代码 

protected void studentload_Click(object sender, EventArgs e)

     {//批量添加学生信息

         SqlConnection conn = DB.dataBaseConn();//链接数据库

         conn.Open();

          try

          {

             string fileurl = typename(studentFileUpload);//调用typename方法取得excel文件路径

             DataSet ds = new DataSet();//取得数据集

             ds = xsldata(fileurl);

             int errorcount = 0;//记录错误信息条数

             int insertcount = 0;//记录插入成功条数

             int updatecount = 0;//记录更新信息条数

              for (int i = 0; i < ds.Tables[0].Rows.Count; i++)

             {

                 string stuid = ds.Tables[0].Rows[i][0].ToString();

                 string stuname = ds.Tables[0].Rows[i][1].ToString();

                 string stusex = ds.Tables[0].Rows[i][2].ToString();

                 string zhuanye = ds.Tables[0].Rows[i][3].ToString();

                 string classname = ds.Tables[0].Rows[i][4].ToString();

                 if (stuid != "" && stuname != "" && stusex != "" && zhuanye != "" && classname != "")

                 {

                                   SqlCommand selectcmd = new SqlCommand("select count(*) from zy_class   where zhuanye='" + zhuanye + "'and classname='" + classname + "'", conn);

                     int count = Convert.ToInt32(selectcmd.ExecuteScalar());

                     if (count > 0)

                     {

                         SqlCommand selectcmd2 = new SqlCommand("select count(*) from stud where   stuid='" + stuid + "'", conn);

                         int count2 = Convert.ToInt32(selectcmd2.ExecuteScalar());

                         if (count2 > 0)

                         {

                             SqlCommand updatecmd = new SqlCommand("update stud set   stuname='" + stuname + "',stusex='" + stusex + "',zhuanye='" + zhuanyei + "',classname='" + classname + "'   where stuid='" + stuid + "'", conn);

                             updatecmd.ExecuteNonQuery();

                             updatecount++;

                         }

                         else

                         {

                             SqlCommand insertcmd= new SqlCommand("insert into stud    values('" + stuid + "','" + stuname + "','" + stusex + "','" + zhuanye + "','" + classname+ "')", conn);

                             insertcmd.ExecuteNonQuery();

                             insertcount++;

                         }

                     }

                     else

                     {

                         Response.Write("<script language='javascript'>alert('专业或班级信息有错!导入失败!请检查!');</script>");

                         break;  

                      }

                 }

                 else

                 {

                     errorcount++;

                 }

             }

             Response.Write("<script language='javascript'>alert('" + insertcount + "条数据导入成功!" + updatecount + "条数据更新成功!" + errorcount + "条数据部分信息为空没有导入!');</script>");

         }

         catch (Exception e)

         {

             Response.Write("<script language='javascript'>alert('导入失败!');</script>");

         }

         finally

         {

             conn.Close();

         }    

     }

 

 

//把EXCEL文件上传到服务器并返回文件路径

private String typename(FileUpload fileloads)

     {

         string fullfilename = fileloads.PostedFile.FileName;

         string filename = fullfilename.Substring(fullfilename.LastIndexOf("//") + 1);

         string type = fullfilename.Substring(fullfilename.LastIndexOf(".") + 1);

         string murl = "";

         if (type == "xls")

         {

             fileloads.PostedFile.SaveAs(Server.MapPath("excel") + "//" + filename);

             murl = (Server.MapPath("excel") + "//" + filename).ToString();

         }

         else

         {

             Response.Write("<script language='javascript'>alert('导入文件格式不对!');</script>");

         }

         return murl;

     }

   //

把excel数据读入dataset返回l数据集

private DataSet xsldata(string filepath)

     {

         string strCon = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + filepath + ";Extended Properties='Excel 8.0;IMEX=1'";

         System.Data.OleDb.OleDbConnection Conn = new System.Data.OleDb.OleDbConnection(strCon);

         string strCom = "SELECT * FROM [Sheet1$]";

         Conn.Open();

         System.Data.OleDb.OleDbDataAdapter myCommand = new System.Data.OleDb.OleDbDataAdapter(strCom, Conn);

         DataSet ds = new DataSet();

         myCommand.Fill(ds, "[Sheet1$]");

         Conn.Close();

         return ds;
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息