R语言操作mongdb各方法集合

tangbinde

#1 mongo.create
mongo <- mongo.create()
## Not run:
mongo <- mongo.create("192.168.30.170")
## End(Not run)

#2 mongo.is.connected mongo.count(mongo, "xrk-advisory.advisories")
mongo <- mongo.create("192.168.30.170")
if (mongo.is.connected(mongo)) {
  print(mongo.count(mongo, "xrk-advisory.advisories"))
}

#3 mongo.disconnect
mongo <- mongo.create("192.168.30.170")
if (mongo.is.connected(mongo)) {
  n_people <- mongo.count(mongo, "guohui.mip")
  mongo.disconnect(mongo)
}

#4 mongo.reconnect
if (mongo.is.connected(mongo))
  mongo.reconnect(mongo)

#5 mongo.get.err
mongo.disconnect(mongo)
if (!mongo.is.connected(mongo)) {
  print("Unable to connect.  Error code:")
  print(mongo.get.err(mongo))
}

#6 mongo.get.primary :get the host
mongo <- mongo.create(c("127.0.0.1", "192.168.30.170"))
if (mongo.is.connected(mongo)) {
  print(mongo.get.primary(mongo))
}

#7 mongo.get.hosts:Get a lists of hosts
## Not run:
mongo <- mongo.create(c("127.0.0.1", "192.168.30.170"), name="xrk-advisory")
if (mongo.is.connected(mongo))
  print(mongo.get.hosts(mongo))

## End(Not run)

#8 mongo.get.socket：Get the the low-level socket number assigned to the given mongo object by mongo.create().
mongo <- mongo.create("192.168.30.170")
if (mongo.is.connected(mongo))
  print(mongo.get.socket(mongo))

#9 mongo.get.timeout:Set the timeout value for network operations on a mongo connection.
mongo <- mongo.create("192.168.30.170")
if (mongo.is.connected(mongo)) {
  mongo.set.timeout(mongo, 2000L)
  timeout <- mongo.get.timeout(mongo)
  if (timeout != 2000L)
    error("expected timeout of 2000");
}

#10 mongo.get.databases
mongo <- mongo.create()
if (mongo.is.connected(mongo)) {
  print(mongo.get.databases(mongo))
  
  mongo.destroy(mongo)
}

#11 mongo.get.database.collections,
mongo <- mongo.create()
if (mongo.is.connected(mongo)) {
  print(mongo.get.database.collections(mongo, "guohui"))   #列出表列表
   mongo.destroy(mongo)
}