现在的位置: 首页 > 综合 > 正文

asp.net(c#) DataTable 快速导入数据库

2016年10月27日 ⁄ 综合 ⁄ 共 1916字 ⁄ 字号 评论关闭

public void InsertTable(DataTable dt, string TabelName, DataColumnCollection dtColum)
    {
      
        //声明数据库连接
        mycon.Open();
        //声明SqlBulkCopy ,using释放非托管资源
        using (SqlBulkCopy sqlBC = new SqlBulkCopy(mycon))
        {
            //一次批量的插入的数据量
            sqlBC.BatchSize = 1000;
            //超时之前操作完成所允许的秒数,如果超时则事务不会提交 ,数据将回滚,所有已复制的行都会从目标表中移除
            sqlBC.BulkCopyTimeout = 60;

            //設定 NotifyAfter 属性,以便在每插入10000 条数据时,呼叫相应事件。
            sqlBC.NotifyAfter = 10000;
            // sqlBC.SqlRowsCopied += new SqlRowsCopiedEventHandler(OnSqlRowsCopied);
            //设置要批量写入的表
            sqlBC.DestinationTableName = TabelName;
            //自定义的datatable和数据库的字段进行对应
            //sqlBC.ColumnMappings.Add("id", "tel");
            //sqlBC.ColumnMappings.Add("name", "neirong");
            for (int i = 0; i < dtColum.Count; i++)
            {
                sqlBC.ColumnMappings.Add(dtColum[i].ColumnName.ToString(), dtColum[i].ColumnName.ToString());
            }
            //批量写入
            sqlBC.WriteToServer(dt);
        }
        mycon.Dispose();
    }
    //响应时事件
    void OnSqlRowsCopied(object sender, SqlRowsCopiedEventArgs e)
    {
        // Response.Write("<br/> OK! ");
    }

DataAdapter.SelectCommand用于获取数据,因此它的CommandText应该是select语句;
DataAdapter.InsertCommand用于插入数据,因此它的CommandText应该是insert语句;
DataAdapter.DeleteCommand用于删除数据,因此它的CommandText应该是delete语句;
DataAdapter.UpdateCommand用于更新数据,因此它的CommandText应该是update语句;

因此你的代码应该这样写:
SelectSQL="select * from tblName";
SqlCommand SelectCmd = new SqlCommand(SelectSQL, Con);

InsertSQL="insert into tblName (Input_Time,Location_ID) values (@Input_Time,@Location_ID)";

SqlCommand InsertCmd = new SqlCommand(InsertSQL, Con);
InsertCmd.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Input_Time",System.Data.SqlDbType.Time));
InsertCmd.Parameters.Add(new System.Data.SqlClient.SqlParameter("@Location_ID",System.Data.SqlDbType.NVarChar));

SqlDataAdapter Dad = new SqlDataAdapter();
Dad.SelectCommand = SelectCmd;
Dad.InsertCommand = InsertCmd;
Dad.Update(DT);

抱歉!评论已关闭.