可以帮我写一个Python连接Postgre数据库执行SQL将结果写入mysql库的代码么
时间: 2024-03-12 20:48:33 浏览: 66
python数据库(mysql)连接代码
当然可以,以下是一个示例代码:
```python
import psycopg2
import mysql.connector
# PostgreSQL 数据库配置
pg_config = {
"host": "localhost",
"database": "postgres",
"user": "postgres",
"password": "password"
}
# MySQL 数据库配置
mysql_config = {
"host": "localhost",
"database": "test",
"user": "root",
"password": "password"
}
# 连接 PostgreSQL 数据库
pg_conn = psycopg2.connect(**pg_config)
pg_cursor = pg_conn.cursor()
# 执行 SQL 查询
pg_cursor.execute("SELECT * FROM my_table")
# 获取查询结果
results = pg_cursor.fetchall()
# 连接 MySQL 数据库
mysql_conn = mysql.connector.connect(**mysql_config)
mysql_cursor = mysql_conn.cursor()
# 写入 MySQL 数据库
mysql_cursor.executemany("INSERT INTO my_table VALUES (%s, %s)", results)
# 提交事务并关闭连接
mysql_conn.commit()
mysql_conn.close()
pg_conn.close()
```
上面的代码示例中,我们使用 `psycopg2` 库连接到 PostgreSQL 数据库,并执行一个查询语句获取结果。
然后,我们使用 `mysql.connector` 库连接到 MySQL 数据库,并使用 `executemany()` 方法将查询结果插入 MySQL 数据库中。最后,我们提交事务并关闭数据库连接。
请注意,此代码示例仅用于演示目的。在实际使用时,您应该确保您的代码中包含适当的错误处理和安全性措施。
阅读全文