You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-04 15:02:09 +03:00
Add support for JSON.MERGE
(#2511)
* Support JSON.MERGE Command * test only 2.6+ ReJson version * test on edge * review * Update test-utils.ts --------- Co-authored-by: Leibale Eidelman <me@leibale.com>
This commit is contained in:
21
packages/json/lib/commands/MERGE.spec.ts
Normal file
21
packages/json/lib/commands/MERGE.spec.ts
Normal file
@@ -0,0 +1,21 @@
|
|||||||
|
import { strict as assert } from 'assert';
|
||||||
|
import testUtils, { GLOBAL } from '../test-utils';
|
||||||
|
import { transformArguments } from './MERGE';
|
||||||
|
|
||||||
|
describe('MERGE', () => {
|
||||||
|
testUtils.isVersionGreaterThanHook([2, 6]);
|
||||||
|
|
||||||
|
it('transformArguments', () => {
|
||||||
|
assert.deepEqual(
|
||||||
|
transformArguments('key', '$', 1),
|
||||||
|
['JSON.MERGE', 'key', '$', '1']
|
||||||
|
);
|
||||||
|
});
|
||||||
|
|
||||||
|
testUtils.testWithClient('client.json.merge', async client => {
|
||||||
|
assert.equal(
|
||||||
|
await client.json.merge('key', '$', 'json'),
|
||||||
|
'OK'
|
||||||
|
);
|
||||||
|
}, GLOBAL.SERVERS.OPEN);
|
||||||
|
});
|
9
packages/json/lib/commands/MERGE.ts
Normal file
9
packages/json/lib/commands/MERGE.ts
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
import { RedisJSON, transformRedisJsonArgument } from '.';
|
||||||
|
|
||||||
|
export const FIRST_KEY_INDEX = 1;
|
||||||
|
|
||||||
|
export function transformArguments(key: string, path: string, json: RedisJSON): Array<string> {
|
||||||
|
return ['JSON.MERGE', key, path, transformRedisJsonArgument(json)];
|
||||||
|
}
|
||||||
|
|
||||||
|
export declare function transformReply(): 'OK';
|
@@ -8,6 +8,7 @@ import * as DEBUG_MEMORY from './DEBUG_MEMORY';
|
|||||||
import * as DEL from './DEL';
|
import * as DEL from './DEL';
|
||||||
import * as FORGET from './FORGET';
|
import * as FORGET from './FORGET';
|
||||||
import * as GET from './GET';
|
import * as GET from './GET';
|
||||||
|
import * as MERGE from './MERGE';
|
||||||
import * as MGET from './MGET';
|
import * as MGET from './MGET';
|
||||||
import * as MSET from './MSET';
|
import * as MSET from './MSET';
|
||||||
import * as NUMINCRBY from './NUMINCRBY';
|
import * as NUMINCRBY from './NUMINCRBY';
|
||||||
@@ -41,6 +42,8 @@ export default {
|
|||||||
forget: FORGET,
|
forget: FORGET,
|
||||||
GET,
|
GET,
|
||||||
get: GET,
|
get: GET,
|
||||||
|
MERGE,
|
||||||
|
merge: MERGE,
|
||||||
MGET,
|
MGET,
|
||||||
mGet: MGET,
|
mGet: MGET,
|
||||||
MSET,
|
MSET,
|
||||||
|
Reference in New Issue
Block a user