sql笨办法同步数据
2024-08-25 19:06:37
Helpers.SqlHelper sqlHelper = new Helpers.SqlHelper("server=***;database=Cms;user id=sa;password=123"); string[] tableNames = { "A", "B", "C", "D", "E" };
var sb = new StringBuilder();
foreach (var tableName in tableNames)
{
var dt = sqlHelper.ExecuteDataTable("select * from "+tableName+" where 0=0"); sb.AppendLine("set identity_insert "+tableName+" on");
sb.AppendLine("truncate table " + tableName + " ");
if (dt != null)
{
var val = string.Empty; for (int i = ; i < dt.Rows.Count; i++)
{
if (i% == )
{
sb.AppendLine("insert into [" + tableName + "](");
for (int r = ; r< dt.Columns.Count; r++)
{
if (r > )
sb.Append(",");
sb.Append(dt.Columns[r].ColumnName);
}
sb.Append(")");
sb.AppendLine("values");
}
else
sb.AppendLine(","); sb.Append("(");
for (int j = ; j < dt.Columns.Count; j++)
{
if (j > )
sb.Append(","); val = dt.Rows[i][j].ToString();
if (dt.Columns[j].DataType == typeof (DateTime) || dt.Columns[j].DataType == typeof (int) ||
dt.Columns[j].DataType == typeof (long))
{
if (string.IsNullOrEmpty(val))
{
sb.Append("null");
}
else
{
sb.Append("'" + val + "'");
}
}
else
{
sb.Append("'" + val.Replace("'", "''") + "'");
}
}
sb.Append(")");
}
}
sb.AppendLine();
sb.AppendLine("set identity_insert " + tableName + " off");
sb.AppendLine();
}
var sql = sb.ToString(); Console.Write(sql);
Console.Read();
identity表导入失败,所以就用了这种笨办法来同步数据
最新文章
- AndroidStudio错误总结及解决(待续)
- jquery插件 - 学习笔记 (插件参数及函数的调用)
- Dojo Data Store——统一数据访问接口
- 实战-Fluxion与wifi热点伪造、钓鱼、中间人攻击、wifi破解
- ASP.NET MVC中简单使用Autofac
- 基于MVC4+EasyUI的Web开发框架经验总结(14)--自动生成图标样式文件和图标的选择操作
- zookeeper Eclipse 开发环境搭建及简单示例
- QuerySet转化为JSON
- PHP学习笔记:利用gd库给图片打图片水印
- JS实现 页面提交防刷新等待提示
- php 获取某个月的周次信息
- c++试题
- SpringMVC 国际化
- java开发中的Mutex vs Semaphore
- android 自定义权限管理
- python - 系统交互操作(subprocess)
- 计算机基础及发展 part2
- Kettle入门教程
- 【jmeter】jMeter使用Badboy录制Web测试脚本
- 联想拯救者s15k重装w10系统教程