Mysql 批量插入数据的方法

使用的方式是 MySqlBulkLoader

方法如下:

1. 转化datatable 为文件

2. 使用MySqlBulkLoader 进行数据的加载

代码：

public static void CreateCSVfile(DataTable dtable, string strFilePath)

{

StreamWriter sw = new StreamWriter(strFilePath, false);

int icolcount = dtable.Columns.Count;

foreach (DataRow drow in dtable.Rows)

{

for (int i = 0; i < icolcount; i++)

{

if (!Convert.IsDBNull(drow[i]))

{

sw.Write(drow[i].ToString());

}

if (i < icolcount - 1)

{

sw.Write(",");

}

sw.Write(sw.NewLine);

}

sw.Close();

sw.Dispose();

}

private void ImportMySQL()

{

DataTable orderDetail = new DataTable("ItemDetail");

DataColumn c = new DataColumn(); // always

orderDetail.Columns.Add(new DataColumn("ID", Type.GetType("System.Int32")));

orderDetail.Columns.Add(new DataColumn("value", Type.GetType("System.Int32")));

orderDetail.Columns.Add(new DataColumn("length", Type.GetType("System.Int32")));

orderDetail.Columns.Add(new DataColumn("breadth", Type.GetType("System.Int32")));

orderDetail.Columns.Add(new DataColumn("total", Type.GetType("System.Decimal")));

orderDetail.Columns["total"].Expression = "value/(length*breadth)";

//Adding dummy entries

DataRow dr = orderDetail.NewRow();

dr["ID"] = 1;

dr["value"] = 50;

dr["length"] = 5;

dr["breadth"] = 8;

orderDetail.Rows.Add(dr);

dr = orderDetail.NewRow();

dr["ID"] = 2;

dr["value"] = 60;

dr["length"] = 15;

dr["breadth"] = 18;

orderDetail.Rows.Add(dr);

//Adding dummy entries

string connectMySQL = "Server=localhost;Database=test;Uid=username;Pwd=password;";

string strFile = "/TempFolder/MySQL" + DateTime.Now.Ticks.ToString() + ".csv";

//Create directory if not exist... Make sure directory has required rights..

if (!Directory.Exists(Server.MapPath("~/TempFolder/")))

Directory.CreateDirectory(Server.MapPath("~/TempFolder/"));

//If file does not exist then create it and right data into it..

if (!File.Exists(Server.MapPath(strFile)))

{

FileStream fs = new FileStream(Server.MapPath(strFile), FileMode.Create, FileAccess.Write);

fs.Close();

fs.Dispose();

}

//Generate csv file from where data read

CreateCSVfile(orderDetail, Server.MapPath(strFile));

using (MySqlConnection cn1 = new MySqlConnection(connectMySQL))

{

cn1.Open();

MySqlBulkLoader bcp1 = new MySqlBulkLoader(cn1);

bcp1.TableName = "productorder"; //Create ProductOrder table into MYSQL database...

bcp1.FieldTerminator = ",";

bcp1.LineTerminator = "\r\n";

bcp1.FileName = Server.MapPath(strFile);

bcp1.NumberOfLinesToSkip = 0;

bcp1.Load();

//Once data write into db then delete file..

try

{

File.Delete(Server.MapPath(strFile));

}

catch (Exception ex)

{

string str = ex.Message;

}

Mysql 批量插入数据的方法相关推荐

thinkphp mysql批量入库_ThinkPHP3.2框架使用addAll()批量插入数据的方法
本文实例讲述了ThinkPHP3.2框架使用addAll()批量插入数据的方法.分享给大家供大家参考,具体如下: thinkphp中model类的addAll()方法可以将数据同时添加到数据库中. / ...
php addall,ThinkPHP3.2框架使用addAll()批量插入数据的方法
这篇文章主要介绍了ThinkPHP3.2框架使用addAll()批量插入数据的方法,结合实例形式分析了thinkPHP针对单条数据插入及批量数据插入操作的相关实现技巧,需要的朋友可以参考下本文实例讲 ...
addall php,ThinkPHP3.2框架使用addAll()批量插入数据的方法
本文实例讲述了ThinkPHP3.2框架使用addAll()批量插入数据的方法.分享给大家供大家参考,具体如下: thinkphp中model类的addAll()方法可以将数据同时添加到数据库中. / ...
php yii 插入,YII框架批量插入数据的方法
本文实例讲述了YII框架批量插入数据的方法.分享给大家供大家参考,具体如下: public function insertSeveral($table, $array_columns) { $sql ...
三种批量插入数据的方法
批量插入数据本文将介绍三种批量插入数据的方法.第一种方法是使用循环语句逐个将数据项插入到数据库中:第二种方法使用的是SqlBulkCopy,使您可以用其他源的数据有效批量加载 SQL Server ...
Mysql批量插入数据问题解决和优化
Mysql批量插入数据问题解决和优化一.问题描述项目中mysql批量插入大概50000左右数据,使用事务和批量,但是速度依旧很慢,大约60s左右,迫切希望改进这个问题. 二.问题原因尽管是批量a ...
MySQL批量插入数据的几种方法
最近公司要求测试数据库的性能,就上网查了一些批量插入数据的代码,发现有好几种不同的用法,插入同样数据的耗时也有区别别的先不说,先上一段代码与君共享方法一: package com.bigdata; ...
mysql 批量插入数据方法_mysql大批量插入数据的4种方法示例
前言本文主要给大家介绍了关于mysql大批量插入数据的4种方法,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍吧方法一:循环插入这个也是最普通的方式,如果数据量不是很大,可以使用, ...
MySQL(一) Python操控mysql批量插入数据
在Python中,通过pymysql模块,编写简短的脚本,即方便快捷地控制MySQL数据库一.连接数据库使用的函数:pymysql.connect 语法:db=pymysql.connect(ho ...

Mysql 批量插入数据的方法

Mysql 批量插入数据的方法相关推荐

最新文章

热门文章