Aiven for PostgreSQL

const { Client } = require('pg');

const client = new Client({
  host: 'pg-service.aivencloud.com',
  port: 12345,
  database: 'defaultdb',
  user: 'avnadmin',
  password: 'your-password',
  ssl: {
    rejectUnauthorized: true,
    ca: fs.readFileSync('./ca.pem').toString()
  }
});

await client.connect();

// Query data
const res = await client.query('SELECT * FROM users WHERE id = $1', [1]);
console.log(res.rows[0]);

// Insert data
await client.query(
  'INSERT INTO users (email, name) VALUES ($1, $2)',
  ['[email protected]', 'Jane Doe']
);

await client.end();

// schema.prisma
datasource db {
  provider = "postgresql"
  url      = env("DATABASE_URL")
}

model User {
  id        Int      @id @default(autoincrement())
  email     String   @unique
  name      String?
  createdAt DateTime @default(now())
}

// client.js
const { PrismaClient } = require('@prisma/client');
const prisma = new PrismaClient();

const user = await prisma.user.create({
  data: {
    email: '[email protected]',
    name: 'John Doe'
  }
});

import java.sql.*;

public class PostgreSQLExample {
    public static void main(String[] args) {
        String url = "jdbc:postgresql://pg-service.aivencloud.com:12345/defaultdb?sslmode=require";
        String user = "avnadmin";
        String password = "your-password";

        try (Connection conn = DriverManager.getConnection(url, user, password)) {
            // Query data
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT * FROM users");
            
            while (rs.next()) {
                System.out.println(rs.getString("name"));
            }

            // Insert data
            PreparedStatement pstmt = conn.prepareStatement(
                "INSERT INTO users (email, name) VALUES (?, ?)"
            );
            pstmt.setString(1, "[email protected]");
            pstmt.setString(2, "John Doe");
            pstmt.executeUpdate();

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

package main

import (
    "database/sql"
    "fmt"
    "log"
    _ "github.com/lib/pq"
)

func main() {
    connStr := "host=pg-service.aivencloud.com port=12345 user=avnadmin password=your-password dbname=defaultdb sslmode=require"
    db, err := sql.Open("postgres", connStr)
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close()

    // Query data
    rows, err := db.Query("SELECT id, email, name FROM users")
    if err != nil {
        log.Fatal(err)
    }
    defer rows.Close()

    for rows.Next() {
        var id int
        var email, name string
        if err := rows.Scan(&id, &email, &name); err != nil {
            log.Fatal(err)
        }
        fmt.Printf("%d: %s (%s)\n", id, name, email)
    }

    // Insert data
    _, err = db.Exec(
        "INSERT INTO users (email, name) VALUES ($1, $2)",
        "[email protected]", "John Doe",
    )
    if err != nil {
        log.Fatal(err)
    }
}

require 'pg'

conn = PG.connect(
  host: 'pg-service.aivencloud.com',
  port: 12345,
  dbname: 'defaultdb',
  user: 'avnadmin',
  password: 'your-password',
  sslmode: 'require'
)

# Query data
result = conn.exec('SELECT * FROM users')
result.each do |row|
  puts "#{row['name']}: #{row['email']}"
end

# Insert data
conn.exec_params(
  'INSERT INTO users (email, name) VALUES ($1, $2)',
  ['[email protected]', 'John Doe']
)

conn.close

avn service cross-region-replica-create \
  --project myproject \
  --service my-pg \
  --destination-cloud aws-eu-west-1

CREATE EXTENSION pg_stat_statements;

-- Top 10 slowest queries
SELECT 
  substring(query, 1, 50) AS query_snippet,
  calls,
  mean_exec_time,
  total_exec_time
FROM pg_stat_statements
ORDER BY mean_exec_time DESC
LIMIT 10;