@cloudbase/wx-cloud-client-sdk - npm Package Compare versions

Comparing version 1.4.0 to 1.5.0

lib/index.d.ts

@@ -8,4 +8,6 @@ import { CloudBaseInstance, ExtendedCloudBaseInstance } from './types';
     init: typeof init;
-    generateHTTPClient: (callFunction: import("./types").CallFunction, fetch: (options: import("@cloudbase/adapter-interface").IFetchOptions) => any, baseUrl: string) => import("./types").OrmClient;
+    generateHTTPClient: (callFunction: import("./types").CallFunction, fetch: (options: import("@cloudbase/adapter-interface").IFetchOptions) => any, baseUrl: string, options?: {
+        sqlBaseUrl?: string | undefined;
+    } | undefined) => import("./types").OrmClient;
 };
 export default _default;

lib/orm/http-orm-client.d.ts

 import { SDKRequestInterface } from '@cloudbase/adapter-interface';
 import { OrmClient, CallFunction } from '../types';
 type ModelFetch = NonNullable<SDKRequestInterface['fetch']>;
-export declare const generateHTTPClient: (callFunction: CallFunction, fetch: ModelFetch, baseUrl: string) => OrmClient;
+export declare const enum EQUERY_PARAM_TYPE {
+    ARRAY = "ARRAY",
+    BOOLEAN = "BOOLEAN",
+    NUMBER = "NUMBER",
+    OBJECT = "OBJECT",
+    STRING = "STRING"
+}
+export declare const generateHTTPClient: (callFunction: CallFunction, fetch: ModelFetch, baseUrl: string, options?: {
+    sqlBaseUrl?: string;
+}) => OrmClient;
 export {};

lib/types/index.d.ts

@@ -287,2 +287,21 @@ /**
     }>>;
+    /**
+     * 运行 sql模板
+     * @param {Object} params - 包含模板名、模板参数、环境类型的参数对象。
+     * @returns {Promise<MethodResponse<unknown>>} 包含记录列表和总数的Promise对象。
+     */
+    runSQLTemplate?: (params: {
+        /**
+         * 模板名称
+         */
+        templateName: string;
+        /**
+         * 模板参数
+         */
+        params?: Record<string, any>;
+        /**
+         * 请求数据的环境类型，默认是 prod，可选值有 prod 和 pre
+         */
+        envType?: EnvType;
+    }) => Promise<MethodResponse<unknown>>;
 }
@@ -289,0 +308,0 @@ /**

lib/wxCloudClientSDK.cjs.js

@@ -148,3 +148,3 @@ 'use strict';
 }
-var VERSION = "1.4.0";
+var VERSION = "1.5.0";
 
@@ -438,3 +438,3 @@ var callDataSource = function (_a) {
 var NOT_SUPPORTED_CODE = 'NotSupported';
-var generateHTTPClient = function (callFunction, fetch, baseUrl) {
+var generateHTTPClient = function (callFunction, fetch, baseUrl, options) {
     var rawQueryClient = createRawQueryClient(callFunction);
@@ -448,3 +448,3 @@ return new Proxy({}, {
             }
-            return generateHTTPClientByDataSourceName(baseUrl, modelName, fetch);
+            return generateHTTPClientByDataSourceName(baseUrl, modelName, fetch, options);
         }
@@ -459,49 +459,129 @@ });
 };
-var generateHTTPClientByDataSourceName = function (baseUrl, modelName, fetch) {
+var generateHTTPClientByDataSourceName = function (baseUrl, modelName, fetch, options) {
     var client = new Proxy({}, {
         get: function (_, methodName) {
-            var httpDataModelMethod = HTTP_DATA_MODEL_METHODS[methodName];
-            if (!httpDataModelMethod) {
-                var error = new Error("\u4E0D\u652F\u6301\u7684\u64CD\u4F5C: ".concat(methodName));
-                throw new WxCloudSDKError(error.message || UNKNOWN_ERROR_MESSAGE, {
-                    originError: error,
-                    code: NOT_SUPPORTED_CODE,
-                    requestId: 'N/A'
-                });
+            if (methodName !== 'runSQLTemplate') {
+                var httpDataModelMethod_1 = HTTP_DATA_MODEL_METHODS[methodName];
+                if (!httpDataModelMethod_1) {
+                    var error = new Error("\u4E0D\u652F\u6301\u7684\u64CD\u4F5C: ".concat(methodName));
+                    throw new WxCloudSDKError(error.message || UNKNOWN_ERROR_MESSAGE, {
+                        originError: error,
+                        code: NOT_SUPPORTED_CODE,
+                        requestId: 'N/A'
+                    });
+                }
+                return function (params) {
+                    if (params === void 0) { params = {}; }
+                    return __awaiter(void 0, void 0, void 0, function () {
+                        var getUrl, method, _a, defaultParams, effectiveParams, envType, url, result, error_1;
+                        var _b;
+                        return __generator(this, function (_c) {
+                            switch (_c.label) {
+                                case 0:
+                                    getUrl = httpDataModelMethod_1.getUrl, method = httpDataModelMethod_1.method, _a = httpDataModelMethod_1.defaultParams, defaultParams = _a === void 0 ? {} : _a;
+                                    effectiveParams = Object.assign({}, defaultParams, params);
+                                    envType = effectiveParams.envType === 'pre' ? 'pre' : 'prod';
+                                    url = [baseUrl, envType, getUrl(modelName)].join('/');
+                                    _c.label = 1;
+                                case 1:
+                                    _c.trys.push([1, 3, , 4]);
+                                    return [4 /*yield*/, fetch({
+                                            url: url,
+                                            body: JSON.stringify(effectiveParams),
+                                            method: method
+                                        })];
+                                case 2:
+                                    result = _c.sent();
+                                    if (result.code) {
+                                        // 抛出错误
+                                        throw createWxCloudSDKError(result === null || result === void 0 ? void 0 : result.message, modelName, methodName, result === null || result === void 0 ? void 0 : result.code, result === null || result === void 0 ? void 0 : result.requestId);
+                                    }
+                                    if (methodName === 'get') {
+                                        // 和 callFunction 实现保持一致
+                                        Object.assign(result, { data: (_b = result.data.record) !== null && _b !== void 0 ? _b : result.data });
+                                    }
+                                    return [2 /*return*/, result];
+                                case 3:
+                                    error_1 = _c.sent();
+                                    throw new WxCloudSDKError((error_1 === null || error_1 === void 0 ? void 0 : error_1.message) || UNKNOWN_ERROR_MESSAGE, {
+                                        originError: error_1
+                                    });
+                                case 4: return [2 /*return*/];
+                            }
+                        });
+                    });
+                };
             }
-            return function (params) {
-                if (params === void 0) { params = {}; }
-                return __awaiter(void 0, void 0, void 0, function () {
-                    var getUrl, method, _a, defaultParams, effectiveParams, envType, url, result, error_1;
-                    var _b;
-                    return __generator(this, function (_c) {
-                        switch (_c.label) {
+            else {
+                if (!(options === null || options === void 0 ? void 0 : options.sqlBaseUrl)) {
+                    var error = new Error("\u4E0D\u652F\u6301\u7684\u64CD\u4F5C: ".concat(methodName));
+                    throw new WxCloudSDKError(error.message || UNKNOWN_ERROR_MESSAGE, {
+                        originError: error,
+                        code: NOT_SUPPORTED_CODE,
+                        requestId: 'N/A'
+                    });
+                }
+                return function (props) { return __awaiter(void 0, void 0, void 0, function () {
+                    var params, templateName, _envType, envType, url, parameter, result, error_2;
+                    var _a, _b, _c, _d, _e, _f, _g, _h;
+                    return __generator(this, function (_j) {
+                        switch (_j.label) {
                             case 0:
-                                getUrl = httpDataModelMethod.getUrl, method = httpDataModelMethod.method, _a = httpDataModelMethod.defaultParams, defaultParams = _a === void 0 ? {} : _a;
-                                effectiveParams = Object.assign({}, defaultParams, params);
-                                envType = effectiveParams.envType === 'pre' ? 'pre' : 'prod';
-                                url = [baseUrl, envType, getUrl(modelName)].join('/');
-                                _c.label = 1;
+                                params = props.params, templateName = props.templateName, _envType = props.envType;
+                                envType = _envType === 'pre' ? 'pre' : 'prod';
+                                url = [options.sqlBaseUrl, envType, templateName, 'run'].join('/');
+                                parameter = Object.entries(params || {}).reduce(function (list, _a) {
+                                    var key = _a[0], value = _a[1];
+                                    if (value !== undefined) {
+                                        var type = "OBJECT" /* EQUERY_PARAM_TYPE.OBJECT */;
+                                        var typeofValue = typeof value;
+                                        switch (typeofValue) {
+                                            case 'boolean': {
+                                                type = "BOOLEAN" /* EQUERY_PARAM_TYPE.BOOLEAN */;
+                                                break;
+                                            }
+                                            case 'number': {
+                                                type = "NUMBER" /* EQUERY_PARAM_TYPE.NUMBER */;
+                                                break;
+                                            }
+                                            case 'string': {
+                                                type = "STRING" /* EQUERY_PARAM_TYPE.STRING */;
+                                                break;
+                                            }
+                                            default: {
+                                                if (Array.isArray(value)) {
+                                                    type = "ARRAY" /* EQUERY_PARAM_TYPE.ARRAY */;
+                                                }
+                                                else {
+                                                    type = "OBJECT" /* EQUERY_PARAM_TYPE.OBJECT */;
+                                                }
+                                            }
+                                        }
+                                        list.push({
+                                            key: key,
+                                            type: type,
+                                            value: type === "STRING" /* EQUERY_PARAM_TYPE.STRING */ ? value : JSON.stringify(value)
+                                        });
+                                    }
+                                    return list;
+                                }, []);
+                                _j.label = 1;
                             case 1:
-                                _c.trys.push([1, 3, , 4]);
+                                _j.trys.push([1, 3, , 4]);
                                 return [4 /*yield*/, fetch({
                                         url: url,
-                                        body: JSON.stringify(effectiveParams),
-                                        method: method
+                                        body: JSON.stringify({ parameter: parameter }),
+                                        method: 'POST'
                                     })];
                             case 2:
-                                result = _c.sent();
-                                if (result.code) {
+                                result = _j.sent();
+                                if ((_a = result === null || result === void 0 ? void 0 : result.Response) === null || _a === void 0 ? void 0 : _a.Error) {
                                     // 抛出错误
-                                    throw createWxCloudSDKError(result === null || result === void 0 ? void 0 : result.message, modelName, methodName, result === null || result === void 0 ? void 0 : result.code, result === null || result === void 0 ? void 0 : result.requestId);
+                                    throw createWxCloudSDKError((_c = (_b = result === null || result === void 0 ? void 0 : result.Response) === null || _b === void 0 ? void 0 : _b.Error) === null || _c === void 0 ? void 0 : _c.Message, modelName, methodName, (_e = (_d = result === null || result === void 0 ? void 0 : result.Response) === null || _d === void 0 ? void 0 : _d.Error) === null || _e === void 0 ? void 0 : _e.Code, (_f = result === null || result === void 0 ? void 0 : result.Response) === null || _f === void 0 ? void 0 : _f.RequestId);
                                 }
-                                if (methodName === 'get') {
-                                    // 和 callFunction 实现保持一致
-                                    Object.assign(result, { data: (_b = result.data.record) !== null && _b !== void 0 ? _b : result.data });
-                                }
-                                return [2 /*return*/, result];
+                                return [2 /*return*/, __assign(__assign({}, ((_g = result === null || result === void 0 ? void 0 : result.Response) !== null && _g !== void 0 ? _g : {})), { data: (_h = result === null || result === void 0 ? void 0 : result.Response) === null || _h === void 0 ? void 0 : _h.Data })];
                             case 3:
-                                error_1 = _c.sent();
-                                throw new WxCloudSDKError((error_1 === null || error_1 === void 0 ? void 0 : error_1.message) || UNKNOWN_ERROR_MESSAGE, {
-                                    originError: error_1
+                                error_2 = _j.sent();
+                                throw new WxCloudSDKError((error_2 === null || error_2 === void 0 ? void 0 : error_2.message) || UNKNOWN_ERROR_MESSAGE, {
+                                    originError: error_2
                                 });
@@ -511,4 +591,4 @@ case 4: return [2 /*return*/];
                     });
-                });
-            };
+                }); };
+            }
         }
@@ -515,0 +595,0 @@ });

lib/wxCloudClientSDK.esm.js

@@ -144,3 +144,3 @@ /******************************************************************************
 }
-var VERSION = "1.4.0";
+var VERSION = "1.5.0";
 
@@ -434,3 +434,3 @@ var callDataSource = function (_a) {
 var NOT_SUPPORTED_CODE = 'NotSupported';
-var generateHTTPClient = function (callFunction, fetch, baseUrl) {
+var generateHTTPClient = function (callFunction, fetch, baseUrl, options) {
     var rawQueryClient = createRawQueryClient(callFunction);
@@ -444,3 +444,3 @@ return new Proxy({}, {
             }
-            return generateHTTPClientByDataSourceName(baseUrl, modelName, fetch);
+            return generateHTTPClientByDataSourceName(baseUrl, modelName, fetch, options);
         }
@@ -455,49 +455,129 @@ });
 };
-var generateHTTPClientByDataSourceName = function (baseUrl, modelName, fetch) {
+var generateHTTPClientByDataSourceName = function (baseUrl, modelName, fetch, options) {
     var client = new Proxy({}, {
         get: function (_, methodName) {
-            var httpDataModelMethod = HTTP_DATA_MODEL_METHODS[methodName];
-            if (!httpDataModelMethod) {
-                var error = new Error("\u4E0D\u652F\u6301\u7684\u64CD\u4F5C: ".concat(methodName));
-                throw new WxCloudSDKError(error.message || UNKNOWN_ERROR_MESSAGE, {
-                    originError: error,
-                    code: NOT_SUPPORTED_CODE,
-                    requestId: 'N/A'
-                });
+            if (methodName !== 'runSQLTemplate') {
+                var httpDataModelMethod_1 = HTTP_DATA_MODEL_METHODS[methodName];
+                if (!httpDataModelMethod_1) {
+                    var error = new Error("\u4E0D\u652F\u6301\u7684\u64CD\u4F5C: ".concat(methodName));
+                    throw new WxCloudSDKError(error.message || UNKNOWN_ERROR_MESSAGE, {
+                        originError: error,
+                        code: NOT_SUPPORTED_CODE,
+                        requestId: 'N/A'
+                    });
+                }
+                return function (params) {
+                    if (params === void 0) { params = {}; }
+                    return __awaiter(void 0, void 0, void 0, function () {
+                        var getUrl, method, _a, defaultParams, effectiveParams, envType, url, result, error_1;
+                        var _b;
+                        return __generator(this, function (_c) {
+                            switch (_c.label) {
+                                case 0:
+                                    getUrl = httpDataModelMethod_1.getUrl, method = httpDataModelMethod_1.method, _a = httpDataModelMethod_1.defaultParams, defaultParams = _a === void 0 ? {} : _a;
+                                    effectiveParams = Object.assign({}, defaultParams, params);
+                                    envType = effectiveParams.envType === 'pre' ? 'pre' : 'prod';
+                                    url = [baseUrl, envType, getUrl(modelName)].join('/');
+                                    _c.label = 1;
+                                case 1:
+                                    _c.trys.push([1, 3, , 4]);
+                                    return [4 /*yield*/, fetch({
+                                            url: url,
+                                            body: JSON.stringify(effectiveParams),
+                                            method: method
+                                        })];
+                                case 2:
+                                    result = _c.sent();
+                                    if (result.code) {
+                                        // 抛出错误
+                                        throw createWxCloudSDKError(result === null || result === void 0 ? void 0 : result.message, modelName, methodName, result === null || result === void 0 ? void 0 : result.code, result === null || result === void 0 ? void 0 : result.requestId);
+                                    }
+                                    if (methodName === 'get') {
+                                        // 和 callFunction 实现保持一致
+                                        Object.assign(result, { data: (_b = result.data.record) !== null && _b !== void 0 ? _b : result.data });
+                                    }
+                                    return [2 /*return*/, result];
+                                case 3:
+                                    error_1 = _c.sent();
+                                    throw new WxCloudSDKError((error_1 === null || error_1 === void 0 ? void 0 : error_1.message) || UNKNOWN_ERROR_MESSAGE, {
+                                        originError: error_1
+                                    });
+                                case 4: return [2 /*return*/];
+                            }
+                        });
+                    });
+                };
             }
-            return function (params) {
-                if (params === void 0) { params = {}; }
-                return __awaiter(void 0, void 0, void 0, function () {
-                    var getUrl, method, _a, defaultParams, effectiveParams, envType, url, result, error_1;
-                    var _b;
-                    return __generator(this, function (_c) {
-                        switch (_c.label) {
+            else {
+                if (!(options === null || options === void 0 ? void 0 : options.sqlBaseUrl)) {
+                    var error = new Error("\u4E0D\u652F\u6301\u7684\u64CD\u4F5C: ".concat(methodName));
+                    throw new WxCloudSDKError(error.message || UNKNOWN_ERROR_MESSAGE, {
+                        originError: error,
+                        code: NOT_SUPPORTED_CODE,
+                        requestId: 'N/A'
+                    });
+                }
+                return function (props) { return __awaiter(void 0, void 0, void 0, function () {
+                    var params, templateName, _envType, envType, url, parameter, result, error_2;
+                    var _a, _b, _c, _d, _e, _f, _g, _h;
+                    return __generator(this, function (_j) {
+                        switch (_j.label) {
                             case 0:
-                                getUrl = httpDataModelMethod.getUrl, method = httpDataModelMethod.method, _a = httpDataModelMethod.defaultParams, defaultParams = _a === void 0 ? {} : _a;
-                                effectiveParams = Object.assign({}, defaultParams, params);
-                                envType = effectiveParams.envType === 'pre' ? 'pre' : 'prod';
-                                url = [baseUrl, envType, getUrl(modelName)].join('/');
-                                _c.label = 1;
+                                params = props.params, templateName = props.templateName, _envType = props.envType;
+                                envType = _envType === 'pre' ? 'pre' : 'prod';
+                                url = [options.sqlBaseUrl, envType, templateName, 'run'].join('/');
+                                parameter = Object.entries(params || {}).reduce(function (list, _a) {
+                                    var key = _a[0], value = _a[1];
+                                    if (value !== undefined) {
+                                        var type = "OBJECT" /* EQUERY_PARAM_TYPE.OBJECT */;
+                                        var typeofValue = typeof value;
+                                        switch (typeofValue) {
+                                            case 'boolean': {
+                                                type = "BOOLEAN" /* EQUERY_PARAM_TYPE.BOOLEAN */;
+                                                break;
+                                            }
+                                            case 'number': {
+                                                type = "NUMBER" /* EQUERY_PARAM_TYPE.NUMBER */;
+                                                break;
+                                            }
+                                            case 'string': {
+                                                type = "STRING" /* EQUERY_PARAM_TYPE.STRING */;
+                                                break;
+                                            }
+                                            default: {
+                                                if (Array.isArray(value)) {
+                                                    type = "ARRAY" /* EQUERY_PARAM_TYPE.ARRAY */;
+                                                }
+                                                else {
+                                                    type = "OBJECT" /* EQUERY_PARAM_TYPE.OBJECT */;
+                                                }
+                                            }
+                                        }
+                                        list.push({
+                                            key: key,
+                                            type: type,
+                                            value: type === "STRING" /* EQUERY_PARAM_TYPE.STRING */ ? value : JSON.stringify(value)
+                                        });
+                                    }
+                                    return list;
+                                }, []);
+                                _j.label = 1;
                             case 1:
-                                _c.trys.push([1, 3, , 4]);
+                                _j.trys.push([1, 3, , 4]);
                                 return [4 /*yield*/, fetch({
                                         url: url,
-                                        body: JSON.stringify(effectiveParams),
-                                        method: method
+                                        body: JSON.stringify({ parameter: parameter }),
+                                        method: 'POST'
                                     })];
                             case 2:
-                                result = _c.sent();
-                                if (result.code) {
+                                result = _j.sent();
+                                if ((_a = result === null || result === void 0 ? void 0 : result.Response) === null || _a === void 0 ? void 0 : _a.Error) {
                                     // 抛出错误
-                                    throw createWxCloudSDKError(result === null || result === void 0 ? void 0 : result.message, modelName, methodName, result === null || result === void 0 ? void 0 : result.code, result === null || result === void 0 ? void 0 : result.requestId);
+                                    throw createWxCloudSDKError((_c = (_b = result === null || result === void 0 ? void 0 : result.Response) === null || _b === void 0 ? void 0 : _b.Error) === null || _c === void 0 ? void 0 : _c.Message, modelName, methodName, (_e = (_d = result === null || result === void 0 ? void 0 : result.Response) === null || _d === void 0 ? void 0 : _d.Error) === null || _e === void 0 ? void 0 : _e.Code, (_f = result === null || result === void 0 ? void 0 : result.Response) === null || _f === void 0 ? void 0 : _f.RequestId);
                                 }
-                                if (methodName === 'get') {
-                                    // 和 callFunction 实现保持一致
-                                    Object.assign(result, { data: (_b = result.data.record) !== null && _b !== void 0 ? _b : result.data });
-                                }
-                                return [2 /*return*/, result];
+                                return [2 /*return*/, __assign(__assign({}, ((_g = result === null || result === void 0 ? void 0 : result.Response) !== null && _g !== void 0 ? _g : {})), { data: (_h = result === null || result === void 0 ? void 0 : result.Response) === null || _h === void 0 ? void 0 : _h.Data })];
                             case 3:
-                                error_1 = _c.sent();
-                                throw new WxCloudSDKError((error_1 === null || error_1 === void 0 ? void 0 : error_1.message) || UNKNOWN_ERROR_MESSAGE, {
-                                    originError: error_1
+                                error_2 = _j.sent();
+                                throw new WxCloudSDKError((error_2 === null || error_2 === void 0 ? void 0 : error_2.message) || UNKNOWN_ERROR_MESSAGE, {
+                                    originError: error_2
                                 });
@@ -507,4 +587,4 @@ case 4: return [2 /*return*/];
                     });
-                });
-            };
+                }); };
+            }
         }
@@ -511,0 +591,0 @@ });

lib/wxCloudClientSDK.umd.js

@@ -150,3 +150,3 @@ (function (global, factory) {
     }
-    var VERSION = "1.4.0";
+    var VERSION = "1.5.0";
 
@@ -440,3 +440,3 @@ var callDataSource = function (_a) {
     var NOT_SUPPORTED_CODE = 'NotSupported';
-    var generateHTTPClient = function (callFunction, fetch, baseUrl) {
+    var generateHTTPClient = function (callFunction, fetch, baseUrl, options) {
         var rawQueryClient = createRawQueryClient(callFunction);
@@ -450,3 +450,3 @@ return new Proxy({}, {
                 }
-                return generateHTTPClientByDataSourceName(baseUrl, modelName, fetch);
+                return generateHTTPClientByDataSourceName(baseUrl, modelName, fetch, options);
             }
@@ -461,49 +461,129 @@ });
     };
-    var generateHTTPClientByDataSourceName = function (baseUrl, modelName, fetch) {
+    var generateHTTPClientByDataSourceName = function (baseUrl, modelName, fetch, options) {
         var client = new Proxy({}, {
             get: function (_, methodName) {
-                var httpDataModelMethod = HTTP_DATA_MODEL_METHODS[methodName];
-                if (!httpDataModelMethod) {
-                    var error = new Error("\u4E0D\u652F\u6301\u7684\u64CD\u4F5C: ".concat(methodName));
-                    throw new WxCloudSDKError(error.message || UNKNOWN_ERROR_MESSAGE, {
-                        originError: error,
-                        code: NOT_SUPPORTED_CODE,
-                        requestId: 'N/A'
-                    });
+                if (methodName !== 'runSQLTemplate') {
+                    var httpDataModelMethod_1 = HTTP_DATA_MODEL_METHODS[methodName];
+                    if (!httpDataModelMethod_1) {
+                        var error = new Error("\u4E0D\u652F\u6301\u7684\u64CD\u4F5C: ".concat(methodName));
+                        throw new WxCloudSDKError(error.message || UNKNOWN_ERROR_MESSAGE, {
+                            originError: error,
+                            code: NOT_SUPPORTED_CODE,
+                            requestId: 'N/A'
+                        });
+                    }
+                    return function (params) {
+                        if (params === void 0) { params = {}; }
+                        return __awaiter(void 0, void 0, void 0, function () {
+                            var getUrl, method, _a, defaultParams, effectiveParams, envType, url, result, error_1;
+                            var _b;
+                            return __generator(this, function (_c) {
+                                switch (_c.label) {
+                                    case 0:
+                                        getUrl = httpDataModelMethod_1.getUrl, method = httpDataModelMethod_1.method, _a = httpDataModelMethod_1.defaultParams, defaultParams = _a === void 0 ? {} : _a;
+                                        effectiveParams = Object.assign({}, defaultParams, params);
+                                        envType = effectiveParams.envType === 'pre' ? 'pre' : 'prod';
+                                        url = [baseUrl, envType, getUrl(modelName)].join('/');
+                                        _c.label = 1;
+                                    case 1:
+                                        _c.trys.push([1, 3, , 4]);
+                                        return [4 /*yield*/, fetch({
+                                                url: url,
+                                                body: JSON.stringify(effectiveParams),
+                                                method: method
+                                            })];
+                                    case 2:
+                                        result = _c.sent();
+                                        if (result.code) {
+                                            // 抛出错误
+                                            throw createWxCloudSDKError(result === null || result === void 0 ? void 0 : result.message, modelName, methodName, result === null || result === void 0 ? void 0 : result.code, result === null || result === void 0 ? void 0 : result.requestId);
+                                        }
+                                        if (methodName === 'get') {
+                                            // 和 callFunction 实现保持一致
+                                            Object.assign(result, { data: (_b = result.data.record) !== null && _b !== void 0 ? _b : result.data });
+                                        }
+                                        return [2 /*return*/, result];
+                                    case 3:
+                                        error_1 = _c.sent();
+                                        throw new WxCloudSDKError((error_1 === null || error_1 === void 0 ? void 0 : error_1.message) || UNKNOWN_ERROR_MESSAGE, {
+                                            originError: error_1
+                                        });
+                                    case 4: return [2 /*return*/];
+                                }
+                            });
+                        });
+                    };
                 }
-                return function (params) {
-                    if (params === void 0) { params = {}; }
-                    return __awaiter(void 0, void 0, void 0, function () {
-                        var getUrl, method, _a, defaultParams, effectiveParams, envType, url, result, error_1;
-                        var _b;
-                        return __generator(this, function (_c) {
-                            switch (_c.label) {
+                else {
+                    if (!(options === null || options === void 0 ? void 0 : options.sqlBaseUrl)) {
+                        var error = new Error("\u4E0D\u652F\u6301\u7684\u64CD\u4F5C: ".concat(methodName));
+                        throw new WxCloudSDKError(error.message || UNKNOWN_ERROR_MESSAGE, {
+                            originError: error,
+                            code: NOT_SUPPORTED_CODE,
+                            requestId: 'N/A'
+                        });
+                    }
+                    return function (props) { return __awaiter(void 0, void 0, void 0, function () {
+                        var params, templateName, _envType, envType, url, parameter, result, error_2;
+                        var _a, _b, _c, _d, _e, _f, _g, _h;
+                        return __generator(this, function (_j) {
+                            switch (_j.label) {
                                 case 0:
-                                    getUrl = httpDataModelMethod.getUrl, method = httpDataModelMethod.method, _a = httpDataModelMethod.defaultParams, defaultParams = _a === void 0 ? {} : _a;
-                                    effectiveParams = Object.assign({}, defaultParams, params);
-                                    envType = effectiveParams.envType === 'pre' ? 'pre' : 'prod';
-                                    url = [baseUrl, envType, getUrl(modelName)].join('/');
-                                    _c.label = 1;
+                                    params = props.params, templateName = props.templateName, _envType = props.envType;
+                                    envType = _envType === 'pre' ? 'pre' : 'prod';
+                                    url = [options.sqlBaseUrl, envType, templateName, 'run'].join('/');
+                                    parameter = Object.entries(params || {}).reduce(function (list, _a) {
+                                        var key = _a[0], value = _a[1];
+                                        if (value !== undefined) {
+                                            var type = "OBJECT" /* EQUERY_PARAM_TYPE.OBJECT */;
+                                            var typeofValue = typeof value;
+                                            switch (typeofValue) {
+                                                case 'boolean': {
+                                                    type = "BOOLEAN" /* EQUERY_PARAM_TYPE.BOOLEAN */;
+                                                    break;
+                                                }
+                                                case 'number': {
+                                                    type = "NUMBER" /* EQUERY_PARAM_TYPE.NUMBER */;
+                                                    break;
+                                                }
+                                                case 'string': {
+                                                    type = "STRING" /* EQUERY_PARAM_TYPE.STRING */;
+                                                    break;
+                                                }
+                                                default: {
+                                                    if (Array.isArray(value)) {
+                                                        type = "ARRAY" /* EQUERY_PARAM_TYPE.ARRAY */;
+                                                    }
+                                                    else {
+                                                        type = "OBJECT" /* EQUERY_PARAM_TYPE.OBJECT */;
+                                                    }
+                                                }
+                                            }
+                                            list.push({
+                                                key: key,
+                                                type: type,
+                                                value: type === "STRING" /* EQUERY_PARAM_TYPE.STRING */ ? value : JSON.stringify(value)
+                                            });
+                                        }
+                                        return list;
+                                    }, []);
+                                    _j.label = 1;
                                 case 1:
-                                    _c.trys.push([1, 3, , 4]);
+                                    _j.trys.push([1, 3, , 4]);
                                     return [4 /*yield*/, fetch({
                                             url: url,
-                                            body: JSON.stringify(effectiveParams),
-                                            method: method
+                                            body: JSON.stringify({ parameter: parameter }),
+                                            method: 'POST'
                                         })];
                                 case 2:
-                                    result = _c.sent();
-                                    if (result.code) {
+                                    result = _j.sent();
+                                    if ((_a = result === null || result === void 0 ? void 0 : result.Response) === null || _a === void 0 ? void 0 : _a.Error) {
                                         // 抛出错误
-                                        throw createWxCloudSDKError(result === null || result === void 0 ? void 0 : result.message, modelName, methodName, result === null || result === void 0 ? void 0 : result.code, result === null || result === void 0 ? void 0 : result.requestId);
+                                        throw createWxCloudSDKError((_c = (_b = result === null || result === void 0 ? void 0 : result.Response) === null || _b === void 0 ? void 0 : _b.Error) === null || _c === void 0 ? void 0 : _c.Message, modelName, methodName, (_e = (_d = result === null || result === void 0 ? void 0 : result.Response) === null || _d === void 0 ? void 0 : _d.Error) === null || _e === void 0 ? void 0 : _e.Code, (_f = result === null || result === void 0 ? void 0 : result.Response) === null || _f === void 0 ? void 0 : _f.RequestId);
                                     }
-                                    if (methodName === 'get') {
-                                        // 和 callFunction 实现保持一致
-                                        Object.assign(result, { data: (_b = result.data.record) !== null && _b !== void 0 ? _b : result.data });
-                                    }
-                                    return [2 /*return*/, result];
+                                    return [2 /*return*/, __assign(__assign({}, ((_g = result === null || result === void 0 ? void 0 : result.Response) !== null && _g !== void 0 ? _g : {})), { data: (_h = result === null || result === void 0 ? void 0 : result.Response) === null || _h === void 0 ? void 0 : _h.Data })];
                                 case 3:
-                                    error_1 = _c.sent();
-                                    throw new WxCloudSDKError((error_1 === null || error_1 === void 0 ? void 0 : error_1.message) || UNKNOWN_ERROR_MESSAGE, {
-                                        originError: error_1
+                                    error_2 = _j.sent();
+                                    throw new WxCloudSDKError((error_2 === null || error_2 === void 0 ? void 0 : error_2.message) || UNKNOWN_ERROR_MESSAGE, {
+                                        originError: error_2
                                     });
@@ -513,4 +593,4 @@ case 4: return [2 /*return*/];
                         });
-                    });
-                };
+                    }); };
+                }
             }
@@ -517,0 +597,0 @@ });

package.json

 {
   "name": "@cloudbase/wx-cloud-client-sdk",
-  "version": "1.4.0",
+  "version": "1.5.0",
   "publishConfig": {
@@ -5,0 +5,0 @@ "access": "public"

New alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

117614

19.02%

Lines of code

2582

11.82%

Worsened metrics

Number of medium supply chain risk alerts

18

20%

No dependency changes