Gunakan Spring Data R2DBC dengan Azure Database for PostgreSQL
Artikel
Artikel ini menunjukkan pembuatan aplikasi sampel yang menggunakan Spring Data R2DBC untuk menyimpan dan mengambil informasi di database Azure Database for PostgreSQL. Sampel akan menggunakan implementasi R2DBC untuk PostgreSQL dari repositori r2dbc-postgresql di GitHub.
R2DBC membawa API reaktif ke database relasional tradisional. Anda dapat menggunakannya dengan Spring WebFlux untuk membuat aplikasi Spring Boot yang sepenuhnya reaktif, yang menggunakan API non-blocking. Ini akan memberikan skalabilitas yang lebih baik daripada pendekatan klasik "satu utas per koneksi".
Ganti tempat penampung dengan nilai berikut, yang digunakan di seluruh artikel ini:
<YOUR_DATABASE_SERVER_NAME>: Nama server PostgreSQL Anda, yang harus unik di seluruh Azure.
<YOUR_DATABASE_NAME>: Nama database server PostgreSQL, yang harus unik dalam Azure.
<YOUR_AZURE_REGION>: Wilayah Azure yang akan Anda gunakan. Anda dapat menggunakan eastus secara default, tetapi kami menyarankan agar Anda mengonfigurasi wilayah yang lebih dekat ke tempat tinggal Anda. Anda dapat melihat daftar lengkap wilayah yang tersedia dengan menggunakan az account list-locations.
<YOUR_POSTGRESQL_ADMIN_PASSWORD> dan <YOUR_POSTGRESQL_NON_ADMIN_PASSWORD>: Kata sandi server database PostgreSQL Anda, yang harus memiliki minimal delapan karakter. Kata sandi Anda harus berisi karakter dari tiga kategori berikut – huruf besar Inggris, huruf kecil Inggris, angka (0-9), dan karakter non-alfanumerik (!, $, #,%, dll.).
<YOUR_LOCAL_IP_ADDRESS>: Alamat IP komputer lokal, tempat Anda akan menjalankan aplikasi Spring Boot. Salah satu cara mudah untuk menemukannya adalah dengan membuka whatismyip.akamai.com.
Catatan
Microsoft merekomendasikan penggunaan alur autentikasi paling aman yang tersedia. Alur autentikasi yang dijelaskan dalam prosedur ini, seperti untuk database, cache, olahpesan, atau layanan AI, memerlukan tingkat kepercayaan yang sangat tinggi dalam aplikasi dan membawa risiko yang tidak ada dalam alur lain. Gunakan alur ini hanya ketika opsi yang lebih aman, seperti identitas terkelola untuk koneksi tanpa kata sandi atau tanpa kunci, tidak layak. Untuk operasi komputer lokal, lebih suka identitas pengguna untuk koneksi tanpa kata sandi atau tanpa kunci.
Berikutnya, buat grup sumber daya menggunakan perintah berikut:
az group create \
--name $AZ_RESOURCE_GROUP \
--location $AZ_LOCATION \
--output tsv
Membuat instans Azure Database for PostgreSQL dan menyiapkan pengguna admin
Hal pertama yang akan Anda buat adalah server PostgreSQL terkelola dengan pengguna admin.
Server PostgreSQL yang Anda buat sebelumnya kosong. Gunakan perintah berikut untuk membuat database baru.
az postgres flexible-server db create \
--resource-group $AZ_RESOURCE_GROUP \
--database-name $AZ_DATABASE_NAME \
--server-name $AZ_DATABASE_SERVER_NAME \
--output tsv
Mengonfigurasi aturan firewall untuk server PostgreSQL Anda
Instans Azure Database for PostgreSQL diamankan secara default. Mereka memiliki firewall yang tidak mengizinkan koneksi masuk. Agar bisa menggunakan database Anda, Anda perlu menambahkan aturan firewall yang akan memungkinkan alamat IP lokal mengakses server database.
Karena Anda mengonfigurasi alamat IP lokal kami di awal artikel ini, Anda dapat membuka firewall server dengan menjalankan perintah berikut:
Jika Anda menyambungkan ke server PostgreSQL dari Subsistem Windows untuk Linux (WSL) di komputer Windows, Anda perlu menambahkan ID host WSL ke firewall Anda.
Dapatkan alamat IP komputer host Anda dengan menjalankan perintah berikut di WSL:
cat /etc/resolv.conf
Salin alamat IP dengan mengikuti istilah nameserver, lalu gunakan perintah berikut untuk mengatur variabel lingkungan untuk Alamat IP WSL:
export AZ_WSL_IP_ADDRESS=<the-copied-IP-address>
Kemudian, gunakan perintah berikut untuk membuka firewall server ke aplikasi berbasis WSL Anda:
Buat skrip SQL yang disebut create_user.sql untuk membuat pengguna non-admin. Tambahkan konten berikut dan simpan secara lokal:
Catatan
Microsoft merekomendasikan penggunaan alur autentikasi paling aman yang tersedia. Alur autentikasi yang dijelaskan dalam prosedur ini, seperti untuk database, cache, olahpesan, atau layanan AI, memerlukan tingkat kepercayaan yang sangat tinggi dalam aplikasi dan membawa risiko yang tidak ada dalam alur lain. Gunakan alur ini hanya ketika opsi yang lebih aman, seperti identitas terkelola untuk koneksi tanpa kata sandi atau tanpa kunci, tidak layak. Untuk operasi komputer lokal, lebih suka identitas pengguna untuk koneksi tanpa kata sandi atau tanpa kunci.
cat << EOF > create_user.sql
CREATE ROLE "$AZ_POSTGRESQL_NON_ADMIN_USERNAME" WITH LOGIN PASSWORD '$AZ_POSTGRESQL_NON_ADMIN_PASSWORD';
GRANT ALL PRIVILEGES ON DATABASE $AZ_DATABASE_NAME TO "$AZ_POSTGRESQL_NON_ADMIN_USERNAME";
EOF
Kemudian, gunakan perintah berikut untuk menjalankan skrip SQL untuk membuat pengguna non-admin Microsoft Entra:
Buka file pom.xml proyek yang dihasilkan, lalu tambahkan driver PostgreSQL reaktif dari repositori r2dbc-postgresql di GitHub. Setelah dependensi spring-boot-starter-webflux, tambahkan teks berikut:
$AZ_DATABASE_SERVER_NAMEGanti variabel , $AZ_DATABASE_NAME, dan $AZ_POSTGRESQL_NON_ADMIN_PASSWORD dengan nilai yang Anda konfigurasi di awal artikel ini.
Peringatan
Untuk alasan keamanan, Azure Database for PostgreSQL perlu menggunakan koneksi SSL. Inilah sebabnya mengapa Anda perlu menambahkan properti konfigurasi spring.r2dbc.properties.sslMode=REQUIRE; jika tidak, driver R2DBC PostgreSQL akan mencoba terhubung menggunakan koneksi yang tidak aman, dan akan gagal.
Catatan
Untuk kinerja yang lebih baik, properti spring.r2dbc.url dikonfigurasi untuk menggunakan kumpulan koneksi menggunakan r2dbc-pool.
Kini Anda dapat memulai aplikasi dengan menggunakan wrapper Maven yang telah disediakan sebagai berikut:
./mvnw spring-boot:run
Berikut adalah cuplikan layar aplikasi yang berjalan untuk pertama kalinya:
Buat skema database
Di dalam kelas DemoApplication utama, konfigurasikan bean Spring baru yang akan membuat skema database, menggunakan kode berikut:
package com.example.demo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.core.io.ClassPathResource;
import org.springframework.data.r2dbc.connectionfactory.init.ConnectionFactoryInitializer;
import org.springframework.data.r2dbc.connectionfactory.init.ResourceDatabasePopulator;
import io.r2dbc.spi.ConnectionFactory;
@SpringBootApplication
public class DemoApplication {
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
@Bean
public ConnectionFactoryInitializer initializer(ConnectionFactory connectionFactory) {
ConnectionFactoryInitializer initializer = new ConnectionFactoryInitializer();
initializer.setConnectionFactory(connectionFactory);
ResourceDatabasePopulator populator = new ResourceDatabasePopulator(new ClassPathResource("schema.sql"));
initializer.setDatabasePopulator(populator);
return initializer;
}
}
Bean Spring ini menggunakan file yang disebut schema.sql, maka buatlah file tersebut di folder src/main/resources, dan tambahkan teks berikut:
DROP TABLE IF EXISTS todo;
CREATE TABLE todo (id SERIAL PRIMARY KEY, description VARCHAR(255), details VARCHAR(4096), done BOOLEAN);
Hentikan aplikasi yang berjalan, lalu mulai kembali menggunakan perintah berikut. Aplikasi sekarang akan menggunakan database demo yang Anda buat sebelumnya, dan membuat tabel todo di dalamnya.
./mvnw spring-boot:run
Berikut adalah tangkapan layar tabel database saat sedang dibuat:
Kodekan aplikasi
Selanjutnya, tambahkan kode Java yang akan menggunakan R2DBC untuk menyimpan dan mengambil data server dari PostgreSQL Anda.
Tambahkan kelas Java Todo baru, di samping kelas DemoApplication, menggunakan kode berikut:
package com.example.demo;
import org.springframework.data.annotation.Id;
public class Todo {
public Todo() {
}
public Todo(String description, String details, boolean done) {
this.description = description;
this.details = details;
this.done = done;
}
@Id
private Long id;
private String description;
private String details;
private boolean done;
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getDescription() {
return description;
}
public void setDescription(String description) {
this.description = description;
}
public String getDetails() {
return details;
}
public void setDetails(String details) {
this.details = details;
}
public boolean isDone() {
return done;
}
public void setDone(boolean done) {
this.done = done;
}
}
Kelas ini adalah model domain yang dipetakan pada tabel todo yang Anda buat sebelumnya.
Untuk mengelola kelas itu, Anda memerlukan repositori. Tentukan antarmuka TodoRepository baru dalam paket yang sama, menggunakan kode berikut:
Repositori ini adalah repositori reaktif yang dikelola Spring Data R2DBC.
Selesaikan aplikasi dengan membuat pengontrol yang dapat menyimpan dan mengambil data. Terapkan kelas TodoController dalam paket yang sama, dan tambahkan kode berikut:
package com.example.demo;
import org.springframework.http.HttpStatus;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@RestController
@RequestMapping("/")
public class TodoController {
private final TodoRepository todoRepository;
public TodoController(TodoRepository todoRepository) {
this.todoRepository = todoRepository;
}
@PostMapping("/")
@ResponseStatus(HttpStatus.CREATED)
public Mono<Todo> createTodo(@RequestBody Todo todo) {
return todoRepository.save(todo);
}
@GetMapping("/")
public Flux<Todo> getTodos() {
return todoRepository.findAll();
}
}
Terakhir, hentikan aplikasi lalu mulai kembali menggunakan perintah berikut:
./mvnw spring-boot:run
Uji aplikasi
Untuk menguji aplikasi, Anda dapat menggunakan cURL.
Pertama, buat item "todo" baru dalam database menggunakan perintah berikut:
curl --header "Content-Type: application/json" \
--request POST \
--data '{"description":"configuration","details":"congratulations, you have set up R2DBC correctly!","done": "true"}' \
http://127.0.0.1:8080
Perintah ini harus menghasilkan item yang dibuat, seperti yang ditampilkan di sini:
{"id":1,"description":"configuration","details":"congratulations, you have set up R2DBC correctly!","done":true}
Selanjutnya, ambil data menggunakan permintaan cURL baru dengan perintah berikut:
curl http://127.0.0.1:8080
Perintah ini akan menghasilkan daftar item "todo", termasuk item yang telah Anda buat, seperti yang ditampilkan berikut ini:
[{"id":1,"description":"configuration","details":"congratulations, you have set up R2DBC correctly!","done":true}]
Berikut adalah tangkapan layar beberapa permintaan cURL:
Selamat! Anda telah menciptakan aplikasi Spring Boot yang sepenuhnya reaktif, yang menggunakan R2DBC untuk menyimpan dan mengambil data dari Azure Database for PostgreSQL.
Membersihkan sumber daya
Untuk membersihkan semua sumber daya yang digunakan selama mulai cepat ini, hapus grup sumber daya dengan menggunakan perintah berikut:
az group delete \
--name $AZ_RESOURCE_GROUP \
--yes
Присоединитесь к серии встреч для создания масштабируемых решений искусственного интеллекта на основе реальных вариантов использования с другими разработчиками и экспертами.