SqlBulkCopy基本使用

以下代码稍加修改即可使用,比较简单

#region SqlBulkCopy
{
    //清空数据
    DataBaseOperator db = new DataBaseOperator( connectionString );
    db.ExecuteNonQuery( "truncate table os_report" );

    //导入数据
    using( SqlConnection conn = new SqlConnection( connectionString ) ) {
        conn.Open();
        using( SqlBulkCopy sbc = new SqlBulkCopy( conn ) ) {

            //服务器上目标表的名称
            sbc.DestinationTableName = "os_report";

            for( int i = 0 ; i < ds.Tables[ 0 ].Columns.Count ; i++ ) {

                //列映射定义数据源中的列和目标表中的列之间的关系
                sbc.ColumnMappings.Add( ds.Tables[ 0 ].Columns[ i ].ColumnName, ds.Tables[ 0 ].Columns[ i ].ColumnName );
            }
            sbc.WriteToServer( ds.Tables[ 0 ] );
        }
    }
}
#endregion