snippets_py
Integration
New integration from credential
mongodb_client = yepcode.integration.mongodb('credential-slug')
New integration from plain authentication data
from pymongo import MongoClient
mongodb_client = MongoClient(
"mongodb://yourhost:27017/",
username="username",
password="password",
tls=False,
)
Insert a Document
Insert a document
db = mongodb_client["your_database_name"]
collection = db["your_collection_name"]
document = {
"name": "John",
"age": 30,
"city": "New York"
}
collection.insert_one(document)
Insert Multiple Documents
Insert multiple documents
db = mongodb_client["your_database_name"]
collection = db["your_collection_name"]
documents = [
{"name": "John", "age": 30},
{"name": "Jane", "age": 25},
{"name": "Alex", "age": 35},
]
result = collection.insert_many(documents)
print(result.inserted_ids)
Find a Document
Find a document
db = mongodb_client["your_database_name"]
collection = db["your_collection_name"]
query = {"name": "John"}
result = collection.find_one(query)
print(result)
Find Multiple Documents
Find multiple documents
db = mongodb_client["your_database_name"]
collection = db["your_collection_name"]
query = {"age": {"$gt": 25}}
docs = collection.find(query)
for doc in docs:
print(doc)
Update a Single Document
Update a single document
db = mongodb_client["your_database_name"]
collection = db["your_collection_name"]
filter_query = {"name": "John"}
update_query = {"$set": {"age": 32}}
collection.update_one(filter_query, update_query)
Update Multiple Documents
Update multiple documents
db = mongodb_client["your_database_name"]
collection = db["your_collection_name"]
filter_query = {"age": {"$eq": 30}}
update_query = {"$inc": {"age": 5}}
result = collection.update_many(filter_query, update_query)
print("Modified %d documents", result.modified_count)
Delete One Document
Delete one document
db = mongodb_client["your_database_name"]
collection = db["your_collection_name"]
query = {"name": "John"}
collection.delete_one(query)
Delete Multiple Documents
Delete multiple documents
db = mongodb_client["your_database_name"]
collection = db["your_collection_name"]
query = {"age": {"$gt": 30}}
result = collection.delete_many(query)
print("Deleted %d documents", result.modified_count)