pymysql（Pymysql查询返回的结果）



学习目标：掌握python执行SQL语句操作MySQL数据库软件

打开cmd下载安装

安装成功

connection就是一个类，conn类对象。

因为位置不知道，所以使用关键字传参。

表明我们可以正常连接到MySQL

python里面最后这个分号可以不用写，sql里面必须要写。

""" 演示python pymysql库的基础操作 """ from pymysql import Connection # 构建到MySQL数据库的链接 conn = Connection( host="localhost", # 主机名(ip) localhost表示自己电脑,ip可用127.0.0.1 port = 3306, # 端口 默认是3306 user = "root", # 账户 password = "" # 密码 ) # print(conn.get_server_info()) # MySQL的基础信息 # 执行非查询性质SQL cursor = conn.cursor() # 获取到游标卡尺 # 选择数据库 conn.select_db("sys") # 执行sql cursor.execute("create table test_pymysql(id int);") # 执行查询性质SQL # 关闭链接 conn.close()

结果以双层元组（元组嵌套）的形式展示。

将表格的形式变成了一个又一个的元组。

""" 演示python pymysql库的基础操作 """ from pymysql import Connection # 构建到MySQL数据库的链接 conn = Connection( host="localhost", # 主机名(ip) localhost表示自己电脑,ip可用127.0.0.1 port = 3306, # 端口 默认是3306 user = "root", # 账户 password = "" # 密码 ) # print(conn.get_server_info()) # MySQL的基础信息 # 执行非查询性质SQL cursor = conn.cursor() # 获取到游标卡尺 # 选择数据库 conn.select_db("sys") # 执行sql cursor.execute("select * from s") results = cursor.fetchall() for r in results: print(r) # 执行查询性质SQL # 关闭链接 conn.close()

学习目标：掌握python执行SQL语句插入数据到MySQL

需要通过commit确认

学习目标：使用SQL语句和pymysql库完成综合案例的开发

构建表

print输出演示一下。

完整代码演示

使用for循环，每循环一次，导入一次数据。

导入完数据后，使用f5刷新就能看到数据。

""" SQL 综合案例，读取文件，写入MySQL数据库中 """ from file_define import JsonFileReader,TexFileReader from data_define import Record from pymysql import Connection text_file_reader = TexFileReader("D:/2011年1月销售数据(1)(1).txt") json_file_reader = JsonFileReader("D:/2011年2月销售数据JSON(2).txt") jan_data: list[Record] = text_file_reader.read_data() # 一月份数据 feb_data: list[Record] = json_file_reader.read_data() # 二月份数据 # 将2个月份的数据合并为1个list来存储 all_data: list[Record] = jan_data + feb_data # 构造MySQL链接对象 conn = Connection( host="localhost", port=3306, user="root", password="", autocommit=True ) # 获得游标对象 cursor = conn.cursor() # 选择数据库 conn.select_db("py_sql") # 组织SQL语句 for record in all_data: sql = (f"insert into orders(order_date,order_id,money,province)" f" values('{record.date}','{record.order_id}',{record.money},'{record.province}')") cursor.execute(sql) conn.close() 

版权声明：

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若内容造成侵权、违法违规、事实不符，请将相关资料发送至xkadmin@xkablog.com进行投诉反馈，一经查实，立即处理！

转载请注明出处，原文链接：https://www.xkablog.com/sqlbc/41293.html