asp.net使用dataset批量添加数据

DateTime time1 = DateTime.Now;

Response.Write(time1 + "<br/>开始时间");

string sql = "Select name,tell,age from Aitems";

SqlConnection cn = new SqlConnection("Data Source=.;Initial Catalog=banks;Persist Security Info=True;User ID=sa;Password=123");

SqlDataAdapter da = new SqlDataAdapter(sql, cn);

DataSet ds = new DataSet();

DataTable tbl;

try

{

cn.Open();

da.Fill(ds, "newTable");

//查看表结构

tbl = ds.Tables[0];

foreach (DataColumn col in tbl.Columns)

{

Response.Write(col.ColumnName);

}

Response.Write("<br/>");

}

finally

{

cn.Close();

}

//向ds中追加要添加的批量数据

DataRow dr;

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

{

//使用DataRow对象为DataSet添加数据

dr = ds.Tables["newTable"].NewRow();

dr["name"] = i.ToString();

dr["tell"] = (i + 1).ToString();

dr["age"] = (i + 2).ToString();

//在数据库中增加新行

ds.Tables["newTable"].Rows.Add(dr);

}

//for (int i = 0; i < tbl.Rows.Count; i++)

//{

// DataRow row = tbl.Rows[i];

// Response.Write("<br/>");

// foreach (DataColumn col in tbl.Columns)

// {

// Response.Write(row[col] + " ");

// }

//}

//在批量添加数据前的准备工作

sql = "insert into Aitems(name,tell,age) VALUES (@item1,@item2,@item3)";

da.InsertCommand = new SqlCommand(sql, cn);

SqlParameter param = new SqlParameter();

param = da.InsertCommand.Parameters.Add(new SqlParameter("@item1", SqlDbType.Char, 50));

param.SourceVersion = DataRowVersion.Current;

param.SourceColumn = "name";

param = da.InsertCommand.Parameters.Add(new SqlParameter("@item2", SqlDbType.Char, 50));

param.SourceVersion = DataRowVersion.Current;

param.SourceColumn = "tell";

param = da.InsertCommand.Parameters.Add(new SqlParameter("@item3", SqlDbType.Char, 50));

param.SourceVersion = DataRowVersion.Current;

param.SourceColumn = "age";

//批量添加数据

try

{

cn.Open();

SqlCommandBuilder ComBuilder = new SqlCommandBuilder(da); ;

da.Update(ds, "newTable");

ds.AcceptChanges();

}

catch (Exception ex)

{

Label1.Text = "数据库错误：" + ex.Message.ToString();

}

finally

{

Label1.Text = "添加成功";

cn.Close();

DateTime time2 = DateTime.Now;

Response.Write(time2 + "结束时间");

}