Compare commits
2 Commits
231895c7cd
...
bcefbb7425
Author | SHA1 | Date | |
---|---|---|---|
|
bcefbb7425 | ||
|
e1d03577dd |
@ -2,6 +2,13 @@
|
||||
|
||||
All notable changes to this project will be documented in this file. See [standard-version](https://github.com/conventional-changelog/standard-version) for commit guidelines.
|
||||
|
||||
### [1.3.3](https://git.archive.systems/Dezzpil/ivanovna.orm/compare/v1.3.2...v1.3.3) (2021-10-13)
|
||||
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* Потерялась зависимость rfdc ([e1d0357](https://git.archive.systems/Dezzpil/ivanovna.orm/commit/e1d03577dd973c6e651a8d175fbabcf5a8c1fd53))
|
||||
|
||||
### [1.3.2](https://git.archive.systems/Dezzpil/ivanovna.orm/compare/v1.3.1...v1.3.2) (2021-10-05)
|
||||
|
||||
|
||||
|
9
orm.d.ts
vendored
9
orm.d.ts
vendored
@ -1,10 +1,13 @@
|
||||
/** @public */
|
||||
export declare abstract class Data {
|
||||
[key: string]: any;
|
||||
/**
|
||||
* @deprecated use fromObject()
|
||||
*/
|
||||
static assign(vo: Data, values: ValuesObject): Data;
|
||||
set(key: string, value: any): void;
|
||||
fromObject(object: ValuesObject): void;
|
||||
toObject(exclude?: string[]): Record<string, any>;
|
||||
toObject(exclude?: string[]): ValuesObject;
|
||||
abstract uniqKey(): string;
|
||||
}
|
||||
|
||||
@ -99,13 +102,13 @@ declare abstract class Storage_2 {
|
||||
abstract save(name: string, uniqKey: string, data: Record<string, any>): Promise<string>;
|
||||
abstract createSession(): StorageSession;
|
||||
abstract count(name: string, query?: Record<string, any>): Promise<number>;
|
||||
abstract remove(collectionName: string, uniqKeyName: string, uniqKey: string): Promise<boolean>;
|
||||
abstract remove(name: string, uniqKey: string, uniqVal: string | number): Promise<boolean>;
|
||||
}
|
||||
export { Storage_2 as Storage }
|
||||
|
||||
/** @public */
|
||||
export declare interface StorageCursor {
|
||||
limit(number_: number): StorageCursor;
|
||||
limit(number: number): StorageCursor;
|
||||
sort(parameters: Record<string, any>): StorageCursor;
|
||||
skip(offset: number): StorageCursor;
|
||||
toArray(): Promise<any[]>;
|
||||
|
14
package-lock.json
generated
14
package-lock.json
generated
@ -1,13 +1,16 @@
|
||||
{
|
||||
"name": "ivna-orm",
|
||||
"version": "1.3.2",
|
||||
"version": "1.3.3",
|
||||
"lockfileVersion": 2,
|
||||
"requires": true,
|
||||
"packages": {
|
||||
"": {
|
||||
"name": "ivna-orm",
|
||||
"version": "1.3.2",
|
||||
"version": "1.3.3",
|
||||
"license": "ISC",
|
||||
"dependencies": {
|
||||
"rfdc": "^1.3.0"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@jest/test-sequencer": "^27.2.3",
|
||||
"@microsoft/api-extractor": "^7.18.11",
|
||||
@ -21,7 +24,6 @@
|
||||
"jest-teamcity": "^1.10.0",
|
||||
"nanoid": "^3.1.28",
|
||||
"prettier": "^2.4.1",
|
||||
"rfdc": "^1.3.0",
|
||||
"standard-version": "^9.3.1",
|
||||
"ts-jest": "^27.0.5",
|
||||
"ts-node": "^10.2.1",
|
||||
@ -5658,8 +5660,7 @@
|
||||
"node_modules/rfdc": {
|
||||
"version": "1.3.0",
|
||||
"resolved": "https://registry.npmjs.org/rfdc/-/rfdc-1.3.0.tgz",
|
||||
"integrity": "sha512-V2hovdzFbOi77/WajaSMXk2OLm+xNIeQdMMuB7icj7bk6zi2F8GGAxigcnDFpJHbNyNcgyJDiP+8nOrY5cZGrA==",
|
||||
"dev": true
|
||||
"integrity": "sha512-V2hovdzFbOi77/WajaSMXk2OLm+xNIeQdMMuB7icj7bk6zi2F8GGAxigcnDFpJHbNyNcgyJDiP+8nOrY5cZGrA=="
|
||||
},
|
||||
"node_modules/rimraf": {
|
||||
"version": "3.0.2",
|
||||
@ -11393,8 +11394,7 @@
|
||||
"rfdc": {
|
||||
"version": "1.3.0",
|
||||
"resolved": "https://registry.npmjs.org/rfdc/-/rfdc-1.3.0.tgz",
|
||||
"integrity": "sha512-V2hovdzFbOi77/WajaSMXk2OLm+xNIeQdMMuB7icj7bk6zi2F8GGAxigcnDFpJHbNyNcgyJDiP+8nOrY5cZGrA==",
|
||||
"dev": true
|
||||
"integrity": "sha512-V2hovdzFbOi77/WajaSMXk2OLm+xNIeQdMMuB7icj7bk6zi2F8GGAxigcnDFpJHbNyNcgyJDiP+8nOrY5cZGrA=="
|
||||
},
|
||||
"rimraf": {
|
||||
"version": "3.0.2",
|
||||
|
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "ivna-orm",
|
||||
"version": "1.3.2",
|
||||
"version": "1.3.3",
|
||||
"description": "Mini ORM for convenience",
|
||||
"main": "dist/index.js",
|
||||
"files": [
|
||||
@ -43,7 +43,6 @@
|
||||
"jest-teamcity": "^1.10.0",
|
||||
"nanoid": "^3.1.28",
|
||||
"prettier": "^2.4.1",
|
||||
"rfdc": "^1.3.0",
|
||||
"standard-version": "^9.3.1",
|
||||
"ts-jest": "^27.0.5",
|
||||
"ts-node": "^10.2.1",
|
||||
@ -60,5 +59,8 @@
|
||||
"semi": false,
|
||||
"singleQuote": true,
|
||||
"tabWidth": 4
|
||||
},
|
||||
"dependencies": {
|
||||
"rfdc": "^1.3.0"
|
||||
}
|
||||
}
|
||||
|
@ -7,6 +7,9 @@ export type ValuesObject = Record<string, any>
|
||||
export abstract class Data {
|
||||
[key: string]: any
|
||||
|
||||
/**
|
||||
* @deprecated use fromObject()
|
||||
*/
|
||||
static assign(vo: Data, values: ValuesObject): Data {
|
||||
for (const key of Object.getOwnPropertyNames(values)) {
|
||||
vo[key] = values[key]
|
||||
@ -26,7 +29,7 @@ export abstract class Data {
|
||||
}
|
||||
}
|
||||
|
||||
toObject(exclude: string[] = []): Record<string, any> {
|
||||
toObject(exclude: string[] = []): ValuesObject {
|
||||
const object = {} as ValuesObject
|
||||
for (const key of Object.getOwnPropertyNames(this)) {
|
||||
if (key.startsWith('__')) {
|
||||
|
@ -1,6 +1,6 @@
|
||||
/** @public */
|
||||
export interface StorageCursor {
|
||||
limit(number_: number): StorageCursor
|
||||
limit(number: number): StorageCursor
|
||||
sort(parameters: Record<string, any>): StorageCursor
|
||||
skip(offset: number): StorageCursor
|
||||
toArray(): Promise<any[]>
|
||||
@ -28,7 +28,7 @@ export abstract class Storage {
|
||||
|
||||
abstract count(name: string, query?: Record<string, any>): Promise<number>
|
||||
|
||||
abstract remove(collectionName: string, uniqKeyName: string, uniqKey: string): Promise<boolean>
|
||||
abstract remove(name: string, uniqKey: string, uniqVal: string | number): Promise<boolean>
|
||||
}
|
||||
|
||||
/** @public */
|
||||
|
@ -1,5 +1,5 @@
|
||||
import { ClientSession, MongoClient, TransactionOptions } from 'mongodb'
|
||||
import { Storage, StorageCursor, StorageSession } from '../storage'
|
||||
import { ErrStorage, Storage, StorageCursor, StorageSession } from '../storage'
|
||||
import { ErrEntityHasNoUniqKeyValue } from '../entity'
|
||||
|
||||
/** @public */
|
||||
@ -36,8 +36,8 @@ export class MongoStorage extends Storage {
|
||||
async save(collectionName: string, uniqKey: string, data: Record<string, any>): Promise<string> {
|
||||
await this._connect()
|
||||
const id = data[uniqKey]
|
||||
const coll = await this._client.db().collection(collectionName)
|
||||
if (id !== null && id !== undefined) {
|
||||
const coll = await this._client.db().collection(collectionName)
|
||||
const filter = { [uniqKey]: id }
|
||||
const result = await coll.findOneAndReplace(filter, data, { upsert: true })
|
||||
if (result.lastErrorObject) {
|
||||
@ -48,7 +48,7 @@ export class MongoStorage extends Storage {
|
||||
return result.lastErrorObject.upserted
|
||||
}
|
||||
|
||||
throw new TypeError(`can not save data to ${collectionName} with result ${result}`)
|
||||
throw new ErrStorage(`can not save data to ${collectionName} with result ${result}`)
|
||||
} else {
|
||||
// Нельзя сохранить сущность без значения уникального ключа
|
||||
// const result = await coll.insertOne(data)
|
||||
@ -70,8 +70,8 @@ export class MongoStorage extends Storage {
|
||||
return this._client
|
||||
}
|
||||
|
||||
async remove(collectionName: string, uniqKeyName: string, uniqKey: string): Promise<boolean> {
|
||||
const coll = await this._client.db().collection(collectionName)
|
||||
async remove(name: string, uniqKeyName: string, uniqKey: string): Promise<boolean> {
|
||||
const coll = await this._client.db().collection(name)
|
||||
const result = await coll.deleteOne({ [uniqKeyName]: uniqKey })
|
||||
return Promise.resolve(result.acknowledged)
|
||||
}
|
||||
|
@ -9,8 +9,8 @@ export class MapCursor implements StorageCursor {
|
||||
this._map = map
|
||||
}
|
||||
|
||||
limit(number_: number): StorageCursor {
|
||||
this._limit = number_
|
||||
limit(number: number): StorageCursor {
|
||||
this._limit = number
|
||||
return this
|
||||
}
|
||||
|
||||
@ -67,7 +67,7 @@ export class MapStorage extends Storage {
|
||||
return Promise.resolve(0)
|
||||
}
|
||||
|
||||
async remove(collectionName: string, uniqKeyName: string, uniqKey: string): Promise<boolean> {
|
||||
async remove(name: string, uniqKeyName: string, uniqKey: string): Promise<boolean> {
|
||||
return Promise.resolve(true)
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user