可以帮我写一个Python连接Postgre数据库执行SQL将结果写入mysql库的代码么
时间: 2024-03-10 22:49:45 浏览: 171
python数据库(mysql)连接代码
当然可以,以下是一个简单的Python脚本,可以连接到PostgreSQL数据库执行SQL查询,并将结果写入到MySQL数据库中:
```python
import psycopg2
import mysql.connector
# PostgreSQL数据库连接信息
pg_host = "localhost"
pg_port = "5432"
pg_database = "mydatabase"
pg_user = "myuser"
pg_password = "mypassword"
# MySQL数据库连接信息
mysql_host = "localhost"
mysql_port = "3306"
mysql_database = "mydatabase"
mysql_user = "myuser"
mysql_password = "mypassword"
# 连接到PostgreSQL数据库
pg_conn = psycopg2.connect(
host=pg_host,
port=pg_port,
database=pg_database,
user=pg_user,
password=pg_password
)
# 创建PostgreSQL数据库游标
pg_cursor = pg_conn.cursor()
# 执行SQL查询语句
pg_cursor.execute("SELECT * FROM mytable")
# 获取查询结果
results = pg_cursor.fetchall()
# 连接到MySQL数据库
mysql_conn = mysql.connector.connect(
host=mysql_host,
port=mysql_port,
database=mysql_database,
user=mysql_user,
password=mysql_password
)
# 创建MySQL数据库游标
mysql_cursor = mysql_conn.cursor()
# 将查询结果写入MySQL数据库
for result in results:
mysql_cursor.execute("INSERT INTO mytable VALUES (%s, %s, %s)", result)
# 提交MySQL数据库事务
mysql_conn.commit()
# 关闭数据库连接
pg_conn.close()
mysql_conn.close()
```
在以上脚本中,我们使用了`psycopg2`库来连接到PostgreSQL数据库,并使用`mysql-connector-python`库来连接到MySQL数据库。我们首先连接到PostgreSQL数据库,然后执行SQL查询语句,获取查询结果后,再连接到MySQL数据库,将查询结果写入MySQL数据库中。
需要注意的是,以上脚本只是一个简单的示例,需要根据实际情况进行修改。例如,需要根据实际的表结构、字段名称等来编写SQL查询语句和插入语句。同时,还需要根据实际的数据库连接信息和权限来修改连接参数和授权信息。
阅读全文