チュートリアル: ストアドプロシージャを使用してデータを変換する

[アーティクル]
05/21/2024

適用対象: Microsoft Fabric の SQL 分析エンドポイントおよびウェアハウス

データを変換するための新しいストアドプロシージャを作成して保存する方法について説明します。

データを変換する

リボンの [ホーム] タブで、[新規 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

後で参照するためにこのクエリを保存するには、[クエリ] タブを右クリックし、[名前の変更] を選択します。
「Create Aggregate Procedure」と入力して、クエリの名前を変更します。
キーボードの 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];
```
後で参照するためにこのクエリを保存するには、[クエリ] タブを右クリックし、[名前の変更] を選択します。
「Run Create Aggregate Procedure」と入力して、クエリの名前を変更します。
キーボードの Enter キーを押すか、タブの外側の任意の場所を選択して、変更を保存します。
[実行] を選択して、クエリを実行します。
リボンにある更新ボタンを選択します。このクエリの実行には 2 分から 3 分かかります。
オブジェクトエクスプローラーで、[エクスプローラー] にある aggregate_sale_by_city テーブルを選択してデータのプレビューを読み込んで、データが正常に読み込まれたことを確認します。