10.PyMySQL模块

PyMySQL模块

1. 安装PyMySQL模块

   pip install pymysql
   

   ---

2. PyMySQL查询数据

   import pymysql
   # 连接数据库
   connection = pymysql.connect(host='127.0.0.1', user='root', password='123456', database='DB')
   # 获取游标对象，cursor=pymysql.cursors.DictCursor 表示返回字典类型的数据
   cursor = connection.cursor(cursor=pymysql.cursors.DictCursor)
   # 需要执行的sql语句，一般情况下Python只操作数据表中的数据，查询用户信息表中的user和password
   sql = 'select * from user_info where user=%s and password=%s;'
   # 执行MySQL命令，sql后面传入user和password参数，可以防止sql注入
   cursor.execute(sql,(user,password))
   
   # 获取执行MySQL命令的一个值
   result = cursor.fetchone()
   # 获取执行MySQL命令的多个值
   result = cursor.fetchmany(10)
   # 获取执行MySQL命令的所有值
   result = cursor.fetchall()
   
   # 关闭游标对象
   cursor.close()
   # 断开数据库连接
   connection.close()
   

   ---

3. PyMySQL增、删、改数据

   import pymysql
   # 连接数据库
   connection = pymysql.connect(host='127.0.0.1', user='root', password='123456', database='DB')
   # 获取游标对象
   cursor = connection.cursor(cursor=pymysql.cursors.DictCursor)
   # 需要执行的sql语句
   sql = 'insert into tb(username,password) values ("python","123456");'
   
   try:
       # 执行MySQL命令
       cursor.execute(sql)
       # 提交到数据库执行，查询不用写这句，但增、删、改需要
       connection.commit()
   except Exception as e:
       # 如果出现异常，打印异常
       print(e)
       # 如果出现异常则回滚try中的语句
       connection.rollback()
   
   # 关闭游标对象
   cursor.close()
   # 断开数据库连接
   connection.close()
   

   ---