node.js 传递模块变量取回结果

Question

我有这个：

test.js:

getData(fetchData)

function fetchData (callback) {
  params = 'query'
  var s = require('./helpers/query')(params)
  callback(params)
}

function getData () {
  fetchData(function (params) { 
    console.log(params)
   })
}

query.js:

module.exports = function (param) {
  var queryString = {}

  var db = require('./queryDB')

  // Check key isn't in db already, key being the param
  db.get(param, function (err, value) {
    if (typeof (value) !== 'undefined') {
      console.log('ALREADY IN DB ', param)
    } else {
      // Put a search query  
      db.put(param, Date(), function (err) {
        if (err) return console.log('Ooops!', err) // some kind of I/O error
        console.log('LOGGED QUERY STRING ', param)
        return param + ' YO!'
      })
    }
  })

  return queryString
}

我希望能够传入要添加到数据库的密钥字符串并在这种情况下返回字符串 params = 'query' 我只是想用 param + ' YO!' 获取字符串所以我知道它正在工作，我做错了什么？

我需要在test.js 中进行回调吗？

更新 1 我添加了一个回调，query.js 仍然返回传递的 params 值并且不返回 param + ' YO!'

更新 2 好的，所以我现在已经承诺了，但似乎仍然无法得到结果，这是更新后的代码仍然无法正常工作

test.js

var query = require('./helpers/query')

console.log(query.searchQuery())

query.js

var ura = require('unique-random-array')
var strings = require('./strings')
var qs = ura(strings.queryString)
var qsSq = ura(strings.queryStringSubQuery)
var query = qs() + qsSq()

module.exports = {
  searchQuery: function() {
    var promise = new Promise(function(resolve, reject) {
      var db = require('./queryDB')
        // Check key isn't in db already, key being the query
      db.get(query, function(err, value) {
        if (typeof(value) !== 'undefined') {
          console.log('ALREADY IN DB', query)
          return
        }
        else {
          // Put a search query  
          db.put(query, Date(), function(err) {
            if (err) return console.log('Ooops!', err) // some kind of I/O error
            // console.log('LOGGED QUERY STRING', query)
              // return query + ' YO!'
          })
        }
      })
      resolve(query, 'all good')
    })

    promise.then(function(result) {
      // console.log(result)
      return result
    }).catch(function(err) {
      // console.error('ERR', err)
    })
  }
}

Answer 1

数据库查询可能是异步的，因此您需要在查询完成后通过某种方式进行回调。 目前，您只需触发查询并返回原始queryString。查询完成后，查询结果将被丢弃。

实现此目的的一种方法是将回调函数传递给查询助手。更清洁的解决方案可能是使用承诺。您可以在on MDN 等案例中找到有关如何使用 Promise 的更多信息。