python中有MySQLdb、pymysql,psycopg2(连接postgresql)等数据库模块,本文用pymysql模块连接mysql数据库,并且读取数据库表
看过其他博文的介绍,把程序和数据库比作两个目的地,将游标比喻成运输货车
很是形象生动!
我用的是Anaconda的编辑器spyder,首先要先下载pymysql模块到本地才能导入
导入pymysql模块
import pymysql as pysql
建立连接和准备sql
连接mysql数据库,将数据库名db,主机 host ,端口port,用户user,密码password,字符集编码charset, 指定游标类型:cursorclass 模块自带的游标类型为 pymysql.cursors.DictCursor,其他模块的游标像MySQLdb.cursors.Cursor,就看你用什么模块了。
connection = pysql.connect(host='', port=, user='',password='',db='',charset='utf8mb4', cursorclass = pysql.cursors.DictCursor)
参数参考:https://blog.csdn.net/qq_41432935/article/details/83001381
host – 数据库服务器所在的主机。 user – 登录用户名。 password – 登录用户密码。 database – 连接的数据库。 port – 数据库开放的端口。(默认: 3306) bind_address – 当客户端有多个网络接口时,请指定连接到主机的接口,参数可以是主机名或IP地址。 unix_socket – 使用unix套接字而不是tcp/ip。 charset – 连接字符集。 sql_mode – 默认SQL模式。 read_default_file – 指定my.cnf文件路径,以便从[client]部分读取参数。 conv – 要使用的转换字典,而不是默认值。 use_unicode – 是否默认为unicode字符串,对于Py3k,此选项默认为true。 client_flag – 发送到MySQL的自定义标志。 cursorclass – 使用自定义的游标类。 init_command – 建立连接时要运行的初始SQL语句。 connect_timeout – 建立连接超时时间。(默认: 10,最小: 1,最大: 31536000) read_default_group – 从配置文件中读取组。 compress – 不支持 named_pipe – 不支持 autocommit – 设置自动提交模式,不设置意味着使用数据库默认。(默认值: False) local_infile – 是否启用“LOAD LOCAL INFILE”命令的使用。(默认值: False) max_allowed_packet – 发送到服务器的数据包的最大大小 (以字节为单位,默认值: 16MB),仅用于限制小于默认值 (16KB) 的 “LOAD LOCAL INFILE” 数据包的大小。 defer_connect – 不要显式连接建设,等待连接调用。(默认值: False) db – 连接数据库别名(兼容MySQLdb) passwd – 密码输入别名(兼容MySQLdb) binary_prefix – 在bytes和bytearray上添加_binary前缀(默认: False)
可以根据上述的参数来设置mysql连接,接下来准备sql语句
select * from table
数据库连接成功,且sql也准备好之后,开始执行在数据库中执行sql语句 以达到我们的查询目的
pymysql是利用游标来执行sql语句的,游标就相当于是一辆货车,把程序中的sql语句运送到数据库中执行,所以要先叫一辆货车,即创建游标cursor
cursor = connection.cursor()
然后往货车上搬货物,让游标带上sql 执行语句
cursor.execute("sql语句")
返回的是执行语句后获得的表长度
当执行完sql语句后,现在这辆货车(游标cursor)已经满载货物(数据)了,怎么取货呢?
想从货车(游标cursor)上取一件货物看看
dataOne = cursor.fetchone()
fetchone()是取下一行的意思,还有
dataMany = cursor.fetchmany()
dataMany = cursor.fetchmany(5)
dataAll = cursor.fetchall()
.fetchmany() 是取几行,可以带参数,准确取出几行 .fetchall()是取全部数据
取完数据记得把数据库大门关了
connection.close() #关闭数据库连接
利用 pymysql连接数据库,读取表内容的功能已实现。
关于提交到数据库操作
connection.commit
只有在插入、更新、删除数据库表时,才需要将sql语句提交到数据库中操作,这时,只需要在sql语句执行(cursor.execute("sql语句"))后,添加上面这句“提交到数据库操作”,即可。