Version: Nightly

Deno

Deno SDK for SurrealDB

The SurrealDB SDK for Deno enables simple and advanced querying of a remote database from server-side code. All connections to SurrealDB are made over WebSockets, and automatically reconnect when the connection is terminated.

To contribute to this documentation, edit this file on GitHub.

To contribute to the SDK code, submit an Issue or Pull Request here.

Connect to SurrealDB

Create a new mod.ts file and add the following code to try out some basic operations using the SurrealDB SDK.

import Surreal from "https://deno.land/x/surrealdb/mod.ts";

const db = new Surreal();

async function main() {
    try {
        // Connect to the database
        await db.connect('http://127.0.0.1:8000/rpc');

        // Signin as a namespace, database, or root user
        await db.signin({
            user: 'root',
            pass: 'root',
        });

        // Select a specific namespace / database
        await db.use('test', 'test');

        // Create a new person with a random id
        let created = await db.create("person", {
            title: 'Founder & CEO',
            name: {
                first: 'Tobie',
                last: 'Morgan Hitchcock',
            },
            marketing: true,
            identifier: Math.random().toString(36).substr(2, 10),
        });

        // Update a person record with a specific id
        let updated = await db.merge("person:jaime", {
            marketing: true,
        });

        // Select all people records
        let people = await db.select("person");

        // Perform a custom advanced query
        let groups = await db.query('SELECT marketing, count() FROM type::table($tb) GROUP BY marketing', {
            tb: 'person',
        });

    } catch (e) {
        console.error('ERROR', e);
    }
}

main();

Then run your app from the command line with:

deno run --allow-net=127.0.0.1:8000 mod.ts

SDK methods

The JavaScript SDK comes with a number of built-in functions.

Function	Description
`async db.connect(url, options)`	Connects to a local or remote database endpoint
`async db.wait()`	Waits for the connection to the database to succeed
`async db.close()`	Closes the persistent connection to the database
`async db.use(namespace,database)`	Switch to a specific namespace and database
`async db.info<T>()`	Returns the record of an authenticated scope user
`async db.signup(vars)`	Signs this connection up to a specific authentication scope
`async db.signin(vars)`	Signs this connection in to a specific authentication scope
`async db.invalidate()`	Invalidates the authentication for the current connection
`async db.authenticate(token)`	Assigns a value as a parameter for this connection
`async db.let(key,val)`	Runs a set of SurrealQL statements against the database
`async db.unset(key)`	Removes a parameter for this connection
`async db.live<T>(tabel, callback,diff)`	Initiate a live query
`async db.listenLive<T>(queryUuid,callback)`	Register a callback for a running live query
`async db.kill(queryUuid)`	Kill a running live query
`async db.query<T>(sql,vars)`	Runs a set of SurrealQL statements against the database
`async db.select<T>(thing)`	Selects all records in a table, or a specific record
`async db.create<T,U>(thing,data)`	Creates a record in the database
`async db.insert<T,U>(thing,data)`	Inserts one or multiple records in the database
`async db.update<T,U>(thing,data)`	Updates all records in a table, or a specific record
`async db.merge<T,U>(thing,data)`	Modifies all records in a table, or a specific record
`async db.patch<T,U>(thing,data)`	Applies JSON Patch changes to all records in a table, or a specific record
`async db.delete<T,U>(thing,data)`	Deletes all records, or a specific record

`.connect()`

Connects to a local or remote database endpoint.

Method Syntax
async db.connect(url, options)

Arguments

Arguments		Description
`url`		The url of the database endpoint to connect to.
`options`		An object with options to initiate the connection to SurrealDB.

Usage example

// Connect to a local endpoint
await db.connect('http://127.0.0.1:8000/rpc');

// Connect to a remote endpoint
await db.connect('https://cloud.surrealdb.com/rpc');

// Specify a namespace and database pair to use
await db.connect('https://cloud.surrealdb.com/rpc', {
    ns: 'surrealdb',
    db: 'docs',
});

// Authenticate with an existing token
// The .authenticate() function is used under the hood.
await db.connect('https://cloud.surrealdb.com/rpc', {
    auth: '.....',
});

// Authenticate using a pair of credentials
await db.connect('https://cloud.surrealdb.com/rpc', {
    auth: {
        user: 'root',
        pass: 'surrealdb',
    },
});

// Use advanced custom logic to prepare the connection to the database
await db.connect('https://cloud.surrealdb.com/rpc', {
    prepare: async (db) => {
        await db.use({ ns: 'surrealdb', db: 'docs' });

        const token = await retrieveToken();
        if (token) await db.authenticate(token);

        // Any queries executed before the .prepare() function finishes will be forced to wait
        // Please note that this is also the case for queries executed within the prepare function
        // Doing so can cause the connection to stay in a initializing state
    },
});

`.wait()`

Waits for the connection to the database to succeed.

Method Syntax
async db.wait()

Example usage

await db.wait();

`.close()`

Closes the persistent connection to the database.

Method Syntax
async db.close()

Example usage

await db.close();

`.use()`

Connects to a local or remote database endpoint.

Method Syntax
db.use({` { ns, db } `})

Arguments

Arguments		Description
`ns`INITIALLY REQUIRED		Switches to a specific namespace.
`db`INITIALLY REQUIRED		Switches to a specific database.

Example usage

await db.use({ ns: 'surrealdb', db: 'docs' });

`.info()`

This method returns the record of an authenticated scope user.

Method Syntax
async db.info<T>()

Example usage

const user = await db.info();

`.signup()`

Signs up to a specific authentication scope.

Method Syntax
async db.signup({`{ NS, DB, SC, [...] }`})

Arguments

Arguments		Description
`NS`REQUIRED		The namespace to sign up to
`DB`REQUIRED		The database to sign up to
`SC`REQUIRED		The scope to sign up to. Also pass any variables used in the scope

Example usage

const token = await db.signup({
    NS: 'surrealdb',
    DB: 'docs',
    SC: 'user',

    // Also pass any properties required by the scope definition
    email: 'info@surrealdb.com',
    pass: '123456',
});

`.signin()`

Signs in to a root, namespace, database or scope user.

Method Syntax
async db.signin({`{ ... }`})

Arguments

Properties		Description
`user`REQUIRED FOR ROOT, NS & DB		The username of the database user
`pass`REQUIRED FOR ROOT, NS & DB		The password of the database user
`NS`REQUIRED FOR DB & SC		The namespace to sign in to
`DB`REQUIRED FOR SC		The database to sign in to
`SC`		The scope to sign in to. Also pass any variables used in the scope

Example usage

// Authenticate with a root user
const token = await db.signin({
    user: 'root',
    pass: 'surrealdb',
});

// Authenticate with a Namespace user
const token = await db.signin({
    NS: 'surrealdb',
    user: 'tobie',
    pass: 'surrealdb',
});

// Authenticate with a Database user
const token = await db.signin({
    NS: 'surrealdb',
    DB: 'docs',
    user: 'tobie',
    pass: 'surrealdb',
});

// Authenticate with a Scope user
const token = await db.signin({
    NS: 'surrealdb',
    DB: 'docs',
    SC: 'user',

    // Also pass any properties required by the scope definition
    email: 'info@surrealdb.com',
    pass: '123456',
});

`.invalidate()`

Invalidates the authentication for the current connection.

Method Syntax
async db.invalidate()

Example usage

await db.invalidate();

`.authenticate()`

Authenticates the current connection with a JWT token.

Method Syntax
async db.authenticate(token)

Arguments

Arguments		Description
`token`REQUIRED		The JWT authentication token.

Example usage

await db.authenticate('eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJTdXJyZWFsREIiLCJpYXQiOjE1MTYyMzkwMjIsIm5iZiI6MTUxNjIzOTAyMiwiZXhwIjoxODM2NDM5MDIyLCJOUyI6InRlc3QiLCJEQiI6InRlc3QiLCJTQyI6InVzZXIiLCJJRCI6InVzZXI6dG9iaWUifQ.N22Gp9ze0rdR06McGj1G-h2vu6a6n9IVqUbMFJlOxxA');

`.let()`

Assigns a value as a parameter for this connection.

Method Syntax
async db.let(key, val)

Arguments

Arguments		Description
`key`REQUIRED		Specifies the name of the variable.
`val`REQUIRED		Assigns the value to the variable name.

Example usage

// Assign the variable on the connection
await db.let('name', {
    first: 'Tobie',
    last: 'Morgan Hitchcock',
});

// Use the variable in a subsequent query
await db.query('CREATE person SET name = $name');

// Use the variable in a subsequent query
await db.query('SELECT * FROM person WHERE name.first = $name.first');

`.unset()`

Removes a parameter for this connection.

Method Syntax
async db.unset(key)

Arguments

Arguments		Description
`sql`REQUIRED		Specifies the SurrealQL statements.

Example usage

// Remove the variable from the connection
await db.unset('name');

`.live()`

Initiates a live query.

Method Syntax
async db.live<T>(table, callback, diff)

Arguments

Arguments		Description
`table`REQUIRED		The table name to listen for changes for
`callback`OPTIONAL		A callback function that processes live notifications
`diff`OPTIONAL		If set to true, live notifications will include an array of JSON Patch objects, rather than the entire record for each notification.

Example usage

// The uuid of the live query will be returned
const queryUuid = await db.live(
    "person",
    // The callback function takes an object with the 'action' and 'result' properties
    ({ action, result }) => {
        // action can be: 'CREATE', 'UPDATE', 'DELETE' or 'CLOSE'
        if (action === 'CLOSE') return;

        // result contains either the entire record, or a set of JSON patches when diff mode is enabled
        processSomeLiveQueryUpdate(result);
    }
)

`.listenLive()`

Creates a record in the database.

Method Syntax
async db.listenLive<T>(queryUuid, callback)

Arguments

Arguments		Description
`queryUuid`REQUIRED		The UUID of a running live query
`callback`REQUIRED		A callback function that processes live notifications

Example usage

await db.listenLive(
    queryUuid,
    // The callback function takes an object with the "action" and "result" properties
    ({ action, result }) => {
        // action can be: "CREATE", "UPDATE", "DELETE" or "CLOSE"
        if (action === 'CLOSE') return;

        // result contains either the entire record, or a set of JSON patches when diff mode is enabled
        processSomeLiveQueryUpdate(result);
    }
)

`.kill()`

Kills a running live query by it's UUID

Method Syntax
async db.kill(queryUuid)

Arguments

Arguments		Description
`queryUuid`REQUIRED		The UUID of the live query you wish to kill

Example usage

await db.kill(queryUuid)

`.query()`

Runs a set of SurrealQL statements against the database.

Method Syntax
async db.query<T>(query, vars)

Arguments

Arguments		Description
`query`REQUIRED		Specifies the SurrealQL statements.
`vars`OPTIONAL		Assigns variables which can be used in the query.

Example usage

type Person = {
    id: string;
    name: string;
};

// Assign the variable on the connection
const result = await db.query<[Person[], Person[]]>(
    'CREATE person SET name = "John"; SELECT * FROM type::table($tb);',
    { tb: 'person' }
);

// Get the first result from the first query
const created = result[0].result[0];

// Get all of the results from the second query
const people = result[1].result;

`.select()`

Selects all records in a table, or a specific record, from the database.

Method Syntax
async db.select(resource)

Arguments

Arguments		Description
`thing`REQUIRED		The table name or a record ID to select.

Example usage

type Person = {
    id: string;
    name: string;
};

// Select all records from a table
const people = await db.select<Person>('person');

// Select a specific record from a table
const [person] = await db.select<Person>('person:h5wxrf2ewk8xjxosxtyc');

Translated query

This function will run the following query in the database.

SELECT * FROM $thing;

`.create()`

Creates a record in the database.

Method Syntax
async db.create<T>(thing, data)

Arguments

Arguments		Description
`thing`REQUIRED		The table name or a record ID to select.
`data`OPTIONAL		The table name or a record ID to select.

Example usage

type Person = {
    id: string;
    name: string;
    settings: {
        active: boolean;
        marketing: boolean;
    };
};

// Create a record with a random ID
const [person] = await db.create<Person>('person');

// Create a record with a specific ID
const [record] = await db.create<Person>('person:tobie', {
    name: 'Tobie',
    settings: {
        active: true,
        marketing: true,
    },
});

// The content you are creating the record with might differ from the return type
const [record] = await db.create<
    Person,
    Pick<Person, 'name'>
>('person:tobie', {
    name: 'Tobie',
});

Translated query

This function will run the following query in the database.

CREATE $thing CONTENT $data;

`.insert()`

Insers one or multiple records in the database.

Method Syntax
async db.insert<T>(thing, data)

Arguments

Arguments		Description
`thing`REQUIRED		The table name to insert to.
`data`OPTIONAL		Either a single document/record or an array of documents/records to insert

Example usage

type Person = {
    id: string;
    name: string;
    settings: {
        active: boolean;
        marketing: boolean;
    };
};

// Insert a single record
const [person] = await db.insert<Person>('person', {
    name: 'Tobie',
    settings: {
        active: true,
        marketing: true,
    },
});

// Insert multiple records
const people = await db.insert<Person>('person', [
    {
        name: 'Tobie',
        settings: {
            active: true,
            marketing: true,
        },
    },
    {
        name: 'Jaime',
        settings: {
            active: true,
            marketing: true,
        },
    },
]);

// The content you are creating the record with might differ from the return type
const people = await db.insert<
    Person,
    Pick<Person, 'name'>
>('person', [
    { name: 'Tobie' },
    { name: 'Jaime' },
]);

Translated query

This function will run the following query in the database.

INSERT INTO $thing $data;

`.update()`

Updates all records in a table, or a specific record, in the database.

Method Syntax
async db.update<T>(thing, data)

NOTE:This function replaces the current document / record data with the specified data.

Arguments

Arguments		Description
`thing`REQUIRED		The table name or the specific record ID to update.
`data`OPTIONAL		The document / record data to insert.

Example usage

type Person = {
    id: string;
    name: string;
    settings: {
        active: boolean;
        marketing: boolean;
    };
};

// Update all records in a table
const people = await db.update<Person>('person');

// Update a record with a specific ID
const [person] = await db.update<Person>('person:tobie', {
    name: 'Tobie',
    settings: {
        active: true,
        marketing: true,
    },
});

// The content you are updating the record with might differ from the return type
const [record] = await db.update<
    Person,
    Pick<Person, 'name'>
>('person:tobie', {
    name: 'Tobie',
});

Translated query

This function will run the following query in the database.

UPDATE $thing CONTENT $data;

`.merge()`

Modifies all records in a table, or a specific record, in the database.

Method Syntax
async db.merge<T>(thing, data)

NOTE:This function merges the current document / record data with the specified data.

Arguments

Arguments		Description
`thing`REQUIRED		The table name or the specific record ID to merge.
`data`OPTIONAL		The document / record data to insert.

Example usage

type Person = {
    id: string;
    name: string;
    updated_at: Date;
    settings: {
        active: boolean;
        marketing: boolean;
    };
};

// Update all records in a table
const people = await db.merge<Person>('person', {
    updated_at: new Date(),
});

// Update a record with a specific ID
const [person] = await db.merge<Person>('person:tobie', {
    updated_at: new Date(),
    settings: {
        active: true,
    },
});

// The content you are merging the record with might differ from the return type
const [record] = await db.merge<
    Person,
    Pick<Person, 'name'>
>('person:tobie', {
    name: 'Tobie',
});

Translated query

This function will run the following query in the database.

UPDATE $thing MERGE $data;

`.patch()`

Applies JSON Patch changes to all records, or a specific record, in the database.

Method Syntax
async db.patch<T>(thing, data)

NOTE:This function patches the current document / record data with the specified JSON Patch data.

Arguments

Arguments		Description
`thing`REQUIRED		The table name or the specific record ID to patch.
`data`OPTIONAL		The JSON Patch data with which to patch the records.

Example usage

// Update all records in a table
const people = await db.patch('person', [
    { op: 'replace', path: '/created_at', value: new Date() },
]);

// Update a record with a specific ID
const [person] = await db.patch('person:tobie', [
    { op: 'replace', path: '/settings/active', value: false },
    { op: 'add', path: '/tags', value: ['developer', 'engineer'] },
    { op: 'remove', path: '/temp' },
]);

Translated query

This function will run the following query in the database.

UPDATE $thing PATCH $data;

`.delete()`

Deletes all records in a table, or a specific record, from the database.

Method Syntax
async db.delete<T>(thing)

Arguments

Arguments		Description
`thing`REQUIRED		The table name or a record ID to delete.

Example usage

// Delete all records from a table
await db.delete('person');

// Delete a specific record from a table
await db.delete('person:h5wxrf2ewk8xjxosxtyc');

Translated query

This function will run the following query in the database.

DELETE * FROM $thing;

Deno

Deno SDK for SurrealDB

Connect to SurrealDB​

SDK methods​

.connect()​

Arguments​

Usage example​

.wait()​

Example usage​

.close()​

Example usage​

.use()​

Arguments​

Example usage​

.info()​

Example usage​

.signup()​

Arguments​

Example usage​

.signin()​

Arguments​

Example usage​

.invalidate()​

Example usage​

.authenticate()​

Arguments​

Example usage​

.let()​

Arguments​

Example usage​

.unset()​

Arguments​

Example usage​

.live()​

Arguments​

Example usage​

.listenLive()​

Arguments​

Example usage​

.kill()​

Arguments​

Example usage​

.query()​

Arguments​

Example usage​

.select()​

Arguments​

Example usage​

Translated query​

.create()​

Arguments​

Example usage​

Translated query​

.insert()​

Arguments​

Example usage​

Translated query​

.update()​

Arguments​

Example usage​

Translated query​

.merge()​

Arguments​

Example usage​

Translated query​

.patch()​

Arguments​

Example usage​

Translated query​

.delete()​

Arguments​

Example usage​

Translated query​

Connect to SurrealDB

SDK methods

`.connect()`

Arguments

Usage example

`.wait()`

Example usage

`.close()`

Example usage

`.use()`

Arguments

Example usage

`.info()`

Example usage

`.signup()`

Arguments

Example usage

`.signin()`

Arguments

Example usage

`.invalidate()`

Example usage

`.authenticate()`

Arguments

Example usage

`.let()`

Arguments

Example usage

`.unset()`

Arguments

Example usage

`.live()`

Arguments

Example usage

`.listenLive()`

Arguments

Example usage

`.kill()`

Arguments

Example usage

`.query()`

Arguments

Example usage

`.select()`

Arguments

Example usage

Translated query

`.create()`

Arguments

Example usage

Translated query

`.insert()`

Arguments

Example usage

Translated query

`.update()`

Arguments

Example usage

Translated query

`.merge()`

Arguments

Example usage

Translated query

`.patch()`

Arguments

Example usage

Translated query

`.delete()`

Arguments

Example usage

Translated query