mysql结合mongodb场景

import mysql.connector
from pymongo import MongoClient

# 连接MySQL数据库
mysql_conn = mysql.connector.connect(user='user', password='password', host='host', database='database')
mysql_cursor = mysql_conn.cursor()

# 连接MongoDB数据库
mongo_client = MongoClient('mongodb://localhost:27017/')
mongo_db = mongo_client['database']
mongo_collection = mongo_db['collection']

def add_user(user_data):
    try:
        # 在MySQL中插入用户数据
        mysql_cursor.execute("INSERT INTO users (name, email) VALUES (%s, %s)", (user_data['name'], user_data['email']))
        mysql_conn.commit()

        # 在MongoDB中插入用户数据
        mongo_collection.insert_one(user_data)

        print("User added successfully.")
    except Exception as e:
        print(f"Error adding user: {e}")
        mysql_conn.rollback()

# 示例用户数据
user_data = {
    'name': 'John Doe',
    'email': 'john.doe@example.com'
}

add_user(user_data)