使用Python对MySQL进行新增、删除、更新和查询操作,可以使用mysql-connector-python库来执行SQL语句。以下是一个基本的步骤和示例代码:

步骤 1: 安装必要的库

如果你还没有安装mysql-connector-python库,可以使用以下命令安装:

pip install mysql-connector-python

如果速度慢,使用镜像下载

pip install mysql-connector-python -i https://pypi.tuna.tsinghua.edu.cn/simple

步骤 2: 连接MySQL数据库

使用mysql-connector-python建立与MySQL数据库的连接:

import mysql.connector

# 建立数据库连接
conn = mysql.connector.connect(
    host='192.168.110.xx',
    user='xx',
    password='xxxx',
    database='xx'
)

步骤 3: 创建游标对象

使用连接对象创建游标对象,用于执行SQL语句:

cursor = conn.cursor()

步骤 4: 执行SQL语句

使用游标对象执行SQL语句进行新增、删除、更新和修改操作。

新增数据
# 插入数据的SQL语句
insert_sql = "INSERT INTO your_table_name (column1, column2, ...) VALUES (%s, %s, ...)"

# 执行插入操作
cursor.execute(insert_sql, ('value1', 'value2', ...))
删除数据
# 删除数据的SQL语句
delete_sql = "DELETE FROM your_table_name WHERE condition"

# 执行删除操作
cursor.execute(delete_sql)
更新数据
# 更新数据的SQL语句
update_sql = "UPDATE your_table_name SET column1 = %s WHERE condition"

# 执行更新操作
cursor.execute(update_sql, ('new_value',))
查询数据
# 查询数据
select_sql = "SELECT column1, column2 FROM your_table_name WHERE condition"
cursor.execute(select_sql)

# 获取所有结果
results = cursor.fetchall()

# 打印结果
for row in results:
    print(row)

修改数据通常是指更新数据,所以使用UPDATE语句。

步骤 5: 提交事务

对于插入、更新和删除操作,需要提交事务以使更改生效:

conn.commit()

步骤 6: 关闭游标和连接

完成操作后,关闭游标和连接:

cursor.close()
conn.close()

完整示例代码

将上述步骤合并到一个完整的示例中:

import mysql.connector

# 建立数据库连接
conn = mysql.connector.connect(
    host='192.168.110.xx',
    user='your_username',
    password='your_password',
    database='your_database'
)

# 创建游标对象
cursor = conn.cursor()

# 插入数据
insert_sql = "INSERT INTO your_table_name (column1, column2, ...) VALUES (%s, %s, ...)"
cursor.execute(insert_sql, ('value1', 'value2', ...))
conn.commit()

# 更新数据
update_sql = "UPDATE your_table_name SET column1 = %s WHERE condition"
cursor.execute(update_sql, ('new_value',))
conn.commit()

# 查询数据
select_sql = "SELECT column1, column2 FROM your_table_name WHERE condition"
cursor.execute(select_sql)

# 获取所有结果
results = cursor.fetchall()

# 打印结果
for row in results:
    print(row)


# 删除数据
delete_sql = "DELETE FROM your_table_name WHERE condition"
cursor.execute(delete_sql)
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()

注意事项

  • 确保将your_usernameyour_passwordyour_databaseyour_table_name和相应的列名、值替换为你的实际数据库信息。
  • 在执行删除和更新操作之前,确保你的SQL语句的条件是正确的,以避免意外删除或修改过多的行。
  • 在生产环境中,不要在代码中硬编码数据库凭据。考虑使用环境变量或配置文件来管理敏感信息。
Logo

DAMO开发者矩阵,由阿里巴巴达摩院和中国互联网协会联合发起,致力于探讨最前沿的技术趋势与应用成果,搭建高质量的交流与分享平台,推动技术创新与产业应用链接,围绕“人工智能与新型计算”构建开放共享的开发者生态。

更多推荐