使用python中的pymysql库,并且转化为数组元组数据
目录
安装pymysql
编写read_mysql_data_by_pymsql.py
编写一个读取mysql,并且转化为元组的工具类
- 
安装pymysql
- pip install pymysql
 
 - 
编写read_mysql_data_by_pymsql.py
- 
# 导入包import pymysql# 配置数据库连接数据mysql_ip_address =\"127.0.0.1\"mysql_user = \"root\"mysql_password = \"root\"mysql_database = \"myst\"mysql_port = 3306mysql_charset = \"utf8\"# sql语句sql_string = \"select * from user\"# 装填数据mysql_connect = pymysql.connect( host=mysql_ip_address, port=mysql_port, user=mysql_user, password=mysql_password, database=mysql_database, charset=mysql_charset,)# 获取游标cursor = mysql_connect.cursor()# 执行sqlcursor.execute(sql_string)# 读取数据read_mysql_data = cursor.fetchall()# 存放数据print(list(read_mysql_data))print(read_mysql_data) - cursor.execute(sql) 执行完毕之后,然后使用list(result) 进行数据转化
 
 - 
 - 运行结果

- 可以看到数据库中的数据已经成功读取了,并且转化为元组了
 
 - 
编写一个读取mysql,并且转化为元组的工具类
 - 
# 导入包import pymysql# 配置数据库连接数据mysql_ip_address =\"127.0.0.1\"mysql_user = \"root\"mysql_password = \"root\"mysql_database = \"myst\"mysql_port = 3306mysql_charset = \"utf8\"query_sql = \"select * from user\"def read_mysql_data(host=mysql_ip_address, port=mysql_port, charset=mysql_charset, user=mysql_user, password=mysql_password, database=mysql_database, query_sql = query_sql): try: # 装填数据 mysql_connect = pymysql.connect( host=host, port=port, user=user, password=password, database=database, charset=charset, ) # 获取游标 cursor = mysql_connect.cursor() # 执行sql cursor.execute(query_sql) # 读取数据 mysql_from_data_list = cursor.fetchall() # 关闭游标 cursor.close() # 关闭连接 mysql_connect.close() except Exception as e: print(e) return list(mysql_from_data_list) print(read_mysql_data())- 可以在工具类上面编写自己数据库的参数
 - 也可以在使用工具时自动填写相关数据
 
         
-  可以在使用的时候填入sql,这里就不在测试了

 - 可以在进行执行的时候传入mysql的连接配置,也可以不传入,函数中传入的mysql配置优先级肯定是最高的,执行不同的sql需要从外部传入,这里默认写了一乐,这个是必须填写的参数。
- 这里使用了try-except捕捉异样
 
 
 


