Databases

1
const { data: databases } = await r.databases.list({
2
  project_id: 'proj_123',
3
});
4
5
for (const db of databases) {
6
  console.log(`${db.name} — ${db.status}`);
7
}

1
interface Database {
2
  id: string;
3
  name: string;
4
  status: string;      // 'provisioning' | 'ready' | 'error'
5
  project_id: string;
6
  created_at: string;
7
}

1
const { data: db } = await r.databases.create({
2
  project_id: 'proj_123',
3
  name: 'main',
4
});
5
6
console.log(db.id);     // 'db_abc...'
7
console.log(db.name);   // 'main'
8
console.log(db.status); // 'provisioning'

1
const { data: db } = await r.databases.ensure({
2
  project_id: 'proj_123',
3
  name: 'main',
4
});
5
6
console.log(db.name);   // 'main'
7
console.log(db.status); // 'ready' (if already provisioned)

1
const { data: creds } = await r.databases.getCredentials({
2
  project_id: 'proj_123',
3
  name: 'main',
4
});
5
6
console.log(creds.host);
7
console.log(creds.port);
8
console.log(creds.database);
9
console.log(creds.username);
10
console.log(creds.password);
11
console.log(creds.connection_string);
12
// postgres://user:pass@host:port/database

1
interface DatabaseCredentials {
2
  host: string;
3
  port: number;
4
  database: string;
5
  username: string;
6
  password: string;
7
  connection_string: string;
8
}

1
// Create a table
2
await r.databases.query({
3
  project_id: 'proj_123',
4
  sql: `CREATE TABLE IF NOT EXISTS orders (
5
    id SERIAL PRIMARY KEY,
6
    user_id TEXT NOT NULL,
7
    amount INTEGER NOT NULL,
8
    created_at TIMESTAMP DEFAULT NOW()
9
  )`,
10
});
11
12
// Insert data with parameterized queries (prevents SQL injection)
13
await r.databases.query({
14
  project_id: 'proj_123',
15
  sql: 'INSERT INTO orders (user_id, amount) VALUES ($1, $2)',
16
  params: ['user_abc', 4999],
17
});
18
19
// Read data
20
const { data: result } = await r.databases.query({
21
  project_id: 'proj_123',
22
  sql: 'SELECT * FROM orders WHERE user_id = $1 ORDER BY created_at DESC',
23
  params: ['user_abc'],
24
});
25
26
console.log(result.columns); // ['id', 'user_id', 'amount', 'created_at']
27
console.log(result.rows);    // [{ id: 1, user_id: 'user_abc', amount: 4999, ... }]
28
console.log(result.rowCount); // 1

1
interface QueryResult {
2
  columns: string[];
3
  rows: Record<string, unknown>[];
4
  rowCount: number;
5
}

1
import { Recursiv } from '@recursiv/sdk';
2
3
const r = new Recursiv();
4
5
const PROJECT_ID = 'proj_123';
6
7
// 1. Ensure the database exists
8
const { data: db } = await r.databases.ensure({
9
  project_id: PROJECT_ID,
10
  name: 'main',
11
});
12
console.log(`Database "${db.name}" status: ${db.status}`);
13
14
// 2. Get connection credentials
15
const { data: creds } = await r.databases.getCredentials({
16
  project_id: PROJECT_ID,
17
  name: 'main',
18
});
19
console.log('Connection string:', creds.connection_string);
20
21
// 3. Run a migration in the sandbox
22
const { data: result } = await r.projects.executeCode(PROJECT_ID, {
23
  code: `
24
    import pg from 'pg';
25
26
    const client = new pg.Client({
27
      connectionString: '${creds.connection_string}',
28
    });
29
    await client.connect();
30
31
    await client.query(\`
32
      CREATE TABLE IF NOT EXISTS users (
33
        id SERIAL PRIMARY KEY,
34
        email TEXT UNIQUE NOT NULL,
35
        name TEXT NOT NULL,
36
        created_at TIMESTAMPTZ DEFAULT NOW()
37
      );
38
    \`);
39
40
    const result = await client.query('SELECT COUNT(*) FROM users');
41
    console.log('Users table ready. Row count:', result.rows[0].count);
42
43
    await client.end();
44
  `,
45
  language: 'typescript',
46
});
47
48
console.log('Migration output:', result.output);

1
import { drizzle } from 'drizzle-orm/node-postgres';
2
import pg from 'pg';
3
4
const { data: creds } = await r.databases.getCredentials({
5
  project_id: 'proj_123',
6
  name: 'main',
7
});
8
9
const pool = new pg.Pool({
10
  connectionString: creds.connection_string,
11
});
12
13
const db = drizzle(pool);

1
// Use the connection string as DATABASE_URL in your .env
2
const { data: creds } = await r.databases.getCredentials({
3
  project_id: 'proj_123',
4
  name: 'main',
5
});
6
7
process.env.DATABASE_URL = creds.connection_string;
8
// Then initialize Prisma normally