这几天因为工作需要对数据库的数据进行同步，顺便研究了一下从2个不同的数据库中同步表结构相同表的数据

网上的一些资料好像都做得很复杂

自己整理写了一个简单的（不考虑性能）同步工具，分享一下表同步过程中遇到的问题，具体请看下面代码吧

ps：如果需要其他数据库支持，请使用dbfactory来创建适配器和commandbuilder来实现（实现过程不变），本文不涉及多数据库支持

检索关键词： sqldataadapter 做表同步 同步2张表的数据 把一张表的数据镜像克隆到另一张表  同步2张表的数据但不进行删除数据

/// <summary> /// 同步表 /// </summary> /// <param name="tableName"/>表名 /// <param name="sourceConnString"/>源数据库连接字符串 /// <param name="targetConnString"/>目标据库连接字符串 /// <param name="add"/>是否处理新增 /// <param name="update"/>是否处理更新 /// <param name="delete"/>是否处理删除 void SynchronousTable(string tableName, string sourceConnString, string targetConnString,bool add,bool update,bool delete) { string sql = string.Format("select * from {0}", tableName); using (SqlDataAdapter sda_source = new SqlDataAdapter(sql, sourceConnString)) { using (SqlDataAdapter sda_target = new SqlDataAdapter(sql, targetConnString)) { //获取自动生成的脚本 SqlCommandBuilder build = new SqlCommandBuilder(sda_target); build.ConflictOption = ConflictOption.OverwriteChanges;//根据主键进行更新 build.SetAllValues = true;//保证更新时，更新语句是设置所有的值，而不是只有修改的列，平常用时，建议为false，性能高，做同步时，建议用true。 build.QuotePrefix = "[";//保留在查询语句中出现的[ build.QuoteSuffix = "]";//保留在查询语句中出现的] sda_target.DeleteCommand = build.GetDeleteCommand(); sda_target.InsertCommand = build.GetInsertCommand(); sda_target.UpdateCommand = build.GetUpdateCommand(); DataTable dt_target = new DataTable(); sda_target.ContinueUpdateOnError = true;//设置执行出错仍然继续 int sum = 0;//总更新数量 sda_source.AcceptChangesDuringFill = false;//保证填充数据后，所有的状态都为add sda_source.Fill(dt_target);//把源表数据填充到待处理的目标表中 if (add)//追加数据 { int num = sda_target.Update(dt_target);//必须设置 sda_target.ContinueUpdateOnError = true;//设置执行出错仍然继续 WriteMessageLine("共执行{0}条插入语句", num); sum += num; } if (update)//更新目标表中和源表中同时存在的数据 { for (int i = dt_target.Rows.Count-1; i >=0; i--) { if (dt_target.Rows[i].RowState != DataRowState.Added) { dt_target.Rows.RemoveAt(i);//移除所有已经添加的数据 } } dt_target.AcceptChanges();//因datatable设置只有unchanged的行才能手工修改状态，这边进行同意所有修改 for (int i = 0; i < dt_target.Rows.Count; i++) { dt_target.Rows[i].SetModified();//设置添加失败的所有行为修改状态 } int num = sda_target.Update(dt_target);//表中可能存在不是修改的数据，这部分数据有新增(当追加数据没有勾时)，所以必须设置sda_target.ContinueUpdateOnError = true; WriteMessageLine("共执行{0}条更新语句", num); sum += num; } dt_target.Rows.Clear();//释放内存，如果表太大，这里不释放，后面就更艰难了 WriteMessageLine("共更新{1}条记录到表{0}", tableName, sum); if (delete)//删除目标表中，源表不存在的数据 { dt_target = new DataTable(); sda_target.MissingSchemaAction = MissingSchemaAction.AddWithKey;//加载结构 <div class="clearfix"></div> </div> <nav aria-label="..."> <ul class="pager"> <li class="previous"><a href="58817">上一篇： CCNP_route札记6 关于OSPF中的hello和DBD顺序 </a></li> <li class="next"><a href="40124">下一篇： awk 轮换 匹配 </a></li> </ul> </nav> <div class="alert alert-warning" role="alert"> <strong>免责声明：</strong> 本文仅代表作者个人观点，与爱易网无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。 </div> <div class="panel panel-default"> <div class="panel-heading"> <h3 class="panel-title">相关资料<span><a target="_blank" class="pull-right" href="/sjkjc/">更多></a></span></h3> </div> <div class="panel-body row"> <ol> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/37600' title=' Java实现MongoDB的日期（Date）分组效能 ' target="_blank"> Java实现MongoDB的日期（Date）分组效能 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/54770' title=' PHP操作MongoDB数据库附数据库装配 ' target="_blank"> PHP操作MongoDB数据库附数据库装配 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/49226' title=' Window7上Oracle11的安装与卸载 ' target="_blank"> Window7上Oracle11的安装与卸载 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/8624' title='www.eygle.com片面改版:)' target="_blank"> www.eygle.com片面改版:)</a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/57257' title=' 批改oracle数据文件大小 ' target="_blank"> 批改oracle数据文件大小 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/49928' title=' oracle内联接、外连接、左外连接、右外连接、全外连接 ' target="_blank"> oracle内联接、外连接、左外连接、右外连接、全外连接 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/42702' title=' Java 操作Access加密、未加密数据库步骤 ' target="_blank"> Java 操作Access加密、未加密数据库步骤 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/43999' title=' 按某几列剔除表中重复数据 ' target="_blank"> 按某几列剔除表中重复数据 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/48945' title=' db2跟oracle中的树查询（递归查询）语句 ' target="_blank"> db2跟oracle中的树查询（递归查询）语句 </a></li></div> </ol> </div> </div> </div> <div class="col-lg-4 hidden-sm hidden-xs"> <!--右边的内容--> <a id="AdPageRight1_AdPageRight" href="http://www.tdyun.com/cloud/?aiyiweb" target="_blank"><img class="img-responsive" src="/images/TdPageAd/vps.png" alt="香港云服务器 免备案 云主机VPS 国内 独立IP 独享15M 月付SSD" /></a> <script src='/Scripts/AdContentPage300_1.js' language='javascript'></script> <script src='/Scripts/AdContentPage300_2.js' language='javascript'></script> <script src='/Scripts/AdContentPage300_3.js' language='javascript'></script> <div class="panel panel-default"> <div class="panel-heading"> <h3 class="panel-title">推荐阅读<span><a target="_blank" class="pull-right" href="/sjkjc/">更多></a></span></h3> </div> <div class="panel-body"> <ol> <li class="articleAbout"><a href=/sjkjc/45731 title=' ArcCatalog中无法重命名地理数据库、要素数据集、表字段别名的有关问题 ' target="_blank"> ArcCatalog中无法重命名地理数据库、要素数据集、表字段别名的有关问题 </a></li> <li class="articleAbout"><a href=/sjkjc/35416 title=' Oracle数据库版本有区别的冷机备份还原 ' target="_blank"> Oracle数据库版本有区别的冷机备份还原 </a></li> <li class="articleAbout"><a href=/sjkjc/38383 title=' [每天一题] 11gOCP 1z0-052 :2013-09-17 DRA-Data Recovery Advisor.B31 ' target="_blank"> [每天一题] 11gOCP 1z0-052 :2013-09-17 DRA-Data Recovery Advisor.B31 </a></li> <li class="articleAbout"><a href=/sjkjc/45229 title=' until cancel的意思和使用场景 ' target="_blank"> until cancel的意思和使用场景 </a></li> <li class="articleAbout"><a href=/sjkjc/43312 title=' 什么是PAGELATCH跟PAGEIOLATCH ' target="_blank"> 什么是PAGELATCH跟PAGEIOLATCH </a></li> <li class="articleAbout"><a href=/sjkjc/42235 title=' oracle中施用job来周期性的定时执行任务 ' target="_blank"> oracle中施用job来周期性的定时执行任务 </a></li> <li class="articleAbout"><a href=/sjkjc/57327 title=' 从浅到深理解索引的实现(1) ' target="_blank"> 从浅到深理解索引的实现(1) </a></li> <li class="articleAbout"><a href=/sjkjc/52190 title=' Oracle系列之7-Trigger ' target="_blank"> Oracle系列之7-Trigger </a></li> <li class="articleAbout"><a href=/sjkjc/26335 title='用SQL Server为Web浏览器提供图像（一）(转)' target="_blank"> 用SQL Server为Web浏览器提供图像（一）(转)</a></li> <li class="articleAbout"><a href=/sjkjc/37009 title=' 装配HBase Snappy ' target="_blank"> 装配HBase Snappy </a></li> <li class="articleAbout"><a href=/sjkjc/54923 title=' SP2-1503: 没法初始化 Oracle 调用界面|SP2-0152: ORACLE 不能正常工作 ' target="_blank"> SP2-1503: 没法初始化 Oracle 调用界面|SP2-0152: ORACLE 不能正常工作 </a></li> <li class="articleAbout"><a href=/sjkjc/56768 title=' 怎么更换BIEE登录界面样式 ' target="_blank"> 怎么更换BIEE登录界面样式 </a></li> <li class="articleAbout"><a href=/sjkjc/55986 title=' 执行db2命令查看异常代码说明的方法 ' target="_blank"> 执行db2命令查看异常代码说明的方法 </a></li> <li class="articleAbout"><a href=/sjkjc/47082 title=' DB2数据库表操作异常SQL0668N Operation not allowed for reason code "1" on table "XXXX" SQLSTATE=57016的解决办法 ' target="_blank"> DB2数据库表操作异常SQL0668N Operation not allowed for reason code "1" on table "XXXX" SQLSTATE=57016的解决办法 </a></li> <li class="articleAbout"><a href=/sjkjc/52173 title=' Oracle OCP札记-110226 ' target="_blank"> Oracle OCP札记-110226 </a></li> <li class="articleAbout"><a href=/sjkjc/49313 title=' oracle 高速删除重复的记录 ' target="_blank"> oracle 高速删除重复的记录 </a></li> <li class="articleAbout"><a href=/sjkjc/26271 title='sqlserver日志文件总结及充满处理' target="_blank"> sqlserver日志文件总结及充满处理</a></li> <li class="articleAbout"><a href=/sjkjc/7836 title='MySQL进阶_create table篇' target="_blank"> MySQL进阶_create table篇</a></li> <li class="articleAbout"><a href=/sjkjc/42437 title=' JSP温习笔记——第10章 连接数据库 之 JDBC相关 ' target="_blank"> JSP温习笔记——第10章 连接数据库 之 JDBC相关 </a></li> <li class="articleAbout"><a href=/sjkjc/36518 title=' Oracle数据库承停 ' target="_blank"> Oracle数据库承停 </a></li> </ol> </div> </div> </div> </div> <div class="clearfix"></div> <footer class=" footer navbar-bottom"> <em>友情链接：</em> <a href="http://www.aiyiweb.com/" target="_blank">爱易网 </a> <a href="http://www.aiyiweb.com/" target="_blank">云虚拟主机技术 </a> <a href="http://www.aiyiweb.com/" target="_blank">云服务器技术 </a> <a href="http://www.aiyiweb.com/" target="_blank">程序设计技术 </a> <a href="http://www.aiyiweb.com/" target="_blank">开发网站 </a> <a href="http://www.aiyiweb.com/" target="_blank">APP开发教程 </a> <br /> <script type="text/javascript">(function(){document.write(unescape('%3Cdiv id="bdcs"%3E%3C/div%3E'));var bdcs = document.createElement('script');bdcs.type = 'text/javascript';bdcs.async = true;bdcs.src = 'http://znsv.baidu.com/customer_search/api/js?sid=15239353030108964139' + '&plate_url=' + encodeURIComponent(window.location.href) + '&t=' + Math.ceil(new Date()/3600000);var s = document.getElementsByTagName('script')[0];s.parentNode.insertBefore(bdcs, s);})();</script> Copyright © 2013-2024 爱易网页 当前在线：693人　 网站在18分28秒内访问总人数：10630人 当前 24.41% 　<a href="https://beian.miit.gov.cn" target="_blank">粤ICP备18100884号-2 </a> <script charset="UTF-8" id="LA_COLLECT" src="//sdk.51.la/js-sdk-pro.min.js"></script> <script>LA.init({ id: "JszEmKrtpbU59dY5", ck: "JszEmKrtpbU59dY5" })</script> </footer> </div> </body> </html>