示例代码如下：
# encoding=utf-8import sqlite3def get_signal_names(db_file_path): names = list() with sqlite3.connect(db_file_path, isolation_level="IMMEDIATE", timeout=60, check_same_thread=False) as con: # 设置可以使用名称来获取查询后的数据 con.row_factory = sqlite3.Row cur = con.cursor() sql = "select distinct(Name) from Channels order by Name asc" cur.execute(sql) results = cur.fetchall() for row in results: names.append(row["Name"]) return namesdef get_channel_record(db_file_path, signal_name): channel = dict() with sqlite3.connect(db_file_path, isolation_level="IMMEDIATE", timeout=60, check_same_thread=False) as con: con.row_factory = sqlite3.Row cur = con.cursor() sql = "select MessageId, MessageChannel, SignalType from test_tb where Name = ?" # 注意(signal_name,)元组类型后的逗号 cur.execute(sql, (signal_name,)) re = cur.fetchone() channel["message_id"] = re["MessageId"] channel["signal_type"] = re["SignalType"] channel["message_channel"] = re["MessageChannel"] return channel更多请关注微信公众号
