import pymongo

# MongoDB connection details
mongo_url = "mongodb://localhost:27017/"
db_name = "steam"
collection_name = "Items"

# Save data in the database
def save_data(data):
    client = pymongo.MongoClient(mongo_url)
    # print(client.list_database_names())
    db = client[db_name]
    collection = db[collection_name]
    documents = collection.find()
    for item in data:
        item["_id"] = item["name"]  # Set the item name as the _id
        # Check if the item already exists in the database
        if collection.count_documents({"_id": item["_id"]}) == 0:
            collection.insert_one(item)
        else:
            collection.update_one({"_id": item["_id"]}, {"$set": item})
    client.close()

# Select all documents from the "Items" table
def select_all():
    client = pymongo.MongoClient(mongo_url)
    db = client[db_name]
    collection = db[collection_name]
    documents = collection.find()
    for document in documents:
        print(document)
    client.close()

# Example usage
# data = [
#     {"name": "item1", "price": 56},
#     {"name": "item2", "price": 20},
#     {"name": "item4", "price": 30}
# ]

# save_data(data)
# select_all()