Class: DynamoDbAdapter
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:40
Amazon DynamoDB adapter for entityTS NoSQL layer.
Supports AWS SDK v3 DynamoDB DocumentClient when available, with a built-in zero-latency in-memory fallback for local development and offline unit tests.
Implements
Constructors
Constructor
new DynamoDbAdapter(
options?):DynamoDbAdapter
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:46
Parameters
| Parameter | Type |
|---|---|
options | DynamoDbAdapterOptions |
Returns
DynamoDbAdapter
Methods
connect()
connect():
Promise<void>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:50
Returns
Promise<void>
Implementation of
disconnect()
disconnect():
Promise<void>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:55
Returns
Promise<void>
Implementation of
ping()
ping():
Promise<boolean>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:60
Returns
Promise<boolean>
Implementation of
insertOne()
insertOne<
T>(collection,doc,options?):Promise<InsertOneResult>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:64
Type Parameters
| Type Parameter | Default type |
|---|---|
T | unknown |
Parameters
| Parameter | Type |
|---|---|
collection | string |
doc | T |
options? | InsertOptions |
Returns
Promise<InsertOneResult>
Implementation of
insertMany()
insertMany<
T>(collection,docs,options?):Promise<InsertManyResult>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:72
Type Parameters
| Type Parameter | Default type |
|---|---|
T | unknown |
Parameters
| Parameter | Type |
|---|---|
collection | string |
docs | T[] |
options? | InsertOptions |
Returns
Promise<InsertManyResult>
Implementation of
find()
find<
T>(collection,filter?,options?):Promise<T[]>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:80
Type Parameters
| Type Parameter | Default type |
|---|---|
T | unknown |
Parameters
| Parameter | Type |
|---|---|
collection | string |
filter? | NoSqlFilter |
options? | FindOptions |
Returns
Promise<T[]>
Implementation of
findOne()
findOne<
T>(collection,filter?,options?):Promise<T|null>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:88
Type Parameters
| Type Parameter | Default type |
|---|---|
T | unknown |
Parameters
| Parameter | Type |
|---|---|
collection | string |
filter? | NoSqlFilter |
options? | Omit<FindOptions, "limit"> |
Returns
Promise<T | null>
Implementation of
updateOne()
updateOne(
collection,filter,update,options?):Promise<UpdateResult>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:96
Parameters
| Parameter | Type |
|---|---|
collection | string |
filter | NoSqlFilter |
update | NoSqlUpdate |
options? | UpdateOptions |
Returns
Promise<UpdateResult>
Implementation of
updateMany()
updateMany(
collection,filter,update,options?):Promise<UpdateResult>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:105
Parameters
| Parameter | Type |
|---|---|
collection | string |
filter | NoSqlFilter |
update | NoSqlUpdate |
options? | UpdateOptions |
Returns
Promise<UpdateResult>
Implementation of
deleteOne()
deleteOne(
collection,filter,options?):Promise<DeleteResult>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:114
Parameters
| Parameter | Type |
|---|---|
collection | string |
filter | NoSqlFilter |
options? | DeleteOptions |
Returns
Promise<DeleteResult>
Implementation of
deleteMany()
deleteMany(
collection,filter,options?):Promise<DeleteResult>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:122
Parameters
| Parameter | Type |
|---|---|
collection | string |
filter | NoSqlFilter |
options? | DeleteOptions |
Returns
Promise<DeleteResult>
Implementation of
countDocuments()
countDocuments(
collection,filter?,options?):Promise<number>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:130
Parameters
| Parameter | Type |
|---|---|
collection | string |
filter? | NoSqlFilter |
options? | CountOptions |
Returns
Promise<number>
Implementation of
aggregate()
aggregate<
T>(collection,pipeline,options?):Promise<T[]>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:138
Type Parameters
| Type Parameter | Default type |
|---|---|
T | unknown |
Parameters
| Parameter | Type |
|---|---|
collection | string |
pipeline | AggregationStage[] |
options? | AggregateOptions |
Returns
Promise<T[]>
Implementation of
beginTransaction()
beginTransaction():
Promise<NoSqlTransaction>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:146
Returns
Promise<NoSqlTransaction>
Implementation of
INoSqlAdapter.beginTransaction
createIndex()
createIndex(
collection,keys,options?):Promise<string>
Defined in: src/nosql/adapters/DynamoDbAdapter.ts:150
Parameters
| Parameter | Type |
|---|---|
collection | string |
keys | Record<string, 1 | -1 | "text" | "2dsphere" | string> |
options? | { unique?: boolean; name?: string; } |
options.unique? | boolean |
options.name? | string |
Returns
Promise<string>