连接SQLite3数据库
1. 导入SQLite3模块
要在Python中使用SQLite3数据库,首先需要导入相应的模块:
import sqlite3
2. 连接数据库
接下来,我们需要建立与SQLite3数据库的连接。可以使用connect()
函数来创建数据库连接对象:
conn = sqlite3.connect('database.db')
其中,database.db
是数据库文件的路径。如果文件不存在,SQLite3会自动创建一个新的数据库文件。
执行SQL查询
1. 创建游标
要执行SQL查询,我们首先需要创建一个游标对象。可以使用cursor()
方法来创建游标:
cursor = conn.cursor()
游标对象可以用于执行SQL语句和获取查询结果。
2. 执行SQL语句
通过执行execute()
方法,我们可以执行SQL查询语句:
cursor.execute("SELECT * FROM table_name")
其中,table_name
是要查询的表名。这里的SQL语句可以根据实际需求进行更改,比如选择特定字段、添加条件等。
3. 获取查询结果
执行SQL查询之后,我们可以使用fetchall()
方法获取所有查询结果:
results = cursor.fetchall()
这将返回一个包含查询结果的列表。
4. 遍历查询结果
我们可以使用循环遍历查询结果,并对每个结果进行相应的处理。以下是一个示例:
for row in results:
# 对每个结果进行处理
print(row)
在这个示例中,我们使用了print()
函数来输出每个查询结果。
关闭数据库连接
1. 提交更改
在执行完所有的SQL语句之后,我们需要提交所有的更改:
conn.commit()
这将确保所有的更改被保存到数据库中。
2. 关闭数据库连接
最后,我们需要关闭与数据库的连接:
conn.close()
这将释放数据库资源,并结束与数据库的连接。
完整示例代码
import sqlite3
# 连接数据库
conn = sqlite3.connect('database.db')
# 创建游标
cursor = conn.cursor()
# 执行SQL语句
cursor.execute("SELECT * FROM table_name")
# 获取查询结果
results = cursor.fetchall()
# 遍历查询结果
for row in results:
# 对每个结果进行处理
print(row)
# 提交更改
conn.commit()
# 关闭数据库连接
conn.close()
以上是使用Python连接SQLite3数据库并执行查询的基本方法。根据实际需求,可以通过修改SQL语句以及处理查询结果的方式,进行更复杂的数据库操作。
注意:在实际使用中,需要根据具体情况调整代码中的数据库文件路径、表名以及执行的SQL语句。