sqlite3数据库中callback函数具体写法举例

在 SQLite3 中，callback 函数通常用于处理查询结果的每一行数据。下面是一个简单的示例：

import sqlite3

# 连接到数据库
conn = sqlite3.connect('example.db')

# 创建一个表
conn.execute('''CREATE TABLE stocks
             (date text, trans text, symbol text, qty real, price real)''')

# 插入一些数据
conn.execute("INSERT INTO stocks VALUES ('2022-01-05','BUY','GOOG',100,35.14)")
conn.execute("INSERT INTO stocks VALUES ('2022-01-06','SELL','AAPL',50,72.04)")
conn.execute("INSERT INTO stocks VALUES ('2022-01-07','BUY','TSLA',75,85.43)")

# 查询数据
def process_row(row):
    print(row)

conn.execute("SELECT * FROM stocks", callback=process_row)

# 关闭连接
conn.close()

在上面的示例中，我们定义了一个名为 `process_row` 的回调函数，它接受一个参数 `row`，表示查询结果中的一行数据。在这个回调函数中，我们只是简单地将这一行数据打印出来。

在执行查询时，我们通过将回调函数作为 `callback` 参数传递给 `execute` 方法来指定它。当查询返回结果时，SQLite3 会对每一行数据都调用一次回调函数，并将该行数据作为参数传递给它。