cdatatable导入mysql_《项目经验》–简单三层使用DataTable向数据库表批量导入数据—向SqlServer一张表中导入数据|学步园...

向数据库的一张表中添加数据&＃xff0c;可以采用单个添加&＃xff0c;即一条数据、一条数据的添加&＃xff1b;也可以采用批量导入&＃xff0c;依次将好些条数据写入数据库的一张表中。文本借助实例《添加系列信息》讲解一种向数据库批量导入数据的方法。

1.界面设计

观看一下添加系列信息部分的界面设计&＃xff1a;

本文主要介绍批量导入系列信息的实现&＃xff0c;单个添加的实现不在此文讲解之列&＃xff01;

2.框架结构

此项目的实现&＃xff0c;我采用简单的三层&＃xff0c;看一下项目框架

3.批量导入数据的实现

下面逐层介绍每层实现&＃xff1a;

3.1 SqlHelper数据库助手类中添加向数据库表导入数据的方法(SqlHelper.cs)

#region 批量导入datatable

///

/// 批量导入datatable

///

/// 数据表

/// 数据表名

/// 列集合

public int InsertTable(DataTable dt, string TabelName, DataColumnCollection dtColum)

{

//打开数据库

GetConn();

try

{

//声明SqlBulkCopy ,using释放非托管资源

using (SqlBulkCopy sqlBC &＃61; new SqlBulkCopy(conn))

{

//一次批量的插入的数据量

//sqlBC.BatchSize &＃61; 1000;

//超时之前操作完成所允许的秒数&＃xff0c;如果超时则事务不会提交 &＃xff0c;数据将回滚&＃xff0c;所有已复制的行都会从目标表中移除

//sqlBC.BulkCopyTimeout &＃61; 60;

//設定 NotifyAfter 属性&＃xff0c;以便在每插入10000 条数据时&＃xff0c;呼叫相应事件。

//sqlBC.NotifyAfter &＃61; 10000;

// sqlBC.SqlRowsCopied &＃43;&＃61; new SqlRowsCopiedEventHandler(OnSqlRowsCopied);

//设置要批量写入的表

sqlBC.DestinationTableName &＃61; TabelName;

//自定义的datatable和数据库的字段进行对应

for (int i &＃61; 0; i

{

sqlBC.ColumnMappings.Add(dtColum[i].ColumnName.ToString(), dtColum[i].ColumnName.ToString());

}

//批量写入

sqlBC.WriteToServer(dt);

}

//导入成功&＃xff0c;返回1

return 1;

}

catch

{

//导入失败返回-1

return -1;

}

finally

{

//关闭数据库

conn.Close();

}

}

#endregion

3.2.DAL层批量导入数据的代码(DaoSeries.cs)

#region 批量导入系列信息

///

/// 批量导入系列信息

///

/// DataTable数据表-dt&＃xff1b;

/// DataColumnCollection 列集合-dtColum

/// 整数:大于0代表导入成功&＃xff1b;否则导入失败

public int ImportDatatable(DataTable dt, DataColumnCollection dtColum)

{

//定义一个整型标记变量

int result;

//调用sqlHelper的"批量导入datatable表"的方法

result &＃61; sqlheler.InsertTable(dt, "T_SeriesInfo", dtColum);

//返回结果

return result;

}

#endregion

3.3.BLL层批量导入数据的代码(MgrSeriesManager.cs)

#region 批量导入系列

///

/// 批量导入系列

///

/// 数据表

/// 数据列集合

/// 整数&＃xff1a;大于0代表导入成功&＃xff0c;否则导入失败

public int ImportDatatable(DataTable dt, DataColumnCollection dtColum)

{

DaoSeries series&＃61;new DaoSeries();

return series.ImportDatatable(dt, dtColum);

}

#endregion

3.4.界面层构造DataTable数据&＃xff0c;向BLL层传递(FrmSeriesManager.aspx,FrmSeriesManager.aspx.cs)

这里构造DataTable数据&＃xff0c;我是采用从界面上传Excel&＃xff0c;然后从Excel获取输入然后存入DataTable的

3.4.1 从界面传入Excel&＃xff0c;调用BLL层Excel转换成DataTable的方法实现

#region 批量导入系列

///

/// 批量导入系列

///

protected void btnImportSeries_Click(object sender, EventArgs e)

{

//BLL层&＃xff0c;添加系列信息类

MgrSeriesManager series &＃61; new MgrSeriesManager();

//BLL层把excel转化为datatable的方法

MgrCreateExcelData createExcelData &＃61; new MgrCreateExcelData();

//获取上传文件地址

string url &＃61; fupImprotSeries.PostedFile.FileName.ToString();

if (url &＃61;&＃61; "")

{

//数据源为空&＃xff0c;弹出提示&＃xff1a;请选择Excel文件&＃xff01;

Page.ClientScript.RegisterStartupScript(Page.GetType(), "message", "");

return;

}

string urlLocation &＃61; url.Substring(url.LastIndexOf("\\") &＃43; 1);//获取文件名

DataTable dt;

//在系统中建文件夹up,并将excel文件另存

this.fupImprotSeries.SaveAs(Server.MapPath("~\\up") &＃43; "\\" &＃43; urlLocation);//记录文件名到服务器相对应的文件夹中

// Response.Write(urlLocation);

//获得文件路径

string strpath &＃61; Server.MapPath("~\\up") &＃43; "\\" &＃43; urlLocation;

//string strpath &＃61; "c:\\abc.xls";

// Response.Write(strpath);

//把excel转换为datatable

dt &＃61; createExcelData.CreateExcelDataSource(strpath);

DataColumnCollection dcc &＃61; dt.Columns;

//导入数据库

int i &＃61; series.ImportDatatable(dt, dcc);

if (i > 0)

{

Page.ClientScript.RegisterStartupScript(Page.GetType(), "message", "");

}

else

{

Page.ClientScript.RegisterStartupScript(Page.GetType(), "message", "");

}

}

#endregion

3.4.2 BLL层Excel转换成DataTable的类(MgrCreateExcelData.cs)

/*************************************************

作者&＃xff1a;jql

小组&＃xff1a;一中考核系统

说明&＃xff1a;把excel转化为datatable

创建日期&＃xff1a;2012年11月25日14:17:06

版本号&＃xff1a;v1.0

版权所有&＃xff1a;信息技术提高班

**********************************************/

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

//引用各命名空间

using System.Data;

using System.Data.OleDb;

using System.Data.SqlClient;

namespace BLL

{

public class MgrCreateExcelData

{

public MgrCreateExcelData()

{

}

///

/// 传入excel路径&＃xff0c;转换为datatable

///

///

///

public DataTable CreateExcelDataSource(string url)

{

DataTable dt &＃61; null;

// string connetionStr &＃61; "Provider&＃61;Microsoft.Ace.OleDb.12.0;" &＃43; "Data Source&＃61;"

// &＃43;url &＃43; ";" &＃43; "Extended Properties&＃61;&＃39;Excel 8.0;HDR&＃61;Yes;IMEX&＃61;1&＃39;;";

//获得excel数据

string connetionStr &＃61; "Provider&＃61;Microsoft.Jet.OleDb.4.0;" &＃43; "data source&＃61;" &＃43; url &＃43; ";Extended Properties&＃61;&＃39;Excel 8.0; HDR&＃61;YES; IMEX&＃61;1&＃39;";

string strSql &＃61; "select * from [Sheet1$]";

OleDbConnection oleConn &＃61; new OleDbConnection(connetionStr);

OleDbDataAdapter oleAdapter &＃61; new OleDbDataAdapter(strSql, connetionStr);

try

{

//把excel数据填充给datatable

dt &＃61; new DataTable();

oleAdapter.Fill(dt);

return dt;

}

catch (Exception ex)

{

throw ex;

}

finally

{

oleAdapter.Dispose();

oleConn.Close();

oleConn.Dispose();

}

}

}

}

至此向数据库批量导入数据就实现了&＃xff0c;如果你想对要导入数据库的数据做合法性判断&＃xff0c;执行Excel转换成Datatable时&＃xff0c;自己加些判断处理就行了&＃xff01;