使用Python加载SQLite数据库表：未找到表

Question

我正在使用 Python 2.7，想把一个用管道符分隔的文件加载到 SQLite 表中。

最开始我尝试使用事务处理，但遇到了一个错误：“操作错误：没有这样的表：ff”。我在函数里加了一个全局声明，但也没用（其实我也没指望它能解决问题，只是想确认一下）。

为了调试，我把函数调用去掉了，直接在循环里加了 INSERT 语句，结果还是同样的错误。

我检查了一下：clt.db 文件已经创建，并且里面有一个空的表 ff。错误发生在第 64 行（curs.execute(insertStmt,obs)，因为行号被删掉了）。

我不知道这是否会影响解决方案（希望不会）：我是在一个微型 EC2 实例上运行这个程序，目标数据库写入的是通过 s3fs 挂载的 S3 存储桶。可能是延迟问题？

--更新：我发现当我关闭连接和游标，然后再重新打开它们时，这个问题就解决了。即使在执行 conn.commit() 之后也一样。我尝试了 time.sleep()，但没有帮助，所以看起来连接和游标真的需要关闭再重新打开，才能让新表的存在被识别。为什么会这样我也不知道。有谁能给点建议吗？

有什么想法吗？谢谢。

Aust。

import csv,sqlite3

dbName = 'clt.db'
conn = sqlite3.connect(dbName)
curs = conn.cursor()


def loadBloc(bloc):
        global conn,curs
        curs.execute('begin')
        for obs in bloc:
                curs.execute(insertStmt,obs)
        conn.commit()
        return None



createCode = '''
create table ff
(
a text not null,
b text not null,
c text not null,
d numeric not null,
e text not null,
f text not null,
g text not null,
h numeric not null,
i numeric not null
);
'''

curs.execute(createCode)
conn.commit()

nb = 10000; cnt = 0
bloc = ["" for i in range(nb)]
f = open(infile,'rt')
csv.register_dialect('pipes',delimiter='\t')
with open('ff.dat','r') as f:
        reader = csv.reader(f,dialect='pipes')
        for row in reader:
                a    = row[0]
                b    = row[1]
                c    = row[2]
                u = c.split('/')
                if len(u) == 3:
                        v = [int(u[i]) for i in range(len(u)) ]
                        c = "{0:4d}-{1:02d}-{2:02d}".format(v[2],v[1],v[0])
                else:
                        c = "1212-12-12"
                d   = row[3]
                e   = row[4]
                f   = row[5]
                g   = row[6]
                h   = row[7]
                i   = row[8]

                obs = (a,b,c,d,e,f,g,h,i)
                insertStmt = 'insert into ff (a,b,c,d,e,f,g,h,i) values (' + ','.join('?'*9) + ');'
                curs.execute(insertStmt,obs)
                conn.commit()

                print cnt
                #bloc[cnt] = (a,b,c,d,e,f,g,h,i)
                #if cnt == nb-1:
                #       loadBloc(bloc)
                #       print "=============================================="
                #       bloc = ["" for i in range(nb)]
                #       cnt = 0
                #else:
                #       cnt = cnt + 1

f.close()
curs.close()
conn.close()

数据库连接数据插入 sqlite 错误调试事务处理游标管理 s3 存储 ec2 实例

使用Python加载SQLite数据库表：未找到表

1 个回答

撰写回答