我试图加载一个python Dataframe 到mysql。它返回错误“处理格式参数失败; Python“timestamp”无法转换为MySQL类型“”。我不知道是关于什么的。
import pandas as pd
from datetime import date
import mysql.connector
from mysql.connector import Error
def priceStock(tickers):
today = pd.to_datetime("today").strftime("%Y-%m-%d")
for ticker in tickers:
conn = mysql.connector.connect(host='103.200.22.212', database='analysis_stock', user='analysis_PhamThiLinhChi', password='Phamthilinhchi')
new_record = stock_historical_data(ticker, '2018-01-01', today)
new_record.insert(0, 'ticker', ticker)
table = 'priceStock'
cursor = conn.cursor()
#loop through the data frame
for i,row in new_record.iterrows():
#here %s means string values
sql = "INSERT INTO " + table + " VALUES (%s,%s,%s,%s,%s,%s,%s)"
#đoán chắc là do format time từ python sang sql ko khớp
cursor.execute(sql, tuple(row))
print("Record inserted")
# the connection is not auto committed by default, so we must commit to save our changes
conn.commit()
priceStock(['VIC'])
1条答案
按热度按时间elcex8rz1#
而不是一次循环和插入一行,您可以使用to_sql一次性加载整个数据框to_sql使用SQLAlchemy并且SQLAlchemy支持MySQL,因此下面的代码应该可以工作
要查看更新的行,请使用以下代码: