教程:使用存储过程转换数据
适用于:✅SQL 分析终结点和 Microsoft Fabric 中的仓库
了解如何创建和保存用于转换数据的新存储过程。
转换数据
从功能区的“主页”选项卡选择“新建 SQL 查询”。
在查询编辑器中,粘贴以下代码以创建存储过程
dbo.populate_aggregate_sale_by_city
。 此存储过程将在后面的步骤中创建并加载dbo.aggregate_sale_by_date_city
表。--Drop the stored procedure if it already exists. DROP PROCEDURE IF EXISTS [dbo].[populate_aggregate_sale_by_city] GO --Create the populate_aggregate_sale_by_city stored procedure. CREATE PROCEDURE [dbo].[populate_aggregate_sale_by_city] AS BEGIN --If the aggregate table already exists, drop it. Then create the table. DROP TABLE IF EXISTS [dbo].[aggregate_sale_by_date_city]; CREATE TABLE [dbo].[aggregate_sale_by_date_city] ( [Date] [DATETIME2](6), [City] [VARCHAR](8000), [StateProvince] [VARCHAR](8000), [SalesTerritory] [VARCHAR](8000), [SumOfTotalExcludingTax] [DECIMAL](38,2), [SumOfTaxAmount] [DECIMAL](38,6), [SumOfTotalIncludingTax] [DECIMAL](38,6), [SumOfProfit] [DECIMAL](38,2) ); --Reload the aggregated dataset to the table. INSERT INTO [dbo].[aggregate_sale_by_date_city] SELECT FS.[InvoiceDateKey] AS [Date], DC.[City], DC.[StateProvince], DC.[SalesTerritory], SUM(FS.[TotalExcludingTax]) AS [SumOfTotalExcludingTax], SUM(FS.[TaxAmount]) AS [SumOfTaxAmount], SUM(FS.[TotalIncludingTax]) AS [SumOfTotalIncludingTax], SUM(FS.[Profit]) AS [SumOfProfit] FROM [dbo].[fact_sale] AS FS INNER JOIN [dbo].[dimension_city] AS DC ON FS.[CityKey] = DC.[CityKey] GROUP BY FS.[InvoiceDateKey], DC.[City], DC.[StateProvince], DC.[SalesTerritory] ORDER BY FS.[InvoiceDateKey], DC.[StateProvince], DC.[City]; END
若要保存此查询供以后参考,请右键单击查询选项卡,然后选择“重命名”。
键入“创建聚合过程”以更改查询名称。
按键盘上的 Enter 或选择选项卡外的任意位置以保存更改。
选择“运行”以执行查询。
选择功能区中的“刷新”按钮。
在“对象资源管理器”中,展开
dbo
架构下的StoredProcedures节点,从而验证能否看到新建的存储过程。从功能区的“主页”选项卡选择“新建 SQL 查询”。
在查询编辑器中粘贴以下代码。 此 T-SQL 执行
dbo.populate_aggregate_sale_by_city
以创建dbo.aggregate_sale_by_date_city
表。--Execute the stored procedure to create the aggregate table. EXEC [dbo].[populate_aggregate_sale_by_city];
若要保存此查询供以后参考,请右键单击查询选项卡,然后选择“重命名”。
键入“运行创建聚合过程”以更改查询名称。
按键盘上的 Enter 或选择选项卡外的任意位置以保存更改。
选择“运行”以执行查询。
选择功能区中的“刷新”按钮。 执行查询需要 2 到 3 分钟。
在“对象资源管理器”中,在“资源管理器”中选择
aggregate_sale_by_city
表以加载数据预览,从而验证已成功加载数据。