SQL中国研发中心

扩展事件在Denali CTP3里的新UI（二）

Qi Samuel Zhang — Wed, 09 Nov 2011 06:28:00 GMT

在前面一篇博文里我们介绍了如何使用扩展事件（XEvent）在Denali CTP3里的新UI创建和修改XEvent session，本文我们将介绍如何用新UI来显示和分析数据，我们将试图找到一个workload中平均开销最大的query。

在Object Explorer里右键点击前文创建的blogtest session，选择Watch Live Data，如图1所示，这将在SSMS里打开一个新的Live Data窗口，这时我们可以执行我们的workload，workload可以是应用程序的运行，也可以是一段SQL的执行，或者重播Profiler记录的SQL Trace，这里我们在SSMS的另一个窗口执行创建Northwind数据库的instnwnd.sql来模拟一个workload。

图1 启动Live Data窗口

当instnwnd.sql执行完毕后，先前打开的Live Data窗口会出现很多行数据，这些就是blogtest session所记录的sql_statement_starting和sql_statement_completed事件，这时可以点击工具栏上的Stop Data Feed按钮（工具栏第二个按钮），这样可以避免和workload无关的事件继续被Live Data窗口显示，如图2 所示。

图2 Live Data窗口

你的Live Data窗口可能只有2个列，name和timestamp，这是仅有的2个所有扩展事件共有的列，你可以选择工具栏上的Choose Columns…按钮添加/删除需要显示的列，我增加了3个列database_name，duration和statement，如图3所示。

图3 选择列

我们要找到Northwind数据库里平均执行时间最长的query，首先我们可以过滤不必要的事件，前文曾提到过Predicate可以在SQL Server端避免不需要的事件被产生，我们同时也支持客户端的过滤器，这可以帮助你做各种分析。点击工具栏上的Filters…按钮，这将打开Filters对话框，这里我们设置两个条件name=sql_statement_completed And database_name=Northwind，如图4所示。为了避免输入错误，你可以从事件列表里拷贝粘帖，你还可以右键点击某个Cell然后选择Filter by this Value，这将自动为你添加一个子句并And到原有条件上。

图4 Filter对话框

过滤掉不必要的事件后我们按照statement来做分组，点击工具栏上的Grouping…按钮，把statement移动到右边，点击OK，如图5所示。

图5 Grouping对话框

分组的目的是为了计算每个分组上duration的平均值，下面可以点击工具栏上的Aggregation…按钮，我们在duration上选择AVG，然后选择在duration(AVG)上按降序排序，如图6所示。

图6 Aggregation对话框

这样duration平均值最大的分组将被显示在第一行，我执行instnwnd.sql的workload里duration最大的分组是INSERT "Order Details" VALUES(10444,17,31.2,10,0)，它的duration是134206微秒，如图7所示。这样我们就找到了平均开销最大的query。

图7 开销最大的query

前文在创建blogtest session时增加了event_file的target，如果你打开SQL Server所在机器的Log目录（比如C:\Program Files\Microsoft SQL Server\MSSQL11.MSSQLSERVER\MSSQL\Log），你会发现一堆blogtest*.xel，你可以双击任何一个文件在SSMS里打开和Live Data类似的窗口，也可以通过SSMS的File|Open|Merge Extended Event Files…菜单在同一窗口里打开多个文件，后面的数据分析和Live Data窗口是一样的。

软件开发工程师徐进

扩展事件在Denali CTP3里的新UI（一）

Qi Samuel Zhang — Wed, 09 Nov 2011 06:19:00 GMT

去年年底时我曾经写过一篇介绍扩展事件（XEvent）在Denali CTP1里新功能的博文，在CTP1中我们提供了一个Object Model和一个简单的UI，在不久前发布的Denali CTP3里我们对XEvent的UI做了更好的支持，本文将进行介绍。

首先我们提供了一个功能强大的对话框用于创建/修改SQL Server里的XEvent Session，你可以在Object Explorer里右键点击Extended Events下的Sessions节点选择New Session…来新建一个Session，如图1所示。这将打开新建Session对话框，这个对话框有4个页面，分别是General、Events、Data Storage （Targets）、Advanced页面，下面我们一一介绍。

图1 新建Session

第一个General页面里你可以输入Session的名字，选择一些选项，比如Session是否和SQL Server一起启动，Session创建成功后是否立即启动该Session等等。我们支持与Profiler里模板类似的概念，只要选择一个模板，Event（包括Action和Predicate）和Target以及某些选项就自动选择好了，但是在CTP3里只有一个Standard模板，这个模板所选择的事件和Profiler里的Standard模板相对应。你也可以把自己创建的Session作为模板保存起来以备后用，保存模板只需要右键点击某个Session然后选择Export Session…即可。这里我们输入blogtest，并选择”Start the event session immediately after session creation”让blogtest在创建成功后立即启动，如图2所示。

图2 General页面

点击左边的Select a page列表里的Events切换到Events页面，这个页面是最复杂的，也是UI能够给你提供最大帮助的地方。你首先看到它分为左右两部分，左边是事件库，所有在SQL Server里注册的扩展事件都列在这里，右边是你选择的事件。在事件的选择上我们做了很多工作来帮助您：1. 你可以点击抬头排序，默认是按事件名排序；2. 可以输入关键字进行过滤，比如图3中我们输入sql_，所有名字含有sql_字样的事件都被列了出来并且高亮显示，过滤可以作用在事件名称上，也可以在事件的名称和描述上，或者事件所含的Fields上，你可以点击事件库右上方的ComboBox切换，所有的过滤都有高亮显示；3. 在Category和Channel上我们实现了和Excel类似的过滤过能，你可以点击Channel右边的下拉箭头选择只看Analytic channel的事件。

找到你需要的事件后，双击它或者点击两部分中间的>按钮加入选择，在这里我们选择了sql_statement_starting和sql_statement_completed事件。你可能注意到了有两个小图标（闪电和漏斗）显示在已选择事件的列表中，下面会介绍。

图3 在Events页面里选择事件

点击Events页面右上方的Configure按钮，页面将会滑动，事件库被隐藏，而配置事件的页面将出现，如图4所示，当然你点击Select可以回到刚才的页面。你会看到闪电和漏斗图标分别出现在了右边配置页面的Actions标签和Filter标签上，闪电代表的是该事件上有多少Global Fields（Actions）关联，漏斗代表该事件有没有Filter（Predicate）关联。

Action是指在发生事件的时刻可以读取的环境数据，比如event_sequence可以为所有事件排序，Profiler里每个事件都含有EventSequence列，而在XEvent里则被作为Action来实现了。

Predicate可以减少不必要的事件收集，比如我可以配置sql_statement_starting事件的Predicate为database_name=’Northwind’，那么发生在其他数据库的sql_statement_starting事件就不会被该Session所收集，Profiler可以为所有事件设置一个Column Filter，而XEvent支持为每个Event设置各自独立不同的Predicate，有兴趣可以参考MSDN里扩展事件对Action和Predicate的介绍。Event Fields标签列出所有该Event的列，某些Event会把一些开销比较大的列作为可选的列，你可以点击前面的CheckBox选择是否收集该列数据，比如sql_statement_starting的statement列就可以被取消选择。

你可以同时选择多个Event并选择/取消Action或配置Filter，在这里我们为sql_statement_starting和sql_statement_completed事件选择database_name action，不添加Filter并保持Event Fields默认值。

图4 在Events页面里配置事件

第三个页面是Data Storage页面，在这个页面里可以选择为Session添加不同的Target，这里我们选择event_file target并保持默认配置。

图5 Data Storage页面

最后一个页面是Advanced页面，这是可以设置控制Session行为的高级选项。有一个选项需要特别注意，”Maximum dispatch latency”，它描述了事件从被触发到写入到Target最长的等待时间，默认值是30秒，如果你使用和Profiler client-side tracing类似的Live Monitoring功能，你可能会希望把它改小，这样事件被触发后可以尽快地显示在SSMS里，但需要注意到是改小它会增加SQL Server的开销，这里我们把它改成5秒。

图6 Advanced页面

点击OK，blogtest session将会被创建成功并显示在Object Explorer里，在Session被创建后，你可以在Object Explorer里右键点击该Session并选择Properties，这将打开和创建Session相同的对话框，进行修改后点击OK即可完成。

右键点击blogtest选择”Watch Live Data”，这将打开前面提到的Live Monitoring功能，我们将会在后续的博文里继续介绍它。

软件开发工程师徐进

利用Contained Database和DAC来开发基于SQL Server "Denali"和SQL Azure之上的应用程序

Qi Samuel Zhang — Tue, 18 Oct 2011 06:46:00 GMT

大家好！

在刚刚结束的Microsoft TechEd China 2011中，我们在分会的一个小时里为大家讲解并演示了如何利用Contained Database和DAC来开发基于SQL Server "Denali"和SQL Azure之上的应用程序。为了能够和更多的开发人员和DBA介绍和分享CDB及DAC，并提供相关资源和工具下载的链接，我们特撰文如下，希望有所帮助。

背景

让应用程序的数据层可以在本地SQL Server服务器、私有云、共有云之间方便的部署、移动、升级和管理，正在迅速成为当前云时代的关键技术之一。SQL Server “Denali” 的新增功能——包含的数据库Contained Database (CDB) 和数据层应用DAC正是为了满足这一需求而研发并推出的。这两项技术在一起所提供的功能，将SQL Server应用程序的开发、部署、和不同环境之间的移动完全流程化了，让开发人员和DBA能够淋漓发挥，游刃有余。

进展

亮点简述

包含的数据库Contained Database (CDB)：排序规则和安全认证已经可以内置在CDB中；
数据层应用DAC：BACPAC既包含数据库的元信息，也包含数据；原地升级；可以防止篡改；
代码名为“Juneau”的SQL Server开发工具：基于Visual Studio 2010，可以从现有数据库中提取信息新建项目；智能感知（IntelliSense）；可深层验证；版本化build；可声明目标平台，定义服务器选择策略；界面友好直观；
导出导入工具：广泛支持SQL Server 2000（仅支持导出）、2005、2008、2008 R2、SQL Server Denali及SQL Azure。

SQL Server Migration Assistant简介（二）

Qi Samuel Zhang — Tue, 07 Jun 2011 08:58:00 GMT

在前一篇博文里我们介绍了使用SSMA for Oracle 5.0做Oracle数据库迁移之前的评估，本文中我们将介绍如何做Schema迁移和数据迁移。

首先我们需要连接目标数据库，点击工具条上的Connect to SQL Server，输入Server name，在Database里输入HR，如图1所示。如果你的SQL Server里不存在HR数据库，点击Connect后SSMA会提示错误，问你是否创建HR数据库，选择Yes。HR数据库创建后SSMA可能会提示SQL Server Agent未运行，这仅在使用服务器端数据迁移时才会用到，默认情况下我们使用的是客户端数据迁移，所以可以点击Continue忽略。

图1 连接到SQL Server服务器

连接上SQL Server服务器后我们就可以迁移Schema了，这里的Schema指数据以外的数据库定义，比如表结构、视图定义、存储过程等等。右键单击Oracle Metadata Explorer里的HR数据库，选择Convert Schema，如图2所示。SSMA运行一段时间后会在最下方的Output栏里显示转换是否有错误、警告或信息。这时你可以展开SQL Server Metadata Explorer里HR数据库的dbo schema，在Procedures文件夹下会发现ADD_JOB_HISTORY等存储过程，Tables文件夹下会发现COUNTRIES等表，说明Schema的迁移已经成功。

图2 转换Schema

如果这时你使用SQL Server客户端工具SQL Server Management Studio或者Visual Studio的Server Explorer查看SQL Server上的HR数据库，你会发现找不到前面所说的存储过程、表或者视图。这是因为Convert Schema菜单项只是在SSMA的Project里进行了转换，并未转换到数据库。这么设计为了让你可以在同步到SQL Server之前再做些其他修改，比如REGIONS表里的REGION_ID列在Oracle里是NUMBER类型，它被SSMA转换成了最安全的float(53)类型，如果你知道REGION_ID就是个整形，你可以把它修改为int类型，当然你最好对COUNTRIES表的REGION列也做同样的修改。

在确认Schema迁移没有问题后，你可以同步到SQL Server数据库了，在SQL Server Metadata Explorer里右键点击HR数据库，选择Synchronize with Database，如图3所示。

图3 同步HR数据库到SQL Server

这时可能会再次弹出SQL Server连接对话框和SQL Server Agent未运行的警告，确认后会显示Synchronize with the Database对话框，如图4所示。对话框里列出了SQL Server数据库和SSMA的树结构的差别，可以选择Hide Equal Objects来过滤掉两边相同的对象。由于我们连接的是新创建的HR数据库，所以左侧显示的都是 [Not Found] 状态，如果你之前做过同步这里会显示不同的状态，这里我们点击OK继续。等待右下角的进度条走完，留意主窗口Output栏是否报错，没有报错的话SQL Server里的对象应该已经创建好了。

图4 Synchronize with the Database对话框

再次使用SQL Server Management Studio或者Visual Studio来查看HR数据库中的对象，会发现一些$SSMA打头的表或者存储过程等，这些是迁移一些特殊对象（比如Oracle的Sequence对象）所创建出来的辅助对象。

在成功迁移了Schema之后，我们就可以来进行迁移的最后一步：数据迁移。有了SSMA的帮助数据迁移也非常简单，右键点击Oracle Metadata Explorer里的HR数据库，选择Migrate Data，如图5所示。SSMA会再次提示Oracle和SQL Server的连接信息，如果之前做过数据迁移可能会有数据覆盖的警告信息，如果有点击Continue继续。

图5 数据迁移

如果你的数据库数据比较多，SSMA会运行较长一段时间，在这过程中你可以随时点击工具栏上的Stop按钮来停止数据迁移。迁移结束后，SSMA会有一个数据迁移报告，如图6所示。该报告描述了迁移过程中那些表的数据被成功迁移，多少行数据被迁移以及耗时多少等等。

图6 数据迁移报告

本文简单介绍了如何使用SSMA for Oracle 5.0来帮助我们把一个Oracle数据库迁移到SQL Server数据库，包括迁移评估、Schema迁移以及数据迁移。

软件开发工程师徐进

SQL Server Migration Assistant简介（一）

Qi Samuel Zhang — Tue, 31 May 2011 03:31:00 GMT

SQL Server Migration Assistant（简称SSMA）是由微软发布的帮助客户更容易地从Oracle/Sybase/MySQL/Access迁移到SQL Server以及SQL Azure的一个工具集，几周前我们刚刚发布了SSMA 5.0版本，该版本支持了最新的代号为Denali的SQL Server的CTP版本，并且增加了对SQL Azure迁移的支持。下表说明了SSMA 5.0所支持的迁移矩阵：

Migrating From	Using SSMA Tool	To SQL Server (2005, 2008, 2008 R2, “Denali”)	To SQL Azure
Sybase	SSMA for Sybase	√	√ (New in SSMA 5.0)
Oracle	SSMA for Oracle	√
MySQL	SSMA for MySQL	√	√
Access	SSMA for Access	√	√

这里我们选择SSMA for Oracle 5.0为例介绍一下SSMA如何帮助您从Oracle迁移到SQL Server 2008 R2。首先我们从这里下载SSMA for Oracle 5.0的压缩包，解压缩后有两个exe文件，SSMA for Oracle 5.0.exe是工具的安装包，SSMA for Oracle 5.0 Extension Pack.exe必须安装在SQL Server 2008 R2所在服务器，用来创建一些辅助运行需要的数据库表和存储过程等。

首次运行SSMA for Oracle需要一个License，如图1所示，你可以点击链接，然后根据提示填写个人信息后免费申请，下载保存之后返回这个对话框选择你保存License的目录然后点击Refresh License按钮即可运行SSMA for Oracle了。

图1 License Management对话框

在主窗口File菜单中选择New Project…菜单项将显示图2所示的对话框，输入项目的名字，选择SQL Server 2008作为迁移的目标数据库版本。

图2 New Project对话框

我们将使用Oracle XE的HR schema为例（下文称之为HR数据库以避免歧义，但其实Oracle并没有SQL Server数据库类似的概念）。SSMA为提高性能，缺省情况下不加载某些示例数据库（包括HR数据库），这个缺省设置可以通过Project Settings来修改，选择Tools菜单的Project Settings菜单项，在弹出的对话框里点击General再选择Loading System Objects，然后勾选HR，如图3所示。

图3 Project Settings对话框

然后我们连接Oracle服务器，点击工具条上的Connect to Oracle，输入Server名称、SID和用户名/密码，如图4所示。连接后会有个警告对话框告诉你hr用户没有足够的权限。由于我们只需要迁移HR数据库，这里可以点击Continue忽略它。如果你的Oracle服务器上有很多数据库，数据加载可能需要比较长的时间，请耐心等待

图4 连接到Oracle服务器

连接上Oracle后我们首先评估一下迁移HR数据库会不会碰到问题，如果碰到问题大约需要多长时间来解决。评估并不需要连接目标SQL Server，只需要在左上方的树里展开Oracle服务器名称，然后展开Schemas，右键点击HR并选择Create Report，如图5所示。

图5 评估HR数据库

SSMA运行一段时间后会打开一个评估报告的对话框，如图6所示。这个评估报告很有用，里面会列出HR数据库里各种对象（包括函数、包、存储过程、表和视图等）能够成功迁移的比例，你可以在左边的树里选择你需要查看的某个对象，比如存储过程，比较Oracle的PL/SQL语法和迁移后的TSQL语法。

图6 评估报告

图7是一个包含有错误的评估报告，当包含错误时，SSMA会估算手工做转换大约需要多少时间，这样你就可以使用评估报告来帮助你做数据库迁移的时间规划。

图7 一个包含错误的评估报告

（未完待续）

软件开发工程师徐进

StreamInsight手札（五）——使用EventFlowDebugger调试事件流

Qi Samuel Zhang — Fri, 15 Apr 2011 07:48:00 GMT

StreamInsight提供了EventFlowDebugger以方便用户进行事件流调试。这一工具拥有直观的图形化界面，支持即时调试和日志调试，支持跟踪和回溯。

本文将介绍EventFlowDebugger基本使用方法。

EventFlowDebugger分为在线模式和离线模式两种使用方法。在线模式下，用户连接到StreamInsight服务器，在线进行调试，或者录制某一段时间的事件流供离线模式使用。离线模式下，用户通过加载Trace文件对事件流进行调试。

下面对其主要功能进行介绍。

连接到服务器（在线）

在线模式需要用户连接到一个正在运行的StreamInsight服务器。

StreamInsight服务器有两种，嵌入服务器和远程服务器：

嵌入服务器（Embedded Server）：var cepServerEmbedded = Server.Create();
远程服务器（Remote Server）：var cepServerRemote = Server.Connect("http://servername/StreamInsight");

如果使用远程服务器，则用户可以直接连接远程服务器的地址。如果程序使用嵌入服务器，则需要在程序中添加如下代码：

ServiceHost _dvHost = null;
IManagementService _service = null;
IManagementService proxy = server.CreateManagementService();
_service = proxy;
_dvHost = new ServiceHost(proxy);

WSHttpBinding binding = new WSHttpBinding(SecurityMode.Message);
binding.Security.Message.ClientCredentialType = MessageCredentialType.Windows;
binding.MaxReceivedMessageSize = 4655360;
_dvHost.AddServiceEndpoint(typeof(IManagementService), binding, "http://localhost:8080");
_dvHost.Open();

同时需要添加引用Microsoft.ComplexEventProcessing.ManagementService.dll，输入加亮部分地址就可以连接嵌入服务器了。

连接到服务器的几种常见错误

错误1

HTTP could not register URL http://+:8001/. Your process does not have access rights to this namespace (see http://go.microsoft.com/fwlink/?LinkId=70353 for details).

这个错误是由于用户对访问的URL没有权限。解决方法如下：

netsh http add urlacl url=http://localhost:8090/MyStreamInsightServer user=<domain\userid>
net localgroup StreamInsightUsers$Default /ADD SOMEDOMAIN\someuser

错误2

一般是URL地址不正确或者StreamInsight程序没有运行。

错误3

一般是由于StreamInsight程序没有运行。

错误4

一般是由于用户没有添加到正确的组。注意检查如下几个用户组：StreamInsightUsers$***, Performance Log Users

错误5

这个错误一般是由于用户程序中有断点。

显示查询（在线和离线）

在通过在线模式连接服务器或者离线模式打开trace文件后，用户可以查看查询的图形化界面：

在线模式下，用户可以通过菜单上的“开始录制”和“停止录制”录制一段时间的事件流。也可以采用Trace.cmd start <文件名>.etl和Trace.cmd stop <文件名>.etl来录制。

事件流分析（在线和离线）

用户可以通过如下菜单来实现对事件流的调试：

重播菜单可以通过但不模式从头开始一步一步调试事件流的变化，也可以直接跳转到用户设置的断点。寻根分析（Root Cause Analysis）��以找出指定事件的事件源。演化分析（Event Propagation Analysis）可以更重指定事件之后的所有演变。通过多个菜单的综合运用，用户就可以找出事件流中的异常事件数据，并进行更进一步的分析。

软件测试工程师金晶

StreamInsight手札（四）——使用IEnumerable接口创建StreamInsight程序

Qi Samuel Zhang — Tue, 12 Apr 2011 07:59:00 GMT

本文将介绍如何利用IEnumerable接口创建StreamInsight应用程序。

IEnumerable与IObservable最大的区别在于IEnumerable是采用Pull模式获取数据，而IObservable则是用Push模式推送数据。

用户首先通过IEnumerable.GetEnumerator来获得数据源的Enumerator，然后通过调用IEnumerator.MoveNext和IEnumerator.Current来获取数据。StreamInsight的输入输出通过一个数据队列连接。输入适配器获得数据，并调用Enqueue将数据放入队列，输出适配器循环检测队列是否为空，如果不是空队列，则调用Dequeue将数据取出。

在HelloInsight程序基础上，可以通过如下修改来实现IEnumerable接口。

1、获取输入数据源的Enumerator（HelloPointInput.cs）：

public HelloPointInput(HelloInputConfig config)

{

_config = config;

var streamReader = new StreamReader(config.fileName);

strings = new List<string>();

while (!streamReader.EndOfStream)

{

strings.Add(streamReader.ReadLine());

}

stringEnumerator = strings.GetEnumerator();

streamReader.Close();

}

2、读取Enumerator中的数据，并放入队列。注意判断队满的情况（HelloPointInput.cs）：

private void ProduceEvents()

{

while (AdapterState != AdapterState.Stopping)

{

if (stringEnumerator.MoveNext())

{

try

{

var line = stringEnumerator.Current;

var pendingEvent = CreateInsertEvent();

pendingEvent.StartTime = DateTime.Now;

pendingEvent.Payload = new HelloPayload

{

str = line

};

EnqueueOperationResult result;

result = Enqueue(ref pendingEvent);

if (result == EnqueueOperationResult.Full)

{

Thread.Sleep(1000);

//Ready();

return;

}

EnqueueCtiEvent(DateTime.Now);

Thread.Sleep(1000);

}

catch

{

//error handling should go here

}

else

{

break;

}

Stopped();

}

注意：在IEnumerator模式下，CTI事件是必须的，否则不会产生数据输出。

3、循环读取队列中的数据，并进行输出处理（HelloPointOutput.cs）：

private void ConsumeEvents()

{

PointEvent<HelloPayload> currEvent;

DequeueOperationResult result;

while (AdapterState != AdapterState.Stopping)

{

result = Dequeue(out currEvent);

if (result == DequeueOperationResult.Empty)

{

Ready();

return;

}

else

{

if (currEvent.EventKind == EventKind.Insert)

{

Console.WriteLine("Output: " +

currEvent.Payload.str

);

}

ReleaseEvent(ref currEvent);

}

Stopped();

}

4、运行程序

建立测试文件：

将输入数据源指向测试文件的存储地址。运行程序，得到如下输出：

软件测试工程师金晶

StreamInsight手札（三）——使用IObservable接口创建StreamInsight程序

Qi Samuel Zhang — Tue, 12 Apr 2011 07:24:00 GMT

本文将介绍如何利用IObservable接口创建StreamInsight应用程序。

Observer是.net Framework 4中引入的开发模式。IObserver<T>和IObservable<T>接口为基于推送的通知提供通用机制，也称为观察者设计模式。IObservable<T> 接口表示发送通知（提供程序）的类；IObserver<T> 接口表示接收通知（观察器）的类。

在下列应用场景下，适合采用Observable模式：

历史数据查询。对有限长的大数据集进行临时的查询。
Ad hoc查询。对数据进行一系列交互的ad hoc查询。
内嵌于用户程序。StreamInsight内嵌于用户应用程序之中。

使用这种开发模型，开发者只需要：

实现IObservable接口
实现IObserver接口
绑定到查询

下面将用示例代码来说明.。

1、安装Reactive Extension for .Net 4：

2、新建一个工程，注意选择.net framework 4.0。

3、添加如下引用。System.CoreEx和System.Reactive在C:\Program Files\Microsoft Cloud Programmability\Reactive Extensions\v1.0.2856.0\Net4\目录下。

定义事件Payload：

namespace HelloInsightObservable

{

public class HelloPayload

{

public int value { get; set; }

}

5、定义InputObservable类实现Iobservable接口

public class InputObservable : IObservable<int>

这个类需要实现Subscribe方法：

public IDisposable Subscribe(IObserver<int> observer)

{

if (observer != null && !this.observers.Contains(observer))

{

this.observers.Add(observer);

}

return observer as IDisposable;

}

我们还需要在这个类里模拟输入。我们定义了一个Timer，当定时器时间到时，调用定时器的回调函数生成一个随机整数，并调用observer的OnNext方法推送数据。

private void GenerateInput(object _)

{

foreach (var observer in observers)

{

int value = random.Next(100);

Console.WriteLine("Random generated data {0} : {1}", generatedNumber, value);

observer.OnNext(value);

generatedNumber++;

if (generatedNumber >= dataNumber)

{

observer.OnCompleted();

timer.Change(Timeout.Infinite, timeSpan);

return;

}

timer.Change(timeSpan, timeSpan);

}

6、将Observable类作为CEP引擎的输入。

在Main函数中添加如下代码。注意加亮部分的代码，这里与适配器方式的程序不同的是，没有插入CTI事件。

var inputObservable = new InputObservable(10);

using (var server = Server.Create("DefaultInstance"))

{

var application = server.CreateApplication("Observable Application");

var stream = inputObservable.ToPointStream(application,

e => PointEvent.CreateInsert(DateTime.Now, new HelloPayload { value = e }),

AdvanceTimeSettings.StrictlyIncreasingStartTime,

"Observable Stream");

var query = from e in stream

where e.value > 50

select e;

}

7、定义OutputObserver类实现Iobserver接口。

class OutputObserver : IObserver<HelloPayload>

{

public virtual void OnCompleted()

{

Console.WriteLine("Stopping query...");

}

public virtual void OnError(Exception e)

{

Console.WriteLine("Unexpected error occured");

}

public virtual void OnNext(HelloPayload payload)

{

Console.WriteLine("DataOutput: {0}", payload.value);

}

8、将OutputObserver绑定到query。

在main函数中添加如下代码：

var outputObserver = new OutputObserver();

var outputObservable = query.ToObservable();

outputObservable.Subscribe(outputObserver);

Console.ReadLine();

Subscribe函数执行后，就会开始接收数据输入，并调用OnNext方法输出。注意最后一句话的作用是让程序继续运行直至数据输入完成，Observable调用Observer的OnComplete方法，或者用户中途通过输入任意字符停止Observer。

9、程序运行的结果如下：

软件测试工程师金晶

利用SQL Server 2008迁移助手完成从Oracle到SQL Server的迁移——视频教学

Qi Samuel Zhang — Tue, 12 Apr 2011 05:41:50 GMT

讲师：资深项目经理王清越

你有Oracle数据库要迁移到SQL Server吗？微软提供了一个免费的工具来帮你做数据库迁移。我们会讨论迁移到 SQL Server的好处，和如何用SQL Server迁移助理（SSMA）来自动做数据库迁移。我们会演示如何用SQL Server迁移助理来迁移数据库模式和PL/SQL程序等。我们一起探讨SQL Server迁移助理（SSMA）如何为你节省数据库迁移的时间和成本。

(Please visit the site to view this video)

如果有什么问题，请直接通过评论提出。

利用SQL Server 2008 R2升级顾问进行升级前的准备和评估——视频教学

Qi Samuel Zhang — Wed, 30 Mar 2011 04:52:54 GMT

讲师：项目经理林默

这个视频教学讲介绍如何利用Microsoft SQL Server 2008 R2升级顾问对SQL Server 2005的实例进行分析，以为升级到 SQL Server 2008 做准备。

(Please visit the site to view this video)

如果有什么问题，请直接通过评论提出。

StreamInsight手札（二）——构建HelloInsight程序

Qi Samuel Zhang — Tue, 29 Mar 2011 08:49:00 GMT

本文将详细介绍如何建立一个简单的StreamInsight程序——HelloInsight。这个程序接受来自输入适配器的字符串输入，并通过输出适配器输出。

1、安装StreamInsight和Visual Studio 2010。

2、新建一个新的工程。可以选择.Net Framework 3.5 SP1或.Net Framework 4。

3、添加引用。引用dll的位置在<your driver>\program files\microsoft streamInsight1.1\C:\Program Files\Microsoft StreamInsight 1.1\Bin。

4、在program.cs using添加到引用：

using Microsoft.ComplexEventProcessing;
using Microsoft.ComplexEventProcessing.Adapters;
using Microsoft.ComplexEventProcessing.Diagnostics;
using Microsoft.ComplexEventProcessing.Linq;
using Microsoft.ComplexEventProcessing.ManagementService;

5、Main函数创建CEP服务器。DefaultInstance是StreamInsight安装时指定的实例名。

using (Server server = Server.Create("DefaultInstance"))
{
Application application = server.CreateApplication("HelloInsight");
}

6、创建事件负载（payload）。事件的负载是输入流里面需要CEP服务器处理的数据。事件负载不能是用户定义类型。

namespace HelloInsight
{
    public class HelloPayload
    {
        public string str { get; set; }
    }
}

7、创建输入输出适配器（Adapter）。输入输出适配器的结构基本一致，这里重点介绍输入适配器，输出适配器与之类似。适配器主要包括：配置类、工厂类和输入/输出类。配置类一般处理输入流的参数，比如流文件的名称等。工厂类用来实现输入、输出适配器的基类。输入、输出类处理数据流并生成可以供CEP服务器处理的事件。

HelloInsight这个例子里将输入的字符串作为参数定义配置类：

namespace HelloInsight.InputAdapters
{
    public class HelloInputConfig
    {
        public string inputString { get; set; }
    }
}

工厂类定义如下：

using Microsoft.ComplexEventProcessing;
using Microsoft.ComplexEventProcessing.Adapters;

namespace HelloInsight.InputAdapters
{
    public class HelloInputFactory : ITypedInputAdapterFactory<HelloInputConfig>
    {
        public InputAdapterBase Create<TPayload>(HelloInputConfig configInfo, EventShape eventShape)
        {
            // All the events are of point type, for this demo
            if (eventShape == EventShape.Point)
                return new HelloPointInput(configInfo);
            else
                return default(InputAdapterBase);
        }
        public void Dispose()
        {
        }
    }
}

输入类定义如下：

using Microsoft.ComplexEventProcessing;
using Microsoft.ComplexEventProcessing.Adapters;

namespace HelloInsight.InputAdapters
{
    public class HelloPointInput : TypedPointInputAdapter<HelloPayload>
    {
        private HelloInputConfig _config;

        public HelloPointInput(HelloInputConfig config)
        {
            _config = config;
        }

        public override void Start()
        {
            ProduceEvents();
        }

        public override void Resume()
        {
            ProduceEvents();
        }

        protected override void Dispose(bool disposing)
        {
            base.Dispose(disposing);
        }

        private void ProduceEvents()
        {
            var pendingEvent = CreateInsertEvent();
            pendingEvent.StartTime = DateTime.Now;
            pendingEvent.Payload = new HelloPayload
            {
                str = _config.inputString
            };

            EnqueueOperationResult result = Enqueue(ref pendingEvent);
            EnqueueCtiEvent(DateTime.Now);

            Stopped();
        }
    }
}

输出类定义如下：

using Microsoft.ComplexEventProcessing;
using Microsoft.ComplexEventProcessing.Adapters;

namespace HelloInsight.OutputAdapters
{
    public class HelloPointOutput : TypedPointOutputAdapter<HelloPayload>
    {
        public HelloPointOutput(HelloOutputConfig config)
        {
        }

        public override void Start()
        {
            ConsumeEvents();
        }

        public override void Resume()
        {
            ConsumeEvents();
        }

        protected override void Dispose(bool disposing)
        {
            base.Dispose(disposing);
        }

        private void ConsumeEvents()
        {
            PointEvent<HelloPayload> currEvent;
            DequeueOperationResult result;

            while (true)
            {
                if (AdapterState.Running == AdapterState)
                {
                    result = Dequeue(out currEvent);
                    if (result == DequeueOperationResult.Empty)
                    {
                        Ready();
                        return;
                    }
                    else
                    {
                        if (currEvent.EventKind == EventKind.Insert)
                        {
                            Console.WriteLine("Output: " +
                            currEvent.Payload.str
                            );
                        }
                        ReleaseEvent(ref currEvent);
                    }
                }
                else if (AdapterState.Stopping == AdapterState)
                {
                    Stopped();
                }
                else
                {
                    return;
                }
            }
        }
    }
}

8、定义CEP服务器上的查询。在HelloInsight这个例子里，使用最简单的查询，即查询出输入流的全部输入。查询使用LINQ。

private static void DirectOutput(CepStream<HelloPayload> cepStream, Application application)
{
    // Return only "Close" values using a where-clause
    var filteredCepStream = from e in cepStream
                            select e;

    RunQuery(filteredCepStream, application, "directly output the input data");
}

private static void RunQuery(CepStream<HelloPayload> cepStream, Application application, string queryDescription)
{
    // Configure output adapter
    var outputConfig = new HelloOutputConfig();

    // Create query and bind to the output adapter
    var query = cepStream.ToQuery(application, Guid.NewGuid().ToString(), queryDescription, typeof(HelloOutputFactory), outputConfig, EventShape.Point, StreamEventOrder.ChainOrdered);

    // Start query
    query.Start();

    // Wait until query change state
    DiagnosticView diagnosticView;

    do
    {
        Thread.Sleep(100);
        diagnosticView = query.Application.Server.GetDiagnosticView(query.Name);
    } while ((string)diagnosticView[DiagnosticViewProperty.QueryState] == "Running");

    // Stop query
    query.Stop();
}

这里，除了加亮部分县市的创建query的方法以外，用户还可以如下创建query：

var queryTemplate = application.CreateQueryTemplate("ExampleTemplate", "Description...", cepStream);
var queryBinder = new QueryBinder(queryTemplate);
queryBinder.BindProducer<StockQuote>("input", inputAdapter, inputConfig, EventShape.Point);
queryBinder.AddConsumer<StockQuote>("output", outputAdapter, outputConfig, EventShape.Point, StreamEventOrder.ChainOrdered);

var query = application.CreateQuery("ExampleQuery", "Description...", queryBinder);

9、Main函数里调用输入输出和查询。

CepStream<HelloPayload> input = CepStream<HelloPayload>.Create("input");

var inputConfig = new HelloInputConfig
{
inputString = "Hello StreamInsight!"
};

var outputConfig = new HelloOutputConfig();
var inputAdapter = application.CreateInputAdapter<HelloInputFactory>("HelloInput", "Description");
var outputAdapter = application.CreateOutputAdapter<HelloOutputFactory>("HelloOutput", "Description");
var inputStream = CepStream<HelloPayload>.Create("InputStream", typeof(HelloInputFactory), inputConfig, EventShape.Point);
DirectOutput(inputStream, application);

10、运行程序，输入的字符串输出到控制台。

至此，HelloInsight的程序创建完成。通过修改输入/输出适配器和查询，用户可以在此基础上实现更加复杂的程序了。

软件测试工程师金晶

StreamInsight手札（一）——初识

Qi Samuel Zhang — Fri, 18 Mar 2011 14:08:00 GMT

StreamInsight是SQL Server 2008 R2的新模块。它是一个基于.NET的平台，用于复杂事件处理（CEP，Complex Event Processing），即对于来自多数据源的无限事件序列提供近乎零延时的连续处理。StreamInsight是一个临时查询处理引擎，它可以支持应用程序对时间窗口内的事件进行查询处理。它对流数据的处理范围包括简单聚合、多数据源事件相关性、事件模式检测、甚至建立复杂事件序列和分析模型。StreamInsight的程序模型可以让用户通过LINQ定义这些查询，同时支持将查询结果无缝整合到C#的代码中。

传统的数据库针对静态数据操作，所有信息先被实体化存储在数据库中，然后被取出，再进行一系列的计算。而StreamInsight则针对的是事件流的操作，事件流从入口通过适配器进入，经过一系列查询逻辑的处理，最终通过输出适配器分发到各个目标上。事件流数据暂时保存于内存中，减少了数据存储与读取的时间。同时，StreamInsight了引入了一种时间窗口机制，即对事件流按照时间窗口切片统计，随着事件流入不断推移时间窗口，保持窗口中统计最新的数据。

因此，StreamInsight适用场景有如下特点：

输入为数据流尤其是多源无限长数据流
数据处理实时性要求高
高吞吐量
不关心中间结果
数据不需要永久保留

比如，多个收费站车辆通过信息作为数据流输入，统计一段时间内车辆的平均数。

下图是StreamInsight的架构：

由上图可以看出，StreamInsight主要包括三个部分：输入适配器（Input Adapter）、输出适配器（Output Adapter）以及CEP服务器。由于输入输出和CEP服务器都是异步运行的，所以StreamInsight提供了事件流调试器（Event Flow Debugger）方便用户调试事件的处理过程。

参考资料：

下载CU2
http://blogs.msdn.com/b/streaminsight/archive/2010/06/28/update-on-the-update.aspx
StreamInsight MSDN文档
http://msdn.microsoft.com/en-us/library/ee362541(SQL.105).aspx
博客
http://blogs.msdn.com/streaminsight/
论坛
http://social.msdn.microsoft.com/Forums/en-US/streaminsight
StreamInsight MSDN
http://msdn.microsoft.com/en-us/ee476990.aspx
样例
http://streaminsight.codeplex.com
Twitter
http://twitter.com/streaminsight

软件测试工程师金晶

将数据库迁移到SQL Azure云数据库的三种方法——视频教学

Qi Samuel Zhang — Tue, 08 Mar 2011 07:51:00 GMT

讲师：范智华

技术类别：SQL Azure、SQL Server

本视频介绍和演示迁移工具：SQL Server迁移助理（SQL Server Migration Assistant）。

(Please visit the site to view this video)

本视频介绍和演示迁移工具：数据层应用程序（Data-tier Application / DAC）。

(Please visit the site to view this video)

本视频介绍和演示迁移工具：脚本生成向导（Generate Script Wizard / GSW）。

(Please visit the site to view this video)

将数据库迁移到SQL Azure的三种工具

Qi Samuel Zhang — Mon, 07 Mar 2011 06:15:00 GMT

对于很多SQL Azure用户来说，使用SQL Azure的第一步就是将已有的数据库迁移到SQL Azure。下面我将向你介绍帮助您迁移数据库的三种工具。

一、SQL Server迁移助理（SQL Server Migration Assistant）

首先介绍的是SQL Server迁移助理（SQL Server Migration Assistant，SSMA）。它有分别针对Access、MySQL、Oracle、Sybase的几种版本。这里我们以SQL Server Migration Assistant 2008 for Access v4.2 为例。

1、先从File菜单打开迁移向导（Migration Wizard）。

2、然后在“创建新工程”（Create New Project）这一步，将迁移到（Migration To）修改为SQL Azure。这是需要注意的关键步骤，因为默认的选项是SQL Server。

3、然后，我们把Access数据库加入到向导中，稍候几秒钟之后，这个向导就会列出Access数据库中的所有表和查询等对象，以供选择。

4、选择好需要迁移的对象之后，下一步，我们需要提供SQL Azure的服务器和数据库名称及登录信息。一般来说，这时我们可以在自己的SQL Azure服务器上创建一个空白数据库。

5、最��，迁移的核心开始执行了。在这一步中，迁移助理先把Access中的对象（包括表、主键、外键、约束等等）转换成SQL Azure中对应的对象，并在SQL Azure数据库中创建这些对象，然后再把表内的所有数据行转换并载入SQL Azure数据库中。对于转换对象的过程，迁移助理生成了详细的报告。我们可以点击Report按钮来浏览。

二、数据层应用程序（Data-tier Application，DAC）

通过数据层应用程序（Data-tier Application，缩写为DAC），我们可以将SQL Server中的数据库的Schema提取出来，并且可以方便地将Schema布署到SQL Azure上。数据层应用程序DAC已经集成在SQL Server Management Studio (2008 R2) 与Visual Studio 2010之中。面前，DAC只能提取和布署Schema，而不能提取、布署表中的数据行。今后，DAC会增加这项功能。

DAC很适宜用于基于数据库的软件的开发过程中，尤其当我们把Visual Studio和Management Studio融合为一体时。

在本文中，我们以Management Studio中的DAC为例，来介绍数据层应用程序的提取与布署。

1、启动提取数据层应用程序的向导。只需要在Object Explorer中右键点击某一个SQL Server的数据库，在弹出的菜单中选“Tasks”，然后选择“Extract Data-tier Application”。这样，提取数据层应用程序的向导就弹出来了

。

2、在这个向导中的Set Properties（设置）页面中，我们可以设置应用程序的名称以及DAC Package的路径。

3、接着，进入Validation and Summary（校验与总结）页面。如果第一步中所选的数据库中有DAC不支持的特性，这一步会报错。

4、进入Build Package页面生成DAC包。下面我们将把刚才生成的DAC包布署到SQL Azure服务器中。

5、在Management Studio的Object Explorer中，右键点击一个SQL Azure服务器。在弹出的菜单中，选择“Deploy Data-tier Application”（布署数据层应用程序）。

6、在弹出的“Deploy Data-tier Application”向导中，进入“Select Package”页面。在这儿，我们选择刚才生成的DAC包。

7、在随后的“Update Configuration”页面中，我们可以修改这次布署的目标数据库的名字。

8、在Summary页面中，可以看到此次布署的总结。

9、最后，在“Deploy DAC”页面中，向导会将DAC包布署到SQL Azure服务器，并且在服务器上注册这个DAC包的元数据。

三、脚本生成向导（Generate Script Wizard，GSW）

使用脚本生成向导来迁移数据库的原理是：将一个数据库的所有Schema与数据行都用GSW导出成Transact-SQL的脚本，然后在SQL数据库中执行这些脚本。具体地说则有下述步骤。

1、在Management Studio的Object Explorer中，右键点击某一SQL Server的数据库。在弹出的菜单中，选取“Tasks”，再在展开的菜单中选择“Generate Scripts”。

2、这时会弹出“Generate and Publish Scripts”向导，即“生成与发布脚本”向导。在这个向导的Introduction页面中，点击Next。

3、在“Choose Objects”页面中，我们可以选择需要迁移的表（Tables）、存储过程（Stored Procedures）、用户定义的数据类型（User-Defined Data Types）以及Schemas。

4、在“Set Scripting Options”页面中，我们需要点击“Advanced”按钮，以更改高级选项。

5、我们需要更改两处高级选项。其一是将“Script for the database engine type”改选为“SQL Azure Database”。这是因为我们要将这个数据库迁移到SQL Azure上。

6、其二是将“Types of data to script”改选为“Schema and data”，以将数据模式与数据行一起迁移。

7、然后，我们可以逃过“Summary”页面，来到“Save or Publish Scripts”页面。在这儿，GSW将把我们选取的数据库对象转录誊写为一个T-SQL的脚本文件。

8、现在，我们就可以在SQL Azure服务器上新建一个数据库，然后通过Management Studio的脚本窗口，在这个数据库中来执行刚才生成的T-SQL脚本。这样，就完成了这次数据库迁移。

软件开发测试工程师范智华

扩展事件在Denali CTP1里的新功能

Qi Samuel Zhang — Thu, 23 Dec 2010 13:28:00 GMT

我的同事林默2009年曾写了一篇关于SQL Server 2008里扩展事件（XEvent）介绍的博文，XEvent在SQL 2008里所有的操作必须用TSQL来实现，不是非常方便。在上个月刚刚发布的Denali CTP1里我们对XEvent提供了更多的支持，建立了一个Object Model，在其基础上提供了SQL Server Management Studio（SSMS）里的一个简单UI并同时对PowerShell提供了支持。

有了Object Model后，我们就可以用写.NET代码来创建XEvent Session，修改Session或者枚举数据库里的所有Session。我们可以在Visual Studio里新建一个简单的.NET 3.5 Console Application，并增加对Microsoft.SqlServer.ConnectionInfo，Microsoft.SqlServer.Management.Sdk.Sfc以及Microsoft.SqlServer.XEvent的引用。如果你在Add Reference对话框的.NET标签找不到这些Assembly的话，你可以通过Browse标签到C:\Program Files\Microsoft SQL Server\110\SDK\Assemblies目录下添加这些Assembly。在Program.cs里先增加下面几个using：

using System.Data.SqlClient;
using Microsoft.SqlServer.Management.XEvent;
using Microsoft.SqlServer.Management.Sdk.Sfc;

然后在Main函数里输入下面的代码（你可能需要改变Connection String）：

using (SqlConnection conn = new SqlConnection("Data Source=.;Integrated Security=True"))
{
    conn.Open();
    XEStore store = new XEStore(new SqlStoreConnection(conn));
    Session session = store.CreateSession("blogtest");
    Event evt = session.AddEvent("sqlserver.sql_statement_starting");
    evt.AddAction("sqlserver.database_name");
    session.AddEvent("sqlserver.sql_statement_completed");
    Target target = session.AddTarget(store.RingBufferTargetInfo);
    session.MaxDispatchLatency = 5; //change dispatch latency to 5sec (default 30sec)
    session.Create();
    session.Start();
}

编译然后运行该程序，一个叫blogtest的XEvent Session就被创建并启动起来。我们可以用SSMS来查看这个session，连接到你Connection String里的数据库服务器，在Object Explorer里展开Management节点，Extended Events是我们新加的一个节点，展开两级后可以看到我们刚刚创建的blogtest，如图1所示。

图1 新加的Extended Events节点

右键点击blogtest节点，在菜单（如图2所示）里你可以启动/停止、导入/导出、删除或者Script选中的Session。导入/导出是针对模板，你可以选择任何一个Session导出为模板分享给别人使用，而Script则生成所选Session的创建/删除SQL语句，可以生成到新窗口、文件、剪贴板或者Agent Job。有了导入/导出和Script之后你就可以在模板和SQL语句之间随意转换。

图2 Session节点上的右键菜单

图2菜单里有个Start PowerShell菜单项，这就是我们前面提到的我们对PowerShell支持。点击它将打开一个PowerShell窗口并进入在Session所在的目录。你在PowerShell里同样可以创建/修改或枚举XEvent Session，如图3所示。你也可以尝试将下面的script保存成C:\blog.ps1，然后在PowerShell窗口里输入C:\blog.ps1来执行它（如果执行.ps1文件出现权限的问题可以输入help set-executionpolicy查看帮助）。

cd \XEvent
$h = hostname
cd $h
$store = dir | where {$_.DisplayName -ieq 'default'}
$session = new-object Microsoft.SqlServer.Management.XEvent.Session
   -argumentlist $store, "blogtest2"
$session.AddEvent("sqlserver.sql_statement_completed")
$session.Create()

图3 在PowerShell里创建XEvent Session

Denali CTP1里SSMS操作XEvent Session的UI还很简单，在此后的CTP里我们会继续增加其他功能，请继续关心我们的blog。

参考文献

软件开发工程师徐进

深入探索PowerPivot客户端和服务器端架构

Qi Samuel Zhang — Tue, 14 Dec 2010 14:25:00 GMT

2008年，我们与聚集在微软技术大会的IT朋友们分享了商业智能的未来。在讲座中，我们谈到自助式商业智能的愿景。2009年，我们与聚集在微软技术大会的IT 朋友们分享了PowerPivot客户端的功能。

2010年12月1日- 2010年12月3日，许多IT朋友们聚集在北京参加微软技术大会（Microsoft TechEd China 2010）。在今年的技术大会上，我们与大家探索PowerPivot客户端和服务器端的总体架构。

当用户使用PivotTable连接到在 Excel 外的数据源（External Data Sources）时，Excel用不同的数据源连接器来做连接。其中，当连接到分析服务器时，Excel用了MSOLAP OLE DB Provider来做连接。在MSOLAP OLE DB Provider的连接字符串，我们提供了分析服务器的名字和连接方式（例如：Server Name， Credentials，等等）。MSOLAP Provider 通过TCP传输来与分析服务器沟通。此外，当连接字符串中有HTTP字符时，MSOLAP Provider 将通过HTTP传输来与安装在服务器的数据泵（data pump）与分析服务器沟通。当连接字符串中指定了部署在Sharepoint Farm中的Excel文件时，MSOLAP Provider也将用HTTP传输。

介绍了TCP 和HTTP传输后，我们也谈到了一个新的Inproc传输。MSOLAP OLEDB Provider通过Inproc传输来连接到内存中的PowerPivot引擎。嵌入在Excel工作簿中的PowerPivot 数据在打开文件时被恢复到PowerPivot引擎。客户端的PowerPivot 插件用了熟悉的Analysis Management Objects（AMO）和ADOMD.Net来对PowerPivot引擎进行查询和操作。

最后，我们谈到了部署在Sharepoint Farm的PowerPivot。我们介绍了在Sharepoint Farm中的几个PowerPivot的组建。这包括了：PowerPivot Web Service（PWS）和PowerPivot System Service（PSS）。PowerPivot Web Service（PWS）是一个在SharePoint前端的薄中间层。PWS 负责把来自Sharepoint Farm外的请求转发到服务器中的PowerPivot服务程序。我们也谈到了在Sharepoint Farm中，MSOLAP OLEDB Provider如何用Window Communication Foundation（WCF）为基础的Channel运输来与PowerPivot System Service（PSS）沟通。

更多参考资源：

PowerPivot 客户和服务器端架构：http://download.microsoft.com/download/9/4/8/948776F7-4533-4EB5-A692-77BD0C72A135/PowerPivot%20ClientServer%20Architecture.pdf
PowerPivot Geek
PowerPivot Pro

期待2011 年的技术大会！谢谢！

项目经理卓伟雄

应用于数据层开发、部署、升级和管理的标准解决方案——数据层应用程序

Qi Samuel Zhang — Tue, 07 Dec 2010 05:57:00 GMT

大家好！

在刚刚结束的Microsoft TechEd 2010，我们通过动手实验，让大家体验了如何使用数据层应用程序（DAC）进行轻松高效准确的数据层开发、部署、升级和管理，并收到了很好的反馈。为了能够和更多的开发人员和数据库管理员介绍和分享DAC，我们特撰文如下，以飨读者。

对于普通应用程序的部署和升级，大家已经非常熟悉和习惯的使用MSI或者Click Once了。那么对于数据层，微软有什么类似的标准而易用的解决方案，可以统一将所需的所有数据库和实例对象（例如，用户表、存储过程、视图、登录等）统一打包，能够对版本，部署和升级条件及策略的声明和控制呢？这就是数据层应用程序（Data-tier Application，DAC）。

数据层应用程序DAC可使用以下两个工具来实现：

可使用 Microsoft Visual Studio 2010 中的数据层应用程序项目编写和构建 DAC，并可以进行对 T-SQL 代码运行静态代码分析、重构 T-SQL 代码、声明版本和部署意向的策略；升级DAC时还可以对数据层应用程序进行架构对比。
可以使用 SQL Server Management Studio 中的提取数据层应用程序向导从现有的数据库中提取 DAC，或进行DAC的部署、升级和统一管理。

数据层应用程序DAC在软件生命周期中的具体应用：

开发：Visual Studio 2010 中添加了一些新功能和增强功能：
- 全面支持数据层应用程序开发。
- 全新的 Transact-SQL 编辑器体验。
- 集成式编辑器、调试器、离线和在线 IntelliSense、语言服务和策略设计器。
- 静态代码分析和构建服务。
部署：引入全新的部署单元DAC包（ DACPAC），从而轻松高效准确地从 Visual Studio 2010 和 SQL Server Management Studio 部署和升级数据层应用程序。DACPAC是.zip格式的，其中包含.XML和.SQL文件，以方便浏览和对比。
管理：SQL Server 2008 R2 引入了 SQL Server 实用工具控制点（SQL Server 实用工具）的概念，极大地简化了多个 SQL Server 实例的管理。您可以采用 SQL Server 实例并将其注册为现有 SQL Server 实用工具，从而同时在实例和应用程序级别监控其性能和配置。这有助于您进行趋势分析，从而提高资源利用率并最终降低成本。详细信息及演示，请参考我们的这篇文章。

更多参考资源：

谢谢！

SQL Server软件测试开发工程师刘春雨

SQL @ TechEd 2010

Qi Samuel Zhang — Fri, 26 Nov 2010 03:29:00 GMT

2010微软技术大会将于2010年12月1日至3日在国家会议中心举办。除了Simon Leung 和Enwei Xie的主题演讲之外，大会将开设6个动手实验营、10个分会技术课程共16个技术分类的近200场精彩课程演讲。

按照时间顺序，SQL中国研发团队将贡献如下课程：

SQL Server 2008 R2 数据压缩的最佳实践技巧和新增功能方峻
12/2, 9:45-10:45 分会场八 DAT-300-3
SQL Server 2008 推出数据压缩后非常受用户欢迎，得到了广泛的采用。本讲座将简单回顾一下数据压缩的功能，然后重点讨论一些常见的客户问题，实践技巧，应用场景和性能影响，并通过这些来帮助您选择什么时候采用哪种压缩技术。之后讲座将介绍 SQL Server 2008 R2 上数据压缩的新功能，对 Unicode 字符数据的压缩。
如果构建企业级的ETL 孙巍
12/2, 9:45-10:45 分会场九 BIC-300-3
数据整合及清洗是企业实现BI的必要步骤，生成及输出的数据是BI系统的数据基石。微软的SQL Server Integration Service（SSIS）提供了一套完整的ETL解决方案，不但从功能上满足了整合及清理的要求，还提供了强大的流程控制及扩展功能。企业级ETL解决方案不但要考虑转换功能实现，更多的是要考虑流程、性能、可管理性、可扩展性。本讲座将从企业对于ETL解决方案的需求开始完整的阐述如何使用SSIS实现企业级ETL。
SQL Server Cluster 多子网支持和新的故障检测机制何民
12/2, 11:00-12:00 分会场二 DAT-300-4
课程由两部分组成：（一）SQL Server 多子网故障转移集群（multi-subnet failover clustering）可用于部署高可用系统之上的灾难恢复系统。本讲座将介绍多子网集群概念，和V-LAN解决方案的比较及部署的最佳实践。（二）即将发布的SQL Server 下一版本中，故障转移集群使用了全新的故障检测机制。这一部分讲座包含对新的系统存储过程sp_server_diagnostics的介绍，新的故障检测机制与SQL Server 2008 R2 之前版本的故障检测机制的对比，如何定制故障条件级别，以及演示。
SQL Server 2008 R2/PowerPivot探秘卓伟雄
12/2, 14:30-15:30 分会场九 BIC-400-1
在这个讲座中，我们将深入探讨 PowerPivot 的架构，PowerPivot的Excel 插件，和不同的组件。我们也会谈到这些组件之间如何沟通。在服务器端，我们将谈到 PowerPivot 如何应用 SharePoint 2010 的共同服务架构，如何连接到Powerpivot 的数据，如何做数据更新，和创建报表中的缩略图。
Microsoft云端数据库的最新进展和前景吴家震
12/2, 15:45-16:45 分会场三 DAT-300-6
云计算是最近几年IT行业的最大，最根本的一场变革，最终实现计算资源可以象其它如水电等公共资源一样随要随取，按需使用。Microsoft和SQL Server部门正在领导云端数据库的变革，此讲座将介绍云端数据库的基本构架，最新进展和功能，以及其未来前景。
Data integration 赵晓燕
12/2, 15:45-16:45 分会场九 BIC-200-3
数据集成（Data Integration）有很多应用场景，如构建数据仓库、实现主数据管理、获取数据同步和一致性、系统迁移或整合以及B2B 数据采集和共享等等。同时数据集成也有多种不同技术方法：大容量或批处理、 Federated查询、数据复制和消息或事件移动。Microsoft拥有多种产品可解决或部分解决数据集成问题，包括Microsoft SQL Server Integration Services（SSIS）、SQL Server Service Broken（服务中介程序）、SQL Server Replication、 Distributed Query（分布查询）、Microsoft BizTalk Server和Microsoft Master Data Services（主数据服务）。虽然单一产品不能解决所有数据集成问题，但这些产品的组合完全可以解决您的需求。本讲演将概述数据集成问题的类型和技术方法，并介绍在哪些情况下使用Microsoft何种产品或产品组合以现实您的数据集成需求。
SQL Server 性能优化（Performance Optimization）殷皓
12/3, 9:00 - 10:00 分会场二 DAT-300-1
SQL Server 关系型数据库平台性能优化的简介：从查询(SQL 语句)，到系统资源等各方面评估瓶颈，用系统化的方式来监控并解决解决系统性能问题。
微软的数据仓库全线解决方案：SQL Server 2008R2/PDW/Fasttrack 杨海俊
12/3, 9:00 - 10:00 分会场三 BIC-300-4
SQL Server Fast Track Data Warehouse 基于 SQL Server 企业版实现向上扩展，提供一个高性能、企业级的数据仓库平台（高达48TB）而无需传统系统所需要的高成本。Microsoft® SQL Server® 2008 R2 并行数据仓库具备很强的可伸缩性，可以通过大规模并行计算（Massively Parallel Processing, MPP）架构，以很低的成本实现很高的性能，数据仓库的规模从数十TB扩展到数百TB。
SQL Server 2011 数据库应用开发新增功能预览方峻
12/3, 10:15-11:15 分会场八 DAT-300-2
本讲座将介绍 SQL Server 2011（Denali）在数据库应用程序开发上所提供的新功能。首先，SQL Server 2011 在T-SQL编程上提供了一系列的新功能，包括 Paging、Sequence、Language Service、错误处理，描述结果集的 metadata，等等，让 T-SQL 应用程序开发更简单有效。之后，讲座将详细讲解 FileTable。FileTable 建立与 FileStream 基础之上，同时提供丰富的文件系统服务，使得您将文件存储在数据库中之后，仍旧保持完整的目录结构，并且可以用现有的程序（如 Word、Excel、Explorer）直接打开这些文件或目录。系统提供文件和数据库的完全整合，及数据库上的所有服务，使得结构性数据和非结构性数据的统一管理更加简单，查询更加丰富。
深入SQL Server 2008 R2报表服务新功能开发陶然
12/3, 14:00-15:00 分会场八 BIC-300-1
SQL Server 2008 R2对报表服务的功能做了很大的增强，不仅加入了报表部件、火花线和指示器等，更加入了免费的地图报表开发的支持，从此可以快速的开发更加丰富和多样化的数据报表，为商务智能服务。本次课程讲为听众讲解并展示这些新功能的特性和开发过程，来帮助大家在实际项目中可以熟练使用。
SQL Server 与SQL Azure云数据库之间的数据无缝迁移李刚毅，范志华
12/3, 15:15-16:15 分会场八 DAT-300-5
您是否正在寻找将您的数据库从MySQL数据库或其他数据库迁移到SQL Azure？或者用最简单的方法把SQL Server数据库上载到SQL Azure？在本讲座中，我们将通过数据访问层和数据层分别为您展示如何实现这种迁移。我们会为您分析和解决迁移过程中的常见问题，并向您介绍可以帮助您顺利完成迁移工作的各种实用工具。
从小众到大众——医疗行业商务智能系统发展浅谈朱宁
12/3, 16:30-17:30 分会场八 BIC-200-1
商务智能系统2005年作为一个新兴词汇出现在医疗行业，短短5年医院商务智能在我院从几个人用的“豪华报表”发展成为每个人都能够用到的自助式BI，从赶时髦的作秀到真正为医院管理、临床、科研提供数据平台、分析工具与决策依据。本文将针对微软商务智能解决方案在医院的应用领域、技术平台、推广模式、实施方法进行详尽阐述。旨在能够让更多医院体会商务智能能带给医院管理与发展上的价值，提高商务智能项目实施的成功率与效率。

此外，按照时间顺序,，SQL中国研发团队还将贡献如下动手实验营：

SQL Server 2008 R2地图报表 (200) 王琦
12/2, 8:30 - 9:30 动手实验室三 DATHOL-200-3
深入理解SQL2008 R2中的集成服务 (200) 孙昆邓子睿
12/2, 8:30 - 9:30 动手实验室六 BICHOL-200-2
SQL Server 2008 R2 和Visual Studio 2010 中的数据层应用（Data-tier Application）(200) 刘春雨毛草
12/2, 11:00 - 12:00 动手实验室六 DATHOL-200-1
SQL Server 2008 R2 故障转移群集维护大法 (200) 赵振宇曾屹
12/2, 13:15-14:15 动手实验室三 DATHOL-200-2
基于SQL Server 2008 R2 Reporting Services的报表库的使用和开发吴穷赖爱民
12/3, 9:00 - 10:00 动手实验室 BICHOL-200-1
使用SQL Server PowerPivot for Excel 2010创建数据报表 (200) 郭亚涛 李瑞霞
12/3, 15:00-16:00 动手实验室六 BICHOL-200-3
使用StreamInsight事件流调试器 (300) 刘星宇曲艺
12/3, 16:15-17:15 动手实验室六 DATHOL-300-1

不见不散！

被“自由行动祝福”环绕的战士——微软实习之魔兽攻略版

Qi Samuel Zhang — Fri, 08 Oct 2010 07:44:00 GMT

“被人绑着推到竞技场里，和自己昂首挺胸迈进去是完全不同的。”

不同于何处？被动与主动。

前者被迫走进竞技场，只能在别人的指挥下去拿指定的武器，根据指令这样进攻那样防守。而自己迈入场地的人，每一步都是自己的选择，可以拿自己最擅长的武器，使用最得心应手的战术。

只有你自己才知道挥舞刀剑和吟唱魔法哪个更得心应手；正面对抗和以智取胜哪个更擅长。要是一个法师不得不去冲锋肉搏，那他的魔法值不就完全浪费了么。而一个战士只有拿起双手剑，才能去打一场漂亮的战斗。

这些与在微软实习有什么关系呢？

你一定曾听说在微软实习有喝不完的酸奶，可以随意着装，办公楼里的台球桌、乒乓桌、XBox随时恭候。隐藏在这些表象背后的是一种公司文化 ——“自由”。而“自由”的公司文化除了让人在工作的时候爽一点，还有什么呢？让我们继续之前那个挥舞双手剑的战士的故事……

即使战士擅长剑术、战术成熟，也可能在战斗中被猎人的陷阱困住，被法师的寒冰箭减速，以致无法接近对手，难以按自己原先的想法战斗，发挥出一身本领。这时，如果有一个圣骑士能给这个战士加上一个“自由行动祝福”【注：“自由行动祝福”可以使目标免疫一切限制移动效果】，那战士就能变得不可阻挡、所向披靡。

如果说实习生是这个战士，微软就是那个可以给他施放“自由行动祝福”的圣骑士。微软是一个可以让人自由发挥的平台，在这里可以真正随心所欲地工作、学习。让你不会由于外界的限制，导致自己的选择失去了意义。对于一个实习生来说，如何体会到这种“自由”呢？

也许你在一家公司的实习经历会是这样的……

领过一堆魔法卷轴，被告知要把这些法术学会；
被告知用刚学的魔法完成一项简单任务；
完成任务后，会被指出有哪些不足之处，还要研习哪些高一级的魔法；
然后接到另外一项任务，在任务中提高你的魔法技能。

然而，“杯具“的你从来对所学的魔法没有丝毫兴趣。几个月下来，既不开心，也没学到什么想学的东西。

而在微软就不同，你完全可以这样…

告诉老板和导师“我是个战士，我擅长用双手剑战斗”。
在导师的指导下选择一项能发挥你优势且收益较大的任务，拿起手中的剑去执行任务。
和周围的人探讨战斗技巧，请教怎样挥舞你的剑才能发挥最大威力。
背上你已练得娴熟的【角斗士的双手巨刃】，开始自己的征程。

只有在这样的环境下，一个战士才能成长与进步。

在不少公司里，实习生往往是一个被动的角色，所要做的就是接受并且执行一条条由上至下的指令。而微软的实习生可以一边学习各种技能、一边埋头于自己感兴趣的项目。微软并不仅仅是“雇佣”实习生来打工，同时也在培养实习生的自主能力，这里有着充足的学习资源，找到所有感兴趣的微软产品和技术。

若在做任务时遇到问题，你可以使用微软内部的Wiki查找你想要的信息；也可以向你身旁的同事请教；或是发邮件给“I Dunno!”（微软的群邮地址），那里会有High-Level的家伙为你指点迷津。

要是想提高你的“剑术”水平，你可以去参加Tech Talk（技术讲座）或看网上讲座视频，那里有人介绍最新的技术、技巧；在微软的电子图书馆里寻找你的“双手剑高阶指导”。

如果想从他人的经历中激发对自己职业规划的思考，你可以给导师或老板发Meeting Request（会议邀请），问问他们是如何从一个小战士成长为一名角斗士的，他们绝不会吝惜将自己成功的经验分享给你。

回想在微软实习半年的收获，我发现最有价值的是我在自由祝福的照耀下，体验了按自己的意愿迈出每一步的快乐，学会了如何去自主地做决定、做事情。有了“自由行动祝福”的环绕，可以少绕很多弯路，少遇到很多绊脚石，就像舞动着一双自由之翼，可以更快地触碰到眩目的天空。

软件测试开发工程师实习生曹书宇

SQL Server 2008 R2新产品介绍——主数据服务

Qi Samuel Zhang — Thu, 02 Sep 2010 04:26:00 GMT

为什么需要主数据服务（Master Data Service ，MDS）?

在信息化的时代，企业每天都需要处理海量的事务数据。如何保障这些海量数据的准确性和安全性成为企业数据管理的重要问题。微软SQL Server 2008 R2 发布的新产品——主数据服务（MDS）提供了有效的机制来帮助企业解决这个问题。

主数据是什么？主数据是企业的基础的、关键的业务数据。比如企业的产品信息、供应商信息、客户信息、人力资源数据等等。主数据的准确与否，决定着企业海量业务数据的是否有效。管理好这些主数据是进行海量数据处理的关键组成部分。

MDS概要介绍

企业的主数据按照实体、模块的方式存储在MDS数据库中。相互联系的实体存放在相同的主数据模块中。实体的属性是主数据存取和安全性管理的最小数据单元。在日常事务流水中，这些最小的数据单元精确的描述和刻画着事务的具体内容。同时在MDS中，可以对这些主数据进行组装和搭配，形成高级的主数据管理单元。这些功能分别在MDS的以下组成部分中实现：

系统管理工具：定义主数据的存储结构
资源管理器：展示和管理主数据的内容
安全性管理模块：定义主数据单元的存取权限

MDS同时提供了：

版本管理工具：维护和管理企业历史上不同时期的主数据
数据集成工具：与已有的系统进行主数据的导入和导出

参考资料

微软新产品介绍：http://www.microsoft.com/sqlserver/2008/en/us/MDS.aspx
MDS 应用程序开发人员参考资料：http://msdn.microsoft.com/en-us/library/ee633763.aspx
MDS 博客：http://blogs.msdn.com/mds/
TechNet技术指引视频：http://technet.microsoft.com/zh-cn/ff959218.aspx

软件测试工程师郝勇

作为技术指引，本片首先概要的介绍了什么是Master Data和Master Data Service，然后简明地演示了微软SQL Server Master Data Service所提供的主要功能。

View Video
Format: wmv
Duration: 3

浅谈SQL Server 2008 R2 中的新组件——StreamInsight

Qi Samuel Zhang — Mon, 28 Jun 2010 02:23:00 GMT

随着信息技术的广泛应用，数据流作为一种新颖的数据结构在日常生活中有着越来越广泛的应用，微软在SQL Server 2008 R2 中推出了分析处理数据流的新组件——StreamInsight。它提供了基于DotNet框架的开发环境，用户能够轻松地使用它来开发出健壮，高效地数据流处理程序。

StreamInsight的本质是复杂事件处理（Complex Event Processing，CEP）的应用程序框架，与传统的数据库查询处理不同，事件处理系统需要同时处理来自多个数据源的海量事件（Event），并且根据用户提供的查询语句以及匹配模式，实时地输出事件分析结果。我们在下表中列出了事件驱动应用和数据库应用的主要区别：

	数据库应用	事件驱动的应用（Event Driven）
查询模式	特定的查询请求	连续的查询
响应时间	从几秒至数天	几毫秒或更少
数据流量	数百条记录/秒	>10000 事件/秒

通过使用StreamInsight，用户可以开发出基于CEP的程序来实时处理大量的原始数据，利用数据之间的层次和关联关系，有效的采用相应的规则进行处理，以降低进行事件分析，事件关联及事件解析等操作的代价。StreamInsight同时能够支持对数据流模式匹配、异常检测、趋势分析等操作，使用户能够更好地管理、监控和挖掘数据，最终使用户得到之前无法了解的信息，并能够更快速和更有效的进行操作决策，提高关键绩效指标（KPI）。

在StreamInsight的应用中，其核心为StreamInsight服务器，它主要由输入，输出适配器（Adaptor）以及CEP引擎（CEP Engine）组成。

CEP引擎（CEP Engine）：所有的输入数据都将再CEP引擎中进行分析和处理，它根据用户定义的查询逻辑，有效地分析和转换输入的数据，并及时输出结果。
适配器（Adaptor）：StreamInsight提供了适配器的框架，开发者能够通过实现不同的接口来开发不同种类的适配器。适配器分为两类，输入适配器（Input Adaptor）是连接外部存储设备如网络服务器，传感器同StreamInsight引擎的接口。而输出适配器则用于处理CEP引擎输出的结果并可以同时触发一系列的操作。

下图给出了StreamInsight应用的整体结构：

StreamInsight平台提供了一个功能强大的对象模型，它包含了许多有用的特性使得我们能够开发出灵活和功能强大StreamInsight的程序。对于初次使用StreamInsight的开发者来说，参考网上的一些实例能够取得事半功倍的效果。

在我加入微软之前，也曾进行过一段时间的数据流研究，当时的感受是，由于没有很好的数据流开发框架，我需要对于不同的应用开发不同的数据流程序来分析算法的有效性，而随着StreamInsight的推出，不仅能够为企业用户创造很大的价值，普通研究者也能够使用它更有效地开展研究工作。

StreamInsight的相关组件可以在微软网站上直接下载，如果您需要获得更多的信息，请访问微软StreamInsight的相关网站。

软件开发工程师李人和

SQL Server 2008 R2新特性——报表部件视频教学

Qi Samuel Zhang — Fri, 18 Jun 2010 03:19:00 GMT

SQL Server 2008 R2的报表服务为客户提供了更好的报表设计和协作体验。其中报表部件集使得客户可以方便的共享和重用报表部件。在本期视频中，我们将和大家分享报表生成器3.0中报表部件集的使用。该视频也能在TechNet IT影城找到。

软件开发测试工程师吴晓晨

View Video
Format: wmv
Duration: 4

SQL Server 2008 R2 StreamInsight简介

Qi Samuel Zhang — Thu, 17 Jun 2010 08:14:00 GMT

作为SQL Server 2008 R2一个主要的部分，StreamInsight提供了复杂事件处理（Complex Event Processing，CEP）功能。它处理的对象是例如证券交易行情、物联网、医疗监护等数量巨大并且需要实时处理的复杂事件。

从体系结构上看，StreamInsight类似于一个基于内存的数据库系统。它通过输入适配器接收事件并保存在内存里面。然后通过LINQ对输入事件进行处理得到结果，用于进一步的处理。StreamInsight的LINQ扩展提供了丰富的功能，包括过滤、分组、汇总、连接等常见的SQL功能，和窗口切分这样比较特殊的功能。

窗口切分是CEP系统和一般DBMS不太一样的一个地方。它用于把一个无限长的输入流转换成为一个一个有限的集合，从而可以方便的进行处理。StreamInsight提供多种窗口切分支持，以适应不同的应用场景需要。例如下面的LINQ查询代码采用了数量为2的计数窗口进行切分，计算后面一个事件相对于前面一个事件的变化值。

var deltas = from e in inputstream

group e by e.DeviceId into eachGroup

from win in eachGroup.CountByStartTimeWindow(2, CountWindowOutputPolicy.PointAlignToWindowEnd)

select new { ValueDelta = win.Delta(e => e.Value), SourceID = eachGroup.Key };

此外，StreamInsight还提供了事件流程调试器，它对于了解事件引擎的内部处理流程、开发和调试应用都有很大的帮助。

和其他微软产品一样，StreamInsight虽然功能很复杂很强大，但是非常容易使用。你可以按照下面的步骤很快把它提供的例子运行起来，开始你的CEP应用之旅。

下载StreamInsight试用版（大小大约是14MB），安装到你的机器上。安装的时候，实例名栏目输入Default。你不需要安装任何的SQL Server实例；
打开Microsoft StreamInsight程序组，点击StreamInsight Samples，下载例子代码并展开；
启动Visual Studio 2008或者2010，打开StreamInsightProductTeamSamples\Applications\ComposingQueries\ ComposingQueries.sln；
打开成功以��，按F7编译，然后Ctrl+F5就可以运行了。

更多的知识，请参考Microsoft StreamInsight程序组里面提供的文档或者查阅无联网。

参考资料

SQL Server 2008 R2数字之旅，http://www.microsoft.com/sqlserver/tour/zh/cn/videos/stream-insight-complex-event-processing.aspx
下载StreamInsight试用版, http://www.microsoft.com/downloads/details.aspx?FamilyId=54ad6107-c552-4d47-b1a1-3f66460f71a9&displaylang=zh-cn
SQL Server 2008 R2 StreamInsight, http://www.microsoft.com/sqlserver/2008/en/us/R2-complex-event.aspx
LINQ, http://msdn.microsoft.com/en-us/netframework/aa904594.aspx

如果你想进一步了解SQL Server 2008 R2的一些新功能，请继续关注SQL CRD的博客。

软件工程师苏宏谋

SQL Server 2008 R2报表服务之地图向导

Qi Samuel Zhang — Wed, 02 Jun 2010 14:12:00 GMT

SQL Server 2008 R2地图向导是Report builder3.0中内嵌的用于导入地图、创建地图、编辑地图以及发布地图的一套可视化的工具。使用地图向导，用户可以轻松地制作出地图相关的报表，并发布供重用。相比于之前需要靠第三方插件的方法，地图向导在便捷性、灵活性、兼容性等多个方面都有了巨大的优势。

下面将详细介绍地图向导的强大功能。准备数据使用地图向导，必须首先有如下信息：

空间数据源。提供空间数据的源的位置或连接，例如，包含空间数据的 SQL Server 实例和数据库的名称，或是Environmental Systems Research Institute, Inc. (ESRI) 形状文件的名称。
空间数据。来自空间数据源，是包含用于指定位置的一系列坐标的字段。
分析数据。用于改变地图显示的分析数据，例如，年度商店销售额。
匹配字段。定义空间数据和分析数据之间关系的匹配字段，例如，唯一标识每个城市的地区和城市的名称。

空间数据用于显示地图，分析数据用于区分显示地图区域，匹配字段用于将分析数据和空间数据关联起来。

ESRI形状文件是一个文件集，其中的数据符合Environmental Systems Research Institute, Inc. (ESRI) 形状文件空间数据格式。该文件集通常包含.shp 文件（包含空间数据）和一个支持文件.dbf。

当您将形状文件指定为空间数据源而该文件位于您的本地计算机中时，空间数据将自动嵌入到报表中。若要动态使用ESRI文件中的空间数据，必须执行以下操作：在Report Builder 3.0中，将.shp文件及.dbf文件同时上载到报表服务器上的同一文件夹，然后链接到作为空间数据源的.shp 文件。

可以通过如下链接或者是其他网络地址获得空间数据。

分析数据可以来自报表数据集，也可能随地图库或ESRI形状文件中的某个地图的空间数据附带。对于随形状文件附带的分析数据，需要使用工具导入到数据库，供后面创建带有分析数据的地图使用。常用的导入工具比如SqlSpatialTools等。

创建地图可以创建地图的方法和地图种类有很多，这里只介绍其中一种。

1、打开Report Builder3.0。

2、欢迎界面选择Map Wizard 或者菜单Insert->Map->Map Wizard。

3、选择ESRI形状文件。

4、浏览文件夹，打开事先准备的.shp文件：

5、单击‘下一步’。

6、选择地图的显示属性。这一步可以放大地图，然后选择只显示其中一块区域。也可以添加Bing的地图层。

7、设置好选项后，单击‘下一步’。

8、选择地图类型：

基本图：只显示区域的地图，例如，销售区域。选项：通过调色板改变颜色或使用一种颜色。调色板是一组预定义的颜色。当分配完调色板中的所有颜色后，将分配颜色的阴影。
颜色分析图：一个按变化的颜色显示分析数据的地图，例如，按区域列出的销售数据。
起泡图：一个在各区域中心以不同气泡大小显示分析数据的地图，例如，按区域列出的销售数据。选项：根据第二个分析字段改变区域颜色以及指定颜色规则。

9、选择颜色分析图，单击‘下一步’。

10、选择新建数据集，单击‘下一步’。

11、点击‘新建’，设置数据集连接字符串等属性。

12、单击‘下一步’。

13、选择所需的分析数据：

14、点击‘下一步’ 。

15、设置匹配字段，建立空间数据与分析数据的映射：

16、单击‘下一步’ 。

17、设置色彩方案和主题：

18、点击‘完成’，完成地图创建。

完成地图向导创建地图之后，可以对创建的地图进行修改，比如编辑标题，添加新的地图层，添加标签等。

创建完成地图之后，可以点击Report builder菜单‘运行’进行预览。还可以将地图发布到报表服务器，以便于浏览和重用。

如果你想进一步了解SQL Server 2008 R2的一些新功能，请继续关注SQL CRD的博客。

软件测试工程师金晶

SQL Server Utility

Qi Samuel Zhang — Mon, 10 May 2010 14:54:00 GMT

在即将发布的SQL Server 2008 R2中，SQL Server Management Studio提供了一个新的管理组件：SQL Server Utility。该组件能够帮助数据库管理员以统一和集中的方式去管理多个数据库实例：Instance以及数据层应用程序：Data-tier Application。（如果你对数据层应用程序没有太多的了解，请参考这里）

本文将对该组件所针对的应用场景和相关概念做些解释，然后会对该组件的主要功能接界面做进一步的介绍。

先来看一下SQL Server Utility所要解决的用户需求吧：随着数据库技术的越来越广泛的使用，很多企业里面都部署了一台以上的数据库服务器，并且在每个数据库服务器上都有着一个或若干个的数据库实例以及更多的数据层应用程序；想象一下，如果一个企业有着10个以上的数据库实例及更多的数据库层应用程序，对这些数据库实例与应用程序的监控与管理将是一个十分耗时而又费力的工作。而SQL Server Utility便是针对这一用户需求而开发的，在SQL Server Utility中，用户可以同时监控多个数据库实例及相关应用程序的使用状态，包括CPU、内存、硬盘等关键资源的使用情况。而且这些数据也会被保留一定时间，企业可以基于这些数据做进一步的分析，从而能够做更好的资源规划。

那么SQL Server Utility是如何做到这一点的呢？我们先来解释一下SQL Server Utility的物理架构和相关概念，然后会进一步解释具体的步骤。下图便是SQL Server Utility的物理架构：

在这一架构中，一个或者多个需要被监控的数据库实例将注册到一个统一的控制点上（UCP），而数据库管理员则可以通过其他与此控制点相连的管理终端上对那些需要被监控的数据库实例进行监控和管理。

为此，数据库管理员完成以下几步：

创建一个UCP。
将需要被监控的数据库实例或者相关的数据库应用程序注册到该UCP中。

在完成上述步骤后，数据库管理员只需要通过SQL Server Management Studio连接到创建好的UCP，便可以在dashboard上看到相关数据库实例的资源使用状态了。例图如下：

接下来我们进一步介绍如何创建一个UCP，以及如何注册一个数据库实例，并会对Utility的管理做一个简要的介绍。

创建一个UCP

1. 在创建一个UCP之前，需要注意以下若干项：

a. 当前的登录帐号必须有数据库管理员权限；
b. 用来创建UCP的数据库实例从来没有被创建过UCP，并且也没有注册到任何其他的UCP中；
c. SQL Server Agent服务必须被设置为自动启动，缺省安装的情况下，SQL Server Agent 服务的启动方式是手动；
d. SQL Server Agent的启动帐号不能是缺省的build-in的域帐号，譬如：Network Service；

2. 打开SQL Server Management Studio, 在View菜单中选择Utility Explorer；

3. 在Utility Explorer上点击：来启动创建UCP向导；

4. 点击下一步来指定在哪个数据库实例上来创建UCP，你可以在本地数据库实例上创建，也可以创建在一个远程的数据库实例上，但是数据库实例的版本号必须高于10.50。

5. 当设置完数据库实例以UCP名称后，点击下一步进入账户设置，你既可以用SQL Server Agent的账户，也可以指定一个域账户：该帐户作会被用作SQL Server Agent的代理账户来收集数据；

6. 点击下一步，进入预验证阶段：

7. 点击下一步，查看汇总信息，一切确认无误，便可以直接进入下一步创建UCP：

8. 点击完成，结束整个创建过程。

创建结束后，当前的数据库实例会缺省的被注册到刚刚创建的UCP中，由于数据在缺省情况下是每十五分钟收集一次，刚刚创建完的UCP没有任何数据，其dashboard看起来会是如下的样子，灰色的饼图表是数据尚未收集成功。

在Utility Explorer上点击Managed Instances, 也可以看到当前的数据库实例已被注册到当前的UCP中：

注册一个数据库实例

1. 在Utility Explorer中，右键点击Managed Instances节点，选择：Enroll Instance菜单来启动数据库实例注册向导；

2. 点击：下一步进入数据库实例选择界面，点击Connect.. 来连接到一个已经存在的数据库实例上；

3. 点击下一步，进入账户设置界面，和创建UCP的过程一样，在这一步需要指定一个有效的域帐户作为SQL Server Agent的代理账户用来收集数据；

4. 点击下一步，进入预验证；和创建UCP的过程一样，向导会对注册数据库实例的一些前提条件进行检查；

5. 一切正常的话，点击下一步查看汇总信息，确认无误，点击下一步，进行注册：

6. 点击完成，结束整个注册过程；

Utility管理

在Utility Explorer中点击Utility Administration可以进入Utility 管理界面，在这里你可以设置数据收集策略；安全策略及Utility数据仓库的一些基础配置。

例如：在数据收集策略中，你可以设置：当该数据库实例对CPU的使用超过70%时，可以认为该数据库实例已经超负荷使用（overutilized）了CPU资源; 而当CPU使用低于5%，认为该数据库实例没有充分利用CPU资源（underutilized）；同样的，你也可以对数据文件，日志文件等进行类似设置。

在安全设置中，你可以设置那些域帐户具有对Utility收集的数据读的权限：

而在数据仓库设置中，你可以设置Utility将对收集的数据保存多久：

如果你想忙上尝试一下使用SQL Server 2008 R2的这一新功能，可以点击此处下载SQL Server 2008 R2的CTP版。如果你想进一步了解SQL Server 2008 R2的一些新功能，请继续关注SQL CRD的博客。

软件测试主管：李俊