mongolite

mongolite

MongoDB client for R.

Connection

library(mongolite)

# Connect to local MongoDB
con <- mongo(collection = "mycollection", db = "mydb")

# Connect with URI
con <- mongo(
  collection = "mycollection",
  db = "mydb",
  url = "mongodb://user:password@host:27017"
)

# With options
con <- mongo(
  collection = "mycollection",
  db = "mydb",
  url = "mongodb://localhost",
  options = ssl_options()
)

Insert

# Insert data frame
con$insert(df)

# Insert single document
con$insert('{"name": "John", "age": 30}')

# Insert multiple documents
con$insert(list(
  list(name = "John", age = 30),
  list(name = "Jane", age = 25)
))

Query

# Find all
df <- con$find()

# Find with query
df <- con$find('{"age": {"$gt": 25}}')

# Select fields
df <- con$find(fields = '{"name": 1, "age": 1, "_id": 0}')

# Sort
df <- con$find(sort = '{"age": -1}')

# Limit
df <- con$find(limit = 10)

# Skip (pagination)
df <- con$find(skip = 10, limit = 10)

# Combined
df <- con$find(
  query = '{"status": "active"}',
  fields = '{"name": 1, "email": 1}',
  sort = '{"created": -1}',
  limit = 100
)

Update

# Update one
con$update('{"name": "John"}', '{"$set": {"age": 31}}')

# Update many
con$update('{"status": "pending"}', '{"$set": {"status": "active"}}', multiple = TRUE)

# Upsert
con$update('{"name": "New"}', '{"$set": {"age": 20}}', upsert = TRUE)

# Replace document
con$replace('{"name": "John"}', '{"name": "John", "age": 32, "city": "NYC"}')

Delete

# Remove one
con$remove('{"name": "John"}', just_one = TRUE)

# Remove many
con$remove('{"status": "inactive"}')

# Remove all
con$remove('{}')

# Drop collection
con$drop()

Aggregation

# Aggregation pipeline
result <- con$aggregate('[
  {"$match": {"status": "active"}},
  {"$group": {"_id": "$category", "count": {"$sum": 1}}},
  {"$sort": {"count": -1}}
]')

# With multiple stages
result <- con$aggregate('[
  {"$match": {"date": {"$gte": {"$date": "2024-01-01"}}}},
  {"$project": {"year": {"$year": "$date"}, "amount": 1}},
  {"$group": {"_id": "$year", "total": {"$sum": "$amount"}}}
]')