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

Merge pull request #1307 from dbgate/feature/redis-gui-refactor

Browse Source 
Feature/redis gui refactor
This commit is contained in:
Jan Prochazka
2025-12-29 15:18:32 +01:00
committed by GitHub
parent 46a52e2b2f 3078e3584c
commit def2dadca1
22 changed files with 1812 additions and 114 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
packages/api/src/controllers/databaseConnections.js
View File

@@ -494,6 +494,20 @@ module.exports = {
return res.result || null;
},
saveRedisData_meta: true,
async saveRedisData({ conid, database, changeSet }, req) {
await testConnectionPermission(conid, req);
const opened = await this.ensureOpened(conid, database);
const res = await this.sendRequest(opened, { msgtype: 'saveRedisData', changeSet });
if (res.errorMessage) {
return {
errorMessage: res.errorMessage,
};
}
return res.result || null;
},
status_meta: true,
async status({ conid, database }, req) {
if (!conid) {

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

@@ -368,6 +368,90 @@ async function handleSaveTableData({ msgid, changeSet }) {
}
}
async function handleSaveRedisData({ msgid, changeSet }) {
try {
const driver = requireEngineDriver(storedConnection);
if (!changeSet || !changeSet.changes || !Array.isArray(changeSet.changes)) {
throw new Error('Invalid changeSet structure');
}
for (const change of changeSet.changes) {
if (change.type === 'string') {
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) {}
}
}
}
if (change.inserts && Array.isArray(change.inserts)) {
for (const insert of change.inserts) {
await driver.query(dbhan, `HSET "${change.key}" "${insert.key}" "${insert.value}"`);
if (insert.ttl !== undefined && insert.ttl !== null && insert.ttl !== -1) {
try {
await dbhan.client.call('HEXPIRE', change.key, insert.ttl, 'FIELDS', 1, insert.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}"`);
}
}
if (change.inserts && Array.isArray(change.inserts)) {
for (const insert of change.inserts) {
await driver.query(dbhan, `ZADD "${change.key}" ${insert.score} "${insert.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}"`);
}
}
if (change.inserts && Array.isArray(change.inserts)) {
for (const insert of change.inserts) {
await driver.query(dbhan, `RPUSH "${change.key}" "${insert.value}"`);
}
}
} else if (change.type === 'set') {
if (change.inserts && Array.isArray(change.inserts)) {
for (const insert of change.inserts) {
await driver.query(dbhan, `SADD "${change.key}" "${insert.value}"`);
}
}
} else if (change.type === 'stream') {
if (change.inserts && Array.isArray(change.inserts)) {
for (const insert of change.inserts) {
const streamId = insert.id === '*' || !insert.id ? '*' : insert.id;
await driver.query(dbhan, `XADD "${change.key}" ${streamId} value "${insert.value}"`);
}
}
}
}
process.send({ msgtype: 'response', msgid });
} catch (err) {
process.send({
msgtype: 'response',
msgid,
errorMessage: extractErrorMessage(err, 'Error saving Redis data'),
});
}
}
async function handleSqlPreview({ msgid, objects, options }) {
await waitStructure();
const driver = requireEngineDriver(storedConnection);
@@ -501,6 +585,7 @@ const messageHandlers = {
schemaList: handleSchemaList,
executeSessionQuery: handleExecuteSessionQuery,
evalJsonScript: handleEvalJsonScript,
saveRedisData: handleSaveRedisData,
// runCommand: handleRunCommand,
};