@alipay/faas-db-builder - npm Package Compare versions

Comparing version 1.0.8 to 1.0.9

lib/common/constant.d.ts

@@ -19,2 +19,3 @@ export declare enum Sort {
     create = "create",
+    batchCreate = "batchCreate",
     count = "count",
@@ -21,0 +22,0 @@ aggregate = "aggregate"

lib/common/constant.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.PipelineStageName=exports.Target=exports.DocumentAction=exports.CollectionAction=exports.Sort=void 0;var Sort;(function(e){e.DESC="desc",e.ASC="asc"})(Sort=exports.Sort||(exports.Sort={}));var CollectionAction;(function(e){e.update="update",e.delete="delete",e.query="query",e.queryList="queryList",e.create="create"})(CollectionAction=exports.CollectionAction||(exports.CollectionAction={}));var DocumentAction;(function(e){e.update="update",e.replace="replace",e.delete="delete",e.query="query",e.queryList="queryList",e.create="create",e.count="count",e.aggregate="aggregate"})(DocumentAction=exports.DocumentAction||(exports.DocumentAction={}));var Target;(function(e){e.collection="collection",e.document="document"})(Target=exports.Target||(exports.Target={}));var PipelineStageName;(function(e){e.match="$match",e.group="$group",e.sample="$sample"})(PipelineStageName=exports.PipelineStageName||(exports.PipelineStageName={}));
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.PipelineStageName=exports.Target=exports.DocumentAction=exports.CollectionAction=exports.Sort=void 0;var Sort;(function(e){e.DESC="desc",e.ASC="asc"})(Sort=exports.Sort||(exports.Sort={}));var CollectionAction;(function(e){e.update="update",e.delete="delete",e.query="query",e.queryList="queryList",e.create="create"})(CollectionAction=exports.CollectionAction||(exports.CollectionAction={}));var DocumentAction;(function(e){e.update="update",e.replace="replace",e.delete="delete",e.query="query",e.queryList="queryList",e.create="create",e.batchCreate="batchCreate",e.count="count",e.aggregate="aggregate"})(DocumentAction=exports.DocumentAction||(exports.DocumentAction={}));var Target;(function(e){e.collection="collection",e.document="document"})(Target=exports.Target||(exports.Target={}));var PipelineStageName;(function(e){e.match="$match",e.group="$group",e.sample="$sample"})(PipelineStageName=exports.PipelineStageName||(exports.PipelineStageName={}));

lib/mongo-builder/Collection.d.ts

 import { Sort } from '../common/constant';
-import type { AddDocumentParam, MongoDocumentOperation, QueryChainCommand } from '../typing';
+import type { AddDocumentParam, AddManyDocumentParam, MongoDocumentOperation, QueryChainCommand } from '../typing';
 import { AggregateBuilder } from './Aggregate';
@@ -10,2 +10,3 @@ import { DocumentBuilder } from './Document';
     add(param: AddDocumentParam): MongoDocumentOperation;
+    batchAdd(param: AddManyDocumentParam): MongoDocumentOperation;
     doc(_id: string): DocumentBuilder;
@@ -12,0 +13,0 @@ limit(limit: number): QueryBuilder;

lib/mongo-builder/Collection.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.CollectionBuilder=void 0;const constant_1=require("../common/constant"),util_1=require("../common/util"),Aggregate_1=require("./Aggregate"),Document_1=require("./Document"),Query_1=require("./Query");class CollectionBuilder{#e;constructor(e){this.#e=e}add(e){return util_1.ActionBuilder.buildDocumentAction(constant_1.DocumentAction.create,this.#e,e.data)}doc(e){return new Document_1.DocumentBuilder(this.#e,e)}limit(e){return new Query_1.QueryBuilder(this.#e).limit(e)}skip(e){return new Query_1.QueryBuilder(this.#e).skip(e)}where(e){return new Query_1.QueryBuilder(this.#e).where(e)}projection(e){return new Query_1.QueryBuilder(this.#e).projection(e)}orderBy(e,r){return new Query_1.QueryBuilder(this.#e).orderBy(e,r)}aggregate(){return new Aggregate_1.AggregateBuilder(this.#e)}get(){return new Query_1.QueryBuilder(this.#e).get()}count(){return new Query_1.QueryBuilder(this.#e).count()}}exports.CollectionBuilder=CollectionBuilder;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.CollectionBuilder=void 0;const constant_1=require("../common/constant"),error_1=require("../common/error"),util_1=require("../common/util"),Aggregate_1=require("./Aggregate"),Document_1=require("./Document"),Query_1=require("./Query");class CollectionBuilder{#e;constructor(e){this.#e=e}add(e){return Array.isArray(e.data)?this.batchAdd(e):util_1.ActionBuilder.buildDocumentAction(constant_1.DocumentAction.create,this.#e,e.data)}batchAdd(e){if(e.data.length>200)throw error_1.DbBuildError.invalidParam("data","Maximum 200 documents");const r={$create:e.data};return typeof e.ordered=="boolean"&&(r.$ordered=e.ordered),util_1.ActionBuilder.buildDocumentAction(constant_1.DocumentAction.batchCreate,this.#e,r)}doc(e){return new Document_1.DocumentBuilder(this.#e,e)}limit(e){return new Query_1.QueryBuilder(this.#e).limit(e)}skip(e){return new Query_1.QueryBuilder(this.#e).skip(e)}where(e){return new Query_1.QueryBuilder(this.#e).where(e)}projection(e){return new Query_1.QueryBuilder(this.#e).projection(e)}orderBy(e,r){return new Query_1.QueryBuilder(this.#e).orderBy(e,r)}aggregate(){return new Aggregate_1.AggregateBuilder(this.#e)}get(){return new Query_1.QueryBuilder(this.#e).get()}count(){return new Query_1.QueryBuilder(this.#e).count()}}exports.CollectionBuilder=CollectionBuilder;

lib/typing.d.ts

@@ -17,5 +17,10 @@ import { QueryCommand } from './command/AbstractCommand';
 }
-export interface AddDocumentParam {
-    data: DocumentData;
+export interface AddOneDocumentParam {
+    data: DocumentData | DocumentData[];
 }
+export interface AddManyDocumentParam {
+    ordered?: boolean;
+    data: DocumentData[];
+}
+export type AddDocumentParam = AddOneDocumentParam | AddManyDocumentParam;
 export interface BaseOptions {
@@ -22,0 +27,0 @@ $match?: object;

package.json

 {
   "name": "@alipay/faas-db-builder",
-  "version": "1.0.8",
+  "version": "1.0.9",
   "description": "db builder",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

46419

increased by1.51%

Lines of code

443

increased by1.61%

No dependency changes