zoukankan      html  css  js  c++  java
  • C# SqlBulkCopy 大量数据导入到数据库

    之前写了一篇C# 直接使用sql语句对数据库操作 (cmd.ExecuteNonQuery)的文章

    这是针对数据量不大的操作,换句话说,效率太低,所以在此介绍一个效率高的、能大批量导入到数据库的方法

    //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

    函数原型

    public void WriteToServer(DataTable table);

     不难看出这个函数需要的是DataTable的数据类型

    正文开始:

    需要using的东西

    using System.Data.SqlClient;//SqlBulkCopy
    using System.Configuration;//ConfigurationManager
    using System.Data;//Datatable

    在app.config中添加connectionstring

      <connectionStrings>
        <add name="connString" connectionString="server=sk**ei**l0*;database=V*Q;integrated security=true"/>
      </connectionStrings>

     就插个代码吧  没什么讲的  注释都有

            static void Main(string[] args)
            {
                DataTable datasource = new DataTable();//数据源,这边没有给它数据源,将就看吧
    
                string connString = ConfigurationManager.ConnectionStrings["connString"].ToString();//config
                SqlConnection conn = new SqlConnection(connString);
           conn.Open(); SqlBulkCopy sqlbulkcopy
    = new SqlBulkCopy(conn); sqlbulkcopy.DestinationTableName = "";//设置数据库表名 sqlbulkcopy.BulkCopyTimeout = 300;//timeout,数据量大的话就需要设置一下,具体视情况而定 try { sqlbulkcopy.WriteToServer(datasource);//写入数据库 } catch (Exception e) { Console.WriteLine(e.Message); } finally { sqlbulkcopy.Close(); conn.Close();// } }

    另一种写法

            static void using_(DataTable datasource,string tablename) {
                using (SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings["connString"].ToString()))
                {
                    conn.Open();
                    using (SqlBulkCopy bulkCopy = new SqlBulkCopy(conn))
                    {
                        bulkCopy.DestinationTableName = tablename;//table name
                        bulkCopy.BatchSize = datasource.Rows.Count;
                        try
                        {
                            bulkCopy.WriteToServer(datasource);//写入数据库
                        }
                        catch (Exception e)
                        {
                            Console.WriteLine(e.Message);
                        }
                        finally
                        {
                            bulkCopy.Close();
                            conn.Close();//
                        }
                    }
                }
            }
    View Code
    MrNou
  • 相关阅读:
    USACO Section 2.2 Subset Sums
    九度 1399 名侦探柯南
    九度 1416 猴子吃坚果
    pch文件的使用(原作者太逗了)
    线程同步
    extern "c"
    进程与线程
    排序算法代码汇总
    Linux Shell 常用命令与目录分区的学习总结 (开始学习linux)
    堆和栈
  • 原文地址:https://www.cnblogs.com/yangsirc/p/8623593.html
Copyright © 2011-2022 走看看