All your databases.In the palm of your hand.

import { createDatabase } from "dbsdk";
import { supabase } from "dbsdk/supabase";
import { createManagement } from "dbsdk/management";
import { supabaseManagement } from "dbsdk/management/supabase";

const management = createManagement({
  adapter: supabaseManagement({
    accessToken: process.env.SUPABASE_ACCESS_TOKEN!, // sbp_... personal access token
  }),
});

// 1. Provision: create the project, then wait until it is active.
const result = await management.create({
  kind: "project",
  name: "my-app",
  organizationId: "my-org-slug", // from management.organizations()
});
const project = await management.wait(result, { timeoutMs: 120_000 });

// 2. Connect to the project you just created: the creation-time password
//    (shown once, in result.secrets) and the real host from the API.
const password = result.secrets.find((s) => s.label === "password")!.value;
const host = await management.raw.databaseHost(project.id);
const db = createDatabase({
  adapter: supabase({
    connectionString: `postgresql://postgres:${encodeURIComponent(password)}@${host}:5432/postgres`,
    connectionMode: "direct",
  }),
});

// 3. Query: one bound parameter, works on a fresh database.
try {
  const value = "hello from dbSDK";
  const { rows } = await db.sql`select ${value}::text as value`;
  // rows[0].value === "hello from dbSDK"
} finally {
  await db.close();
}

import { createDatabase } from "dbsdk";
import { neon } from "dbsdk/neon";
import { createManagement } from "dbsdk/management";
import { neonManagement } from "dbsdk/management/neon";

const management = createManagement({
  adapter: neonManagement({ apiKey: process.env.NEON_API_KEY! }),
});

// 1. Provision: create the project, then wait until every operation
//    finishes. wait() issues GET requests only; it never resubmits.
const result = await management.create({ kind: "project", name: "my-app" });
const project = await management.wait(result, { timeoutMs: 120_000 });

// 2. Connect to that project: an official connection URI, redacted by
//    default and revealed only with the explicit reveal: true opt-in.
const uri = await management.raw.connectionUri({
  projectId: project.id,
  databaseName: "neondb",
  roleName: "neondb_owner",
  reveal: true,
});
const db = createDatabase({
  adapter: neon({ connectionString: uri, transport: "http" }),
});

// 3. Query: one bound parameter, works on a fresh database.
try {
  const value = "hello from dbSDK";
  const { rows } = await db.sql`select ${value}::text as value`;
  // rows[0].value === "hello from dbSDK"
} finally {
  await db.close();
}

import { createDatabase } from "dbsdk";
import { planetscale } from "dbsdk/planetscale";
import { createManagement } from "dbsdk/management";
import { planetscaleManagement } from "dbsdk/management/planetscale";

const management = createManagement({
  adapter: planetscaleManagement({
    tokenId: process.env.PLANETSCALE_TOKEN_ID!,
    tokenSecret: process.env.PLANETSCALE_TOKEN_SECRET!,
    organization: "my-org-slug", // required owner for all CRUD
  }),
});

// 1. Provision: cluster_size is required by the official API. Every
//    mutation is engine-gated: a non-PostgreSQL parent is refused
//    before anything is sent.
const result = await management.create({
  kind: "project",
  name: "my-database",
  providerOptions: { cluster_size: "PS-10-GP" },
});
const database = await management.wait(result);

// 2. Credentials: role passwords are one-time secrets. Create a role on
//    the database's default branch ("main"), then read the real host,
//    port, username, and database name back through connection().
const scope = { projectId: database.id, branchId: "main" };
const roleResult = await management.create({ kind: "role", name: "app", scope });
const role = await management.wait(roleResult);
const details = await management.connection({ kind: "role", id: role.id, scope });
const password = roleResult.secrets[0]!.value; // shown once, never again
const db = createDatabase({
  adapter: planetscale({
    connectionString: `postgresql://${encodeURIComponent(details.role!)}:${encodeURIComponent(password)}@${details.host}:${details.port}/${encodeURIComponent(details.database!)}`,
    connectionMode: "direct",
  }),
});

// 3. Query: one bound parameter, works on a fresh database.
try {
  const value = "hello from dbSDK";
  const { rows } = await db.sql`select ${value}::text as value`;
  // rows[0].value === "hello from dbSDK"
} finally {
  await db.close();
}

import { createDatabase } from "dbsdk";
import { postgres } from "dbsdk/postgres";

// Connect an existing PostgreSQL endpoint: no provisioning step, the
// same query client the managed providers hand you.
const db = createDatabase({
  adapter: postgres({ connectionString: process.env.DATABASE_URL! }),
});

try {
  const value = "hello from dbSDK";
  const { rows } = await db.sql`select ${value}::text as value`;
  // rows[0].value === "hello from dbSDK"
} finally {
  await db.close();
}