Surreal

The Surreal class is the primary interface for connecting to a SurrealDB instance, managing connections, executing queries, and handling database sessions. It extends SurrealSession and inherits all session management and query execution capabilities.

By default, a Surreal instance operates with a default session scope, but you can create additional isolated sessions using the session management methods.

Extends: SurrealSessionSurrealQueryable

Source: api/surreal.ts

Constructor Syntax

new Surreal(options?)
ParameterTypeDescription
options DriverOptionsDriver-wide configuration options for customizing engines, codecs, and implementations.

Basic Usage

import { Surreal } from 'surrealdb';

const db = new Surreal();

With Custom Options

import { Surreal } from 'surrealdb';

const db = new Surreal({
codecOptions: {
useNativeDates: true // Use native Date objects instead of DateTime
}
});

Returns the current connection status.

Type: ConnectionStatus

Values: "disconnected" | "connecting" | "reconnecting" | "connected"

Example:

console.log(db.status); // "connected"

Returns whether the connection is currently established. This is equivalent to checking if status === "connected".

Type: boolean

Example:

if (db.isConnected) {
console.log('Database is connected');
}

A promise that resolves when the connection is established and ready, or rejects if a connection error occurs.

Type: Promise<void>

Example:

await db.ready;
console.log('Connection is ready');

The Surreal class inherits all properties from SurrealSession, including:

  • namespace - Current namespace

  • database - Current database

  • accessToken - Current access token

  • parameters - Session parameters

  • session - Session ID

  • isValid - Session validity status

Connect to a local or remote SurrealDB instance.

Method Syntax

db.connect(url, opts?)
ParameterTypeDescription
url string | URLThe endpoint URL to connect to (e.g., "ws://localhost:8000", "http://localhost:8000/rpc").
opts ConnectOptionsConnection-specific options such as namespace, database, and authentication.

Promise<true> - Resolves to true when connection is successful

WebSocket Connection

await db.connect('ws://localhost:8000');

HTTP Connection

await db.connect('http://localhost:8000/rpc');

With Namespace and Database

await db.connect('ws://localhost:8000', {
namespace: 'my_namespace',
database: 'my_database'
});

With Authentication

await db.connect('ws://localhost:8000', {
namespace: 'my_namespace',
database: 'my_database',
authentication: {
username: 'root',
password: 'root'
}
});

With Custom Reconnect Options

await db.connect('ws://localhost:8000', {
reconnect: {
enabled: true,
attempts: 10,
retryDelay: 1000,
retryDelayMax: 10000,
retryDelayMultiplier: 2
}
});

Disconnect from the active SurrealDB instance.

Method Syntax

db.close()

Promise<true> - Resolves to true when disconnection is successful

await db.close();
console.log('Connection closed');

Check the health status of the connected SurrealDB instance.

Method Syntax

db.health()

Promise<void> - Resolves if the instance is healthy, rejects otherwise

try {
await db.health();
console.log('Database is healthy');
} catch (error) {
console.error('Health check failed:', error);
}

Retrieve version information from the connected SurrealDB instance.

Method Syntax

db.version()

Promise<VersionInfo> - An object containing version information

const info = await db.version();
console.log(info.version); // "surrealdb-2.1.0"

Check whether a specific feature is available in the current connection.

Method Syntax

db.isFeatureSupported(feature)
ParameterTypeDescription
feature FeatureA feature from the Features object (e.g. Features.LiveQueries, Features.Api).

boolean - true if the feature is supported, false otherwise

import { Surreal, Features } from 'surrealdb';

if (db.isFeatureSupported(Features.LiveQueries)) {
console.log('Live queries are supported');
}

List all active sessions on the current connection.

Method Syntax

db.sessions()

Promise<Uuid[]> - An array of session IDs

const sessionIds = await db.sessions();
console.log('Active sessions:', sessionIds);

Create a new isolated session on the current connection. The new session will have its own namespace, database, variables, and authentication state, but will share the same connection.

Sessions are automatically restored when the connection reconnects. Call reset() on the returned session to destroy it.

Method Syntax

db.newSession()

Promise<SurrealSession> - A new SurrealSession instance

// Create a new isolated session
const session = await db.newSession();

// Use different namespace/database in the new session
await session.use({ namespace: 'other_ns', database: 'other_db' });

// Query in the new session context
const results = await session.select('users');

// Destroy the session when done
await session.reset();

Close the primary session. This is equivalent to calling close() on the connection.

Method Syntax

db.closeSession()

Promise<void> - Resolves when the session is closed

await db.closeSession();

Export the database contents as a SQL string.

Method Syntax

db.export(options?)
ParameterTypeDescription
options SqlExportOptionsOptions to customize what gets exported.

Promise<string> - The exported database as a SQL string

Export Everything

const sql = await db.export();

Export Only Specific Tables

const sql = await db.export({
tables: ['users', 'posts'],
records: true
});

Export Schema Only (No Records)

const sql = await db.export({
records: false,
tables: true,
functions: true
});

Import database contents from a SQL string.

Method Syntax

db.import(input)
ParameterTypeDescription
input stringThe SQL string to import into the database.

Promise<void> - Resolves when the import is complete

const sqlData = `
DEFINE TABLE users SCHEMAFULL;
DEFINE FIELD name ON users TYPE string;
CREATE users:john SET name = 'John Doe';
`;

await db.import(sqlData);
console.log('Data imported successfully');

The Surreal class implements the EventPublisher interface and emits various events during the connection lifecycle. Subscribe to events using the subscribe() method.

Emitted when the connection attempt starts.

Payload: None

Example:

const unsubscribe = db.subscribe('connecting', () => {
console.log('Connecting to database...');
});

Emitted when the connection is successfully established.

Payload: [version: string] - The SurrealDB version string

Example:

db.subscribe('connected', (version) => {
console.log('Connected to SurrealDB version:', version);
});

Emitted when the connection is attempting to reconnect after being disconnected.

Payload: None

Example:

db.subscribe('reconnecting', () => {
console.log('Attempting to reconnect...');
});

Emitted when the connection is closed.

Payload: None

Example:

db.subscribe('disconnected', () => {
console.log('Disconnected from database');
});

Emitted when a connection error occurs.

Payload: [error: Error] - The error object

Example:

db.subscribe('error', (error) => {
console.error('Connection error:', error.message);
});

The Surreal class also inherits and re-emits events from SurrealSession:

  • auth - Emitted when authentication state changes

  • using - Emitted when namespace/database changes

Subscribe to connection and session events.

Method Syntax

db.subscribe(event, listener)
ParameterTypeDescription
event keyof SurrealEventsThe event name to subscribe to.
listener FunctionCallback function invoked when the event is emitted.

() => void - An unsubscribe function to remove the event listener

const unsubscribe = db.subscribe('connected', (version) => {
console.log('Connected:', version);
});

// Later, unsubscribe from the event
unsubscribe();

As Surreal extends SurrealSession, it inherits all authentication and query methods:

  • use() - Set namespace and database

  • set() - Set a session parameter

  • unset() - Remove a session parameter

  • reset() - Reset the session

As Surreal extends SurrealQueryable (via SurrealSession), it also inherits all query execution methods:

This class does not use generic type parameters.

import { Surreal } from 'surrealdb';

// Create and connect
const db = new Surreal({
codecOptions: {
useNativeDates: true
}
});

// Subscribe to connection events
db.subscribe('connecting', () => console.log('Connecting...'));
db.subscribe('connected', (version) => console.log('Connected:', version));
db.subscribe('error', (error) => console.error('Error:', error));

// Connect to database
await db.connect('ws://localhost:8000', {
namespace: 'my_namespace',
database: 'my_database',
authentication: {
username: 'root',
password: 'root'
}
});

// Check connection status
console.log('Connected:', db.isConnected); // true
console.log('Status:', db.status); // "connected"

// Get version info
const version = await db.version();
console.log('Version:', version.version);

// Execute queries (inherited from SurrealSession/SurrealQueryable)
const users = await db.select('users');
console.log('Users:', users);

// Create a new isolated session
const session = await db.newSession();
await session.use({ namespace: 'other_ns', database: 'other_db' });
const otherData = await session.select('data');

// Export database
const backup = await db.export({ records: true });
console.log('Backup size:', backup.length);

// Close connection
await db.close();

Was this page helpful?