Python数据库编程:连接SQLite数据库

本文将为初学者详细讲解Python连接SQLite数据库的方法。我们将通过简单易懂的方式,介绍如何使用Python进行数据库编程,并提供相应的代码案例。在学习本文前,您需要先了解基本的Python编程语言知识,以及SQLite数据库的基础知识。

1. 安装SQLite3模块

在使用Python连接SQLite数据库之前,需要先安装SQLite3模块。可以通过以下命令在命令行中安装:

$ pip install pysqlite3

安装完成后,我们就可以开始连接SQLite数据库了。

2. 连接SQLite数据库

在Python中,连接SQLite数据库非常简单。我们只需要使用Python自带的SQLite3模块,调用connect()函数即可建立与数据库的连接。connect()函数的参数是数据库文件的路径。例如:

import sqlite3

def connect_db():
    conn = sqlite3.connect('example.db')
    return conn

上述代码中,我们定义了一个名为connect_db()的函数,其中调用了connect()函数建立了与SQLite数据库example.db的连接,并将连接对象返回。

3. 创建表格

连接上SQLite数据库之后,我们可以使用execute()函数来执行SQL语句,从而创建表格。例如,我们可以使用以下代码创建一个名为users的表格:

def create_table(conn):
    c = conn.cursor()
    c.execute('''CREATE TABLE users
                 (id INT PRIMARY KEY     NOT NULL,
                 name           TEXT    NOT NULL,
                 age            INT     NOT NULL,
                 address        CHAR(50),
                 salary         REAL);
            ''')
    conn.commit()
    print('Table created successfully')

上述代码中,我们定义了一个名为create_table()的函数,其中调用了cursor()函数来获得一个游标对象,然后使用execute()函数执行SQL语句来创建名为users的表格。在执行完SQL语句后,我们需要调用commit()函数来提交更改。

4. 插入数据

创建好表格后,我们可以使用execute()函数来插入数据到表格中。例如,我们可以使用以下代码向名为users的表格插入一条数据:

def insert_data(conn):
    c = conn.cursor()
    c.execute("""INSERT INTO users (id, name, age, address, salary)
                  VALUES (1, 'John', 25, 'USA', 5000.00);
            """)
    conn.commit()
    print('Data inserted successfully')

上述代码中,我们定义了一个名为insert_data()的函数,其中调用了cursor()函数来获得一个游标对象,然后使用execute()函数执行SQL语句来向名为users的表格插入一条数据。在执行完SQL语句后,我们需要调用commit()函数来提交更改。

5. 查询数据

使用execute()函数还可以查询SQLite数据库中的数据。例如,我们可以使用以下代码查询名为users的表格中的所有数据:

def select_data(conn):
    c = conn.cursor()
    cursor = c.execute("SELECT id, name, age, address, salary from users")
    for row in cursor:
        print('ID =', row[0])
        print('NAME =', row[1])
        print('AGE =', row[2])
        print('ADDRESS =', row[3])
        print('SALARY =', row[4], '
')

上述代码中,我们定义了一个名为select_data()的函数,其中调用了cursor()函数来获得一个游标对象,然后使用execute()函数执行SQL语句来查询名为users的表格中的所有数据。在查询完成后,我们可以使用for循环遍历查询结果,并打印出每条数据对应的各个字段。

6. 关闭SQLite数据库连接

使用完SQLite数据库后,我们需要关闭与数据库的连接。可以使用close()函数来关闭数据库连接。例如:

def close_db(conn):
    conn.close()
    print('Database connection closed')

上述代码中,我们定义了一个名为close_db()的函数,其中调用了close()函数来关闭与SQLite数据库的连接。

到此为止,我们已经介绍了Python连接SQLite数据库的方法。希望本篇文章能够对初学者有所帮助。如果您想深入了解Python的数据库编程,可以继续学习其他相关知识。

猿教程
请先登录后发表评论
  • 最新评论
  • 总共0条评论