兩臺SQLServer數(shù)據(jù)同步解決方案

SQLServerSQLServer復(fù)制的概念性。SQL出版效勞器、訂閱效勞器、分發(fā)效勞器、出版物、文章SQL拷貝復(fù)制到分發(fā)效勞器，分發(fā)效勞器包含有一個分發(fā)數(shù)據(jù)庫，可接收數(shù)據(jù)的全部轉(zhuǎn)變，并保存這些轉(zhuǎn)變，再把這些轉(zhuǎn)變分發(fā)給訂閱效勞器SQLSERVERSQLSERVER1、快照復(fù)制〔呆會我們就使用這個〕2、事務(wù)復(fù)制3、合并復(fù)制就一步一步來實現(xiàn)復(fù)制的步驟。第一先來配置出版效勞器選中指定[效勞器]節(jié)點(diǎn)從[工具]下拉菜單的[復(fù)制]子菜單中選擇[公布、訂閱效勞器和分發(fā)]命令系統(tǒng)彈出一個對話框點(diǎn)[下一步]然后看著提示始終操作到完成。當(dāng)完成了出版效勞器的設(shè)置以后系統(tǒng)會為該效勞器的樹形構(gòu)造中添加一(distribution)其次創(chuàng)立出版物選中指定的效勞器會彈出一個對話框選擇要創(chuàng)立出版物的數(shù)據(jù)庫，然后單擊[創(chuàng)立公布]在[創(chuàng)立公布向?qū)的提示對話框中單擊[下一步]系統(tǒng)就會彈出一個對話(其他兩個大家可以去看看幫助)單擊[下一步]系統(tǒng)要求指定可以訂閱該公布的數(shù)據(jù)庫效勞器類型，ORACLEACCESS這里我們選擇運(yùn)行“SQLSERVER2000“的數(shù)據(jù)庫效勞器第三設(shè)計訂閱選中指定的訂閱效勞器從[工具]下拉菜單中選擇[復(fù)制]子菜單的[懇求訂閱]依據(jù)單擊[下一步]操作直到系統(tǒng)會提示檢查SQLSERVERSQLSERVER單擊[完成]。完成訂閱操作。完成上面的步驟其實復(fù)制也就是成功了。但是如何來知道復(fù)制是否成功了0023：59：59C:\ProgramFiles\MicrosoftSQLServer\MSSQL\REPLDATA\unc\XIAOWANGZI_database_database一些以時間做為文件名的文件夾差不多一分中就產(chǎn)生一個。要是你還不信的話就翻開你的數(shù)據(jù)庫看在訂閱的效勞器的指定訂閱數(shù)據(jù)庫下看是不是看到了你剛才所公布的表—一個手工同步的方案--定時同步效勞器上的數(shù)據(jù)--例子:--測試環(huán)境,SQLServer2000,遠(yuǎn)程效勞器名:xz,用戶名為:sa,無密碼,測試數(shù)據(jù)庫:test--效勞器上的表(查詢分析器連接到效勞器上創(chuàng)立)createtable[user](idintprimarykey,numbervarchar(4),namevarchar(10))go--以下在局域網(wǎng)(本機(jī)操作):null表示增記錄,1表示修改正的記錄,0表示無變化的記錄ifexists(select*fromdbo.sysobjectswhereid=object_id(N”[user]”)andOBJECTPROPERTY(id,N”IsUserTable”)=1)droptable[user]GOcreatetable[user](idintidentity(1,1),numbervarchar(4),namevarchar(10),statebit)gostatecreatetriggert_stateon[user]afterupdateasupdate[user]setstate=1from[user]ajoininsertedbona.id=b.idwherea.stateisnotnullgo--為了便利同步處理,創(chuàng)立鏈接效勞器到要同步的效勞器--這里的遠(yuǎn)程效勞器名為:xz,用戶名為:sa,無密碼master..sysserverswheresrvname=”srv_lnk”)execsp_dropserver”srv_lnk”,”droplogins”goexecsp_addlinkedserver”srv_lnk”,””,”SQLOLEDB”,”xz”execsp_addlinkedsrvlogin”srv_lnk”,”false”,null,”sa”go--創(chuàng)立同步處理的存儲過程ifexists(select*fromdbo.sysobjectswhereid=andOBJECTPROPERTY(id,N”IsProcedure”)=1)dropprocedure[dbo].[p_synchro]GOcreateprocp_synchroas--setXACT_ABORTonMSDTC--execmaster..xp_cmdshell”isql/S“xz“/U“sa“/P““/q“execmaster..xp_cmdshell””netstartmsdtc””,no_output“”,no_outputMSDTC--execmaster..xp_cmdshell”netstartmsdtc”,no_output--進(jìn)展分布事務(wù)處理,假設(shè)表用標(biāo)識列做主鍵,用下面的方法--BEGINDISTRIBUTEDTRANSACTION--同步刪除的數(shù)據(jù)deletefromsrv_lnk.test.dbo.[user]whereidnotin(selectidfrom[user])--同步增的數(shù)據(jù)insertintosrv_lnk.test.dbo.[user]selectid,number,namefrom[user]wherestateisnull--同步修改的數(shù)據(jù)updatesrv_lnk.test.dbo.[user]setnumber=b.number,name=fromsrv_lnk.test.dbo.[user]ajoin[user]bona.id=b.idwhereb.state=1--同步后更本機(jī)的標(biāo)志update[user]setstate=0whereisnull(state,1)=1--COMMITTRANgo--創(chuàng)立作業(yè),定時執(zhí)行數(shù)據(jù)同步的存儲過程ifexists(SELECT1frommsdb..sysjobswherename=”數(shù)據(jù)處理”)EXECUTEmsdb.dbo.sp_delete_job@job_name=”數(shù)據(jù)處理”execmsdb..sp_add_job@job_name=”數(shù)據(jù)處理”--創(chuàng)立作業(yè)步驟declare@sqlvarchar(800),@dbnamevarchar(250)select@sql=”execp_synchro”--數(shù)據(jù)處理的命令,@dbname=db_name--執(zhí)行數(shù)據(jù)處理的數(shù)據(jù)庫名execmsdb..sp_add_jobstep@job_name=”數(shù)據(jù)處理”,@step_name=”數(shù)據(jù)同步”,@subsystem=”TSQL”,@database_name=@dbname,@command=@sql,@retry_attempts5,@retry_interval=5--重試間隔--創(chuàng)立調(diào)度EXECmsdb..sp_add_jobschedule@job_name@name=”時間安排”,@freq_type=4,--每天@freq_interval=1,--每天執(zhí)行一次=00000--0goSQLServerSQLServer復(fù)制的概念性。SQL出版效勞器、訂閱效勞器、分發(fā)效勞器、出版物、文章SQL拷貝復(fù)制到分發(fā)效勞器，分發(fā)效勞器包含有一個分發(fā)數(shù)據(jù)庫，可接收數(shù)據(jù)的全部轉(zhuǎn)變，并保存這些轉(zhuǎn)變，再把這些轉(zhuǎn)變分發(fā)給訂閱效勞器SQLSERVERSQLSERVER1、快照復(fù)制〔呆會我們就使用這個〕2、事務(wù)復(fù)制3、合并復(fù)制就一步一步來實現(xiàn)復(fù)制的步驟。第一先來配置出版效勞器選中指定[效勞器]節(jié)點(diǎn)從[工具]下拉菜單的[復(fù)制]子菜單中選擇[公布、訂閱效勞器和分發(fā)]命令系統(tǒng)彈出一個對話框點(diǎn)[下一步]然后看著提示始終操作到完成。當(dāng)完成了出版效勞器的設(shè)置以后系統(tǒng)會為該效勞器的樹形構(gòu)造中添加一(distribution)其次創(chuàng)立出版物選中指定的效勞器會彈出一個對話框選擇要創(chuàng)立出版物的數(shù)據(jù)庫，然后單擊[創(chuàng)立公布]在[創(chuàng)立公布向?qū)的提示對話框中單擊[下一步]系統(tǒng)就會彈出一個對話(其他兩個大家可以去看看幫助)單擊[下一步]系統(tǒng)要求指定可以訂閱該公布的數(shù)據(jù)庫效勞器類型，ORACLEACCESS這里我們選擇運(yùn)行“SQLSERVER2000“的數(shù)據(jù)庫效勞器第三設(shè)計訂閱選中指定的訂閱效勞器從[工具]下拉菜單中選擇[復(fù)制]子菜單的[懇求訂閱]依據(jù)單擊[下一步]操作直到系統(tǒng)會提示檢查SQLSERVERSQLSERVER單擊[完成]。完成訂閱操作。完成上面的步驟其實復(fù)制也就是成功了。但是如何來知道復(fù)制是否成功了0023：59：59C:\ProgramFiles\MicrosoftSQLServer\MSSQL\REPLDATA\unc\XIAOWANGZI_database_database一些以時間做為文件名的文件夾差不多一分中就產(chǎn)生一個。要是你還不信的話就翻開你的數(shù)據(jù)庫看在訂閱的效勞器的指定訂閱數(shù)據(jù)庫下看是不是看到了你剛才所公布的表—一個手工同步的方案--定時同步效勞器上的數(shù)據(jù)--例子:--測試環(huán)境,SQLServer2000,遠(yuǎn)程效勞器名:xz,用戶名為:sa,無密碼,測試數(shù)據(jù)庫:test--效勞器上的表(查詢分析器連接到效勞器上創(chuàng)立)createtable[user](idintprimarykey,numbervarchar(4),namevarchar(10))go--以下在局域網(wǎng)(本機(jī)操作):null表示增記錄,1表示修改正的記錄,0表示無變化的記錄ifexists(select*fromdbo.sysobjectswhereid=object_id(N”[user]”)andOBJECTPROPERTY(id,N”IsUserTable”)=1)droptable[user]GOcreatetable[user](idintidentity(1,1),numbervarchar(4),namevarchar(10),statebit)gostatecreatetriggert_stateon[user]afterupdateasupdate[user]setstate=1from[user]ajoininsertedbona.id=b.idwherea.stateisnotnullgo--為了便利同步處理,創(chuàng)立鏈接效勞器到要同步的效勞器--這里的遠(yuǎn)程效勞器名為:xz,用戶名為:sa,無密碼master..sysserverswheresrvname=”srv_lnk”)execsp_dropserver”srv_lnk”,”droplogins”goexecsp_addlinkedserver”srv_lnk”,””,”SQLOLEDB”,”xz”execsp_addlinkedsrvlogin”srv_lnk”,”false”,null,”sa”go--創(chuàng)立同步處理的存儲過程ifexists(select*fromdbo.sysobjectswhereid=andOBJECTPROPERTY(id,N”IsProcedure”)=1)dropprocedure[dbo].[p_synchro]GOcreateprocp_synchroas--setXACT_ABORTonMSDTC--execmaster..xp_cmdshell”isql/S“xz“/U“sa“/P““/q“execmaster..xp_cmdshell””netstartmsdtc””,no_output“”,no_outputMSDTC--execmaster..xp_cmdshell”netstartmsdtc”,no_output--進(jìn)展分布事務(wù)處理,假設(shè)表用標(biāo)識列做主鍵,用下面的方法--BEGINDISTRIBUTEDTRANSACTION--同步刪除的數(shù)據(jù)deletefromsrv_lnk.test.dbo.[user]whereidnotin(selectidfrom[user])--同步增的數(shù)據(jù)insertintosrv_lnk.test.dbo.[user]selectid,number,namefrom[user]wherestateisnull--同步修改的數(shù)據(jù)updatesrv_lnk.test.dbo.[user]setnumber=b.number,name=fromsrv_lnk.test.dbo.[user]ajoin[user]bona.id=b.idwhereb.state=1--同步后更本機(jī)的標(biāo)志update[user]setstate=0whereisnull(state,1)=1--COMMITTRANgo--創(chuàng)立作業(yè),定時執(zhí)行數(shù)據(jù)同步的存儲過程ifexists(SELECT1frommsdb..sysjobswherename=”數(shù)據(jù)處理”)EXECUTEmsdb.dbo.sp_delete_job@job_name=”數(shù)據(jù)處理”execmsdb..sp_add_job@job_name=”數(shù)據(jù)處理”--創(chuàng)立作業(yè)步驟declare@sqlvarchar(800),@dbnamevarchar(250)select@sql=”execp_synchro”--數(shù)據(jù)處理的命令,@dbname=db_name-