Azure Resource Manager Postgresql Dotnet

using Azure.Identity;using Azure.ResourceManager;using Azure.ResourceManager.PostgreSql;using Azure.ResourceManager.PostgreSql.FlexibleServers;
// Local dev: DefaultAzureCredential. Production: set AZURE_TOKEN_CREDENTIALS=prod or AZURE_TOKEN_CREDENTIALS=<specific_credential>var credential = new DefaultAzureCredential(    DefaultAzureCredential.DefaultEnvironmentVariableName);// Or use a specific credential directly in production:// See https://learn.microsoft.com/dotnet/api/overview/azure/identity-readme?view=azure-dotnet#credential-classes// var credential = new ManagedIdentityCredential();ArmClient client = new ArmClient(credential);

using Azure.ResourceManager.PostgreSql.FlexibleServers;using Azure.ResourceManager.PostgreSql.FlexibleServers.Models;
ResourceGroupResource resourceGroup = await client    .GetDefaultSubscriptionAsync()    .Result    .GetResourceGroupAsync("my-resource-group");
PostgreSqlFlexibleServerCollection servers = resourceGroup.GetPostgreSqlFlexibleServers();
PostgreSqlFlexibleServerData data = new PostgreSqlFlexibleServerData(AzureLocation.EastUS){    Sku = new PostgreSqlFlexibleServerSku("Standard_D2ds_v4", PostgreSqlFlexibleServerSkuTier.GeneralPurpose),    AdministratorLogin = "pgadmin",    AdministratorLoginPassword = "YourSecurePassword123!",    Version = PostgreSqlFlexibleServerVersion.Ver16,    Storage = new PostgreSqlFlexibleServerStorage    {        StorageSizeInGB = 128,        AutoGrow = StorageAutoGrow.Enabled,        Tier = PostgreSqlStorageTierName.P30    },    Backup = new PostgreSqlFlexibleServerBackupProperties    {        BackupRetentionDays = 7,        GeoRedundantBackup = PostgreSqlFlexibleServerGeoRedundantBackupEnum.Disabled    },    HighAvailability = new PostgreSqlFlexibleServerHighAvailability    {        Mode = PostgreSqlFlexibleServerHighAvailabilityMode.ZoneRedundant,        StandbyAvailabilityZone = "2"    },    AvailabilityZone = "1",    AuthConfig = new PostgreSqlFlexibleServerAuthConfig    {        ActiveDirectoryAuth = PostgreSqlFlexibleServerActiveDirectoryAuthEnum.Enabled,        PasswordAuth = PostgreSqlFlexibleServerPasswordAuthEnum.Enabled    }};
ArmOperation<PostgreSqlFlexibleServerResource> operation = await servers    .CreateOrUpdateAsync(WaitUntil.Completed, "my-postgresql-server", data);
PostgreSqlFlexibleServerResource server = operation.Value;Console.WriteLine($"Server created: {server.Data.FullyQualifiedDomainName}");

PostgreSqlFlexibleServerResource server = await resourceGroup    .GetPostgreSqlFlexibleServerAsync("my-postgresql-server");
PostgreSqlFlexibleServerDatabaseCollection databases = server.GetPostgreSqlFlexibleServerDatabases();
PostgreSqlFlexibleServerDatabaseData dbData = new PostgreSqlFlexibleServerDatabaseData{    Charset = "UTF8",    Collation = "en_US.utf8"};
ArmOperation<PostgreSqlFlexibleServerDatabaseResource> operation = await databases    .CreateOrUpdateAsync(WaitUntil.Completed, "myappdb", dbData);
PostgreSqlFlexibleServerDatabaseResource database = operation.Value;Console.WriteLine($"Database created: {database.Data.Name}");

PostgreSqlFlexibleServerFirewallRuleCollection firewallRules = server.GetPostgreSqlFlexibleServerFirewallRules();
// Allow specific IP rangePostgreSqlFlexibleServerFirewallRuleData ruleData = new PostgreSqlFlexibleServerFirewallRuleData{    StartIPAddress = System.Net.IPAddress.Parse("10.0.0.1"),    EndIPAddress = System.Net.IPAddress.Parse("10.0.0.255")};
ArmOperation<PostgreSqlFlexibleServerFirewallRuleResource> operation = await firewallRules    .CreateOrUpdateAsync(WaitUntil.Completed, "allow-internal", ruleData);
// Allow Azure servicesPostgreSqlFlexibleServerFirewallRuleData azureServicesRule = new PostgreSqlFlexibleServerFirewallRuleData{    StartIPAddress = System.Net.IPAddress.Parse("0.0.0.0"),    EndIPAddress = System.Net.IPAddress.Parse("0.0.0.0")};
await firewallRules.CreateOrUpdateAsync(WaitUntil.Completed, "AllowAllAzureServicesAndResourcesWithinAzureIps", azureServicesRule);

PostgreSqlFlexibleServerConfigurationCollection configurations = server.GetPostgreSqlFlexibleServerConfigurations();
// Get current configurationPostgreSqlFlexibleServerConfigurationResource config = await configurations    .GetAsync("max_connections");
// Update configurationPostgreSqlFlexibleServerConfigurationData configData = new PostgreSqlFlexibleServerConfigurationData{    Value = "500",    Source = "user-override"};
ArmOperation<PostgreSqlFlexibleServerConfigurationResource> operation = await configurations    .CreateOrUpdateAsync(WaitUntil.Completed, "max_connections", configData);
// Common PostgreSQL configurations to tunestring[] commonParams = {     "max_connections",     "shared_buffers",     "work_mem",     "maintenance_work_mem",    "effective_cache_size",    "log_min_duration_statement"};

PostgreSqlFlexibleServerActiveDirectoryAdministratorCollection admins =     server.GetPostgreSqlFlexibleServerActiveDirectoryAdministrators();
PostgreSqlFlexibleServerActiveDirectoryAdministratorData adminData =     new PostgreSqlFlexibleServerActiveDirectoryAdministratorData{    PrincipalType = PostgreSqlFlexibleServerPrincipalType.User,    PrincipalName = "[email protected]",    TenantId = Guid.Parse("<tenant-id>")};
ArmOperation<PostgreSqlFlexibleServerActiveDirectoryAdministratorResource> operation = await admins    .CreateOrUpdateAsync(WaitUntil.Completed, "<entra-object-id>", adminData);

// List servers in resource groupawait foreach (PostgreSqlFlexibleServerResource server in resourceGroup.GetPostgreSqlFlexibleServers()){    Console.WriteLine($"Server: {server.Data.Name}");    Console.WriteLine($"  FQDN: {server.Data.FullyQualifiedDomainName}");    Console.WriteLine($"  Version: {server.Data.Version}");    Console.WriteLine($"  State: {server.Data.State}");    Console.WriteLine($"  SKU: {server.Data.Sku.Name} ({server.Data.Sku.Tier})");    Console.WriteLine($"  HA: {server.Data.HighAvailability?.Mode}");}
// List databases in serverawait foreach (PostgreSqlFlexibleServerDatabaseResource db in server.GetPostgreSqlFlexibleServerDatabases()){    Console.WriteLine($"Database: {db.Data.Name}");}

// List available backupsawait foreach (PostgreSqlFlexibleServerBackupResource backup in server.GetPostgreSqlFlexibleServerBackups()){    Console.WriteLine($"Backup: {backup.Data.Name}");    Console.WriteLine($"  Type: {backup.Data.BackupType}");    Console.WriteLine($"  Completed: {backup.Data.CompletedOn}");}
// Point-in-time restorePostgreSqlFlexibleServerData restoreData = new PostgreSqlFlexibleServerData(AzureLocation.EastUS){    CreateMode = PostgreSqlFlexibleServerCreateMode.PointInTimeRestore,    SourceServerResourceId = server.Id,    PointInTimeUtc = DateTimeOffset.UtcNow.AddHours(-2)};
ArmOperation<PostgreSqlFlexibleServerResource> operation = await servers    .CreateOrUpdateAsync(WaitUntil.Completed, "my-postgresql-restored", restoreData);

PostgreSqlFlexibleServerData replicaData = new PostgreSqlFlexibleServerData(AzureLocation.WestUS){    CreateMode = PostgreSqlFlexibleServerCreateMode.Replica,    SourceServerResourceId = server.Id,    Sku = new PostgreSqlFlexibleServerSku("Standard_D2ds_v4", PostgreSqlFlexibleServerSkuTier.GeneralPurpose)};
ArmOperation<PostgreSqlFlexibleServerResource> operation = await servers    .CreateOrUpdateAsync(WaitUntil.Completed, "my-postgresql-replica", replicaData);

PostgreSqlFlexibleServerResource server = await resourceGroup    .GetPostgreSqlFlexibleServerAsync("my-postgresql-server");
// Stop server (saves costs when not in use)await server.StopAsync(WaitUntil.Completed);
// Start serverawait server.StartAsync(WaitUntil.Completed);
// Restart serverawait server.RestartAsync(WaitUntil.Completed, new PostgreSqlFlexibleServerRestartParameter{    RestartWithFailover = true,    FailoverMode = PostgreSqlFlexibleServerFailoverMode.PlannedFailover});

PostgreSqlFlexibleServerResource server = await resourceGroup    .GetPostgreSqlFlexibleServerAsync("my-postgresql-server");
PostgreSqlFlexibleServerPatch patch = new PostgreSqlFlexibleServerPatch{    Sku = new PostgreSqlFlexibleServerSku("Standard_D4ds_v4", PostgreSqlFlexibleServerSkuTier.GeneralPurpose),    Storage = new PostgreSqlFlexibleServerStorage    {        StorageSizeInGB = 256,        Tier = PostgreSqlStorageTierName.P40    }};
ArmOperation<PostgreSqlFlexibleServerResource> operation = await server    .UpdateAsync(WaitUntil.Completed, patch);

PostgreSqlFlexibleServerResource server = await resourceGroup    .GetPostgreSqlFlexibleServerAsync("my-postgresql-server");
await server.DeleteAsync(WaitUntil.Completed);

using Azure;
try{    ArmOperation<PostgreSqlFlexibleServerResource> operation = await servers        .CreateOrUpdateAsync(WaitUntil.Completed, "my-postgresql", data);}catch (RequestFailedException ex) when (ex.Status == 409){    Console.WriteLine("Server already exists");}catch (RequestFailedException ex) when (ex.Status == 400){    Console.WriteLine($"Invalid configuration: {ex.Message}");}catch (RequestFailedException ex){    Console.WriteLine($"Azure error: {ex.Status} - {ex.Message}");}

// Npgsql connection stringstring connectionString = $"Host={server.Data.FullyQualifiedDomainName};" +    "Database=myappdb;" +    "Username=pgadmin;" +    "Password=YourSecurePassword123!;" +    "SSL Mode=Require;Trust Server Certificate=true;";
// With Entra ID token (recommended)var credential = new DefaultAzureCredential();var token = await credential.GetTokenAsync(    new TokenRequestContext(new[] { "https://ossrdbms-aad.database.windows.net/.default" }));
string connectionString = $"Host={server.Data.FullyQualifiedDomainName};" +    "Database=myappdb;" +    $"[email protected];" +    $"Password={token.Token};" +    "SSL Mode=Require;";