enable serverless, realtime analytics
on postgres in seconds.

import psycopg2 from urllib.parse import urlparse # Example PostgreSQL database URL db_url = "postgresql://username:password@hostname:5432/database_name" # Parse the database URL url = urlparse(db_url) try: # Establish a connection to the PostgreSQL database using the URL connection = psycopg2.connect( database=url.path[1:], user=url.username, password=url.password, host=url.hostname, port=url.port ) # Create a cursor to perform database operations cursor = connection.cursor() # Run query cursor.execute("SELECT AVG(UserID) FROM hits") value = cursor.fetchone() print("Value: ", value) # Close the cursor and connection cursor.close() connection.close() except (Exception, psycopg2.Error) as error: print("Error while connecting to PostgreSQL:", error) finally: # Close connection, if it was opened if connection: connection.close()

import { drizzle } from 'drizzle-orm/postgres-js' import postgres from 'postgres' const hits = pgTable('hits', { userId: bigint('userID', { mode: 'number' }) }) const connectionString = process.env.DATABASE_URL const client = postgres(connectionString) const db = drizzle(client); const avg = await db .select({ avg: sql`avg(${hits.userId})`, }) .from(hits)

const { Pool } = require('pg'); const pool = new Pool({ connectionString: process.env.DATABASE_URL }); // Example usage (async () => { const query = 'SELECT AVG(UserID) AS avg FROM hits'; const client = await pool.connect(); const res = await client.query(query); console.log(res[0].avg); client.release(); await pool.end(); })();

import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; import java.sql.ResultSet; import java.sql.SQLException; import java.math.BigInteger; public class PostgresExample { private static final String URL = System.getenv("DB_URL"); private static final String USER = System.getenv("DB_USER"); private static final String PASSWORD = System.getenv("DB_PASSWORD"); public static void main(String[] args) { // Connect to the PostgreSQL database try (Connection connection = DriverManager.getConnection(URL, USER, PASSWORD)) { String querySQL = "SELECT AVG(UserID) as avg FROM hits;"; try (ResultSet resultSet = statement.executeQuery(querySQL)) { while (resultSet.next()) { BigInteger avg = resultSet.getInt("avg"); System.out.printf("Average: %d", avg); } } } } catch (SQLException e) { System.out.println("Connection failure."); e.printStackTrace(); } } }