记录维维的每一篇Hello World

9.jpg

连接MySQL

  1. import pymysql
  3. sqlHost = "localhost"  # 本地连接
  4. sqlUser = "root"  # 用户
  5. sqlPassWord = "root"  # 密码
  6. # 打开数据库连接
  7. db = pymysql.connect(host=sqlHost, 
  8.                      user=sqlUser, 
  9.                      password=sqlPassWord,
  10.                      charset='utf8')

创建数据库并创建数据表

  1. # python + pymysql 创建数据库
  2. import pymysql
  4. # 创建连接
  5. sqlHost = "localhost"  # 本地连接
  6. sqlUser = "root"  # 用户
  7. sqlPassWord = "root"  # 密码
  8. sqlDatabase = "one"  # 数据库名字
  9. # 打开数据库连接
  10. db = pymysql.connect(host=sqlHost,
  11.                      user=sqlUser,
  12.                      password=sqlPassWord,
  13.                      charset='utf8')
  14. # 创建游标
  15. cursor = db.cursor()
  17. # 创建数据库的sql(如果数据库存在就不创建，防止异常)
  18. sql = "CREATE DATABASE IF NOT EXISTS %s" % sqlDatabase
  19. # 执行创建数据库的sql
  20. cursor.execute(sql)
  21. db.commit()
  22. db.close()
  23. # 二次连接
  24. # 打开数据库连接
  25. db = pymysql.connect(host=sqlHost,
  26.                      user=sqlUser,
  27.                      password=sqlPassWord,
  28.                      database=sqlDatabase,
  29.                      charset='utf8')
  30. # 使用cursor()方法获取操作游标
  31. cursor = db.cursor()
  32. # 使用execute方法执行SQL语句
  33. cursor.execute("SELECT VERSION()")
  34. # 数据表名字
  35. sqlTableName = "peoples"
  36. # 如果数据表已经存在使用 execute() 方法删除表。
  37. cursor.execute(f"DROP TABLE IF EXISTS {sqlTableName}")
  38. # 创建数据表SQL语句
  39. sqlCreateTable = f"""CREATE TABLE {sqlTableName} (
  40.          姓名 CHAR(20) NOT NULL,
  41.          手机号 CHAR(40),
  42.          公司 CHAR(100),
  43.          工作 CHAR(40),
  44.          邮箱 CHAR(100));"""
  45. cursor.execute(sqlCreateTable)
  46. # 提交到数据库运行并关闭
  47. db.commit()
  48. db.close()

创建数据表并插入数据

  1. from faker import Faker
  2. import pymysql
  4. sqlHost = "localhost"  # 本地连接
  5. sqlUser = "root"  # 用户
  6. sqlPassWord = "root"  # 密码
  7. sqlDatabase = "one"  # 数据库名字
  8. # 打开数据库连接
  9. db = pymysql.connect(host=sqlHost, 
  10.                      user=sqlUser, 
  11.                      password=sqlPassWord,
  12.                      database=sqlDatabase, 
  13.                      charset='utf8')
  14. # 使用cursor()方法获取操作游标
  15. cursor = db.cursor()
  16. # 使用execute方法执行SQL语句
  17. cursor.execute("SELECT VERSION()")
  18. # 数据表名字
  19. sqlTableName = "peoples"
  20. # 如果数据表已经存在使用 execute() 方法删除表。
  21. cursor.execute(f"DROP TABLE IF EXISTS {sqlTableName}")
  22. # 创建数据表SQL语句
  23. sqlCreateTable = f"""CREATE TABLE {sqlTableName} (
  24.          姓名 CHAR(20) NOT NULL,
  25.          手机号 CHAR(40),
  26.          公司 CHAR(100),
  27.          工作 CHAR(40),
  28.          邮箱 CHAR(100));"""
  29. cursor.execute(sqlCreateTable)
  30. # SQL 插入语句
  31. fd = Faker('zh_CN')
  32. for i in range(12):
  33.     sqlInsertData = "INSERT INTO %s (姓名, 手机号, 公司, 工作, 邮箱)"\
  34.                     "VALUES ('%s', '%s', '%s', '%s', '%s');" % \
  35.                     (sqlTableName,
  36.                      fd.name(),
  37.                      fd.phone_number(),
  38.                      fd.bs(),
  39.                      fd.job(),
  40.                      fd.company_email())
  41.     cursor.execute(sqlInsertData)
  43. # 提交到数据库执行
  44. db.commit()
  45. # 关闭数据库连接
  46. db.close()

查询数据

  1. from faker import Faker
  2. import pymysql
  4. sqlHost = "localhost"  # 本地连接
  5. sqlUser = "root"  # 用户
  6. sqlPassWord = "root"  # 密码
  7. sqlDatabase = "one"  # 数据库名字
  8. # 打开数据库连接
  9. db = pymysql.connect(host=sqlHost,
  10.                      user=sqlUser,
  11.                      password=sqlPassWord,
  12.                      database=sqlDatabase,
  13.                      charset='utf8')
  14. # 使用cursor()方法获取操作游标
  15. cursor = db.cursor()
  16. # 使用execute方法执行SQL语句
  17. cursor.execute("SELECT VERSION()")
  18. # 数据表名字
  19. sqlTableName = "peoples"
  20. # SQL 查询语句
  21. sqlSelectData = "SELECT * FROM %s" % sqlTableName
  22. try:
  23.     cursor.execute(sqlSelectData)
  24.     # 获取所有记录列表
  25.     results = cursor.fetchall()
  26.     for row in results:
  27.         print(row)
  28. except:
  29.     pass
  31. # 提交到数据库执行
  32. db.commit()
  33. # 关闭数据库连接
  34. db.close()

更新数据

  1. import pymysql
  3. sqlHost = "localhost"  # 本地连接
  4. sqlUser = "root"  # 用户
  5. sqlPassWord = "root"  # 密码
  6. sqlDatabase = "one"  # 数据库名字
  7. # 打开数据库连接
  8. db = pymysql.connect(host=sqlHost,
  9.                      user=sqlUser,
  10.                      password=sqlPassWord,
  11.                      database=sqlDatabase,
  12.                      charset='utf8')
  13. # 使用cursor()方法获取操作游标
  14. cursor = db.cursor()
  15. # 使用execute方法执行SQL语句
  16. cursor.execute("SELECT VERSION()")
  17. # 数据表名字
  18. sqlTableName = "peoples"
  19. # 更新语句
  20. sqlUpData = "UPDATE %s SET 公司 = 'New company'" % sqlTableName
  21. cursor.execute(sqlUpData)
  22. # 提交到数据库执行
  23. db.commit()
  24. # 关闭数据库连接
  25. db.close()

删除数据

  1. import pymysql
  3. sqlHost = "localhost"  # 本地连接
  4. sqlUser = "root"  # 用户
  5. sqlPassWord = "root"  # 密码
  6. sqlDatabase = "one"  # 数据库名字
  7. # 打开数据库连接
  8. db = pymysql.connect(host=sqlHost,
  9.                      user=sqlUser,
  10.                      password=sqlPassWord,
  11.                      database=sqlDatabase,
  12.                      charset='utf8')
  13. # 使用cursor()方法获取操作游标
  14. cursor = db.cursor()
  15. # 使用execute方法执行SQL语句
  16. cursor.execute("SELECT VERSION()")
  17. # 数据表名字
  18. sqlTableName = "peoples"
  19. # SQL删除记录语句
  20. sqlDeleteData = "DELETE FROM %s WHERE 工作 = '程序员'" % sqlTableName
  21. cursor.execute(sqlDeleteData)
  22. # 提交到数据库执行
  23. db.commit()
  24. # 关闭数据库连接
  25. db.close()

删除数据表

  1. import pymysql
  3. sqlHost = "localhost"  # 本地连接
  4. sqlUser = "root"  # 用户
  5. sqlPassWord = "root"  # 密码
  6. sqlDatabase = "one"  # 数据库名字
  7. # 打开数据库连接
  8. db = pymysql.connect(host=sqlHost,
  9.                      user=sqlUser,
  10.                      password=sqlPassWord,
  11.                      database=sqlDatabase,
  12.                      charset='utf8')
  13. # 使用cursor()方法获取操作游标
  14. cursor = db.cursor()
  15. # 使用execute方法执行SQL语句
  16. cursor.execute("SELECT VERSION()")
  17. # 数据表名字
  18. sqlTableName = "peoples"
  19. # table删除记录语句
  20. cursor.execute("DROP TABLE %s" % sqlTableName)
  21. # 提交到数据库执行
  22. db.commit()
  23. # 关闭数据库连接
  24. db.close()

删除数据库

  1. import pymysql
  3. sqlHost = "localhost"  # 本地连接
  4. sqlUser = "root"  # 用户
  5. sqlPassWord = "root"  # 密码
  6. sqlDatabase = "one"  # 数据库名字
  7. # 打开数据库连接
  8. db = pymysql.connect(host=sqlHost,
  9.                      user=sqlUser,
  10.                      password=sqlPassWord,
  11.                      database=sqlDatabase,
  12.                      charset='utf8')
  13. # 使用cursor()方法获取操作游标
  14. cursor = db.cursor()
  15. # 使用execute方法执行SQL语句
  16. cursor.execute("SELECT VERSION()")
  17. # database删除记录语句
  18. cursor.execute("DROP DATABASE %s" % 'one')
  19. # 提交到数据库执行
  20. db.commit()
  21. # 关闭数据库连接
  22. db.close()

注意事项

1、MySQL方言与python不兼容

2、增删改查等操作必须提交到数据库执行

3、数据库可视化工具推荐http://www.navicat.com.cn/download/navicat-premium，好用但需要付费

python环境

电脑：Windows10

python：3.10.4