C# 条件量大时用临时表
2015-12-08 10:47
471 查看
/// <summary>
/// 把相关的ID生成一张临时表结构,并填充相关数据;
/// </summary>
/// <param name="Parameter">传送相关生成临时表的SQL语句,这样主要为了可以把保存条件临时表变得通用</param>
public byte[] ExecuteSaveTempGoodsStyleData(string tempSql, byte[] dsbyte, string sql)
{
DataSet dsRet = (DataSet)G._DeserializeObj(dsbyte);//转化成数据集
byte[] ret = null;
Database db = CreateDatabase();
SqlConnection sqlCon = null;
using (DbConnection conn = db.CreateConnection())
{
try
{
string str = sql;
sqlCon = new SqlConnection(conn.ConnectionString);
sqlCon.Open();
SqlCommand cmd = new SqlCommand(tempSql, sqlCon);//构建生成的临时表结构
int m = cmd.ExecuteNonQuery();
foreach (DataTable dt in dsRet.Tables)
{
string dtTempName = "#" + dt.TableName; //构建需要插入数据的临时表名称
SqlBulkCopy sqlBC = new SqlBulkCopy(sqlCon);//启用批量复制;
sqlBC.BulkCopyTimeout = 5000;
sqlBC.DestinationTableName = dtTempName;
sqlBC.NotifyAfter = 100;
sqlBC.WriteToServer(dt);
}
SqlDataAdapter da = new SqlDataAdapter(sql, sqlCon);
DataSet ds = new DataSet();
da.Fill(ds);
ret = G.SerializateObj(ds);
}
catch (System.Exception ex)
{
G.LogErr("ExecuteSaveTempGoodsStyleData", ex);
}
finally
{
sqlCon.Close();
}
}
return ret;
}
/// 把相关的ID生成一张临时表结构,并填充相关数据;
/// </summary>
/// <param name="Parameter">传送相关生成临时表的SQL语句,这样主要为了可以把保存条件临时表变得通用</param>
public byte[] ExecuteSaveTempGoodsStyleData(string tempSql, byte[] dsbyte, string sql)
{
DataSet dsRet = (DataSet)G._DeserializeObj(dsbyte);//转化成数据集
byte[] ret = null;
Database db = CreateDatabase();
SqlConnection sqlCon = null;
using (DbConnection conn = db.CreateConnection())
{
try
{
string str = sql;
sqlCon = new SqlConnection(conn.ConnectionString);
sqlCon.Open();
SqlCommand cmd = new SqlCommand(tempSql, sqlCon);//构建生成的临时表结构
int m = cmd.ExecuteNonQuery();
foreach (DataTable dt in dsRet.Tables)
{
string dtTempName = "#" + dt.TableName; //构建需要插入数据的临时表名称
SqlBulkCopy sqlBC = new SqlBulkCopy(sqlCon);//启用批量复制;
sqlBC.BulkCopyTimeout = 5000;
sqlBC.DestinationTableName = dtTempName;
sqlBC.NotifyAfter = 100;
sqlBC.WriteToServer(dt);
}
SqlDataAdapter da = new SqlDataAdapter(sql, sqlCon);
DataSet ds = new DataSet();
da.Fill(ds);
ret = G.SerializateObj(ds);
}
catch (System.Exception ex)
{
G.LogErr("ExecuteSaveTempGoodsStyleData", ex);
}
finally
{
sqlCon.Close();
}
}
return ret;
}
相关文章推荐
- C# 数据批量插入及更新
- 测试TTS(文本到语音功能)
- C# 类初始化顺序
- (转) C#多线程赛跑实例
- Microsoft.CompactFramework.CSharp.targets not found
- 【转】c#中关于文件的操作
- C#单例模式的泛型定义
- C#的Activator.CreateInstance方法
- C#反射详解
- c# 多线程 调用带参数函数
- C#借助FieldOffset属性实现共用体与强制类型转换
- C#邮件发送
- C#操作XML的方法
- c#通用递归生成无限层级树
- C#特性详解
- 造轮子:C#中将图片转化成base64字符串
- c#获取当前月的第一天和最后一天
- C# Mvc中文件下载
- C#遍历类的属性 PropertyInfo.Attributes
- c# 动态操作 zip\rar 文件,压缩解压组件使用