Connect from code

Airhouse speaks the Postgres wire protocol, so you use the Postgres driver you already know. There’s no Airhouse-specific client library to install. Every example below connects to the database demo as user alice on localhost:5445. Replace these with your own connection parameters from Connect with psql.

Airhouse fully supports the simple query protocol. Its support for the extended query protocol (prepared statements with bound parameters) covers common use, but complex prepared-statement flows can fail. The per-driver tips below keep you on the well-supported path.

Python
Node.js
Go
Java (JDBC)

Use psycopg2 (or psycopg2-binary) and enable autocommit:

import psycopg2

conn = psycopg2.connect(
    host="localhost",
    port=5445,
    dbname="demo",
    user="alice",
    password="alice-password",
)
conn.set_session(autocommit=True)

with conn.cursor() as cur:
    cur.execute("SELECT kind, count(*) FROM lake.main.events GROUP BY kind")
    for kind, n in cur.fetchall():
        print(kind, n)

conn.set_session(autocommit=True) stops psycopg2 from wrapping every statement in an implicit transaction. Without it, a connection can appear to hang.

Use the pg package:

import { Client } from "pg";

const client = new Client({
  host: "localhost",
  port: 5445,
  database: "demo",
  user: "alice",
  password: "alice-password",
});
await client.connect();

const { rows } = await client.query(
  "SELECT kind, count(*) AS n FROM lake.main.events GROUP BY kind",
);
console.log(rows);

await client.end();

Use pgx:

package main

import (
	"context"
	"fmt"

	"github.com/jackc/pgx/v5"
)

func main() {
	ctx := context.Background()
	conn, err := pgx.Connect(ctx, "postgres://alice:alice-password@localhost:5445/demo")
	if err != nil {
		panic(err)
	}
	defer conn.Close(ctx)

	var n int64
	err = conn.QueryRow(ctx, "SELECT count(*) FROM lake.main.events").Scan(&n)
	if err != nil {
		panic(err)
	}
	fmt.Println(n)
}

Use the standard PostgreSQL JDBC driver:

import java.sql.*;

public class Example {
    public static void main(String[] args) throws Exception {
        String url = "jdbc:postgresql://localhost:5445/demo";
        try (Connection conn = DriverManager.getConnection(url, "alice", "alice-password");
             Statement stmt = conn.createStatement();
             ResultSet rs = stmt.executeQuery("SELECT count(*) FROM lake.main.events")) {
            while (rs.next()) {
                System.out.println(rs.getLong(1));
            }
        }
    }
}

If you run into errors with prepared statements, add preferQueryMode=simple to the JDBC URL so the driver uses the simple query protocol: jdbc:postgresql://localhost:5445/demo?preferQueryMode=simple.

Connection strings

Most tools accept a Postgres URL:

postgresql://<user>:<password>@<host>:5445/<database>

Add ?sslmode=require when the server has TLS enabled. URL-encode special characters in the password.

Next steps

BI and SQL tools
Service accounts: mint short-lived credentials for your application’s users

Get Started

Concepts

Connect

Guides

Reference

Connect from code

Connection strings

Next steps

​Connection strings

​Next steps

Connection strings

Next steps