MySQL——使用Python操作MySQL

在Python中操作MySQL数据库时，我们使用较多的库是 PyMySQL,如果你选择使用 PyMySQL库，那么首先需要通过pip安装它。pip install pymysql命令就是用来安装PyMySQL的。

安装PyMySQL

• 1.打开你的命令行工具（如cmd、PowerShell、Terminal等）。

• 2.输入以下命令来安装PyMySQL：

  pip install pymysql
  

  如果你使用的是Python 3（这是大多数现代系统上的默认情况），并且系统中同时安装了Python 2，你可能需要使用pip3而不是pip：

  pip3 install pymysql
  

使用PyMySQL操作MySQL

• 注意：这里我们的MySQL环境是装在虚拟机中的，连接的也是虚拟机中的MySQl环境，因此需要在操作之前打开我们的虚拟机
• 直接上代码，在代码中进行讲解

import pymysql# 1、创建连接
# 需要传入一些参数：
# host -->  所在的主机名或者是域名或者是ip地址
# port -->  运行的端口号 --> 可以在虚拟机中进行查看指令如下（一般端口号都为3306）
#       ps -aux | grep mysql  找到MySQL运行的进程号
#       netstat -tnlp | grep mysql 的进程号 找到MySQL的端口
# user --> 用户名
# passwd --> 密码
# db --> 指定要操作的数据库
# 例如：
# 连接的变量名自定义
conn = pymysql.connect(host='master', port=3306, user='root', passwd='123456',db='Test')# 2、创建游标cursor，游标名称自定义 -->  用来执行后面的命令
cur = conn.cursor()
# cur.execute("use stu_test") # 切换数据库# 3、准备好你要执行的SQL语句，一般用变量接收
selerc_sql = 'select * from Test.Student'# 4、用游标中的execute方法执行sql语句
cur.execute(selerc_sql)# 5、如果有返回值 可以通过游标中的一些方法进行获取
print(cur.fetchone())  # 获取一条数据print(cur.fetchall())  # 获取所有数据print(cur.fetchmany(5))  # 获取指定大小的数据数据# 6、关闭游标，关闭连接
cur.close()
conn.close()

• 创建表并导入数据

import pymysqlif __name__ == '__main__':# 连接数据库conn = pymysql.connect(host='192.168.147.100',user='root',password='123456',port=3306,db='Test')# 建立游标cursor = conn.cursor()# 创建一个表名为’aa‘的表create_sql = 'create table aa (id int,name varchar(255))'# 用游标执行sql语句cursor.execute(create_sql)# 插入数据insert_sql = 'insert into aa values(1,"zxs")'# 用游标执行插入语句cursor.execute(insert_sql)# 执行执行插入语句时 需要提交事务 注意这里的方法是在连接数据库时，定义的变量中conn.commit()# 关闭游标、关闭连接cursor.close()conn.close()

注意：当我们写完代码，执行成功后，只能看到执行成功的提示，并看不到具体的表和数据，需要在虚拟机中进行查看，或者是在与虚拟机连接后的Navicat中进行查看。

• 插入数据—外界传入数据、传入多条数据

import pymysqlif __name__ == '__main__':conn = pymysql.connect(host='192.168.147.100',user='root',password='123456',port=3306,db='Test')cursor = conn.cursor()# 外界传入数据name_a = 'cyy'insert_sql = f'insert into aa values(0,"{name_a}")'cursor.execute(insert_sql)# 提交事务conn.commit()
############################################################ 写入多条数据 name_list = [('cyy1'), ('zc1'), ('cyy2')]# 这里第一个参数可以写 0 或者 null 是因为在创建表的时候将第一列设置成了自增列，若不是自增列还需自己给一个值# 因此传入数据时需要根据你表的结构传入# 所有的值接受都是%s, 还不需要引号insert_sql = 'insert into aa values(0,%s)' # 用 executemany 方法执行cursor.executemany(insert_sql, name_list)# 提交事务的过程可能会有数据插入不成功的时候，可以使用try Exception 的方法回滚事务try:conn.commit()except Exception as e:# 回滚事务conn.rollback()
#################################################################	# 表中有多列时，需传入多个数据也是一样的做法，有多少个数据，就写几个%s,一一对应即可# 这里’bb‘表中有 id name age 这三列 且id列为自增列name_list = [('cyy1', 23), ('zc1', 21), ('cyy2', 1)]insert_sql = 'insert into bb values(0,%s,%s)'   cursor.executemany(insert_sql, name_list)try:conn.commit()except Exception as e:# 回滚事务conn.rollback()
##############################################################cursor.close()conn.close()