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
  • 相关阅读:
    管道命令'|' 和xargs find命令找到后把所有找到的删除
    UVa
    【手势交互】9. PS Move
    jquery时间格式化插件
    Android学习路线(十三)Activity生命周期——暂停和恢复(Pausing and Resuming )一个Activity
    hdu 2604 Queuing (矩阵高速幂)
    【Linux驱动】TQ2440 DM9000E网卡驱动移植(Linux-2.6.30.4)
    bzoj2648 SJY摆棋子
    Hive编程指南_学习笔记01
    通信协议中的转义符
  • 原文地址:https://www.cnblogs.com/yangsirc/p/8623593.html
Copyright © 2011-2022 走看看