Python操作mysql数据库实现增删查改功能的方法

Python操作MySQL数据库实现增删查改功能的方法

1. 安装Python的MySQL模块

在Python中操作MySQL需要使用到MySQL模块，可以使用pip来安装：

pip install mysql-connector-python

2. 连接到MySQL数据库

连接到MySQL数据库需要使用到相应的参数，比如主机名、用户名、密码、数据库名等。可以使用以下代码连接到本地的MySQL服务器：

import mysql.connector

# 连接数据库
cnx = mysql.connector.connect(user='用户名', password='密码',
                              host='127.0.0.1',
                              database='数据库名')

# 关闭连接
cnx.close()

3. 执行SQL语句

可以使用cursor对象执行SQL语句，cursor对象可以使用cnx.cursor()来创建。执行查询操作可以使用execute()方法执行，执行后使用fetchall()方法来获取所有结果：

import mysql.connector

# 连接数据库
cnx = mysql.connector.connect(user='用户名', password='密码',
                              host='127.0.0.1',
                              database='数据库名')

# 获取cursor对象
cursor = cnx.cursor()

# 执行查询操作
query = ("SELECT * FROM 表名")
cursor.execute(query)

# 获取查询结果
for row in cursor.fetchall():
    print(row)

# 关闭连接
cnx.close()

4. 增加数据

可以使用INSERT INTO语句来增加一条数据，插入数据前需要定义好要插入的数据：

import mysql.connector

# 连接数据库
cnx = mysql.connector.connect(user='用户名', password='密码',
                              host='127.0.0.1',
                              database='数据库名')

# 获取cursor对象
cursor = cnx.cursor()

# 插入数据
add_data = ("INSERT INTO 表名 "
            "(列1, 列2, 列3) "
            "VALUES (%s, %s, %s)")
data_values = ('值1', '值2', '值3')
cursor.execute(add_data, data_values)

# 提交数据
cnx.commit()

# 关闭连接
cnx.close()

5. 删除数据

可以使用DELETE FROM语句来删除一条数据，删除数据前需要定义好要删除的数据：

import mysql.connector

# 连接数据库
cnx = mysql.connector.connect(user='用户名', password='密码',
                              host='127.0.0.1',
                              database='数据库名')

# 获取cursor对象
cursor = cnx.cursor()

# 删除数据
delete_data = ("DELETE FROM 表名 WHERE 列1 = %s")
data_value = ('值1',)
cursor.execute(delete_data, data_value)

# 提交数据
cnx.commit()

# 关闭连接
cnx.close()

6. 修改数据

可以使用UPDATE语句来修改一条数据，修改数据前需要定义好要修改的数据：

import mysql.connector

# 连接数据库
cnx = mysql.connector.connect(user='用户名', password='密码',
                              host='127.0.0.1',
                              database='数据库名')

# 获取cursor对象
cursor = cnx.cursor()

# 修改数据
update_data = ("UPDATE 表名 SET 列2 = %s WHERE 列1 = %s")
data_values = ('新值2', '值1')
cursor.execute(update_data, data_values)

# 提交数据
cnx.commit()

# 关闭连接
cnx.close()

示例说明1：查询学生信息

假设我们有一个学生信息的表students，有id、name、age、gender四个字段。我们要查询所有学生的信息并输出到控制台上，代码如下：

import mysql.connector

# 连接数据库
cnx = mysql.connector.connect(user='用户名', password='密码',
                              host='127.0.0.1',
                              database='数据库名')

# 获取cursor对象
cursor = cnx.cursor()

# 执行查询操作
query = ("SELECT * FROM students")
cursor.execute(query)

# 获取查询结果
for (id, name, age, gender) in cursor.fetchall():
    print('id:{}, name:{}, age:{}, gender:{}'.format(id, name, age, gender))

# 关闭连接
cnx.close()

示例说明2：增加学生信息

我们要往学生信息的表students中插入一条学生信息，这个学生id为1001，名字为“小明”，年龄为18岁，性别为男。代码如下：

import mysql.connector

# 连接数据库
cnx = mysql.connector.connect(user='用户名', password='密码',
                              host='127.0.0.1',
                              database='数据库名')

# 获取cursor对象
cursor = cnx.cursor()

# 插入数据
add_data = ("INSERT INTO students "
            "(id, name, age, gender) "
            "VALUES (%s, %s, %s, %s)")
data_values = ('1001', '小明', '18', '男')
cursor.execute(add_data, data_values)

# 提交数据
cnx.commit()

# 关闭连接
cnx.close()