用.NET SqlBulkCopy类执行批量复制

using System;

using System.Collections.Generic;

using System.Text;

using System.Data.SqlClient;

using System.IO;

using System.Data;

namespace BCP {

class Program{

static void Main(){

string cString = "Data Source=(local);User ID=tester;Password=tester;Initial Catalog=Northwind;";

using (SqlConnectionconn = new SqlConnection(cString)) {
conn.Open();
SqlCommandcomm = new SqlCommand("SELECT FirstName, LastName, HomePhone, Title FROM Employees;", conn);
SqlDataReader reader = comm.ExecuteReader();

using (SqlConnection conn2 = new SqlConnection(cString)) {

conn2.Open();

using (SqlBulkCopybcp = new SqlBulkCopy(conn2)){
DataTabledt = new DataTable();
DataRowdr;
DataColumn dc;
bcp.DestinationTableName = "dbo.Employees_bcp";

dc = new DataColumn();
dc.ColumnName = "Last";
dt.Columns.Add(dc);

dc = new DataColumn();
dc.ColumnName = "First";
dt.Columns.Add(dc);

dc = new DataColumn();
dc.ColumnName = "HomePhone";
dt.Columns.Add(dc);

dc = new DataColumn();
dc.ColumnName = "Title";
dt.Columns.Add(dc);
StreamReadersr = new StreamReader(@"c:\emp.txt");

string input;

while ((input = sr.ReadLine()) != null) {

string[] s = input.Split(new char[] {','});
dr = dt.NewRow();
dr["Last"] = s[0];
dr["First"] = s[1];
dr["HomePhone"] = s[2];
dr["Title"] = s[3];
dt.Rows.Add(dr);

}
sr.Close();

try {
bcp.ColumnMappings.Add("Last", "LastName");
bcp.ColumnMappings.Add("First", "FirstName");
bcp.ColumnMappings.Add("Title","Title");
bcp.ColumnMappings.Add("HomePhone","HomePhone");
bcp.WriteToServer(dt);

} catch (Exception ex){
Console.WriteLine(ex.Message);

} finally {
reader.Close();

} } } } } } }