首页 / MYSQL / Mysql 批量插入数据的方法

Mysql 批量插入数据的方法

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Mysql 批量插入数据的方法，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2683字，纯文字阅读大概需要4分钟。

内容图文

使用的方式是 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;
     }
     }
}

 

原文：http://www.cnblogs.com/rongfengliang/p/4175174.html

内容总结

以上是互联网集市为您收集整理的Mysql 批量插入数据的方法全部内容，希望文章能够帮你解决Mysql 批量插入数据的方法所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1074016.html

来源：【匿名】