dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-18 00:56:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Implement handleSaveRedisData for Redis data types including JSON, hash, zset, and list

Browse Source
This commit is contained in:
Stela Augustinova
2025-12-19 15:16:19 +01:00
parent 8cd09342e1
commit bcff01b0bf
1 changed files with 26 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
packages/api/src/proc/databaseConnectionProcess.js
View File

@@ -379,6 +379,32 @@ async function handleSaveRedisData({ msgid, changeSet }) {
for (const change of changeSet.changes) { for (const change of changeSet.changes) {
if (change.type === 'string') { if (change.type === 'string') {
await driver.query(dbhan, `SET "${change.key}" "${change.value}"`); await driver.query(dbhan, `SET "${change.key}" "${change.value}"`);
} else if (change.type === 'json') {
await driver.query(dbhan, `JSON.SET "${change.key}" $ '${change.value.replace(/'/g, "\\'")}'`);
} else if (change.type === 'hash') {
if (change.updates && Array.isArray(change.updates)) {
for (const update of change.updates) {
await driver.query(dbhan, `HSET "${change.key}" "${update.key}" "${update.value}"`);
if (update.ttl !== undefined && update.ttl !== null && update.ttl !== -1) {
try {
await dbhan.client.call('HEXPIRE', change.key, update.ttl, 'FIELDS', 1, update.key);
} catch (e) {}
}
}
}
} else if (change.type === 'zset') {
if (change.updates && Array.isArray(change.updates)) {
for (const update of change.updates) {
await driver.query(dbhan, `ZADD "${change.key}" ${update.score} "${update.member}"`);
}
}
} else if (change.type === 'list') {
if (change.updates && Array.isArray(change.updates)) {
for (const update of change.updates) {
await driver.query(dbhan, `LSET "${change.key}" ${update.index} "${update.value}"`);
}
}
} }
} }