SQLite3 使用整理
SQLite3是一个开源的嵌入式数据库引擎,其使用可以大大简化数据库的管理和维护。以下是一些SQLite3的使用和操作的常见示例:
- 创建数据库:
import sqlite3
# 创建一个数据库连接
conn = sqlite3.connect('test.db')
# 创建一个cursor对象
c = conn.cursor()
# 创建表
c.execute('''CREATE TABLE stocks
(date text, trans text, symbol text, qty real, price real)''')
# 关闭cursor
c.close()
# 提交事务
conn.commit()
# 关闭连接
conn.close()
- 查询数据库:
import sqlite3
conn = sqlite3.connect('test.db')
c = conn.cursor()
# 查询表中所有数据
c.execute("SELECT * FROM stocks")
print(c.fetchall())
# 关闭cursor
c.close()
# 关闭连接
conn.close()
- 插入数据到数据库:
import sqlite3
conn = sqlite3.connect('test.db')
c = conn.cursor()
# 插入数据
c.execute("INSERT INTO stocks VALUES ('2020-01-05','BUY','RHAT',100,35.14)")
# 提交事务
conn.commit()
# 关闭cursor
c.close()
# 关闭连接
conn.close()
- 更新数据库中的数据:
import sqlite3
conn = sqlite3.connect('test.db')
c = conn.cursor()
# 更新数据
c.execute("UPDATE stocks SET price = ? WHERE symbol = ?", (35.15, 'RHAT'))
# 提交事务
conn.commit()
# 关闭cursor
c.close()
# 关闭连接
conn.close()
- 删除数据库中的数据:
import sqlite3
conn = sqlite3.connect('test.db')
c = conn.cursor()
# 删除数据
c.execute("DELETE FROM stocks WHERE symbol = ?", ('RHAT',))
# 提交事务
conn.commit()
# 关闭cursor
c.close()
# 关闭连接
conn.close()
- 使用事务:
import sqlite3
conn = sqlite3.connect('test.db')
c = conn.cursor()
# 开始事务
conn.execute('BEGIN TRANSACTION')
try:
c.execute("INSERT INTO stocks VALUES ('2020-01-05','BUY','RHAT',100,35.14)")
c.execute("UPDATE stocks SET price = ? WHERE symbol = ?", (35.15, 'RHAT'))
# 提交事务
conn.commit()
except:
# 发生错误时回滚
conn.rollback()
# 关闭cursor
c.close()
# 关闭连接
conn.close()
以上代码展示了如何使用Python的sqlite3库来创建和管理SQLite数据库。这些操作包括创建表、查询数据、插入数据、更新数据、删除数据以及如何使用事务来确保数据的一致性。
评论已关闭