Python代码:利用pyodc实现从一个MySQL数据库中按照筛选条件导出数据并另存到另一个MySQL数据库中
时间: 2024-03-16 08:47:36 浏览: 86
以下是一份示例代码,使用pyodbc连接MySQL数据库并从中筛选数据,并将所选数据插入到另一个MySQL数据库中:
```python
import pyodbc
# 连接源数据库
source_conn = pyodbc.connect('DRIVER={MySQL ODBC 8.0 Unicode Driver};'
'SERVER=source_server_address;'
'DATABASE=source_database_name;'
'UID=source_username;'
'PWD=source_password;'
'PORT=source_port;')
# 连接目标数据库
target_conn = pyodbc.connect('DRIVER={MySQL ODBC 8.0 Unicode Driver};'
'SERVER=target_server_address;'
'DATABASE=target_database_name;'
'UID=target_username;'
'PWD=target_password;'
'PORT=target_port;')
# 设置筛选条件
# 这里只是一个示例,实际应用中需要根据具体情况设置
filter_condition = "WHERE column1='value1' AND column2='value2'"
# 从源数据库中查询数据
source_cursor = source_conn.cursor()
source_cursor.execute(f"SELECT * FROM source_table {filter_condition}")
selected_data = source_cursor.fetchall()
# 将数据插入到目标数据库中
target_cursor = target_conn.cursor()
for row in selected_data:
# 这里需要根据目标数据库中表的具体情况来设置插入语句
target_cursor.execute(f"INSERT INTO target_table (column1, column2, ...) VALUES (?, ?, ...)", row)
# 提交事务
target_conn.commit()
# 关闭连接
source_conn.close()
target_conn.close()
```
需要注意的是,上述代码仅供参考,实际应用中需要根据具体情况做出相应的修改。同时,还需要根据实际情况安装MySQL ODBC驱动程序。
阅读全文