草庐IT

node.js - 在 Node 中重用 MongoDB 连接

coder 2023-11-04 原文

这是我得到的错误:[错误:db 对象已经连接,不能多次调用 open]。我在这个誓言测试中有一个全局 mongo 对象。

mongo = new mongo.Db(config.api.apiTest, new mongo.Server('localhost', 27017, {}), {native_parser: off, safe: true})

当我第二次尝试打开它时出现此错误。

所以即使我第一次使用 db.close() 它似乎也没有关闭。是否有另一种重用连接的方法?

.addBatch(
  "Redis - ":
    "Standard account - ":
      topic: ->

        # .
        redisClient.del "#{ accountId }:900"

        mongo.open (error, db) =>
          secondDb = db.db config.api.accountTest

          secondDb.collection 'accounts', (error, accountsColl) =>
            accountsColl.update {'accountId': ObjectID(accountId)}, { "$unset": {'permission': ''}}, (error, records) =>
              console.log "Unset? " + records
              db.close()
          db.close()


        inventory = nock('http://inventory.honshuu.vgrnt:80')
            .get("/devices/?accountId=#{ accountId }&userId=#{ userId }")
            .reply(200, 'OK')

        httpRequest.get 'http://127.0.0.1:18091/inventory/devices/?token=testtoken', @callback
        return

      "Ratelimit is applied correctly":
        (error, response, body) ->
          accountLimit = response.headers['x-ratelimit-limit']
          assert.equal response.headers['x-ratelimit-remaining'], 240-1
          assert.equal response.headers['x-ratelimit-reset'], 900

    "account":
      topic: ->
        # Need to fetch permission in db.
        # redisClient.del "permission-#{ accountId }", (error, result) =>
        #   console.log "removes"
        #   console.log result

        inventory = nock('http://inventory.honshuu.vgrnt:80')
          .get("/devices/?accountId=#{ accountId }&userId=#{ userId }")
          .reply(200, 'OK')

        mongo.open (error, db) =>
          secondDb = db.db config.api.accountTest
          console.log secondDb

          secondDb.collection 'accounts', (error, accountsColl) =>
            accountsColl.update {'accountId': ObjectID(accountId)}, { 'permission': 1000}, (error, records) =>
              console.log "updated? " + records
              httpRequest.get 'http://127.0.0.1:18091/inventory/devices/?token=testtoken', @callback
              return

        return

      "account has more rate tokens":
        (error, response, body) ->
          console.log response
          console.log error
          # accountLimit = response.headers['x-ratelimit-limit']
          # assert.equal response.headers['x-ratelimit-remaining'], 1000-1
          # assert.equal response.headers['x-ratelimit-reset'], 900
          # assert.equal response.headers['x-ratelimit-limit'], 1000
)

最佳答案

就像 Node 中的大多数东西一样,db.close 是异步的并接受回调。您需要传递回调或对其进行 promise 并返回 promise 。您的下一个连接调用应该只在您确定数据库连接已关闭时完成,并且您只能通过处理回调知道这一点。

db.close(function (err) {
  if (err) return console.error('OH NOES, AN ERROR:', err);
  console.log('SUCCESS!');
  // db is now closed, do whatevs
});

关于node.js - 在 Node 中重用 MongoDB 连接,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30650424/

有关node.js - 在 Node 中重用 MongoDB 连接的更多相关文章

  1. ruby - 续集在添加关联时访问many_to_many连接表 - 2

    我正在使用Sequel构建一个愿望list系统。我有一个wishlists和itemstable和一个items_wishlists连接表(该名称是续集选择的名称)。items_wishlists表还有一个用于facebookid的额外列(因此我可以存储opengraph操作),这是一个NOTNULL列。我还有Wishlist和Item具有续集many_to_many关联的模型已建立。Wishlist类也有:selectmany_to_many关联的选项设置为select:[:items.*,:items_wishlists__facebook_action_id].有没有一种方法可以

  2. ruby - 无法在 60 秒内获得稳定的 Firefox 连接 (127.0.0.1 :7055) - 2

    我使用的是Firefox版本36.0.1和Selenium-Webdrivergem版本2.45.0。我能够创建Firefox实例,但无法使用脚本继续进行进一步的操作无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)错误。有人能帮帮我吗? 最佳答案 我遇到了同样的问题。降级到firefoxv33后一切正常。您可以找到旧版本here 关于ruby-无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055),我们在StackOverflow上找到一个类

  3. ruby - 我的 Ruby IRC 机器人没有连接到 IRC 服务器。我究竟做错了什么? - 2

    require"socket"server="irc.rizon.net"port="6667"nick="RubyIRCBot"channel="#0x40"s=TCPSocket.open(server,port)s.print("USERTesting",0)s.print("NICK#{nick}",0)s.print("JOIN#{channel}",0)这个IRC机器人没有连接到IRC服务器,我做错了什么? 最佳答案 失败并显示此消息::irc.shakeababy.net461*USER:Notenoughparame

  4. ruby-on-rails - 连接字符串时如何在 <%=%> block 内输出 html_safe? - 2

    考虑一下:现在这些情况:#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2#output:http://domain.com/?foo=1&bar=2我需要用其他字符串输出URL。我如何保证&符号不会被转义?由于我无法控制的原因,我无法发送&。求助!把我的头发拉到这里:\编辑:为了澄清,我实际上有一个像这样的数组:@images=[{:id=>"fooid",:url=>"http://

  5. ruby - Faye WebSocket,关闭处理程序被触发后重新连接到套接字 - 2

    我有一个super简单的脚本,它几乎包含了FayeWebSocketGitHub页面上用于处理关闭连接的内容:ws=Faye::WebSocket::Client.new(url,nil,:headers=>headers)ws.on:opendo|event|p[:open]#sendpingcommand#sendtestcommand#ws.send({command:'test'}.to_json)endws.on:messagedo|event|#hereistheentrypointfordatacomingfromtheserver.pJSON.parse(event.d

  6. ruby-on-rails - 什么会导致与 APNS 的连接间歇性断开连接? - 2

    我有一个ruby​​脚本可以打开与Apple推送服务器的连接并发送所有待处理的通知。我看不出任何原因,但当Apple断开我的脚本时,我遇到了管道损坏错误。我已经编写了我的脚本来适应这种情况,但我宁愿只是找出它发生的原因,这样我就可以在第一时间避免它。它不会始终根据特定通知断开连接。它不会以特定的字节传输大小断开连接。一切似乎都是零星的。您可以在单个连接上发送的数据传输或有效负载计数是否有某些限制?看到人们的解决方案始终保持一个连接打开,我认为这不是问题所在。我看到连接在3次通知后断开,我看到它在14次通知后断开。我从未见过它能超过14点。有没有人遇到过这种类型的问题?如何处理?

  7. ruby - 如何断开现有的 ruby​​ 续集与数据库的连接? - 2

    我的意思是之前建立的那个DB=Sequel.sqlite('my_blog.db')或DB=Sequel.connect('postgres://user:password@localhost/my_db')或DB=Sequel.postgres('my_db',:user=>'user',:password=>'password',:host=>'localhost')等等。Sequel::Database类没有名为“disconnect”的公共(public)实例方法,尽管它有一个“connect”。也许有人已经遇到过这个问题。我将不胜感激。 最佳答案

  8. ruby-on-rails - Assets 管道损坏 : Not compiling on the fly css and js files - 2

    我开始了一个新的Rails3.2.5项目,Assets管道不再工作了。CSS和Javascript文件不再编译。这是尝试生成Assets时日志的输出:StartedGET"/assets/application.css?body=1"for127.0.0.1at2012-06-1623:59:11-0700Servedasset/application.css-200OK(0ms)[2012-06-1623:59:11]ERRORNoMethodError:undefinedmethod`each'fornil:NilClass/Users/greg/.rbenv/versions/1

  9. ruby-on-rails - Rails - 理解 application.js 和 application.css - 2

    rails新手。只是想了解\assests目录中的这两个文件。例如,application.js文件有如下行://=requirejquery//=requirejquery_ujs//=require_tree.我理解require_tree。只是将所有JS文件添加到当前目录中。根据上下文,我可以看出requirejquery添加了jQuery库。但是它从哪里得到这些jQuery库呢?我没有在我的Assets文件夹中看到任何jquery.js文件——或者直接在我的整个应用程序中没有看到任何jquery.js文件?同样,我正在按照一些说明安装TwitterBootstrap(http:

  10. ruby-on-rails - 遗留数据库的 ActiveRecord 连接表 - 2

    我有一个遗留数据库,我正在努力让ActiveRecord使用它。我遇到了连接表的问题。我有以下内容:classTvShow然后我有一个名为tvshowlinkepisode的表,它有2个字段:idShow、idEpisode所以我有2个表和它们之间的连接(多对多关系),但是连接使用非标准外键。我的第一个想法是创建一个名为TvShowEpisodeLink的模型,但没有主键。我的想法是,由于外键是非标准的,我可以使用set_foreign_key并进行一些控制。最后,我想说一些类似TvShow.find(:last).episodes或Episode.find(:last).tv_sho

随机推荐