使用 Python 在 SQLite 数据库中插入二进制文件

Question

我正在尝试编写一个简单的 Python 脚本，将 .odt 文档插入 SQLite 数据库。这是我到目前为止所做的，但它似乎不起作用：

f=open('Loremipsum.odt', 'rb')
k=f.read()
f.close()
cursor.execute="INSERT INTO notes (note) VALUES ('%s')" %(sqlite.Binary(k))
cursor.close()
conn.close()

我没有收到任何错误消息，但据我所知，没有插入记录。我究竟做错了什么？另外，如何将存储的文档提取回来？谢谢！

Answer 1

不确定您使用的 sqlite.Binary 是什么，但无论如何，这是一个工作示例：

import sqlite3

# let's just make an arbitrary binary file...
with open('/tmp/abin', 'wb') as f:
  f.write(''.join(chr(i) for i in range(55)))
# ...and read it back into a blob
with open('/tmp/abin', 'rb') as f:
  ablob = f.read()

# OK, now for the DB part: we make it...:
db = sqlite3.connect('/tmp/thedb')
db.execute('CREATE TABLE t (thebin BLOB)')
db.execute('INSERT INTO t VALUES(?)', [buffer(ablob)])
db.commit()
db.close()

# ...and read it back:
db = sqlite3.connect('/tmp/thedb')
row = db.execute('SELECT * FROM t').fetchone()
print repr(str(row[0]))

使用 Python 2.6 运行时，此代码按预期显示： '\x00\x01\x02\x03\x04\x05\x06\x07\x08\t\n\x0b\x0c\r\x0e\x0f\x10\x11\x12\x13\x14\x15\x16\x17\ x18\x19\x1a\x1b\x1c\x1d\x1e\x1f !"#$%&\'()*+,-./0123456'

注意需要使用buffer 插入blob，并使用str 将其作为字符串读回（因为它也使用buffer 类型作为结果）——如果你只是去将其写入磁盘不需要后一段（因为文件的write 方法确实接受缓冲区对象，就像它接受字符串一样）。

Answer 2

给定的示例存在多个问题。我将会 一一解决。

• 没有错误检查。我们要么需要使用 try/except/finally 构造或使用with 关键字。
• Python 方法与 C# 属性不同。您没有运行 execute 方法，而是将一些字符串分配给对象。 （在 Python 中，方法也是对象。）
• 非常重要的是您的代码会受到SQL 注入攻击。我们永远不应该使用 Python 字符串操作来构建 SQL 语句。我们应该始终使用占位符。
• 示例不完整。这导致了一个棘手的问题。假设有一个CREATE TABLE 语句，那么将创建一个新的隐式事务。并且必须发出commit 语句才能将数据保存到数据库文件中。在 SQLite 中，SELECT 以外的任何语句都会启动一个隐式事务。 （某些数据库，如 MySQL，默认处于自动提交模式。对于 SQLite，情况并非如此。）

这是一个正确的工作示例，它将 LibreOffice 文档写入 SQLite 数据库的 docs 表：

#!/usr/bin/env python

import sqlite3


def readData():

    fl = open('book.odt', 'rb')

    with fl:
        data = fl.read()

    return data


con = sqlite3.connect('test.db')

with con:

    cur = con.cursor()     
    cur.execute("CREATE TABLE IF NOT EXISTS docs(Data BLOB)")

    data = readData()

    sql = "INSERT INTO docs(Data) VALUES (?)" 
    cur.execute(sql, (sqlite3.Binary(data), ))

book.odt 文件位于当前工作目录中。我们没有手动调用commit 方法，因为这是由with 关键字在后台处理的。

编辑删除了 lite 别名

Answer 3

问题：

1. 您没有显示您运行的完整代码。您不应该让回答者猜测sqlite.Binary(k) 之类的东西。

2. 基本问题：您没有提交交易。在conn.close()之前使用conn.commit()。