Class: RethinkDBAdapter

// Use Container instead of DataStore on the server
import {Container} from 'js-data'
import RethinkdbDBAdapter from 'js-data-rethinkdb'

// Create a store to hold your Mappers
const store = new Container()

// Create an instance of RethinkdbDBAdapter with default settings
const adapter = new RethinkdbDBAdapter()

// Mappers in "store" will use the RethinkDB adapter by default
store.registerAdapter('rethinkdb', adapter, { default: true })

// Create a Mapper that maps to a "user" table
store.defineMapper('user')

Members

---

<static> OPERATORS

Default predicate functions for the filtering operators.

Properties:

Name	Type	Default	Description
==	function		Equality operator.
=	function	=	Same as ==.
!=	function		Inequality operator.
!	function	=	Same as !=.
>	function		"Greater than" operator.
>=	function		"Greater than or equal to" operator.
<	function		"Less than" operator.
<=	function		"Less than or equal to" operator.
isectEmpty	function		Operator to test that the intersection between two arrays is empty.
isectNotEmpty	function		Operator to test that the intersection between two arrays is NOT empty.
in	function		Operator to test whether a value is found in the provided array.
notIn	function		Operator to test whether a value is NOT found in the provided array.
contains	function		Operator to test whether an array contains the provided value.
notContains	function		Operator to test whether an array does NOT contain the provided value.

Source:

• index.js, line 150

---

authKey :string

RethinkDB authorization key.

Type:

• string

Source:

• index.js, line 56

---

bufferSize :number

Buffer size for connection pool.

Type:

• number

Default Value:

• 10

Source:

• index.js, line 64

---

db :string

Default database.

Type:

• string

Default Value:

• "test"

Source:

• index.js, line 73

---

debug :boolean

Whether to log debugging information.

Type:

• boolean

Default Value:

• false

Source:

• index.js, line 82

---

deleteOpts :Object

Default options to pass to r#delete.

Type:

• Object

Default Value:

• {}

Source:

• index.js, line 272

---

host :string

RethinkDB host.

Type:

• string

Default Value:

• "localhost"

Source:

• index.js, line 91

---

insertOpts :Object

Default options to pass to r#insert.

Type:

• Object

Default Value:

• {}

Source:

• index.js, line 252

---

max :number

Maximum connections in pool.

Type:

• number

Default Value:

• 50

Source:

• index.js, line 109

---

min :number

Minimum connections in pool.

Type:

• number

Default Value:

• 10

Source:

• index.js, line 100

---

operators :Object

Override the default predicate functions for specified operators.

Type:

• Object

Default Value:

• {}

Source:

• index.js, line 292

---

port :number

RethinkDB port.

Type:

• number

Default Value:

• 10

Source:

• index.js, line 118

---

r :Object

The rethinkdbdash instance used by this adapter. Use this directly when you need to write custom queries.

Type:

• Object

Source:

• index.js, line 301

---

raw :boolean

Whether to return a more detailed response object.

Type:

• boolean

Default Value:

• false

Source:

• index.js, line 127

---

runOpts :Object

Default options to pass to r#run.

Type:

• Object

Default Value:

• {}

Source:

• index.js, line 282

---

updateOpts :Object

Default options to pass to r#update.

Type:

• Object

Default Value:

• {}

Source:

• index.js, line 262

Methods

---

afterCreate()

Source:

• index.js, line 323

---

afterCreateMany()

Source:

• index.js, line 329

---

afterDestroy()

Source:

• index.js, line 335

---

afterDestroyAll()

Source:

• index.js, line 341

---

afterFind()

Source:

• index.js, line 347

---

afterFindAll()

Source:

• index.js, line 353

---

afterUpdate()

Source:

• index.js, line 359

---

afterUpdateAll()

Source:

• index.js, line 365

---

afterUpdateMany()

Source:

• index.js, line 371

---

beforeCreate()

Source:

• index.js, line 377

---

beforeCreateMany()

Source:

• index.js, line 383

---

beforeDestroy()

Source:

• index.js, line 389

---

beforeDestroyAll()

Source:

• index.js, line 395

---

beforeFind()

Source:

• index.js, line 401

---

beforeFindAll()

Source:

• index.js, line 407

---

beforeUpdate()

Source:

• index.js, line 413

---

beforeUpdateAll()

Source:

• index.js, line 419

---

beforeUpdateMany()

Source:

• index.js, line 425

---

create(mapper, props, opts)

Create a new record.

Parameters:

Name	Type	Argument	Description
mapper	Object		The mapper.
props	Object		The record to be created.
opts	Object	<optional>	Configuration options. Properties Name Type Argument Default Description insertOpts Object <optional> Options to pass to r#insert. raw boolean <optional> false Whether to return a more detailed response object. runOpts Object <optional> Options to pass to r#run.

Source:

• index.js, line 566

Returns:

Type

Promise

---

createMany(mapper, props, opts)

Create multiple records in a single batch.

Parameters:

Name	Type	Argument	Description
mapper	Object		The mapper.
props	Object		The records to be created.
opts	Object	<optional>	Configuration options. Properties Name Type Argument Default Description insertOpts Object <optional> Options to pass to r#insert. raw boolean <optional> false Whether to return a more detailed response object. runOpts Object <optional> Options to pass to r#run.

Source:

• index.js, line 616

Returns:

Type

Promise

---

dbg()

Source:

• index.js, line 431

---

destroy(mapper, id, opts)

Destroy the record with the given primary key.

Parameters:

Name	Type	Argument	Description
mapper	Object		The mapper.
id	string | number		Primary key of the record to destroy.
opts	Object	<optional>	Configuration options. Properties Name Type Argument Default Description deleteOpts Object <optional> Options to pass to r#delete. raw boolean <optional> false Whether to return a more detailed response object. runOpts Object <optional> Options to pass to r#run.

Source:

• index.js, line 668

Returns:

Type

Promise

---

destroyAll(mapper, query, opts)

Destroy the records that match the selection query.

Parameters:

Name	Type	Argument	Description
mapper	Object		the mapper.
query	Object	<optional>	Selection query. Properties Name Type Argument Description where Object <optional> Filtering criteria. orderBy string | Array <optional> Sorting criteria. sort string | Array <optional> Same as query.sort. limit number <optional> Limit results. skip number <optional> Offset results. offset number <optional> Same as query.skip.
opts	Object	<optional>	Configuration options. Properties Name Type Argument Default Description deleteOpts Object <optional> Options to pass to r#delete. operators Object <optional> Override the default predicate functions for specified operators. raw boolean <optional> false Whether to return a more detailed response object. runOpts Object <optional> Options to pass to r#run.

Source:

• index.js, line 707

Returns:

Type

Promise

---

filterSequence(mapper, query, opts)

Apply the specified selection query to the provided RQL sequence.

Parameters:

Name	Type	Argument	Description
mapper	Object		The mapper.
query	Object	<optional>	Selection query. Properties Name Type Argument Description where Object <optional> Filtering criteria. orderBy string | Array <optional> Sorting criteria. sort string | Array <optional> Same as query.sort. limit number <optional> Limit results. skip number <optional> Offset results. offset number <optional> Same as query.skip.
opts	Object	<optional>	Configuration options. Properties Name Type Argument Description operators Object <optional> Override the default predicate functions for specified operators.

Source:

• index.js, line 447

---

find(mapper, id, opts)

Retrieve the record with the given primary key.

Parameters:

Name	Type	Argument	Description
mapper	Object		The mapper.
id	string | number		Primary key of the record to retrieve.
opts	Object	<optional>	Configuration options. Properties Name Type Argument Default Description raw boolean <optional> false Whether to return a more detailed response object. runOpts Object <optional> Options to pass to r#run. with Array.<string> <optional> [] Relations to eager load.

Source:

• index.js, line 890

Returns:

Type

Promise

---

findAll(mapper, query, opts)

Retrieve the records that match the selection query.

Parameters:

Name	Type	Argument	Description
mapper	Object		The mapper.
query	Object	<optional>	Selection query. Properties Name Type Argument Description where Object <optional> Filtering criteria. orderBy string | Array <optional> Sorting criteria. sort string | Array <optional> Same as query.sort. limit number <optional> Limit results. skip number <optional> Offset results. offset number <optional> Same as query.skip.
opts	Object	<optional>	Configuration options. Properties Name Type Argument Default Description operators Object <optional> Override the default predicate functions for specified operators. raw boolean <optional> false Whether to return a more detailed response object. runOpts Object <optional> Options to pass to r#run. with Array.<string> <optional> [] Relations to eager load.

Source:

• index.js, line 999

Returns:

Type

Promise

---

getOperator(operator, opts)

Resolve the predicate function for the specified operator based on the given options and this adapter's settings.

Parameters:

Name	Type	Argument	Description
operator	string		The name of the operator.
opts	Object	<optional>	Configuration options. Properties Name Type Argument Description operators Object <optional> Override the default predicate functions for specified operators.

Source:

• index.js, line 1138

Returns:

The predicate function for the specified operator.

Type

*

---

getOpt(opt, opts)

Resolve the value of the specified option based on the given options and this adapter's settings.

Parameters:

Name	Type	Argument	Description
opt	string		The name of the option.
opts	Object	<optional>	Configuration options.

Source:

• index.js, line 1157

Returns:

The value of the specified option.

Type

*

---

loadBelongsTo()

Load a belongsTo relationship.

Source:

• index.js, line 850

Returns:

Type

Promise

---

loadHasMany()

Load a hasMany relationship.

Source:

• index.js, line 772

Returns:

Type

Promise

---

loadHasOne()

Load a hasOne relationship.

Source:

• index.js, line 818

Returns:

Type

Promise

---

log()

Logging utility method.

Source:

• index.js, line 1172

---

makeBelongsToForeignKey()

Return the foreignKey from the given record for the provided relationship.

Source:

• index.js, line 839

Returns:

Type

*

---

makeHasManyForeignKey()

Return the foreignKey from the given record for the provided relationship.

There may be reasons why you may want to override this method, like when the id of the parent doesn't exactly match up to the key on the child.

Source:

• index.js, line 758

Returns:

Type

*

---

update(mapper, id, props, opts)

Apply the given update to the record with the specified primary key.

Parameters:

Name	Type	Argument	Description
mapper	Object		The mapper.
id	string | number		The primary key of the record to be updated.
props	Object		The update to apply to the record.
opts	Object	<optional>	Configuration options. Properties Name Type Argument Default Description updateOpts Object <optional> Options to pass to r#update. raw boolean <optional> false Whether to return a more detailed response object. runOpts Object <optional> Options to pass to r#run.

Source:

• index.js, line 1194

Returns:

Type

Promise

---

updateAll(mapper, props, query, opts)

Apply the given update to all records that match the selection query.

Parameters:

Name	Type	Argument	Description
mapper	Object		The mapper.
props	Object		The update to apply to the selected records.
query	Object	<optional>	Selection query. Properties Name Type Argument Description where Object <optional> Filtering criteria. orderBy string | Array <optional> Sorting criteria. sort string | Array <optional> Same as query.sort. limit number <optional> Limit results. skip number <optional> Offset results. offset number <optional> Same as query.skip.
opts	Object	<optional>	Configuration options. Properties Name Type Argument Default Description operators Object <optional> Override the default predicate functions for specified operators. raw boolean <optional> false Whether to return a more detailed response object. runOpts Object <optional> Options to pass to r#run. updateOpts Object <optional> Options to pass to r#update.

Source:

• index.js, line 1248

Returns:

Type

Promise

---

updateMany(mapper, records, opts)

Update the given records in a single batch.

Parameters:

Name	Type	Argument	Description
mapper	Object		The mapper.
records	Array.<Object>		The records to update.
opts	Object	<optional>	Configuration options. Properties Name Type Argument Default Description insertOpts Object <optional> Options to pass to r#insert. raw boolean <optional> false Whether to return a more detailed response object. runOpts Object <optional> Options to pass to r#run.

Source:

• index.js, line 1308

Returns:

Type

Promise