【仿RabbitMQ消息队列项目day3】sqlite3数据库快速上手

import sqlite3
 
# 连接到SQLite数据库（如果数据库不存在，会自动在当前目录创建）
conn = sqlite3.connect('example.db')
cursor = conn.cursor()
 
# 创建一个表
cursor.execute('''CREATE TABLE IF NOT EXISTS stocks
               (date text, trans text, symbol text, qty real, price real)''')
 
# 插入一条记录
cursor.execute("INSERT INTO stocks VALUES ('2022-01-05', 'BUY', 'RHAT', 100, 35.14)")
 
# 查询记录
cursor.execute('SELECT * FROM stocks')
rows = cursor.fetchall()
for row in rows:
    print(row)
 
# 关闭连接
conn.commit()
cursor.close()
conn.close()

这段代码演示了如何使用Python的sqlite3库进行基本的数据库操作，包括创建表、插入数据和查询数据。首先，它连接到名为example.db的SQLite数据库，然后创建一个名为stocks的表（如果该表不存在），接着插入一条记录，并且通过查询语句获取这条记录，最后关闭游标和连接。这个例子简单易懂，非常适合初学者学习和使用。