restore query sql

Author: Percocco

Minio-SQL-connector/api/controllers/controller.js

@@ -6,6 +6,7 @@ const logger = new Logger("controller")
 
 
 const queryMongo = async (req, res) => {
+    logger.info(req.body, req.query)
     if (req.headers.israwquery)
         return await res.send(await service.rawQuery(req.query, req.body.prefix, req.body.bucketName, req.headers.visibility)) && logger.info("Raw query finished")
     logger.info("Query mongo")

Minio-SQL-connector/api/services/service.js

@@ -43,7 +43,7 @@ async function sync() {
                 let index = 1
                 for (let obj of bucketObjects) {
                     try {
-                        await sleep(delays)
+                        //await sleep(delays)
                         logger.debug("Bucket ", bucketIndex, " of ", buckets.length)
                         logger.debug("Scanning object ", index++, " of ", bucketObjects.length, ",", obj.name)
                         let extension = obj.name.split(".").pop()

Minio-SQL-connector/config.template.js

@@ -21,6 +21,7 @@ module.exports = {
     password: '',
     port: 5432
   },
+  logLevel: "info",
   syncInterval : 86400000,
   doNotSyncAtStart : false,
   delays : 1,

Minio-SQL-connector/utils/common.js

@@ -278,10 +278,10 @@ module.exports = {
   },
 
   bodyCheck: async (req, res, next) => {
-    if (req?.body?.mongoQuery && (
-      Object.keys(req?.body?.mongoQuery).length == 1 && req.body.mongoQuery[''] == '' ||
-      req.body.mongoQuery[''] == '{"$gte":null,"$lte":null}') || !req.body || !req.body.mongoQuery)
-      req.body.mongoQuery = req.query
+    if(req?.body?.mongoQuery && req.body.mongoQuery[''] == '{"$gte":null,"$lte":null}')
+      delete req.body.mongoQuery['']
+    if (!req.body.query && req?.body?.mongoQuery && !(Object.keys(req?.body?.mongoQuery).length == 1 && req.body.mongoQuery[''] == ''))
+      //req.body ? req.body.mongoQuery = req.query : req.body = { mongoQuery: req.query }
     objectCheck([req.body.mongoQuery, req.query])
     next()
   }

Minio-SQL-connector/utils/minioWriter.js

@@ -428,7 +428,7 @@ module.exports = {
 
   async getObject(bucketName, objectName, format) {
 
-    log("Now getting object " + objectName + " in bucket " + bucketName)
+    logger.trace("Now getting object " + objectName + " in bucket " + bucketName)
 
     let resultMessage
     let errorMessage