python查询mysql、Python连接MySQL查询数据

MySQL是一种流行的关系型数据库管理系统，它可以通过Python进行连接和查询。Python提供了许多用于MySQL连接和查询的库，如pymysql、mysql-connector-python等。介绍如何使用Python连接MySQL并查询数据。

安装MySQL驱动

在使用Python连接MySQL之前，需要安装相应的MySQL驱动。这里以pymysql为例，使用pip命令进行安装：

pip install pymysql

连接MySQL数据库

在安装好MySQL驱动之后，可以使用以下代码连接MySQL数据库：

import pymysql
# 打开数据库连接
db = pymysql.connect(host="localhost", user="root", password="password", database="test")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 查询数据
sql = "SELECT * FROM students"
cursor.execute(sql)
# 获取所有记录列表
results = cursor.fetchall()
# 输出结果
for row in results:
    id = row[0]
    name = row[1]
    age = row[2]
    grade = row[3]
    print("id=%s,name=%s,age=%s,grade=%s" % (id, name, age, grade))
# 关闭数据库连接
db.close()

查询数据

查询数据是MySQL的一个重要功能，Python也可以通过MySQL驱动进行查询。以下是一个简单的查询数据的例子：

import pymysql
# 打开数据库连接
db = pymysql.connect(host="localhost", user="root", password="password", database="test")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 查询数据
sql = "SELECT * FROM students"
cursor.execute(sql)
# 获取所有记录列表
results = cursor.fetchall()
# 输出结果
for row in results:
    id = row[0]
    name = row[1]
    age = row[2]
    grade = row[3]
    print("id=%s,name=%s,age=%s,grade=%s" % (id, name, age, grade))
# 关闭数据库连接
db.close()

插入数据

除了查询数据，Python也可以通过MySQL驱动进行插入数据。以下是一个简单的插入数据的例子：

import pymysql
# 打开数据库连接
db = pymysql.connect(host="localhost", user="root", password="password", database="test")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 插入数据
sql = "INSERT INTO students(name, age, grade) VALUES ('Tom', 18, 'A')"
cursor.execute(sql)
# 提交到数据库执行
db.commit()
# 关闭数据库连接
db.close()

更新数据

除了插入数据，Python也可以通过MySQL驱动进行更新数据。以下是一个简单的更新数据的例子：

import pymysql
# 打开数据库连接
db = pymysql.connect(host="localhost", user="root", password="password", database="test")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 更新数据
sql = "UPDATE students SET age = 19 WHERE name = 'Tom'"
cursor.execute(sql)
# 提交到数据库执行
db.commit()
# 关闭数据库连接
db.close()

删除数据

除了更新数据，Python也可以通过MySQL驱动进行删除数据。以下是一个简单的删除数据的例子：

import pymysql
# 打开数据库连接
db = pymysql.connect(host="localhost", user="root", password="password", database="test")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 删除数据
sql = "DELETE FROM students WHERE name = 'Tom'"
cursor.execute(sql)
# 提交到数据库执行
db.commit()
# 关闭数据库连接
db.close()

异常处理

在进行MySQL连接和查询时，可能会出现一些异常，如连接失败、查询失败等。为了避免程序崩溃，需要进行异常处理。以下是一个简单的异常处理的例子：

import pymysql
# 打开数据库连接
try:
    db = pymysql.connect(host="localhost", user="root", password="password", database="test")
except Exception as e:
    print("连接失败：%s" % e)
# 使用cursor()方法获取操作游标
try:
    cursor = db.cursor()
except Exception as e:
    print("获取游标失败：%s" % e)
# 查询数据
try:
    sql = "SELECT * FROM students"
    cursor.execute(sql)
    results = cursor.fetchall()
    for row in results:
        id = row[0]
        name = row[1]
        age = row[2]
        grade = row[3]
        print("id=%s,name=%s,age=%s,grade=%s" % (id, name, age, grade))
except Exception as e:
    print("查询失败：%s" % e)
# 关闭数据库连接
try:
    db.close()
except Exception as e:
    print("关闭连接失败：%s" % e)