欢迎访问宙启技术站
智能推送

使用Python编写的数据库操作函数

发布时间:2023-05-19 15:43:03

Python是一种很强大的编程语言,可以用来开发各种应用程序,其中包括数据库应用。在Python中,我们可以使用不同的数据库来存储和管理数据,如MySQL、SQLite、PostgreSQL等。下面将介绍使用Python编写的一些常见数据库操作函数。

1. 连接数据库

在Python中,我们可以使用第三方模块来连接不同的数据库。这些模块提供了不同的API来连接,查询和管理数据库。下面是MySQL数据库的连接代码:

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost", "root", "123456", "test")

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 执行SQL语句
cursor.execute("SELECT VERSION()")

# 获取单条数据 
data = cursor.fetchone()

# 输出结果
print("Database version:", data)

# 关闭数据库连接
db.close()

上面的代码使用了pymysql模块来连接MySQL数据库。我们可以使用connect()方法来连接数据库,将主机名,用户名,密码和数据库名称作为参数。如果连接成功,我们就可以通过获取游标对象来执行SQL语句。最后,我们关闭数据库连接并输出结果。

2. 插入数据

在Python中,我们可以使用execute()方法来执行插入数据的SQL语句。下面是一个插入数据的例子:

# 打开数据库连接
db = pymysql.connect("localhost", "root", "123456", "test")

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 插入数据
sql = "INSERT INTO students(name, age) VALUES ('Tom', 20)"
try:
    # 执行SQL语句
    cursor.execute(sql)
    # 提交到数据库执行
    db.commit()
    print("数据插入成功")
except:
    # 发生错误时回滚
    db.rollback()
    print("数据插入失败")

# 关闭数据库连接
db.close()

上面的代码插入了一条数据到students表中。我们可以使用try...except语句来捕获可能发生的错误,如果执行成功,我们就可以提交事务,否则就回滚操作。

3. 查询数据

在Python中,我们可以使用execute()方法来执行查询数据的SQL语句。下面是一个查询数据的例子:

# 打开数据库连接
db = pymysql.connect("localhost", "root", "123456", "test")

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 查询数据
sql = "SELECT * FROM students"
try:
    # 执行SQL语句
    cursor.execute(sql)
    # 获取所有记录列表
    results = cursor.fetchall()
    # 遍历结果
    for row in results:
        name = row[0]
        age = row[1]
        # 输出结果
        print("name=%s,age=%s" % (name, age))
except:
    print("数据查询失败")

# 关闭数据库连接
db.close()

上面的代码查询了students表中的所有数据,并逐条输出结果。

4. 更新数据

在Python中,我们可以使用execute()方法来执行更新数据的SQL语句。下面是一个更新数据的例子:

# 打开数据库连接
db = pymysql.connect("localhost", "root", "123456", "test")

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 更新数据
sql = "UPDATE students SET age = age + 1 WHERE name = 'Tom'"
try:
    # 执行SQL语句
    cursor.execute(sql)
    # 提交到数据库执行
    db.commit()
    print("数据更新成功")
except:
    # 发生错误时回滚
    db.rollback()
    print("数据更新失败")

# 关闭数据库连接
db.close()

上面的代码更新了students表中名为Tom的学生的年龄加1。我们可以使用execute()方法来执行更新数据的SQL语句,并使用commit()方法提交事务。

5. 删除数据

在Python中,我们也可以使用execute()方法来执行删除数据的SQL语句。下面是一个删除数据的例子:

# 打开数据库连接
db = pymysql.connect("localhost", "root", "123456", "test")

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 删除数据
sql = "DELETE FROM students WHERE name = 'Tom'"
try:
    # 执行SQL语句
    cursor.execute(sql)
    # 提交到数据库执行
    db.commit()
    print("数据删除成功")
except:
    # 发生错误时回滚
    db.rollback()
    print("数据删除失败")

# 关闭数据库连接
db.close()

上面的代码删除了students表中名为Tom的学生的数据。我们可以使用execute()方法来执行删除数据的SQL语句,并使用commit()方法提交事务。

总之,Python提供了很多强大的API来连接不同的数据库,执行SQL语句,并管理数据。如果你要开发数据库应用程序,可以使用Python来编写这些操作函数,使得工作更加高效和方便。