mysql端口调用pymysql_使用PyMySQL操作MySQL数据库

安装

pip3 install PyMySQL或者python3 -m pip install PyMySQL

连接MySQL数据库

注意&＃xff1a;连接之前先确保你已经安装MySQL数据库

MYSQL_CONFIG &＃61; {

&＃39;host&＃39;: &＃39;localhost&＃39;, # IP地址

&＃39;port&＃39;: 3306, # 端口

&＃39;user&＃39;: &＃39;root&＃39;, # 用户名

&＃39;passwd&＃39;: &＃39;123456&＃39;, # 密码

&＃39;db&＃39;: &＃39;myclass&＃39;, # 数据库

&＃39;charset&＃39;: &＃39;utf8&＃39;, # 编码

}

conn &＃61; pymysql.connect(**MYSQL_CONFIG) # 数据库连接

cur &＃61; conn.cursor() # 游标对象

MYSQL_CONFIG中的指标为连接数据库的重要参数&＃xff0c;参数的相关说明请看以上注释&＃xff0c;相关参数的值请换成你自己的。

本人习惯将参数以字典的方式存储&＃xff0c;并在连接时用两个*号来对字典进行解包(有兴趣的小伙伴可以自行搜索python容器解包的相关知识)&＃xff0c;这样做的好处就是可以抽取关键数据&＃xff0c;并将数据放在可配置化脚本中。

当然&＃xff0c;你也可以用关键字参数的形式把数据写到connect()方法中&＃xff0c;如pymysql.connect(host &＃61; &＃39;localhost&＃39;, port &＃61; 3306, ...)

创建连接后我们可以得到一个数据库连接对象conn和游标对象cur

执行SQL查询语句

成功连接数据库后&＃xff0c;我们就可以执行相关的SQL语句来增删改查我们的数据了。

myclass数据库中存在student表&＃xff0c;我们执行SQL语句来查询student表中的数据

数据表如下

name

age

height

Mary

18

155.0

Tony

20

175.0

Lisa

19

165.5

执行SQL语句需要用到cur对象中的execute()方法

执行后获取数据的方法主要有以下三种&＃xff1a;

fetchone(): 获取下一个查询结果集&＃xff0c;结果集是一个对象&＃xff0c;第一次执行取SQL结果集的第一条数据

fetchmany(n): 获取前n条数据的结果集

fetchall(): 获取全部的数据结果集

fetchone

sql &＃61; "SELECT * FROM student"

n &＃61; cur.execute(sql) # 执行后得到数据的条数

for i in range(n):

print(f&＃39;--这是第{i &＃43; 1}条数据--&＃39;)

info &＃61; cur.fetchone()

print(info)

执行结果如下

--这是第1条数据--

(&＃39;Mary&＃39;, 18, 155.0)

--这是第2条数据--

(&＃39;Tony&＃39;, 20, 175.0)

--这是第3条数据--

(&＃39;Lisa&＃39;, 19, 165.5)

n值是执行查询语句返回的结果条数&＃xff0c;fetchone()第一次执行取的是第一条数据&＃xff0c;之后执行就是取下一条数据&＃xff0c;遍历n就可以取到每一条数据。

fetchmany

sql &＃61; "SELECT * FROM student"

n &＃61; cur.execute(sql) # 执行后得到数据的条数

info &＃61; cur.fetchmany(2) # 取前面两条数据

print(info)

执行结果如下

((&＃39;Mary&＃39;, 18, 155.0), (&＃39;Tony&＃39;, 20, 175.0))

fetchmany()可以取执行结果集的任意条数据&＃xff0c;如果取n则返回全部数据的数据集。

fetchall

sql &＃61; "SELECT * FROM student"

n &＃61; cur.execute(sql) # 执行后得到数据的条数

info &＃61; cur.fetchall() # 取所有数据

print(info)

执行结果如下

((&＃39;Mary&＃39;, 18, 155.0), (&＃39;Tony&＃39;, 20, 175.0), (&＃39;Lisa&＃39;, 19, 165.5))

fetchall()就是取执行结果的所有数据的数据集

执行SQL插入语句

上面已经对PyMySQL中SQL的查询方式进行了简单的说明和实现&＃xff0c;至于其他的增、删、改操作其实跟上面的查询操作差不多&＃xff0c;主要还是使用到cur对象的execute()方法来执行。

但是执行增、删、改操作时需要注意的是&＃xff0c;在使用execute()方法执行SQL语句后&＃xff0c;还要在后面加一句conn.commit()&＃xff0c;用于将事务提交到数据库执行。

如下

sql &＃61; "INSERT INTO student VALUES (&＃39;Ben&＃39;, 19, 166.5)"

cur.execute(sql) # 执行

conn.commit() # 提交

执行成功后&＃xff0c;可以通过查询方法fatchall查看结果&＃xff0c;结果如下

((&＃39;Mary&＃39;, 18, 155.0), (&＃39;Tony&＃39;, 20, 175.0), (&＃39;Lisa&＃39;, 19, 165.5), (&＃39;Ben&＃39;, 19, 166.5))

可以看到最后面多了一条新的数据&＃xff0c;说明数据插入成功。

删和改的操作跟插入是一样的&＃xff0c;在这里就不做过多演示了&＃xff0c;有兴趣的小伙伴可以自己尝试去实现。

务必记得要加上commit()语句哦&＃xff0c;否则执行后不会发生任何变化。

关闭数据库

在执行完增、删、改、查操作后&＃xff0c;最后一定记得要关闭游标和数据库连接&＃xff0c;以避免数据库资源的消耗和产生不同连接之间的冲突。

关闭语句如下

cur.close() # 关闭游标

conn.close() # 关闭数据库连接