我是一名刚开始学习Python的学生,我的任务是创建一个关系型数据库管理系统。我认为我已经做得很好了,但似乎遇到了难题。这是我的代码:
import csv
import sqlite3
conn = sqlite3.connect('unfccc.db')
c = conn.cursor()
c.execute('''CREATE TABLE unfccc (
Country TEXT,
CodeCountryFormat TEXT,
NamePollutant TEXT,
NameYearSector TEXT,
NameParent TEXT,
Sector TEXT,
CodeSector TEXT,
CNUEDSPD TEXT
)''')
def insert_row(Country, CodeCountryFormat, NamePollutant, NameYearSector, NameParent, Sector, CodeSector, CNUEDSPD):
c.execute("INSERT INTO unfccc VALUES (?, ?, ?, ?, ?, ?, ?, ?)", (Country, CodeCountryFormat, NamePollutant, NameYearSector, NameParent, Sector, CodeSector, CNUEDSPD))
conn.commit()
with open('UNFCCC_v20.csv') as csvfile:
readCSV = csv.reader(csvfile, delimiter='\t')
counter = 0
for row in readCSV:
insert_row(row[0], row[1], row[2], row[3], row[4], row[5], row[6], row[7])
counter = counter+1
print('%d down, more to go' % counter)
conn.close()
当我使用第4行将输入指向:memory:时,它可以完美地运行,并且我认为自己拥有了一个关系型数据库。
但是,当我尝试像这样运行代码,将数据写入db文件时,我会得到这个错误:
File "<ipython-input-13-4c50216842bc>", line 19, in insert_row
c.execute("INSERT INTO unfccc VALUES (?, ?, ?, ?, ?, ?, ?, ?)", (Country, CodeCountryFormat, NamePollutant, NameYearSector, NameParent, Sector, CodeSector, CNUEDSPD))
OperationalError: disk I/O error
我在stackoverflow上进行了搜索,并使用了谷歌,但我认为我找到的任何情况都不符合我在这里尝试做的事情(或者我没有足够的知识来弄清楚发生了什么)。我注意到我的代码另外一个问题是,它将数据输入到内存中非常快,但当我写入到数据库文件时,速度非常慢,这不应该是硬件限制,因为我正在使用SSD。任何帮助将不胜感激!