WHCSRL 技术网

python 与 mysql 连接(增删改查)_Jack

1、

查询数据库的某一张表

  1. #!/usr/bin/python
  2. # -*- coding: UTF-8 -*-
  3. # 查询数据库的某一张表
  4. import MySQLdb
  5. db = ""
  6. def mysql_conn():
  7. global db
  8. try:
  9. # 打开数据库连接
  10. db = MySQLdb.connect("localhost", "root", "dong2025", "mysql8", charset='utf8')
  11. # 使用cursor()方法获取操作游标
  12. cursor = db.cursor()
  13. # SQL 查询数据库中的某一张表
  14. sql = "SELECT * FROM BOOK WHERE BOOK_ID > 3"
  15. # 执行sql语句
  16. cursor.execute(sql)
  17. # fetchall():接收全部的返回结果行.
  18. # alldata = cursor.fetchall()
  19. # return alldata
  20. # fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
  21. onedate = cursor.fetchone()
  22. return onedate
  23. except:
  24. # Rollback in case there is any error
  25. db.rollback()
  26. finally:
  27. db.close()
  28. my_con = mysql_conn()
  29. print(my_con)

2、

SQL 插入语句

  1. #!/usr/bin/python
  2. # -*- coding: UTF-8 -*-
  3. # SQL 插入语句
  4. import MySQLdb
  5. db = ""
  6. def mysql_conn():
  7. global db
  8. try:
  9. # 打开数据库连接
  10. db = MySQLdb.connect("localhost", "root", "dong2025", "mysql8", charset='utf8')
  11. # 使用cursor()方法获取操作游标
  12. cursor = db.cursor()
  13. # SQL 插入语句
  14. sql = """
  15. INSERT INTO BOOK(book_id, SORT, book_name, writer, OUTPUT, price)
  16. VALUES (11, 'T8988', '数据科学家', '作者_李克强', '深圳出版社', 666.00)
  17. """
  18. # 执行sql语句
  19. cursor.execute(sql)
  20. # 提交到数据库执行
  21. db.commit()
  22. except:
  23. # Rollback in case there is any error
  24. db.rollback()
  25. finally:
  26. db.close()
  27. mysql_conn()

3、

 SQL update更新语句

  1. #!/usr/bin/python
  2. # -*- coding: UTF-8 -*-
  3. # SQL update更新语句
  4. import MySQLdb
  5. db = ""
  6. def mysql_conn():
  7. global db
  8. try:
  9. # 打开数据库连接
  10. db = MySQLdb.connect("localhost", "root", "dong2025", "mysql8", charset='utf8')
  11. # 使用cursor()方法获取操作游标
  12. cursor = db.cursor()
  13. # SQL update更新语句
  14. sql = "UPDATE BOOK SET book_name = 'python算法导论' WHERE book_id= 9"
  15. print(sql)
  16. # 执行sql语句
  17. cursor.execute(sql)
  18. # 提交到数据库执行
  19. db.commit()
  20. except:
  21. # Rollback in case there is any error
  22. db.rollback()
  23. finally:
  24. db.close()
  25. mysql_conn()

4、

SQL 删除语句

  1. #!/usr/bin/python
  2. # -*- coding: UTF-8 -*-
  3. # SQL 删除语句
  4. import MySQLdb
  5. db = ""
  6. def mysql_conn():
  7. global db
  8. try:
  9. # 打开数据库连接
  10. db = MySQLdb.connect("localhost", "root", "dong2025", "mysql8", charset='utf8')
  11. # 使用cursor()方法获取操作游标
  12. cursor = db.cursor()
  13. # SQL delete语句
  14. str_num = 8
  15. sql = F"DELETE FROM BOOK WHERE book_id= {str_num}"
  16. print(sql)
  17. # 执行sql语句
  18. cursor.execute(sql)
  19. # 提交到数据库执行
  20. db.commit()
  21. except:
  22. # Rollback in case there is any error
  23. db.rollback()
  24. finally:
  25. db.close()
  26. mysql_conn()

5、

6、

7、

8、

推荐阅读