无法通过 python 将 CSV 文件的行插入到 MYSQL 数据库中

Question

我需要读取一个 CSV 文件，其中包含每个国家/地区每天的感染人数，然后使用 python 将这些行插入到 MYSQL 数据库中。我已经创建了数据库，它包含与 CSV 文件相同数量的列。当我尝试运行下面的代码时，我收到以下错误消息："ValueError: Could not process parameters"。你能看看他的代码是否有问题并告诉我吗？非常感谢！

import pandas as pd
import mysql.connector


mydb = mysql.connector.connect(
  host="127.0.0.1",
  user="root",
  passwd="xxxx",
  database="covid19_ca"
)

mycursor = mydb.cursor()

dataframe = pd.read_csv('total_cases_modified.csv')
print(dataframe)

for row in dataframe:
    mycursor.execute('INSERT INTO covid_per_day_per_country (date, World, Afghanistan) VALUES("%s", "%s", "%s"")', row)    
    mydb.commit()
    cursor.close()

for _, row in dataframe.iterrows():
    values = (row['date'], row['World'], row['Afghanistan'], row['Albania'], row['Algeria'], row['Andorra'], row['Angola'], row['Anguilla'], row['AntiguaAndBarbuda'], row['Argentina'], row['Armenia'], row['Aruba'], row['Australia'], row['Austria'], row['Azerbaijan'], row['Bahamas'], row['Bahrain'], row['Bangladesh'], row['Barbados'], row['Belarus'], row['Belgium'], row['Belize'], row['Benin'], row['Bermuda'], row['Bhutan'], row['Bolivia'], row['BonaireSintEustatiusAndSaba'], row['BosniaAndHerzegovina'], row['Botswana'], row['Brazil'], row['BritishVirginIslands'], row['Brunei'], row['Bulgaria'], row['BurkinaFaso'], row['Burundi'], row['Cambodia'], row['Cameroon'], row['Canada'], row['CapeVerde'], row['CaymanIslands'], row['CentralAfricanRepublic'], row['Chad'], row['Chile'], row['China'], row['Colombia'], row['Comoros'], row['Congo'], row['CostaRica'], row['CotedIvoire'], row['Croatia'], row['Cuba'], row['Curacao'], row['Cyprus'], row['CzechRepublic'], row['DemocraticRepublicCongo'], row['Denmark'], row['Djibouti'], row['Dominica'], row['DominicanRepublic'], row['Ecuador'], row['Egypt'], row['ElSalvador'], row['EquatorialGuinea'], row['Eritrea'], row['Estonia'], row['Ethiopia'], row['FaeroeIslands'], row['FalklandIslands'], row['Fiji'], row['Finland'], row['France'], row['FrenchPolynesia'], row['Gabon'], row['Gambia'], row['Georgia'], row['Germany'], row['Ghana'], row['Gibraltar'], row['Greece'], row['Greenland'], row['Grenada'], row['Guam'], row['Guatemala'], row['Guernsey'], row['Guinea'], row['GuineaBissau'], row['Guyana'], row['Haiti'], row['Honduras'], row['Hungary'], row['Iceland'], row['India'], row['Indonesia'], row['International'], row['Iran'], row['Iraq'], row['Ireland'], row['IsleofMan'], row['Israel'], row['Italy'], row['Jamaica'], row['Japan'], row['Jersey'], row['Jordan'], row['Kazakhstan'], row['Kenya'], row['Kosovo'], row['Kuwait'], row['Kyrgyzstan'], row['Laos'], row['Latvia'], row['Lebanon'], row['Lesotho'], row['Liberia'], row['Libya'], row['Liechtenstein'], row['Lithuania'], row['Luxembourg'], row['Macedonia'], row['Madagascar'], row['Malawi'], row['Malaysia'], row['Maldives'], row['Mali'], row['Malta'], row['Mauritania'], row['Mauritius'], row['Mexico'], row['Moldova'], row['Monaco'], row['Mongolia'], row['Montenegro'], row['Montserrat'], row['Morocco'], row['Mozambique'], row['Myanmar'], row['Namibia'], row['Nepal'], row['Netherlands'], row['NewCaledonia'], row['NewZealand'], row['Nicaragua'], row['Niger'], row['Nigeria'], row['NorthernMarianaIslands'], row['Norway'], row['Oman'], row['Pakistan'], row['Palestine'], row['Panama'], row['PapuaNewGuinea'], row['Paraguay'], row['Peru'], row['Philippines'], row['Poland'], row['Portugal'], row['PuertoRico'], row['Qatar'], row['Romania'], row['Russia'], row['Rwanda'], row['SaintKittsAndNevis'], row['SaintLucia'], row['SaintVincentAndtheGrenadines'], row['SanMarino'], row['SaoTomeAndPrincipe'], row['SaudiArabia'], row['Senegal'], row['Serbia'], row['Seychelles'], row['SierraLeone'], row['Singapore'], row['SintMaarten'], row['Slovakia'], row['Slovenia'], row['Somalia'], row['SouthAfrica'], row['SouthKorea'], row['SouthSudan'], row['Spain'], row['SriLanka'], row['Sudan'], row['Suriname'], row['Swaziland'], row['Sweden'], row['Switzerland'], row['Syria'], row['Taiwan'], row['Tajikistan'], row['Tanzania'], row['Thailand'], row['Timor'], row['Togo'], row['TrinidadAndTobago'], row['Tunisia'], row['Turkey'], row['TurksAndCaicosIslands'], row['Uganda'], row['Ukraine'], row['UnitedArabEmirates'], row['UnitedKingdom'], row['UnitedStates'], row['UnitedStatesVirginIslands'], row['Uruguay'], row['Uzbekistan'], row['Vatican'], row['Venezuela', row['Vietnam'], row['WesternSahara'], row['Yemen'], row['Zambia'], row['Zimbabwe'])
    mycursor.execute('INSERT INTO covid_per_day_per_country (date, World, Afghanistan, Albania, Algeria, Andorra, Angola, Anguilla, AntiguaAndBarbuda, Argentina, Armenia, Aruba, Australia, Austria, Azerbaijan, Bahamas, Bahrain, Bangladesh, Barbados, Belarus, Belgium, Belize, Benin, Bermuda, Bhutan, Bolivia, BonaireSintEustatiusAndSaba, BosniaAndHerzegovina, Botswana, Brazil, BritishVirginIslands, Brunei, Bulgaria, BurkinaFaso, Burundi, Cambodia, Cameroon, Canada, CapeVerde, CaymanIslands, CentralAfricanRepublic,Chad, Chile, China, Colombia, Comoros, Congo, CostaRica, CotedIvoire, Croatia, Cuba, Curacao, Cyprus, CzechRepublic, DemocraticRepublicCongo, Denmark, Djibouti, Dominica, DominicanRepublic, Ecuador, Egypt, ElSalvador, EquatorialGuinea, Eritrea, Estonia, Ethiopia, FaeroeIslands, FalklandIslands, Fiji, Finland, France, FrenchPolynesia,Gabon, Gambia, Georgia, Germany, Ghana, Gibraltar, Greece, Greenland, Grenada, Guam, Guatemala, Guernsey, Guinea, GuineaBissau, Guyana, Haiti, Honduras, Hungary, Iceland, India, Indonesia, International, Iran, Iraq, Ireland, IsleofMan, Israel, Italy, Jamaica, Japan, Jersey, Jordan, Kazakhstan, Kenya, Kosovo, Kuwait, Kyrgyzstan, Laos, Latvia, Lebanon, Lesotho, Liberia, Libya, Liechtenstein, Lithuania, Luxembourg, Macedonia, Madagascar, Malawi, Malaysia, Maldives, Mali, Malta, Mauritania, Mauritius, Mexico, Moldova, Monaco, Mongolia, Montenegro, Montserrat, Morocco, Mozambique, Myanmar, Namibia, Nepal, Netherlands, NewCaledonia, NewZealand, Nicaragua, Niger, Nigeria, NorthernMarianaIslands, Norway, Oman, Pakistan, Palestine, Panama, PapuaNewGuinea, Paraguay, Peru, Philippines, Poland, Portugal, PuertoRico, Qatar, Romania, Russia, Rwanda, SaintKittsAndNevis, SaintLucia, SaintVincentAndtheGrenadines, SanMarino, SaoTomeAndPrincipe, SaudiArabia, Senegal, Serbia, Seychelles, SierraLeone, Singapore, SintMaarten, Slovakia, Slovenia, Somalia, SouthAfrica, SouthKorea, SouthSudan, Spain, SriLanka, Sudan, Suriname, Swaziland, Sweden, Switzerland, Syria, Taiwan, Tajikistan, Tanzania, Thailand, Timor, Togo, TrinidadAndTobago, Tunisia, Turkey, TurksAndCaicosIslands, Uganda, Ukraine, UnitedArabEmirates, UnitedKingdom, UnitedStates, UnitedStatesVirginIslands, Uruguay, Uzbekistan, Vatican, Venezuela, Vietnam, WesternSahara, Yemen, Zambia, Zimbabwe) VALUES("%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s")', values)

mydb.commit()

values = (row['Antigua and Barbuda'])
mycursor.execute('INSERT INTO covid_per_day_per_country (Antigua and Barbuda) VALUES ("%s")', values)

ProgrammingError: 1064 (42000): 你的 SQL 语法有错误；查看与您的 MySQL 服务器版本相对应的手册，了解在第 1

行 'and Barbuda) VALUES ("%s")' 附近使用的正确语法

Answer 1

首选的 pandas 方法是使用 to_sql 函数。首先安装 sqlalchemy 包。然后试试这段代码。 table 和数据框中的列名必须相同。

from sqlalchemy import create_engine

engine = create_engine('mysql://root:xxxx@127.0.0.1/')
dataframe.to_sql('covid19_ca', engine)

如果你想继续使用你的代码并遍历数据框（注意它是 not recommended），你可以尝试这样的事情：

for _, row in dataframe.iterrows():
    values = (row['date'], row['World'], row['Afghanistan'])
    mycursor.execute('INSERT INTO covid_per_day_per_country (date, World, Afghanistan) VALUES("%s", "%s", "%s")', values)
    mydb.commit()

无法通过 python 将 CSV 文件的行插入到 MYSQL 数据库中

Unable to insert rows of a CSV file into a MYSQL database through python

python

mysql

database

mysql-connector

pandas