Просто быстрый вопрос, ребята: я создал базу данных в mysql (мнения):
mysql> show databases;
+--------------------+
| Database |
+--------------------+
| information_schema |
| mysql |
| opinions |
| performance_schema |
| sys |
+--------------------+
5 rows in set (0.06 sec)
У меня также есть кадр данных pandas df
:
import pandas as pd
df = pd.read_csv('file.csv', sep='|', names=['id', 'opinions'])
df.head(3)
Вне:
id content
0 id1 'blablababla
1 id2 'blalbabla
...
n idn 'blalbabl
Затем я хотел бы загрузить df
в виде таблицы (items
) в базу данных opinions
. Вот что я пробовал:
import mysql.connector
from sqlalchemy import create_engine
engine = create_engine('mysql+mysqlconnector://user:password@localhost:3306/opinions', echo=False)
df.to_sql(name='items', con=engine, if_exists = 'replace', index=False)
df
Однако я получил это исключение:
OperationalError: (mysql.connector.errors.OperationalError) 2055: Lost connection to MySQL server at 'localhost:3306', system error: 32 Broken pipe
Как мне загрузить или записать таблицу df
в базу данных opinions
?
cnx = pymysql.connect(user='user', password='pw', host= '127.0.0.1', port=3306, db='mydb', autocommit=True) df=psql.read_sql_query('call sproc', con=cnx)
- person jezrael   schedule 07.06.2016OperationalError: (1045, "Access denied for user 'user'@'localhost' (using password: YES)")
- person tumbleweed   schedule 07.06.2016items
. Я просто хочу научиться писать это.... Это всего лишь пример, это не настоящий случай @Merlin - person tumbleweed   schedule 07.06.2016