チュートリアル:geo 分散型データベースを実装する (Azure SQL Database)

[アーティクル]
12/21/2023

SQL Database 内のデータベースおよびクライアントアプリケーションをリモートリージョンにフェールオーバーするよう構成し、フェールオーバー計画をテストします。学習内容は次のとおりです。

フェールオーバーグループを作成します。
SQL Database 内のデータベースを照会する Java アプリケーションを実行する
[テストフェールオーバー]

Azure サブスクリプションをお持ちでない場合は、開始する前に無料アカウントを作成してください。

前提条件

注意

この記事では、Azure と対話するために推奨される PowerShell モジュールである Azure Az PowerShell モジュールを使用します。 Az PowerShell モジュールの使用を開始するには、「Azure PowerShell をインストールする」を参照してください。 Az PowerShell モジュールに移行する方法については、「AzureRM から Az への Azure PowerShell の移行」を参照してください。

重要

PowerShell Azure Resource Manager モジュールは Azure SQL Database で引き続きサポートされますが、今後の開発はすべて Az.Sql モジュールを対象に行われます。これらのコマンドレットについては、「AzureRM.Sql」を参照してください。 Az モジュールと AzureRm モジュールのコマンドの引数は実質的に同じです。

このチュートリアルに取り組む前に、次のものがインストールされていることを確認してください。

Azure PowerShell
Azure SQL Database 内の単一データベース。次の方法で作成します。
注意

このチュートリアルでは、AdventureWorksLT サンプルデータベースを使用します。

重要

このチュートリアルの手順を実行しているコンピューターのパブリック IP アドレスを使用するようにファイアウォール規則を確実に設定してください。データベースレベルのファイアウォールルールは、セカンダリサーバーに自動的にレプリケートされます。

詳細については、データベースレベルのファイアウォール規則の作成に関するページを参照してください。ご利用のコンピューターのサーバーレベルのファイアウォール規則に使用する IP アドレスを調べる場合は、サーバーレベルのファイアウォールの作成に関するページを参照してください。

フェールオーバーグループを作成する

既存のサーバーと別のリージョンにある新しいサーバーとの間で、Azure PowerShell を使用してフェールオーバーグループを作成します。その後、そのフェールオーバーグループにサンプルデータベースを追加します。

PowerShell
Azure CLI

重要

このサンプルには、Azure PowerShell Az 1.0 以降が必要です。 Get-Module -ListAvailable Az を実行して、インストールされているバージョンを確認します。インストールする必要がある場合は、Azure PowerShell モジュールのインストールに関するページを参照してください。

Connect-AzAccount を実行して Azure にサインインします。

フェールオーバーグループを作成するには、次のスクリプトを実行します。

$admin = "<adminName>"
$password = "<password>"
$resourceGroup = "<resourceGroupName>"
$location = "<resourceGroupLocation>"
$server = "<serverName>"
$database = "<databaseName>"
$drLocation = "<disasterRecoveryLocation>"
$drServer = "<disasterRecoveryServerName>"
$failoverGroup = "<globallyUniqueFailoverGroupName>"

# create a backup server in the failover region
New-AzSqlServer -ResourceGroupName $resourceGroup -ServerName $drServer `
    -Location $drLocation -SqlAdministratorCredentials $(New-Object -TypeName System.Management.Automation.PSCredential `
    -ArgumentList $admin, $(ConvertTo-SecureString -String $password -AsPlainText -Force))

# create a failover group between the servers
New-AzSqlDatabaseFailoverGroup –ResourceGroupName $resourceGroup -ServerName $server `
    -PartnerServerName $drServer –FailoverGroupName $failoverGroup –FailoverPolicy Automatic -GracePeriodWithDataLossHours 2

# add the database to the failover group
Get-AzSqlDatabase -ResourceGroupName $resourceGroup -ServerName $server -DatabaseName $database | `
    Add-AzSqlDatabaseToFailoverGroup -ResourceGroupName $resourceGroup -ServerName $server -FailoverGroupName $failoverGroup

重要

az login を実行して Azure にサインインします。

$admin = "<adminName>"
$password = "<password>"
$resourceGroup = "<resourceGroupName>"
$location = "<resourceGroupLocation>"
$server = "<serverName>"
$database = "<databaseName>"
$drLocation = "<disasterRecoveryLocation>" # must be different then $location
$drServer = "<disasterRecoveryServerName>"
$failoverGroup = "<globallyUniqueFailoverGroupName>"

# create a backup server in the failover region
az sql server create --admin-password $password --admin-user $admin `
    --name $drServer --resource-group $resourceGroup --location $drLocation

# create a failover group between the servers
az sql failover-group create --name $failoverGroup --partner-server $drServer `
    --resource-group $resourceGroup --server $server --add-db $database `
    --failover-policy Automatic --grace-period 2

geo レプリケーションの設定は、Azure portal でデータベースを選択し、 [設定]>[geo レプリケーション] の順に選択することで変更することもできます。

geo レプリケーションの設定

サンプルプロジェクトを実行する

コンソールで次のコマンドを実行して Maven プロジェクトを作成します。

mvn archetype:generate "-DgroupId=com.sqldbsamples" "-DartifactId=SqlDbSample" "-DarchetypeArtifactId=maven-archetype-quickstart" "-Dversion=1.0.0"

「Y」と入力して Enter キーを押します。
新しいプロジェクトのディレクトリに移動します。
```
cd SqlDbSample
```
お好みのエディターを使用して、プロジェクトフォルダーの pom.xml ファイルを開きます。
以下の dependency セクションを追加して、Microsoft JDBC Driver for SQL Server 依存関係を追加します。この依存関係を、上位の dependencies セクション内に貼り付けてください。
```
<dependency>
  <groupId>com.microsoft.sqlserver</groupId>
  <artifactId>mssql-jdbc</artifactId>
 <version>6.1.0.jre8</version>
</dependency>
```

dependencies セクションの後に properties セクションを追加して Java バージョンを指定します。

<properties>
  <maven.compiler.source>1.8</maven.compiler.source>
  <maven.compiler.target>1.8</maven.compiler.target>
</properties>

properties セクションの後に build セクションを追加してマニフェストファイルをサポートします。

<build>
  <plugins>
    <plugin>
      <groupId>org.apache.maven.plugins</groupId>
      <artifactId>maven-jar-plugin</artifactId>
      <version>3.0.0</version>
      <configuration>
        <archive>
          <manifest>
            <mainClass>com.sqldbsamples.App</mainClass>
          </manifest>
        </archive>
     </configuration>
    </plugin>
  </plugins>
</build>

pom.xml ファイルを保存して閉じます。

..\SqlDbSample\src\main\java\com\sqldbsamples にある App.java ファイルを開き、その内容を次のコードで置き換えます。

package com.sqldbsamples;

import java.sql.Connection;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Timestamp;
import java.sql.DriverManager;
import java.util.Date;
import java.util.concurrent.TimeUnit;

public class App {

   private static final String FAILOVER_GROUP_NAME = "<your failover group name>";  // add failover group name

   private static final String DB_NAME = "<your database>";  // add database name
   private static final String USER = "<your admin>";  // add database user
   private static final String PASSWORD = "<password>";  // add database password

   private static final String READ_WRITE_URL = String.format("jdbc:" +
      "sqlserver://%s.database.windows.net:1433;database=%s;user=%s;password=%s;encrypt=true;" +
      "hostNameInCertificate=*.database.windows.net;loginTimeout=30;",
      FAILOVER_GROUP_NAME, DB_NAME, USER, PASSWORD);
   private static final String READ_ONLY_URL = String.format("jdbc:" +
      "sqlserver://%s.secondary.database.windows.net:1433;database=%s;user=%s;password=%s;encrypt=true;" +
      "hostNameInCertificate=*.database.windows.net;loginTimeout=30;",
      FAILOVER_GROUP_NAME, DB_NAME, USER, PASSWORD);

   public static void main(String[] args) {
      System.out.println("#######################################");
      System.out.println("## GEO DISTRIBUTED DATABASE TUTORIAL ##");
      System.out.println("#######################################");
      System.out.println("");

      int highWaterMark = getHighWaterMarkId();

      try {
         for(int i = 1; i < 1000; i++) {
             //  loop will run for about 1 hour
             System.out.print(i + ": insert on primary " +
                (insertData((highWaterMark + i)) ? "successful" : "failed"));
             TimeUnit.SECONDS.sleep(1);
             System.out.print(", read from secondary " +
                (selectData((highWaterMark + i)) ? "successful" : "failed") + "\n");
             TimeUnit.SECONDS.sleep(3);
         }
      } catch(Exception e) {
         e.printStackTrace();
   }
}

private static boolean insertData(int id) {
   // Insert data into the product table with a unique product name so we can find the product again
   String sql = "INSERT INTO SalesLT.Product " +
      "(Name, ProductNumber, Color, StandardCost, ListPrice, SellStartDate) VALUES (?,?,?,?,?,?);";

   try (Connection connection = DriverManager.getConnection(READ_WRITE_URL);
           PreparedStatement pstmt = connection.prepareStatement(sql)) {
      pstmt.setString(1, "BrandNewProduct" + id);
      pstmt.setInt(2, 200989 + id + 10000);
      pstmt.setString(3, "Blue");
      pstmt.setDouble(4, 75.00);
      pstmt.setDouble(5, 89.99);
      pstmt.setTimestamp(6, new Timestamp(new Date().getTime()));
      return (1 == pstmt.executeUpdate());
   } catch (Exception e) {
      return false;
   }
}

private static boolean selectData(int id) {
   // Query the data previously inserted into the primary database from the geo replicated database
   String sql = "SELECT Name, Color, ListPrice FROM SalesLT.Product WHERE Name = ?";

   try (Connection connection = DriverManager.getConnection(READ_ONLY_URL);
           PreparedStatement pstmt = connection.prepareStatement(sql)) {
      pstmt.setString(1, "BrandNewProduct" + id);
      try (ResultSet resultSet = pstmt.executeQuery()) {
         return resultSet.next();
      }
   } catch (Exception e) {
      return false;
   }
}

private static int getHighWaterMarkId() {
   // Query the high water mark id stored in the table to be able to make unique inserts
   String sql = "SELECT MAX(ProductId) FROM SalesLT.Product";
   int result = 1;
   try (Connection connection = DriverManager.getConnection(READ_WRITE_URL);
           Statement stmt = connection.createStatement();
           ResultSet resultSet = stmt.executeQuery(sql)) {
      if (resultSet.next()) {
          result =  resultSet.getInt(1);
         }
      } catch (Exception e) {
       e.printStackTrace();
      }
      return result;
   }
}

App.java ファイルを保存して閉じます。
コマンドコンソールで、次のコマンドを実行します。
```
mvn package
```

アプリケーションを起動します。手動で停止しない限り約 1 時間実行されるので、その間にフェールオーバーテストを実行できます。

mvn -q -e exec:java "-Dexec.mainClass=com.sqldbsamples.App"

#######################################
## GEO DISTRIBUTED DATABASE TUTORIAL ##
#######################################

1. insert on primary successful, read from secondary successful
2. insert on primary successful, read from secondary successful
3. insert on primary successful, read from secondary successful
...

[テストフェールオーバー]

以下に示した各スクリプトを実行してフェールオーバーをシミュレートし、アプリケーションの結果を観察します。データベースの移行中、いくつかの挿入と選択が失敗します。そのようすに注目してください。

PowerShell
Azure CLI

次のコマンドを使用して、テスト中にディザスターリカバリーサーバーのロールを確認することができます。

(Get-AzSqlDatabaseFailoverGroup -FailoverGroupName $failoverGroup `
    -ResourceGroupName $resourceGroup -ServerName $drServer).ReplicationRole

フェールオーバーをテストするには、次の手順に従います。

フェールオーバーグループの手動フェールオーバーを開始します。

Switch-AzSqlDatabaseFailoverGroup -ResourceGroupName $resourceGroup `
 -ServerName $drServer -FailoverGroupName $failoverGroup

フェールオーバーグループを再びプライマリサーバーに戻します。

Switch-AzSqlDatabaseFailoverGroup -ResourceGroupName $resourceGroup `
 -ServerName $server -FailoverGroupName $failoverGroup

次のコマンドを使用して、テスト中にディザスターリカバリーサーバーのロールを確認することができます。

az sql failover-group show --name $failoverGroup --resource-group $resourceGroup --server $drServer

フェールオーバーをテストするには、次の手順に従います。

フェールオーバーグループの手動フェールオーバーを開始します。

az sql failover-group set-primary --name $failoverGroup --resource-group $resourceGroup --server $drServer

フェールオーバーグループを再びプライマリサーバーに戻します。

az sql failover-group set-primary --name $failoverGroup --resource-group $resourceGroup --server $server

次のステップ

高可用性とディザスターリカバリーのチェックリストを確認してください。

関連する Azure SQL データベースコンテンツ:

次の方法で共有

チュートリアル:geo 分散型データベースを実装する (Azure SQL Database)

前提条件

フェールオーバーグループを作成する

サンプルプロジェクトを実行する

[テストフェールオーバー]

次のステップ

フィードバック

その他のリソース

次の方法で共有

チュートリアル:geo 分散型データベースを実装する (Azure SQL Database)

前提条件

フェールオーバー グループを作成する

サンプル プロジェクトを実行する

[テスト フェールオーバー]

次のステップ

フィードバック

その他のリソース

フェールオーバーグループを作成する

サンプルプロジェクトを実行する

[テストフェールオーバー]