学习目标:掌握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()
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容,请联系我们,一经查实,本站将立刻删除。
如需转载请保留出处:https://51itzy.com/kjqy/184125.html