Python SQLite – 连接到数据库
在本文中,我们将讨论如何使用Python的 sqlite3 模块连接到 SQLite 数据库。
连接到数据库
可以使用connect()方法建立到 SQLite 数据库的连接,将要访问的数据库的名称作为参数传递。如果该数据库不存在,则会创建它。
sqliteConnection = sqlite3.connect('sql.db')
但是如果你想在建立连接后执行一些查询怎么办。为此,必须使用连接实例上的cursor()方法创建游标,该方法将执行我们的 SQL 查询。
cursor = sqliteConnection.cursor()
print('DB Init')
要执行的SQL查询可以写成字符串的形式,然后通过调用游标对象的execute()方法来执行。然后,可以使用fetchall()方法从服务器获取结果,在这种情况下,它是 SQLite 版本号。
query = 'SQL query;'
cursor.execute(query)
result = cursor.fetchall()
print('SQLite Version is {}'.format(result))
考虑下面的示例,我们将连接到 SQLite 数据库并运行一个简单的查询 select sqlite_version();找到我们正在使用的 SQLite 的版本。
例子:
Python
import sqlite3
try:
# Connect to DB and create a cursor
sqliteConnection = sqlite3.connect('sql.db')
cursor = sqliteConnection.cursor()
print('DB Init')
# Write a query and execute it with cursor
query = 'select sqlite_version();'
cursor.execute(query)
# Fetch and output result
result = cursor.fetchall()
print('SQLite Version is {}'.format(result))
# Close the cursor
cursor.close()
# Handle errors
except sqlite3.Error as error:
print('Error occured - ', error)
# Close DB Connection irrespective of success
# or failure
finally:
if sqliteConnection:
sqliteConnection.close()
print('SQLite Connection closed')
输出: