using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using System.Data;
|
using System.Data.SqlClient;
|
using Microsoft.Practices.EnterpriseLibrary.Data;
|
|
namespace ThreadTestSMGW
|
{
|
public class DataSql
|
{
|
//Database da = DatabaseFactory.CreateDatabase("ConnectionString");
|
////插入数据
|
//public int InsertSql(string starttime,string endtime)
|
//{
|
// string sql = @"insert into tb_jzcs(creattime,updatetime) values(@createtime,@updatetime) ;select @@IDENTITY;";
|
// System.Data.SqlClient.SqlCommand cmd = new SqlCommand();
|
// cmd.Parameters.Add(new SqlParameter() { ParameterName = "@createtime", Value = starttime });
|
// cmd.Parameters.Add(new SqlParameter() { ParameterName="@updatetime",Value=endtime});
|
// cmd.CommandText = sql;
|
// cmd.CommandType = CommandType.Text;
|
// cmd.CommandTimeout = 1000000000;
|
// object ret=da.ExecuteScalar(cmd);
|
// return Convert.ToInt32(ret);
|
//}
|
|
//public void UpdateSql(string time,int id)
|
//{
|
// string sql = @"update tb_jzcs set updatetime=@updatetime where id=@id";
|
// System.Data.SqlClient.SqlCommand cmd = new SqlCommand();
|
// cmd.Parameters.Add(new SqlParameter() { ParameterName = "@updatetime", Value = time });
|
// cmd.Parameters.Add(new SqlParameter() { ParameterName="@id",Value=id});
|
// cmd.CommandText = sql;
|
// cmd.CommandType = CommandType.Text;
|
// cmd.CommandTimeout = 1000000000;
|
// da.ExecuteNonQuery(cmd);
|
//}
|
|
/**/
|
/// <summary>
|
/// SqlBulkCopy
|
/// </summary>
|
/// <param name="connectionString">目标连接字符</param>
|
/// <param name="TableName">目标表</param>
|
/// <param name="dt">源数据</param>
|
public void SqlBulkCopyByDatatable(string connectionString, string TableName, DataTable dt)
|
{
|
using (SqlConnection conn = new SqlConnection(connectionString))
|
{
|
//生成SqlBulkCopy 实例，构造函数指定了目标数据库，使用SqlBulkCopyOptions.UseInternalTransaction是指迁移动作指定在一个Transaction当中，如果数据迁移中产生错误或异常将发生回滚。
|
using (SqlBulkCopy sqlbulkcopy = new SqlBulkCopy(connectionString, SqlBulkCopyOptions.UseInternalTransaction))
|
{
|
try
|
{
|
sqlbulkcopy.BulkCopyTimeout = 5000;//指定操作完成的Timeout时间
|
sqlbulkcopy.DestinationTableName = TableName;
|
for (int i = 0; i < dt.Columns.Count; i++)
|
{
|
sqlbulkcopy.ColumnMappings.Add(dt.Columns[i].ColumnName, dt.Columns[i].ColumnName);
|
}
|
|
|
sqlbulkcopy.WriteToServer(dt);//WriteToServer方法就是将数据源拷备到目标数据库。在使用WriteToServer方法之前必须先指定 DestinationTableName属性，也就是目标数据库的表名
|
}
|
catch (System.Exception ex)
|
{
|
throw ex;
|
}
|
}
|
}
|
}
|
}
|
}
|
