SQL Azure 資料同步化技術

　SQL Azure 為雲端上的 SQL Server 資料庫，是基於 Windows Azure 平台能力所開發的雲端資料庫服務，與 Windows Azure 許多服務相同，都擁有高度的 Scale-Out 的能力，以及在雲端環境內強大的運算與儲存能力，而透過 SQL Azure 平台的特性，企業可以應用 SQL Azure 作為企業交換資料的中繼站，或是運用它作為服務前端 OLTP 應用程式的資料儲存位置，並與本地系統的資料庫或資料倉儲進行資料的同步化（Data Synchronization）。然而基於 SQL Azure 設計上的特性，傳統最廣為 SQL Server DBA 所使用的資料庫複製（Database Replication）無法在 SQL Azure 上使用，因此必須另外使用別的方法來處理資料同步的問題。唯一可以在 SQL Azure 和 SQL Server（或另一個 SQL Azure）之間進行資料同步的作法，就是寫程式來處理。

　所幸，微軟在同步化處理的領域中，早已發展出一套標準作法，並且將此作法開發成基礎功能，稱為 Microsoft Sync Framework，最新的版本是 2.1，它主要分為三個部份，最底層的是各式資料的供應者，Sync Framework 目前支援來自檔案系統（Microsoft.Synchronization.Files.dll）、資料庫（Microsoft.Synchronization.Data.dll）、輕量級資料（Microsoft.Synchronization.MetadataStorage.dll）以及作為發展同步化能力的簡單提供者（Microsoft.Synchronization.SimpleProvider.dll）等；中層是管理資料之間同步化走向的流程控制層（Orchestration），由 Microsoft.Synchronization.dll 的類別提供，所有的資料交換方向與步驟都經由此層管理；最上層則是處理同步化的控制器（Controller），由應用程式開發人員所撰寫，主要是啟動同步化流程以及應用 Orchestration 操縱資料同步流程的工作。

　要使用 Sync Framework 開發同步化應用程式時，開發人員要做的工作是撰寫 Orchestration 處理資料同步的程序，如果要同步的資料雙方都是相同且被 Sync Framework 所支援的話，那麼撰寫 Orchestration 的工作將會更簡單，SQL Azure/SQL Server 間的同步化就是因為 Sync Framework 對 SQL Server 的直接支援，因此可以大幅降低撰寫 Orchestration 所需要的工作量。下列程式碼即是一個簡單的 SQL Azure/SQL Server 資料庫同步化的程式碼：

[C#]
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
 
using System.Data.SqlClient;
using Microsoft.Synchronization.Data.SqlServer;
using Microsoft.Synchronization.Data;
using Microsoft.Synchronization;
 
namespace SQLAzureDataSync
{
    class Program
    {
        public static string sqlazureConnectionString =
@"Server=[Your SQL Azure Server].database.windows.net;
Database=AdventureWorksLTSQLAzure;
User ID=[Your SQL Azure User Name]@[Your SQL Azure Server];
Password=[Your SQL Azure Password];Trusted_Connection=False;Encrypt=True;";
        public static string sqllocalConnectionString =
@"Server=(local);Database=AdventureWorksLT2008;Trusted_Connection=True";
        public static readonly string scopeName = "alltablesyncgroup";
 
        static void Main(string[] args)
        {
            // Test if input arguments were supplied:
            if (args.Length == 0)
            {
                System.Console.WriteLine("Please enter an argument.");
                System.Console.WriteLine("Usage: SyncTest.exe -setup");
                System.Console.WriteLine("        SyncTest.exe -sync");
            }
            else if (args[0] == "-setup")
                Setup();
            else if (args[0] == "-sync")
                Sync();
        }
 
        public static void Setup()
        {
            try
            {
 
                SqlConnection sqlServerConn = new SqlConnection(sqllocalConnectionString);
                SqlConnection sqlAzureConn = new SqlConnection(sqlazureConnectionString);
                DbSyncScopeDescription myScope = new DbSyncScopeDescription(scopeName);
 
                DbSyncTableDescription Customer =
SqlSyncDescriptionBuilder.GetDescriptionForTable("Customer", sqlServerConn);
                DbSyncTableDescription Product =
SqlSyncDescriptionBuilder.GetDescriptionForTable("Product", sqlServerConn);
 
                // Add the tables from above to the scope
                myScope.Tables.Add(Customer);
                myScope.Tables.Add(Product);
 
                // Setup SQL Server for sync
                SqlSyncScopeProvisioning sqlServerProv = new SqlSyncScopeProvisioning(sqlServerConn, myScope);
                if (!sqlServerProv.ScopeExists(scopeName))
                {
                    // Apply the scope provisioning.
                    Console.WriteLine("Provisioning SQL Server for sync " + DateTime.Now);
                    sqlServerProv.Apply();
                    Console.WriteLine("Done Provisioning SQL Server for sync " + DateTime.Now);
                }
                else
                    Console.WriteLine("SQL Server Database server already provisioned for sync " + DateTime.Now);
 
                // Setup SQL Azure for sync
                SqlSyncScopeProvisioning sqlAzureProv = new SqlSyncScopeProvisioning(sqlAzureConn, myScope);
                if (!sqlAzureProv.ScopeExists(scopeName))
                {
                    // Apply the scope provisioning.
                    Console.WriteLine("Provisioning SQL Azure for sync " + DateTime.Now);
                    sqlAzureProv.Apply();
                    Console.WriteLine("Done Provisioning SQL Azure for sync " + DateTime.Now);
                }
                else
                    Console.WriteLine("SQL Azure Database server already provisioned for sync " + DateTime.Now);
 
                sqlAzureConn.Close();
                sqlServerConn.Close();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex);
            }
        }
 
        public static void Sync()
        {
            try
            {
 
                SqlConnection sqlServerConn = new SqlConnection(sqllocalConnectionString);
                SqlConnection sqlAzureConn = new SqlConnection(sqlazureConnectionString);
                SyncOrchestrator orch = new SyncOrchestrator
                {
                    LocalProvider = new SqlSyncProvider(scopeName, sqlAzureConn),
                    RemoteProvider = new SqlSyncProvider(scopeName, sqlServerConn),
                    Direction = SyncDirectionOrder.UploadAndDownload
                };
                Console.WriteLine("ScopeName={0} ", scopeName.ToUpper());
                Console.WriteLine("Starting Sync " + DateTime.Now);
                ShowStatistics(orch.Synchronize());
 
                sqlAzureConn.Close();
                sqlServerConn.Close();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex);
            }
        }
 
        public static void ShowStatistics(SyncOperationStatistics syncStats)
        {
            string message;
 
            message = "\tSync Start Time :" + syncStats.SyncStartTime.ToString();
            Console.WriteLine(message);
            message = "\tSync End Time   :" + syncStats.SyncEndTime.ToString();
            Console.WriteLine(message);
            message = "\tUpload Changes Applied :" + syncStats.UploadChangesApplied.ToString();
            Console.WriteLine(message);
            message = "\tUpload Changes Failed  :" + syncStats.UploadChangesFailed.ToString();
            Console.WriteLine(message);
            message = "\tUpload Changes Total   :" + syncStats.UploadChangesTotal.ToString();
            Console.WriteLine(message);
            message = "\tDownload Changes Applied :" + syncStats.DownloadChangesApplied.ToString();
            Console.WriteLine(message);
            message = "\tDownload Changes Failed  :" + syncStats.DownloadChangesFailed.ToString();
            Console.WriteLine(message);
            message = "\tDownload Changes Total   :" + syncStats.DownloadChangesTotal.ToString();
            Console.WriteLine(message);
        }
    }
}

　這個簡單的程式碼分為兩個部份，一個是準備資料結構的程式碼，由 Setup() 程式來處理，它會呼叫 SqlSyncDescriptionBuilder.GetDescriptionForTable() 取得來源資料庫的表格描述資料（Data Schema），接著利用 SqlSyncScopeProvisioning.Apply() 將描述資料的指令碼送到目標資料庫進行處理，以同步來源與目標資料庫的資料表。

NOTE
若想知道 Apply() 傳了什麼樣的指令到目標資料庫，你可以使用 SqlSyncScopeProvisioning.Script() 方法取得指令碼。

　另一個則是實際執行資料同步的程式碼，由 Sync() 程式來處理，由於 Sync Framework 已包含完整的 Orchestration 機制，所以程式碼非常簡單：

[C#]
SqlConnection sqlServerConn = new SqlConnection(sqllocalConnectionString);
SqlConnection sqlAzureConn = new SqlConnection(sqlazureConnectionString);
SyncOrchestrator orch = new SyncOrchestrator
{
    LocalProvider = new SqlSyncProvider(scopeName, sqlAzureConn),
    RemoteProvider = new SqlSyncProvider(scopeName, sqlServerConn),
    Direction = SyncDirectionOrder.UploadAndDownload
};
Console.WriteLine("ScopeName={0} ", scopeName.ToUpper());
Console.WriteLine("Starting Sync " + DateTime.Now);
ShowStatistics(orch.Synchronize());
 
sqlAzureConn.Close();
sqlServerConn.Close();

　

　同樣的程式碼也可以使用 SQL Azure/SQL Azure 之間的同步化，別忘了 SQL Azure 的特性就是只要修改連線字串就能使用，無須修改資料存取的程式碼，所以 Sync Framework 內的程式也幾乎不用修改就能相容並在 SQL Azure 上執行。

　

NOTE
若需要在大型資料庫中使用這支同步化程式，則你需要在目標資料庫的提供者中加入兩個設定，一個是 MemoryDataCacheSize（使用記憶體的大小），另一個是 ApplicationTransactionSize（批次交易的大小），以控制在大量資料庫同步時的交易筆數，以避免交易時間太長導致 SQL Azure Gateway 因連線時間太長而自動將連線關閉。

參考資料：

• SQL Server to SQL Azure Synchronization
• SQL Azure to SQL Azure Synchronization
• How to Sync Large SQL Server Databases to SQL Azure

A：試試看先把 html tag 組好再用 master..xp_cmdshell…

A：QUOTENAME 函數的用意是將字串前後加上…

Internet Explorer 9 Beta 隆重登場

立即試用Visual Studio 2010

Silverlight 4

Microsoft 軟體開發日，馬上報名！

小光再變身 ?! 萬聖節版小光再登場！

風雲再起！
Windows Phone 7 開發準備大全!!

ff833670(v=msdn.10).md

Windows Azure 的效能性拓展方法(英文)

楔子：

　　自從 iXXXXX那隻手機開始爆紅，使用者除了重視軟體的功能外，更在意起軟體的 UI (User Interface)，因此程式開發人員與視覺設計人員間的合作日漸重要。

　　然而，坊間仍不時聽聞程式與設計人員合作有磨合的情況，都不外乎是雙方在觀念與想法上有落差，導致溝通時出現嚴重問題。其實，這一切是都因為程式與設計人員均來自於不同的背景，使得在思考和溝通上無法如此契合。

　　但各位千萬不要洩氣！為了反映廣大開發人員的心聲，小編特別重金禮聘了 B+ Studio 兩名當家花旦，陳大比和郭小比，共同企劃一味 msD²n 清涼帖，來跟各位分享關於雙 D 在生活及工作上的大小趣事，希望能透過觀念上的交流，讓雙方的合作更加順利，因此帖有助於替各位排排毒、降肝火，順便藥到病除，就敬請各位看官按時服用。

　　程式與設計人員，大多來自不同的背景，因此在性格跟品味上，都有很大的差異。

　　就像程式人員的工作環境總被幅射電腦和螢幕包圍，附近一定堆滿一疊一疊踢到腳就會殘廢的的磚塊書，甚至在離開座位時，還不忘抱上鍵盤一塊行動，在在都顯示了他們的宅對於技術上的熱情與執著。

　　而設計人員則是一派優雅，桌面井然有序，配上簡單的幾幅相框點綴，總是在意穿著及愛 Mac電腦外型，也突顯他們在生活上的優雅，以及對於品味的堅持。

　　雖然雙方在工作環境、衣著，甚至生活中在意的事都有不同，但在合作時，如果能先豎大耳朵，用心聽聽對方的聲音，這將會是一個很好的開始！（拍手）

10 月份安全性公告摘要