Python-操作mysql数据库

#获取到mysql数据库的连接对象conn=Connection(    host="127.0.0.1", #主机名    port=3308,  #端口，默认3306    user="root",  #用户    password="root"  #密码)######执行语句块###########打印mysql数据库版本信息，测试是否连接成功print(conn.get_server_info())  #5.7.36-log######执行语句块##########
#最后关闭连接conn.close()

#1、在test库下查询表信息conn.select_db("test02")#执行SQL语句cursor.execute("SELECT * FROM student t LIMIT 1,10 ")# cursor.execute("SELECT * FROM student t where t.s_id=2")#获取查询结果results:tuple=cursor.fetchall();#获取查询结果:(2, '小李500', 928, '1340', '上海4000', 1)for res in results:    print(f"获取查询结果:{res}")

##2、执行插入语句nums=cursor.execute("INSERT INTO student (s_id, student_name, age, phone, addr, test01) "                    "VALUES (3333334, '小李333', 333, '13403333', '上海3333', 33)")# conn.commit()  #或设置自动提交 autocommit=Trueprint(f"成功插入条数：{nums}")  #成功插入条数：1

###main面向对象数据分析案例，主业务逻辑代码##实现步骤# 1、设计一个类，可以完成数据的 封装Record# 2、设计一个抽象类，用于读取文件中的相关内容# 3、读取文件内容# 4、数据处理from pymysql import Connectionfrom classPack.example.ReadJsonFile import ReadJsonFilefrom classPack.example.ReadTxtFile import ReadTxtFilefrom classPack.example.Record import RecordreadtxtFile=ReadTxtFile("D:/2011年1月销售数据.txt")readJsonFile = ReadJsonFile("D:/2011年2月销售数据JSON.txt")text_data=readtxtFile.read_file_data()json_data=readJsonFile.read_file_data()record_list:list[Record]=text_data+json_data# print(f"record_list:{record_list}")# 获取到mysql数据库的连接对象conn = Connection(   host="127.0.0.1",  # 主机名   port=3308,  # 端口，默认3306   user="root",  # 用户   password="root",  # 密码   autocommit=True  # 自动提交)# 打印mysql数据库版本信息，测试是否连接成功print(conn.get_server_info())  # 5.7.36-log# 获取游标对象cursor = conn.cursor()# 1、在test库下查询表信息conn.select_db("test02")for record in record_list:    # 使用for循环插入数据库    sql=f"INSERT INTO orders (order_id, money, province, date)"         f" VALUES ('{record.order_id}', {record.money}, "         f"'{record.province}', '{record.date}')"    cursor.execute(sql)#关闭连接conn.close()