C# 从Excel读取数据向SQL server写入

Dawn ·

更新时间:2024-09-20

· 639 次阅读

第一次写C#与sql的东西，主要任务是从Excel读取数据，再存到SQL server中。

　　先上读取Excel文件的code如下。


public bool GetFiles(string equipName)
    {
      //choose all sheet? or all data in sheet?
      string strExcel = "select * from [Sheet1$]";
      //初始化system.IO的配置（路径)
      DirectoryInfo directoryInfo1 = new DirectoryInfo(WPath + equipName + "\\Working");
      //用文件流来获取文件夹中所有文件，存放到
      FileInfo[] files1 = directoryInfo1.GetFiles();
      foreach (FileInfo file in files1) // Directory.GetFiles(srcFolder)
      {
        // 连接到excel 数据源,  xlsx要用ACE
        string strConn = ("Provider=Microsoft.ACE.OLEDB.12.0;" + "Data Source= " + file.FullName + "; Extended Properties='Excel 12.0';");
        OleDbConnection OledbConn = new OleDbConnection(strConn);
        if (IsUsed(file.FullName))
        {
          flag = IsUsed(file.FullName);
          continue;
        }
        try
        {
          OledbConn.Open();
          // 存入datatable
          OleDbDataAdapter dAdapter = new OleDbDataAdapter(strExcel, strConn);　　　　　　　　　　　　//写入ds中的一个table
          dAdapter.Fill(ds);
          OledbConn.Dispose();
          OledbConn.Close();
        }
        catch (Exception ex)
        {
        }
      }
    }

foreach用于遍历所有Excel文件；

strExcel用于选择Excel文件中sheet的内容，select * 表示选取sheet中所有行和列；

strConn用于设置读取的方法，provider的设置很重要，ACE表示最新的.xlsx文件，jet 表示读取.xls文件，两者有点区别，DataSource表示文件名，包括路径。

OleDbDataAdapter 用于按（命令）去执行填充dataset的功能

dataset简而言之可以理解为虚拟的数据库或是Excel文件。而dataset里的datatable 可以理解为数据库中的table活着Excel里的sheet（Excel里面不是可以新建很多表吗）。

这样说应该很容易懂了，相当于dataset只是暂时存放下数据，微软官方解释是存在内存中。至于为啥要找个“中介”来存数据，这个估计是为了和SQL匹配。

好了，接下来说下这次的重点。

在把Excel的数据存到dataset后，我们要把dataset的数据存入SQL才算完事。

废话不多说先上后面的代码：（总的代码）


using System.IO;
using System.Data;
using System.Configuration;
using System.ServiceProcess;
using System.Data.SqlClient;
using System.Data.OleDb;
using System.Timers;using System;
namespace DataCollection_model_HD
{
  public partial class Service1 : ServiceBase
  {
    public Service1()
    {
      InitializeComponent();
      InitTimer();
    }
    #region 各种配置的全局定义
    //定义一个dataset 用于暂时存放excel中的数据,后续要存入datatable
    DataSet ds = new DataSet();
    Timer TimModel = new Timer();
    public static string LogPath = ConfigurationManager.AppSettings["LogPath"].ToString();
    public static string WPath = ConfigurationManager.AppSettings["WorkingPath"].ToString();
    public static string APath = ConfigurationManager.AppSettings["ArchivePath"].ToString();
    //数据库登录
    //注意Integrated Security不写（false）表示必须要用pwd登录，true表示不用密码也能进入数据库
    public static string ConnStr = ConfigurationManager.AppSettings["ConnStr"].ToString();
    //用于记录log的时候，机台名字
    public static string machineName = "test";
    #endregion
    #region 定时器的初始化，及其事务
    //这个按钮用于模拟服务(定时器）启动
    public void InitTimer()
    {
      //DFL的定时器 
      TimModel.Interval = 15 * 1000;
      //定时器的事务
      TimModel.Elapsed += new ElapsedEventHandler(ElapsedEventDFL);
      TimModel.Enabled = true;
      TimModel.AutoReset = true;
    }
    private void ElapsedEventDFL(object source, ElapsedEventArgs e)
    {
      if (GetFiles("test"))
      {
        //多次读取数据，存在多个文件时但其中某个文件在使用的bug
        ds.Tables.Clear();
        Log4App.WriteLine(" ---- End the collect ! ----", LogPath, machineName, System.Threading.Thread.CurrentThread.ManagedThreadId.ToString(), Log4AES.Type.Information);
      }
      else
      {
        DataToSql("test");
        BackupData("test");
        Log4App.WriteLine(" ---- End the collect ! ----", LogPath, machineName, System.Threading.Thread.CurrentThread.ManagedThreadId.ToString(), Log4AES.Type.Information);
      }
    }
    #endregion
    //log初始化设置
    Log4Application Log4App = new Log4Application();
    /*用于移动源文件到指定文件夹，也就是备份源数据文件
    copy all file in folder Working to Achieve*/
    public void BackupData(string equipName)
    {
      //需要存放（备份）的文件夹路径（Achieve）
      string ArchivePath = APath + equipName + " Equipment Temp. monitoring by third tool\\Archive";
      //读取数据源文件的文件夹路径（Working）
      string WorkingPath = WPath + equipName + " Equipment Temp. monitoring by third tool\\Working";
      //初始化system.IO的配置（路径)
      DirectoryInfo directoryInfo = new DirectoryInfo(WorkingPath);
      //用文件流来获取文件夹中所有文件，存放到
      FileInfo[] files = directoryInfo.GetFiles();
      //循环的把所有机台数据备份到Achieve文件夹
      try
      {
        foreach (FileInfo file in files) // Directory.GetFiles(srcFolder)
        {
          //使用IO中的Moveto函数进行移动文件操作
          file.MoveTo(Path.Combine(ArchivePath, file.Name));
        }
      }
      catch (Exception ex)
      {
      }
    }
    //判断Excel是否在被人使用
    public bool IsUsed(String fileName)
    {
      bool result = false;
      try
      {
        FileStream fs = File.OpenWrite(fileName);
        fs.Close();
      }
      catch
      {
        result = true;
      }
      return result;
    }
    //将xls文件投入datatable ， 返回一个datatable为 ds.table[0]
    public bool GetFiles(string equipName)
    {
      bool flag = false;
      //choose all sheet? or all data in sheet?
      string strExcel = "select * from [Sheet1$]";
      //初始化system.IO的配置（路径)
      DirectoryInfo directoryInfo1 = new DirectoryInfo(WPath + equipName + " Equipment Temp. monitoring by third tool\\Working");
      //用文件流来获取文件夹中所有文件，存放到
      FileInfo[] files1 = directoryInfo1.GetFiles();
      foreach (FileInfo file in files1) // Directory.GetFiles(srcFolder)
      {
        // 连接到excel 数据源,  xlsx要用ACE
        string strConn = ("Provider=Microsoft.ACE.OLEDB.12.0;" + "Data Source= " + file.FullName + "; Extended Properties='Excel 12.0';");
        OleDbConnection OledbConn = new OleDbConnection(strConn);
        if (IsUsed(file.FullName))
        {
          flag = IsUsed(file.FullName);
          continue;
        }
        try
        {
          OledbConn.Open();
          // 存入datatable，Excel表示哪一个sheet，conn表示连接哪一个Excel文件（jet、ACE）
          OleDbDataAdapter dAdapter = new OleDbDataAdapter(strExcel, strConn);
          dAdapter.Fill(ds);
          OledbConn.Dispose();
          OledbConn.Close();
        }
        catch (Exception ex)
        {
        }
      }
      return flag;
    }
    // 将datatable中的数据存入SQL server
    public void DataToSql(string equipName)
    {
      //初始化配置 sqlserver的服务器名用户等
      SqlConnection Conn = new SqlConnection(ConnStr);
      Conn.Open();
      //配置SQLBulkCopy方法，真正用于复制数据到数据库的方法
      SqlBulkCopy bulkCopy = new SqlBulkCopy(ConnStr, SqlBulkCopyOptions.UseInternalTransaction)
      {
        DestinationTableName = "ModelTest_HD"
      };
      try
      {
        foreach (DataColumn item in ds.Tables[0].Columns)
        {
          //只复制所选的相关列
          bulkCopy.ColumnMappings.Add(item.ColumnName, item.ColumnName);
        }
        //开始复制到sql,每次在数据库中添加
        bulkCopy.WriteToServer(ds.Tables[0]);
        bulkCopy.Close();
        //copy完了，要清空ds的内容，不然会引起循环写入上一个内容
        ds.Tables.Clear();
      }
      catch (Exception ex)
      {
      }
      finally
      {
        //关闭数据库通道
        Conn.Close();
      }
    }
    protected override void OnStart(string[] args)
    {
      //启动服务时做的事情
    }
    protected override void OnStop()
    {
      //停止服务时做的事情
    }
  }
}

认真看注释可以看出本程序的逻辑就是：

1、读取到Excel数据

2、存Excel数据到SQL server

3、备份Excel文件到另一个文件夹

其中一些功能大家可以看一看，注释也写的很清楚。对于初学者 configurationmanager的内容是在 app.config中设置的，这里直接去配置就行（类似html）


foreach (DataColumn item in ds.Tables[0].Columns)
{
//只复制所选的相关列
bulkCopy.ColumnMappings.Add(item.ColumnName, item.ColumnName);
}

注意这一段代码，表示只复制数据库与Excel表中 “列名”一致的数据，如果不一致就不复制。（注意数据的格式，int还char 这些必须弄清楚）

然后bulkCopy.WriteToServer(ds.Tables[0])这里，就是把ds.tables的数据复制到SQLserver ，Tables[0]表示ds第一张表（其实我们也只有一张表，至于怎么在dataset中新建table自己可以查查资料）

最后的最后，注意释放这些dataset，或者table。然后通道也记得close一下。

祝大家学习快乐。

以上就是C# 从Excel读取数据向SQL server写入的详细内容，更多关于c# 向SQL server写入数据的资料请关注软件开发网其它相关文章！

SQL Server C# SQL 数据

1024 个赞

需要登录后方可回复, 如果你还没有账号请注册新账号

详解css栅格系统在项目中的灵活运用

Ursula 2020-04-01

908

利用CSS3实现折角效果实例源码

Psyche 2020-08-11

632

使用CSS的table-cell属性实现左图右文的排版方法详解

Isadora 2020-08-10

969

详解PHP变量传值赋值和引用赋值变量销毁

Vidonia 2020-10-17

723

关于C#中yield return用法的思考

Lillian 2023-07-22

491

C#实现从PPT中提取文本的示例代码

Ophelia 2023-07-22

1546

C#特性AttributeUsage简介与使用教程

Echo 2023-07-22

252

C#单例模式Singleton的实现详解

Irma 2023-07-22

1288

C#中System.Text.Json匿名对象反序列化

Phaedra 2023-07-22

C#实现文件操作(复制,移动,删除)的方法详解

Sabah 2023-07-22

1133

C#实现系统休眠或静止休眠的方法

Laila 2023-07-22

1421

利用C#实现可以继承的枚举

Rhea 2023-07-22

1644

C# 读写编辑INI文件的操作

Georgia 2023-07-22

1124

C#使用kernel32.dll读写INI文件的案例详解

Grace 2023-07-22

1586

C#使用动态库DllImport(kernel32)读写ini文件的步骤

Canace 2023-07-22

1486

C#实现文件压缩与解压功能的示例代码

Agnes 2023-07-22

214

C#中时间类的使用方法详解

Bonnie 2023-07-22

1405

C#操作JSON(序列化与反序列化)的方法详解

Raizel 2023-07-22

933

C# 中的智能枚举之如何在枚举中增加行为(示例代码)

Aurora 2023-07-22

1219

python简单几步实现时间日期处理到数据文件的读写

Nora 2023-07-24

926

我要提问

致谢

帮助他人，成就自己。

人生最大成功就是伸出热情而温暖的双手，尽自己所能去帮助身边的每一个人，只要无私的奉献，就会收获到美好的生活。

1024问感谢每一位朋友的帮助和支持。

软件开发网提供编程的基础软件技术培训教程,软件开发编程实例讲解Go,Node,HTML,CSS,Javascript,Python,Java,Ruby,C,PHP,MySQL等软件开发编程语言以及数据开发的基础知识，也提供大量的软件开发在线实例、从入门到精通就在1024问。

育儿网微养生全球行美食街育儿菜谱大全海南旅游女性养狗百科星座