Tutorial: Menerapkan database terdistribusi secara geografis (Azure SQL Database)

Berlaku untuk:Azure SQL Database

Konfigurasikan database di SQL Database dan aplikasi klien untuk failover ke wilayah jarak jauh dan uji rencana failover. Anda akan mempelajari cara untuk:

Membuat grup failover
Menjalankan aplikasi Java untuk mengkueri database di Azure SQL Database
Pengujian pengalihan layanan

Jika Anda tidak memiliki langganan Azure, buat akun gratis sebelum Anda memulai.

Prasyarat

Catatan

Artikel ini menggunakan modul Azure Az PowerShell, yang merupakan modul PowerShell yang direkomendasikan untuk berinteraksi dengan Azure. Untuk mulai menggunakan modul Az PowerShell, lihat Menginstal Azure PowerShell. Untuk mempelajari cara bermigrasi ke modul Az PowerShell, lihat Memigrasikan Azure PowerShell dari AzureRM ke Az.

Penting

Modul PowerShell Azure Resource Manager (AzureRM) tidak digunakan lagi pada 29 Februari 2024. Semua pengembangan di masa mendatang harus menggunakan modul Az.Sql. Pengguna disarankan untuk bermigrasi dari AzureRM ke modul Az PowerShell untuk memastikan dukungan dan pembaruan yang berkelanjutan. Modul AzureRM tidak lagi dipertahankan atau didukung. Argumen untuk perintah dalam modul Az PowerShell dan dalam modul AzureRM secara substansial identik. Untuk informasi selengkapnya tentang kompatibilitasnya, lihat Memperkenalkan modul Az PowerShell baru.

Untuk menyelesaikan tutorial, pastikan Anda telah menginstal item berikut:

Azure PowerShell
Database tunggal di Azure SQL Database. Untuk membuat satu penggunaan,
Tutorial ini menggunakan AdventureWorksLT database sampel, yang merupakan database sampel opsional yang dimuat saat Anda membuat Azure SQL Database baru.

Penting

Pastikan untuk menyiapkan aturan firewall untuk menggunakan alamat IP publik komputer tempat Anda melakukan langkah-langkah dalam tutorial ini. Aturan firewall tingkat database akan direplikasi secara otomatis ke server sekunder.

Untuk informasi, lihat Membuat aturan firewall tingkat database atau untuk menentukan alamat IP yang digunakan untuk aturan firewall tingkat server untuk komputer Anda lihat Mulai Cepat: Membuat aturan firewall tingkat server di portal Microsoft Azure.

Membuat grup failover

Dengan menggunakan Azure PowerShell, buat grup failover antara server yang sudah ada dan server baru di wilayah lain. Lalu tambahkan sampel database ke grup failover.

PowerShell
Azure CLI

Penting

Sampel ini memerlukan Azure PowerShell Az 1.0 atau yang lebih baru. Jalankan Get-Module -ListAvailable Az untuk melihat versi mana yang dipasang. Jika Anda perlu memasang, lihat Pasang modul Azure PowerShell.

Jalankan Connect-AzAccount untuk masuk ke Azure.

Untuk membuat grup failover, jalankan skrip berikut:

$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

Penting

Jalankan az login untuk masuk ke 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

Pengaturan geo-replikasi juga dapat diubah di portal Microsoft Azure, dengan memilih database Anda, lalu Pengaturan>Geo-Replikasi.

Diagram dengan peta global memperlihatkan kemampuan replikasi geografis dengan replika utama di AS Barat dan replika sekunder di Eropa Barat.

Jalankan proyek sampel

Di konsol, buat proyek Maven dengan perintah berikut:

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

Ketik Y dan tekan Masuk.
Mengubah direktori ke proyek baru.
```
cd SqlDbSample
```
Dengan menggunakan editor favorit Anda, buka file pom.xml di folder proyek Anda.
Tambahkan Driver Microsoft JDBC untuk dependensi Microsoft SQL Server dengan menambahkan bagian dependency berikut. Dependensi harus ditempelkan dalam bagian dependencies yang lebih besar.
```
<dependency>
  <groupId>com.microsoft.sqlserver</groupId>
  <artifactId>mssql-jdbc</artifactId>
 <version>6.1.0.jre8</version>
</dependency>
```

Tentukan versi Java dengan menambahkan bagian properties setelah bagian dependencies:

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

Mendukung file manifes dengan menambahkan bagian build setelah bagian properties:

<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>

Simpan dan tutup file pom.xml.

Buka file App.java yang terletak di ..\SqlDbSample\src\main\java\com\sqldbsamples dan ganti konten dengan kode berikut:

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;
   }
}

Simpan dan tutup file App.java.
Di konsol perintah, jalankan perintah berikut:
```
mvn package
```

Mulai aplikasi yang akan berjalan selama sekitar 1 jam sampai berhenti secara manual, memberikan Anda waktu untuk menjalankan tes failover.

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
...

Pengujian pengalihan layanan

Jalankan skrip berikut untuk mensimulasikan failover dan amati hasil aplikasi. Perhatikan bagaimana beberapa sisipan dan pemilihan akan gagal selama migrasi database.

PowerShell
Azure CLI

Anda dapat memeriksa peran server pemulihan bencana selama pengujian dengan perintah berikut:

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

Untuk menguji failover:

Mulai failover manual dari grup failover.

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

Mengembalikan grup failover kembali ke server utama:

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

Anda dapat memeriksa peran server pemulihan bencana selama pengujian dengan perintah berikut:

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

Untuk menguji failover:

Mulai failover manual dari grup failover.

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

Mengembalikan grup failover kembali ke server utama:

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

Saran dan Komentar

Apakah halaman ini membantu?

Last updated on 2025-06-16

Bagikan melalui

Tutorial: Menerapkan database terdistribusi secara geografis (Azure SQL Database)

Prasyarat

Membuat grup failover

Jalankan proyek sampel

Pengujian pengalihan layanan

Konten terkait

Saran dan Komentar

Sumber Daya Tambahan: