class Program
{
static void Main(string[] args)
{
string cString = "Data Source=.;User ID=sa;password=zaza;Initial Catalog=tempDB;";
using (SqlConnection conn = new SqlConnection(cString))
{
conn.Open();
SqlCommand comm = new SqlCommand("SELECT FirstName, LastName, HomePhone, Title FROM Employees;", conn);
SqlDataReader reader = comm.ExecuteReader();
using (SqlConnection conn2 = new SqlConnection(cString))
{
conn2.Open();
using (SqlBulkCopy bcp = new SqlBulkCopy(conn2))
{
DataTable dt = new DataTable();
DataRow dr;
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);
StreamReader sr = new StreamReader(@"c:emp.txt");
string input;
while ((input = sr.ReadLine()) != null)
{
string[] s = input.Split(new char[4]);
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();
}
}
}
}
}
}
这是代码..
{
static void Main(string[] args)
{
string cString = "Data Source=.;User ID=sa;password=zaza;Initial Catalog=tempDB;";
using (SqlConnection conn = new SqlConnection(cString))
{
conn.Open();
SqlCommand comm = new SqlCommand("SELECT FirstName, LastName, HomePhone, Title FROM Employees;", conn);
SqlDataReader reader = comm.ExecuteReader();
using (SqlConnection conn2 = new SqlConnection(cString))
{
conn2.Open();
using (SqlBulkCopy bcp = new SqlBulkCopy(conn2))
{
DataTable dt = new DataTable();
DataRow dr;
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);
StreamReader sr = new StreamReader(@"c:emp.txt");
string input;
while ((input = sr.ReadLine()) != null)
{
string[] s = input.Split(new char[4]);
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();
}
}
}
}
}
}
这是代码..
解决方案 »
- 更改字段长度的问题
- 如何查询带有通配符(% _)的字符串?
- 请问一个关系代数的运算问题
- 兄弟们,请教一个关于数据迁移的问题
- 两台异地(但在同一局域网内)数据库服务器的数据同步问题!!!在线等待
- SQL SERVER 里 把数据库的数据文件和日志文件拷贝出来,到另外一个数据库中怎么还原?
- sql server里money类型的问题
- 我不小心用sql server 2000 sp2的enterprise manager 删除了数据库,硬盘还没有写入,请问如何才能恢复!大霞出手啊!谢谢了
- 存储过程如何返回这个值?help!!!
- 谁能给我说说吗
- update语句的疑问
- 请问如何给SQL的一列写入加1增长的数
. 是什么?
<appSettings>
<add key="SQLConn" value="server=.;database=centerLF;UID=sa;PWD=1111"></add>
<add key="SQLConnCIS" value="server=.;database=cisdb;UID=sa;PWD=1111"></add>
</appSettings>
具体用到数据链接的界面:
SqlConnection cn = new SqlConnection((string)Page.Cache["SQLConn"] + ";Pooling=true;Connection Reset=false;Connection Lifetime=30;Min Pool Size=3");
<appSettings>
<add key="SQLConn" value="server=.;database=centerLF;UID=sa;PWD=1111"></add>
<add key="SQLConnCIS" value="server=.;database=cisdb;UID=sa;PWD=1111"></add>
</appSettings>
具体用到数据链接的界面:
SqlConnection cn = new SqlConnection((string)Page.Cache["SQLConn"] + ";Pooling=true;Connection Reset=false;Connection Lifetime=30;Min Pool Size=3");
<add name="cString" connectionString="Data Source=.;User ID=sa;password=zaza;Initial Catalog=tempDB"
providerName="System.Data.SqlClient" />
</connectionStrings>
数据库名=demo; 服务器=服务器名称;Integrated Security=SSPI 服务器=服务器名称主要是这句话的设置!sql2005 ,测试过了,保证可用!