如何使用 mysql 连接器创建 sql 连接以通过 df.to_sql() 写入数据库
how to create sql connection using mysql connector to write to database via df.to_sql()
是否可以使用 mySql 连接器而不是 sqlalchemy 创建引擎?大多数时候人们使用 sqlalchemy 创建一个引擎,然后使用它使用 to_sql.
写入数据库
engine = create_engine("mysql+pymysql://{user}:{pw}@localhost/{db}"
.format(user="user",
pw="Password",
db="dbname"))
df.to_sql(con=engine, name='Summary', if_exists='replace', index=False)
这是不可能的。 df.to_sql 需要一个 SQLAlchemy 引擎作为连接:
con: sqlalchemy.engine.(Engine or Connection) or sqlite3.Connection
Using SQLAlchemy makes it possible to use any DB supported by that
library. Legacy support is provided for sqlite3.Connection objects.
如果您愿意,可以使用 MySQL 连接器作为引擎的连接方言:
engine = create_engine("mysql+mysqlconnector://{user}:{pw}@localhost/{db}"
.format(user="user",
pw="Password",
db="dbname"))
是否可以使用 mySql 连接器而不是 sqlalchemy 创建引擎?大多数时候人们使用 sqlalchemy 创建一个引擎,然后使用它使用 to_sql.
写入数据库 engine = create_engine("mysql+pymysql://{user}:{pw}@localhost/{db}"
.format(user="user",
pw="Password",
db="dbname"))
df.to_sql(con=engine, name='Summary', if_exists='replace', index=False)
这是不可能的。 df.to_sql 需要一个 SQLAlchemy 引擎作为连接:
con: sqlalchemy.engine.(Engine or Connection) or sqlite3.Connection
Using SQLAlchemy makes it possible to use any DB supported by that library. Legacy support is provided for sqlite3.Connection objects.
如果您愿意,可以使用 MySQL 连接器作为引擎的连接方言:
engine = create_engine("mysql+mysqlconnector://{user}:{pw}@localhost/{db}"
.format(user="user",
pw="Password",
db="dbname"))