博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
C#将Excel数据表导入SQL数据库的两种方法(转)
阅读量:7044 次
发布时间:2019-06-28

本文共 7630 字,大约阅读时间需要 25 分钟。

最近用写个winform程序想用excel 文件导入数据库中,网上寻求办法,找到了这个经过尝试可以使用。

方法一:

实现在c#中可高效的将excel数据导入到sqlserver数据库中,很多人通过循环来拼接sql,这样做不但容易出错而且效率低下,最好的办法是使用bcp,也就是System.Data.SqlClient.SqlBulkCopy 类来实现。

using System;        using System.Collections.Generic;        using System.ComponentModel;        using System.Data;        using System.Drawing;        using System.Linq;        using System.Text;        using System.Windows.Forms;        using System.Data.OleDb;                namespace ExcelToSQL        {            public partial class Form1 : Form            {                public Form1()                {                    InitializeComponent();                }                        private void button1_Click(object sender, EventArgs e)                {                    //测试,将excel中的student导入到sqlserver的db_test中,如果sql中的数据表不存在则创建                        string connString = "server = (local); uid = sa; pwd = sa; database = db_test";                    System.Windows.Forms.OpenFileDialog fd = new OpenFileDialog();                       if (fd.ShowDialog() == DialogResult.OK)                       {                        TransferData(fd.FileName, "student", connString);                    }                   }                           public void TransferData(string excelFile, string sheetName, string connectionString)                   {                       DataSet ds = new DataSet();                    try                      {                        //获取全部数据                         string strConn = "Provider = Microsoft.Jet.OLEDB.4.0;" + "Data Source=" + excelFile + ";" + "Extended Properties = Excel 8.0;";                           OleDbConnection conn = new OleDbConnection(strConn);                        conn.Open();                        string strExcel = "";                        OleDbDataAdapter myCommand = null;                           strExcel = string.Format("select * from [{0}$]", sheetName);                        myCommand = new OleDbDataAdapter(strExcel, strConn);                        myCommand.Fill(ds, sheetName);                                  //如果目标表不存在则创建,excel文件的第一行为列标题,从第二行开始全部都是数据记录                         string strSql = string.Format("if not exists(select * from sysobjects where name = '{0}') create table {0}(", sheetName);   //以sheetName为表名                                 foreach (System.Data.DataColumn c in ds.Tables[0].Columns)                        {                               strSql += string.Format("[{0}] varchar(255),", c.ColumnName);                           }                           strSql = strSql.Trim(',') + ")";                                     using (System.Data.SqlClient.SqlConnection sqlconn = new System.Data.SqlClient.SqlConnection(connectionString))                           {                            sqlconn.Open();                               System.Data.SqlClient.SqlCommand command = sqlconn.CreateCommand();                               command.CommandText = strSql;                               command.ExecuteNonQuery();                               sqlconn.Close();                        }                           //用bcp导入数据                            //excel文件中列的顺序必须和数据表的列顺序一致,因为数据导入时,是从excel文件的第二行数据开始,不管数据表的结构是什么样的,反正就是第一列的数据会插入到数据表的第一列字段中,第二列的数据插入到数据表的第二列字段中,以此类推,它本身不会去判断要插入的数据是对应数据表中哪一个字段的                         using (System.Data.SqlClient.SqlBulkCopy bcp = new System.Data.SqlClient.SqlBulkCopy(connectionString))                           {                               bcp.SqlRowsCopied += new System.Data.SqlClient.SqlRowsCopiedEventHandler(bcp_SqlRowsCopied);                               bcp.BatchSize = 100;//每次传输的行数                                bcp.NotifyAfter = 100;//进度提示的行数                                bcp.DestinationTableName = sheetName;//目标表                                bcp.WriteToServer(ds.Tables[0]);                        }                       }                       catch (Exception ex)                       {                           System.Windows.Forms.MessageBox.Show(ex.Message);                       }                 }                             //进度显示                    void bcp_SqlRowsCopied(object sender, System.Data.SqlClient.SqlRowsCopiedEventArgs e)                   {                       this.Text = e.RowsCopied.ToString();                       this.Update();                   }              }           }

方法二:

先将Excel文件转换成DataTable,然后再循环将记录插入到数据库表中,这种方式可以任由程序员来选择将哪列数据导入到数据表的哪个字段中

using System;      using System.Collections.Generic;      using System.ComponentModel;      using System.Data;      using System.Drawing;      using System.Linq;      using System.Text;      using System.Windows.Forms;      using System.Data.OleDb;      using System.Data.SqlClient;           namespace ExcelToSQL      {          public partial class Form2 : Form          {              public Form2()              {                  InitializeComponent();              }                   DataTable dt = new DataTable();              string connString = "server = (local); uid = sa; pwd = sa; database = db_test";              SqlConnection conn;                   private void button1_Click(object sender, EventArgs e)              {                  System.Windows.Forms.OpenFileDialog fd = new OpenFileDialog();                  if (fd.ShowDialog() == DialogResult.OK)                  {                      string fileName = fd.FileName;                      bind(fileName);                  }              }              private void bind(string fileName)              {                  string strConn = "Provider=Microsoft.Jet.OLEDB.4.0;" +                       "Data Source=" + fileName + ";" +                       "Extended Properties='Excel 8.0; HDR=Yes; IMEX=1'";                  OleDbDataAdapter da = new OleDbDataAdapter("SELECT *  FROM [student$]", strConn);                  DataSet ds = new DataSet();                  try                 {                      da.Fill(ds);                      dt = ds.Tables[0];                      this.dataGridView1.DataSource = dt;                  }                  catch (Exception err)                  {                      MessageBox.Show("操作失败!" + err.ToString());                  }              }                   //将Datagridview1的记录插入到数据库                private void button2_Click(object sender, EventArgs e)              {                  conn = new SqlConnection(connString);                  conn.Open();                  if (dataGridView1.Rows.Count > 0)                  {                      DataRow dr = null;                      for (int i = 0; i < dt.Rows.Count; i++)                      {                          dr = dt.Rows[i];                          insertToSql(dr);                      }                      conn.Close();                      MessageBox.Show("导入成功!");                  }                  else                 {                      MessageBox.Show("没有数据!");                  }              }              private void insertToSql(DataRow dr)              {                  //excel表中的列名和数据库中的列名一定要对应                  string name = dr["StudentName"].ToString();                  string sex = dr["Sex"].ToString();                  string no = dr["StudentIDNO"].ToString();                  string major = dr["Major"].ToString();                  string sql = "insert into student values('" + name + "','" + sex + "','" + no + "','" + major +"')";                           SqlCommand cmd = new SqlCommand(sql, conn);                             cmd.ExecuteNonQuery();              }          }      }

 

转载于:https://www.cnblogs.com/yellowcool/p/7448117.html

你可能感兴趣的文章
关于cronjob的用法
查看>>
对于fork()用法的初步探讨
查看>>
Javascript 数组循环遍历之forEach
查看>>
HTML & CSS之小白初入江湖
查看>>
写一个简单的webserver
查看>>
通过 InnoSetup 美化安装界面
查看>>
一次不怎么愉快的滴滴面试经历
查看>>
Android的资源管理器的创建过程
查看>>
php验证身份证函数
查看>>
[使用 Weex 和 Vue 开发原生应用] 1 如何配置开发环境
查看>>
红帽发布 Ansible Tower 3.4:在混合云中实践DevOps更便捷
查看>>
Linus 发文宣布Linux Kernel 5.0 正式发布
查看>>
定制你的敏捷方法:以结果为导向
查看>>
关于Visual Studio 2019的前期详情
查看>>
PWA即将推向所有Chrome平台
查看>>
官宣!微软宣布桌面版 Edge将基于Chromium进行开发\n
查看>>
运用供应链管理实现更快速、更高质量的交付
查看>>
3·15曝光丨智能机器人一年拨打40亿个骚扰电话,6亿人信息已遭泄露!
查看>>
ASP.NET Core 2.1带来SignalR、Razor类库
查看>>
敏捷2016大会主题演讲:现代敏捷
查看>>