将 Pandas 数据框写入 MySQL

Question

我正在尝试将 Python Pandas 数据框写入 MySQL 数据库。我意识到可以使用 sqlalchemy for this，但我想知道是否还有另一种可能更简单的方法，最好是已经内置在 Pandas 中。我花了相当长的时间尝试使用 For 循环来实现它，但这并不可行。

如果有人知道更好的方法，将不胜感激。

非常感谢！

Answer 1

sqlalchemy 的另一个选项可以使用 to_sql，但在未来发布将被弃用，但现在在版本 pandas 0.18.1 文档 中是仍然活跃。

根据 pandas 文档pandas.DataFrame.to_sql，您可以使用以下语法：

DataFrame.to_sql(name, con, flavor='sqlite', schema=None, if_exists='fail', index=True, index_label=None, chunksize=None, dtype=None)

你指定con type/mode和flavor 'mysql'，这里有一些描述：

con : SQLAlchemy 引擎或 DBAPI2 连接（传统模式） 使用 SQLAlchemy 可以使用该库支持的任何数据库。如果是 DBAPI2 对象，则仅支持 sqlite3。

flavor : {'sqlite', 'mysql'}, default 'sqlite' SQL 的味道 采用。使用 SQLAlchemy 引擎时忽略。 'mysql' 已弃用，并且 将在以后的版本中删除，但会进一步支持 通过 SQLAlchemy 引擎。

Answer 2

你可以使用pymysql来做到这一点：

例如，假设您有一个 MySQL 数据库，其中包含下一个用户、密码、主机和端口，并且您想要写入数据库“data_2”。

import pymysql
user = 'root'
passw = 'my-secret-pw-for-mysql-12ud'
host =  '172.17.0.2'
port = 3306
database = 'data_2'

如果您已经创建了数据库：

conn = pymysql.connect(host=host,
                       port=port,
                       user=user, 
                       passwd=passw,  
                       db=database,
                       charset='utf8')

data.to_sql(name=database, con=conn, if_exists = 'replace', index=False, flavor = 'mysql')

如果您没有创建数据库，当数据库已经存在时也有效：

conn = pymysql.connect(host=host, port=port, user=user, passwd=passw)

conn.cursor().execute("CREATE DATABASE IF NOT EXISTS {0} ".format(database))
conn = pymysql.connect(host=host,
                       port=port,
                       user=user, 
                       passwd=passw,  
                       db=database,
                       charset='utf8')

data.to_sql(name=database, con=conn, if_exists = 'replace', index=False, flavor = 'mysql')

类似的线程：

1. Writing to MySQL database with pandas using SQLAlchemy, to_sql
2. How to insert pandas dataframe via mysqldb into database?