使用SQLAlchemy写入MySQL数据库，使用SQLAlchemy，to_sql

Question

尝试使用to_sql将pandas数据框写入MySQL表。以前一直使用flavor ='mysql'，但是它将在未来贬值，并希望开始过渡到使用SQLAlchemy引擎。

示例代码：

import pandas as pd 
import mysql.connector 
from sqlalchemy import create_engine 

engine = create_engine('mysql+mysqlconnector://[user]:[pass]@[host]:[port]/[schema]', echo=False) 
cnx = engine.raw_connection() 
data = pd.read_sql('SELECT * FROM sample_table', cnx) 
data.to_sql(name='sample_table2', con=cnx, if_exists = 'append', index=False) 

读取工作正常，但to_sql有一个错误：

DatabaseError：执行失败的SQL 'SELECT名字从SQLITE_MASTER其中type =' 表” AND名字= ';'：字符串格式化过程中的参数数量错误

为什么它看起来像试图使用sqlite？什么是sqlalchemy与mysql连接的正确使用，特别是mysql.connector？

我也尝试过将引擎作为连接传递，并且给了我一个引用无游标对象的错误。

data.to_sql(name='sample_table2', con=engine, if_exists = 'append', index=False) 
>>AttributeError: 'Engine' object has no attribute 'cursor' 

Answer 1

到位raw_connection的使用引擎（）工作：

import pandas as pd 
import mysql.connector 
from sqlalchemy import create_engine 

engine = create_engine('mysql+mysqlconnector://[user]:[pass]@[host]:[port]/[schema]', echo=False) 
data.to_sql(name='sample_table2', con=engine, if_exists = 'append', index=False) 

这个是昨天给了我以前的错误

Answer 2

或者为什么当我试图不明确，使用pymysql包...

import pymysql 
from sqlalchemy import create_engine 
cnx = create_engine('mysql+pymysql://[user]:[pass]@[host]:[port]/[schema]', echo=False) 

data = pd.read_sql('SELECT * FROM sample_table', cnx) 
data.to_sql(name='sample_table2', con=cnx, if_exists = 'append', index=False) 

Answer 3

我知道问题的标题包含单词SQLAlchemy，但是我在问题和解答中看到需要导入pymysql或mysql.connector，并且也可以在不调用SQLAlchemy的情况下使用pymysql完成这项工作。

import pymysql 
user = 'root' 
passw = 'my-secret-pw-for-mysql-12ud' # In previous posts variable "pass" 
host = '172.17.0.2' 
port = 3306 

database = 'sample_table' # In previous posts similar to "schema" 

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

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

我认为这个解决方案虽然没有使用SQLAlchemy，但可能是好的。

Answer 4

使用pymysql和SQLAlchemy的，这个工程的熊猫v0.22：

import pandas as pd 
import pymysql 
from sqlalchemy import create_engine 

user = 'yourUserName' 
passw = 'password' 
host = 'hostName' # either localhost or ip e.g. '172.17.0.2' or hostname address 
port = 3306 
database = 'dataBaseName' 

mydb = create_engine('mysql+pymysql://' + user + ':' + passw + '@' + host + ':' + str(port) + '/' + database , echo=False) 

directory = r'directoryLocation' # path of csv file 
csvFileName = 'something.csv' 

df = pd.read_csv(os.path.join(directory, csvFileName)) 

df.to_sql(name=csvFileName[:-4], con=mydb, if_exists = 'replace', index=False) 

""" 
if_exists: {'fail', 'replace', 'append'}, default 'fail' 
    fail: If table exists, do nothing. 
    replace: If table exists, drop it, recreate it, and insert data. 
    append: If table exists, insert data. Create if does not exist. 
"""