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

fix: use [''] syntax for mongosh col calls

Browse Source
This commit is contained in:
Pavel
2025-07-29 15:31:13 +02:00
parent 9da32a13de
commit 4892dbce5e
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
plugins/dbgate-plugin-mongo/src/frontend/driver.js
View File

@@ -88,14 +88,14 @@ const driver = {
getCollectionUpdateScript(changeSet, collectionInfo) { getCollectionUpdateScript(changeSet, collectionInfo) {
let res = ''; let res = '';
for (const insert of changeSet.inserts) { for (const insert of changeSet.inserts) {
res += `db.${insert.pureName}.insertOne(${jsonStringifyWithObjectId({ res += `db['${insert.pureName}'].insertOne(${jsonStringifyWithObjectId({
...insert.document, ...insert.document,
...insert.fields, ...insert.fields,
})});\n`; })});\n`;
} }
for (const update of changeSet.updates) { for (const update of changeSet.updates) {
if (update.document) { if (update.document) {
res += `db.${update.pureName}.replaceOne(${jsonStringifyWithObjectId( res += `db['${update.pureName}'].replaceOne(${jsonStringifyWithObjectId(
update.condition update.condition
)}, ${jsonStringifyWithObjectId({ )}, ${jsonStringifyWithObjectId({
...update.document, ...update.document,
@@ -112,13 +112,13 @@ const driver = {
if (!_.isEmpty(set)) updates.$set = set; if (!_.isEmpty(set)) updates.$set = set;
if (!_.isEmpty(unset)) updates.$unset = unset; if (!_.isEmpty(unset)) updates.$unset = unset;
res += `db.${update.pureName}.updateOne(${jsonStringifyWithObjectId( res += `db['${update.pureName}'].updateOne(${jsonStringifyWithObjectId(
update.condition update.condition
)}, ${jsonStringifyWithObjectId(updates)});\n`; )}, ${jsonStringifyWithObjectId(updates)});\n`;
} }
} }
for (const del of changeSet.deletes) { for (const del of changeSet.deletes) {
res += `db.${del.pureName}.deleteOne(${jsonStringifyWithObjectId(del.condition)});\n`; res += `db['${del.pureName}'].deleteOne(${jsonStringifyWithObjectId(del.condition)});\n`;
} }
return res; return res;
}, },
@@ -128,7 +128,7 @@ const driver = {
}, },
getCollectionExportQueryScript(collection, condition, sort) { getCollectionExportQueryScript(collection, condition, sort) {
return `db.${collection} return `db['${collection}']
.find(${JSON.stringify(convertToMongoCondition(condition) || {})}) .find(${JSON.stringify(convertToMongoCondition(condition) || {})})
.sort(${JSON.stringify(convertToMongoSort(sort) || {})})`; .sort(${JSON.stringify(convertToMongoSort(sort) || {})})`;
}, },
@@ -182,9 +182,9 @@ const driver = {
async getScriptTemplateContent(scriptTemplate, props) { async getScriptTemplateContent(scriptTemplate, props) {
switch (scriptTemplate) { switch (scriptTemplate) {
case 'dropCollection': case 'dropCollection':
return `db.${props.pureName}.drop();`; return `db['${props.pureName}'].drop();`;
case 'findCollection': case 'findCollection':
return `db.${props.pureName}.find();`; return `db['${props.pureName}'].find();`;
} }
}, },
}; };