diff --git a/examples/basic-example-v1-with-table-service/index.ts b/examples/basic-example-v1-with-table-service/index.ts index 5129251b..cfb498a7 100644 --- a/examples/basic-example-v1-with-table-service/index.ts +++ b/examples/basic-example-v1-with-table-service/index.ts @@ -224,7 +224,7 @@ async function selectPrepared(session: Session, data: ThreeIds[], logger: Logger '$episodeId': episode.getTypedValue('episodeId') }); const result = Series.createNativeObjects(resultSets[0]); - logger.info(`Select prepared query ${JSON.stringify(result, null, 2)}`); + logger.info(`Parametrized select query ${JSON.stringify(result, null, 2)}`); } } await withRetries(select); diff --git a/examples/basic-example-v2-with-query-service/index.ts b/examples/basic-example-v2-with-query-service/index.ts index e3170c41..6d78578f 100644 --- a/examples/basic-example-v2-with-query-service/index.ts +++ b/examples/basic-example-v2-with-query-service/index.ts @@ -165,7 +165,7 @@ async function selectWithParameters(driver: Driver, data: ThreeIds[], logger: Lo const {value: resultSet} = await resultSets.next(); const {value: row} = await resultSet.rows.next(); await opFinished; - logger.info(`Select prepared query ${JSON.stringify(row, null, 2)}`); + logger.info(`Parametrized select query ${JSON.stringify(row, null, 2)}`); } } }); diff --git a/examples/url-shortener/database.ts b/examples/url-shortener/database.ts index 32b375eb..568d655f 100644 --- a/examples/url-shortener/database.ts +++ b/examples/url-shortener/database.ts @@ -53,18 +53,17 @@ VALUES ($shortenUrl, $sourceUrl);`; return shortenUrl; } - export async function selectSource( shortenUrl: string, session: Session, logger: Logger): Promise { const query = ` ${SYNTAX_V1} - DECLARE $shortenUrl as Utf8; +DECLARE $shortenUrl as Utf8; - SELECT * - FROM ${URLS_TABLE} - WHERE shorten = $shortenUrl;`; +SELECT * +FROM ${URLS_TABLE} +WHERE shorten = $shortenUrl;`; async function execute() : Promise { logger.info('Preparing query...'); @@ -75,7 +74,7 @@ export async function selectSource( '$shortenUrl': requestSourceUrl.getTypedValue('shorten') }); const result = UrlsMatch.createNativeObjects(resultSets[0]); - logger.info('Select prepared query', result); + logger.info('Parametrized select query', result); if (result.length == 0) { return ''; } else { diff --git a/package-lock.json b/package-lock.json index 4bf01bac..bd9cc228 100644 --- a/package-lock.json +++ b/package-lock.json @@ -18,7 +18,7 @@ "reflect-metadata": "^0.1.13", "typed-emitter": "^2.1.0", "uuid": "^8.3.2", - "ydb-sdk-proto": "^1.1.0" + "ydb-sdk-proto": "^1.2.5" }, "devDependencies": { "@commitlint/cli": "^17.6.1", @@ -10198,10 +10198,13 @@ } }, "node_modules/ydb-sdk-proto": { - "version": "1.2.3", - "resolved": "https://registry.npmjs.org/ydb-sdk-proto/-/ydb-sdk-proto-1.2.3.tgz", - "integrity": "sha512-rz8NeYoxsw/tU/7W1QAgsSH42y9vHcexLZUyWtQ2pp7Uu0YORltG5cXkXb7YKVomAao736Il/PL9fonDl/7CMQ==", - "license": "Apache" + "version": "1.2.5", + "resolved": "https://registry.npmjs.org/ydb-sdk-proto/-/ydb-sdk-proto-1.2.5.tgz", + "integrity": "sha512-Sk74VpLQF5k0h+Ev0z83s1BMjpJmiyD2p2fqe3SrusXAmBL2JtB7DbNaejgTJVRlDUfJBjjreQ4Ah0Q16n+XSw==", + "license": "Apache", + "dependencies": { + "protobufjs": "^7.4.0" + } }, "node_modules/yn": { "version": "3.1.1", @@ -17958,9 +17961,12 @@ "dev": true }, "ydb-sdk-proto": { - "version": "1.2.3", - "resolved": "https://registry.npmjs.org/ydb-sdk-proto/-/ydb-sdk-proto-1.2.3.tgz", - "integrity": "sha512-rz8NeYoxsw/tU/7W1QAgsSH42y9vHcexLZUyWtQ2pp7Uu0YORltG5cXkXb7YKVomAao736Il/PL9fonDl/7CMQ==" + "version": "1.2.5", + "resolved": "https://registry.npmjs.org/ydb-sdk-proto/-/ydb-sdk-proto-1.2.5.tgz", + "integrity": "sha512-Sk74VpLQF5k0h+Ev0z83s1BMjpJmiyD2p2fqe3SrusXAmBL2JtB7DbNaejgTJVRlDUfJBjjreQ4Ah0Q16n+XSw==", + "requires": { + "protobufjs": "^7.4.0" + } }, "yn": { "version": "3.1.1", diff --git a/package.json b/package.json index cb4af6ee..e627b865 100644 --- a/package.json +++ b/package.json @@ -43,7 +43,7 @@ "reflect-metadata": "^0.1.13", "typed-emitter": "^2.1.0", "uuid": "^8.3.2", - "ydb-sdk-proto": "^1.1.0" + "ydb-sdk-proto": "^1.2.5" }, "devDependencies": { "@commitlint/cli": "^17.6.1", diff --git a/src/topic/topic-client.ts b/src/topic/topic-client.ts index 2dec6334..040aa7d8 100644 --- a/src/topic/topic-client.ts +++ b/src/topic/topic-client.ts @@ -26,7 +26,6 @@ export type ICreateReaderArgs = { }[]; consumer?: (string|null); readerName?: (string|null); - } export type ICommitOffsetArgs = { path: (string|null);