怎么使用Python操作MySQL的各种功能

数据库   发布日期:2025年03月01日   浏览次数:258

这篇文章主要介绍“怎么使用Python操作MySQL的各种功能”,在日常操作中,相信很多人在怎么使用Python操作MySQL的各种功能问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”怎么使用Python操作MySQL的各种功能”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

连接MySQL

在Python中,我们可以使用

  1. pymysql
库来连接MySQL数据库。
  1. import pymysql
  2. # 连接MySQL
  3. conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')
  4. # 获取游标
  5. cursor = conn.cursor()
  6. # 执行SQL语句
  7. cursor.execute('SELECT * FROM users')
  8. # 获取结果集
  9. result = cursor.fetchall()
  10. print(result)
  11. # 关闭游标和连接
  12. cursor.close()
  13. conn.close()

以上代码中,我们首先使用

  1. pymysql
库连接了MySQL数据库,并获取了游标。然后,我们执行了一个简单的
  1. SELECT
语句,并获取了结果集。最后,我们关闭了游标和连接。

增删改查

在MySQL中,我们可以使用

  1. INSERT
  1. DELETE
  1. UPDATE
  1. SELECT
语句来完成增删改查操作。在Python中,我们同样可以使用
  1. pymysql
库来执行这些操作。

插入数据

  1. import pymysql
  2. # 连接MySQL
  3. conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')
  4. # 获取游标
  5. cursor = conn.cursor()
  6. # 插入数据
  7. sql = "INSERT INTO users(username, password) VALUES (%s, %s)"
  8. params = ('Tom', '123456')
  9. cursor.execute(sql, params)
  10. # 提交事务
  11. conn.commit()
  12. # 关闭游标和连接
  13. cursor.close()
  14. conn.close()

以上代码中,我们使用

  1. INSERT
语句向
  1. users
表中插入了一条数据。在执行
  1. execute
方法时,我们可以使用占位符
  1. %s
来表示参数,然后在执行时传入对应的参数。最后,我们提交了事务,并关闭了游标和连接。

删除数据

  1. import pymysql
  2. # 连接MySQL
  3. conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')
  4. # 获取游标
  5. cursor = conn.cursor()
  6. # 删除数据
  7. sql = "DELETE FROM users WHERE id = %s"
  8. params = (1,)
  9. cursor.execute(sql, params)
  10. # 提交事务
  11. conn.commit()
  12. # 关闭游标和连接
  13. cursor.close()
  14. conn.close()

以上代码中,我们使用

  1. DELETE
语句删除了
  1. users
表中
  1. id
为1的数据。在执行
  1. execute
方法时,我们同样使用了占位符
  1. %s
来表示参数。最后,我们提交了事务,并关闭了游标和连接。

更新数据

  1. import pymysql
  2. # 连接MySQL
  3. conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')
  4. # 获取游标
  5. cursor = conn.cursor()
  6. # 更新数据
  7. sql = "UPDATE users SET password = %s WHERE username = %s"
  8. params = ('654321', 'Tom')
  9. cursor.execute(sql, params)
  10. # 提交事务
  11. conn.commit()
  12. # 关闭游标和连接
  13. cursor.close()
  14. conn.close()

以上代码中,我们使用

  1. UPDATE
语句更新了
  1. users
表中
  1. username
  1. Tom
的数据的密码。在执行
  1. execute
方法时,我们同样使用了占位符
  1. %s
来表示参数。最后,我们提交了事务,并关闭了游标和连接。

查询数据

  1. import pymysql
  2. # 连接MySQL
  3. conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')
  4. # 获取游标
  5. cursor = conn.cursor()
  6. # 查询数据
  7. sql = "SELECT * FROM users WHERE username = %s"
  8. params = ('Tom',)
  9. cursor.execute(sql, params)
  10. # 获取结果集
  11. result = cursor.fetchall()
  12. print(result)
  13. # 关闭游标和连接
  14. cursor.close()
  15. conn.close()

以上代码中,我们使用

  1. SELECT
语句查询了
  1. users
表中
  1. username
  1. Tom
的数据。在执行
  1. execute
方法时,我们同样使用了占位符
  1. %s
来表示参数。最后,我们获取了结果集,并关闭了游标和连接。

批量操作

在MySQL中,我们可以使用

  1. INSERT
  1. DELETE
  1. UPDATE
  1. SELECT
语句来批量操作数据。在Python中,我们同样可以使用
  1. pymysql
库来批量操作数据。

批量插入数据

  1. import pymysql
  2. # 连接MySQL
  3. conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')
  4. # 获取游标
  5. cursor = conn.cursor()
  6. # 批量插入数据
  7. sql = "INSERT INTO users(username, password) VALUES (%s, %s)"
  8. params = [('Tom', '123456'), ('Jerry', '654321'), ('Alice', '111111')]
  9. cursor.executemany(sql, params)
  10. # 提交事务
  11. conn.commit()
  12. # 关闭游标和连接
  13. cursor.close()
  14. conn.close()

以上代码中,我们使用

  1. executemany
方法批量插入了多条数据。在执行
  1. executemany
方法时,我们使用了一个元组列表来表示多个参数。最后,我们提交了事务,并关闭了游标和连接。

批量删除数据

  1. import pymysql
  2. # 连接MySQL
  3. conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')
  4. # 获取游标
  5. cursor = conn.cursor()
  6. # 批量删除数据
  7. sql = "DELETE FROM users WHERE id = %s"
  8. params = [(1,), (2,), (3,)]
  9. cursor.executemany(sql, params)
  10. # 提交事务
  11. conn.commit()
  12. # 关闭游标和连接
  13. cursor.close()
  14. conn.close()

以上代码中,我们使用

  1. executemany
方法批量删除了多条数据。在执行
  1. executemany
方法时,我们同样使用了一个元组列表来表示多个参数。最后,我们提交了事务,并关闭了游标和连接。

批量更新数据

  1. import pymysql
  2. # 连接MySQL
  3. conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')
  4. # 获取游标
  5. cursor = conn.cursor()
  6. # 批量更新数据
  7. sql = "UPDATE users SET password = %s WHERE username = %s"
  8. params = [('123456', 'Tom'), ('654321', 'Jerry'), ('111111', 'Alice')]
  9. cursor.executemany(sql, params)
  10. # 提交事务
  11. conn.commit()
  12. # 关闭游标和连接
  13. cursor.close()
  14. conn.close()

以上就是怎么使用Python操作MySQL的各种功能的详细内容,更多关于怎么使用Python操作MySQL的各种功能的资料请关注九品源码其它相关文章!