这几天因为工作需要对数据库的数据进行同步，顺便研究了一下从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="40126">上一篇： 【Oracle Log file 回复】 已归档、非当前的 Redo LogFile 损坏 </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/53623' title=' MongoDB学习笔记(1) ' target="_blank"> MongoDB学习笔记(1) </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/35251' title=' 微微信.NET 为何采用文件系统而不是数据库 ' target="_blank"> 微微信.NET 为何采用文件系统而不是数据库 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/39883' title=' Oracle优化经典稿子-索引原理篇·转 ' target="_blank"> Oracle优化经典稿子-索引原理篇·转 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/43627' title=' oracle 中查寻一个表的主键和索引 ' target="_blank"> oracle 中查寻一个表的主键和索引 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/40081' title=' nverchar或float部类 转换成百分比 ' target="_blank"> nverchar或float部类 转换成百分比 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/55571' title=' 安插时候自动添加ID的触发器 ' target="_blank"> 安插时候自动添加ID的触发器 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/36318' title=' 在myeclipse中通过jdbc访问mysql出现拒绝访问的解决方法 ' target="_blank"> 在myeclipse中通过jdbc访问mysql出现拒绝访问的解决方法 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/36594' title=' Eclipse下使用findbugs开展代码审查 ' target="_blank"> Eclipse下使用findbugs开展代码审查 </a></li></div> <div class="col-md-6 col-xs-12"> <li class="articleAbout"><a href='/sjkjc/45531' title=' Hibernate HBM里的 数据库部类 ' target="_blank"> Hibernate HBM里的 数据库部类 </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/vps2.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/26213 title='防止ADO连接SQLServer时的隐式连接_Sql2000函数组件_MSSQL教程' target="_blank"> 防止ADO连接SQLServer时的隐式连接_Sql2000函数组件_MSSQL教程</a></li> <li class="articleAbout"><a href=/sjkjc/51244 title=' 数据库分库分表(sharding)系列(4) 多数据源的事务处理 ' target="_blank"> 数据库分库分表(sharding)系列(4) 多数据源的事务处理 </a></li> <li class="articleAbout"><a href=/sjkjc/35906 title=' felayman——jdbc连接数据库的绝佳结构 ' target="_blank"> felayman——jdbc连接数据库的绝佳结构 </a></li> <li class="articleAbout"><a href=/sjkjc/57775 title=' oracle添 行锁 ' target="_blank"> oracle添 行锁 </a></li> <li class="articleAbout"><a href=/sjkjc/56514 title=' 事宜的操作 ' target="_blank"> 事宜的操作 </a></li> <li class="articleAbout"><a href=/sjkjc/38438 title=' oracle不能启动的有关问题 ' target="_blank"> oracle不能启动的有关问题 </a></li> <li class="articleAbout"><a href=/sjkjc/53286 title=' oracle10g sample schema 没安装,无hr用户 ' target="_blank"> oracle10g sample schema 没安装,无hr用户 </a></li> <li class="articleAbout"><a href=/sjkjc/46501 title=' 数据库表修补 ' target="_blank"> 数据库表修补 </a></li> <li class="articleAbout"><a href=/sjkjc/47881 title=' DBCP,CP30及proxool连接池在spring+hibernate中的配备 ' target="_blank"> DBCP,CP30及proxool连接池在spring+hibernate中的配备 </a></li> <li class="articleAbout"><a href=/sjkjc/53194 title=' h2数据库中关于字符串转化作日期的函数 ' target="_blank"> h2数据库中关于字符串转化作日期的函数 </a></li> <li class="articleAbout"><a href=/sjkjc/50754 title=' hibernate 做批量数据操作心得 ' target="_blank"> hibernate 做批量数据操作心得 </a></li> <li class="articleAbout"><a href=/sjkjc/47155 title=' 小米科技 电商机构 Mongodb sharding Cluster with Replica Set 集群 文档 ' target="_blank"> 小米科技 电商机构 Mongodb sharding Cluster with Replica Set 集群 文档 </a></li> <li class="articleAbout"><a href=/sjkjc/26192 title='利用存储过程得到某一指定的表与其它的表之间的外键关系_Sql2000存储过程_MSSQL教程' target="_blank"> 利用存储过程得到某一指定的表与其它的表之间的外键关系_Sql2000存储过程_MSSQL教程</a></li> <li class="articleAbout"><a href=/sjkjc/42711 title=' 匡正FLEA_Helper_Pager,让其支持source为sql时的多数据库操作 ' target="_blank"> 匡正FLEA_Helper_Pager,让其支持source为sql时的多数据库操作 </a></li> <li class="articleAbout"><a href=/sjkjc/57271 title=' 数据库同步跟数据库复制技术分析 ' target="_blank"> 数据库同步跟数据库复制技术分析 </a></li> <li class="articleAbout"><a href=/sjkjc/52292 title=' 查询表空间和数据文件对应关系的步骤 ' target="_blank"> 查询表空间和数据文件对应关系的步骤 </a></li> <li class="articleAbout"><a href=/sjkjc/41387 title=' asp.net复原备份数据库（C#） ' target="_blank"> asp.net复原备份数据库（C#） </a></li> <li class="articleAbout"><a href=/sjkjc/55793 title=' 在进行多表关联复杂查询时出现 ORA-00600: 内部异常代码, 参数: [19004], [], [], [], [], [], [], [] ' target="_blank"> 在进行多表关联复杂查询时出现 ORA-00600: 内部异常代码, 参数: [19004], [], [], [], [], [], [], [] </a></li> <li class="articleAbout"><a href=/sjkjc/51169 title=' Oracle基础学习札记（4） ' target="_blank"> Oracle基础学习札记（4） </a></li> <li class="articleAbout"><a href=/sjkjc/48854 title=' 集聚函数-字符串连接 ' target="_blank"> 集聚函数-字符串连接 </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 爱易网页 当前在线：1094人　 网站在16时47分24秒内访问总人数：187049人 当前 67.04% 　<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>