培训第二十五天（python中执行mysql操作并将python脚本共享）

mysql下载路径：

MySQL :: MySQL Community Downloads

 [root@2 ~]# vim py001.pya=3b=4print(a+b)print(a**2+b**2)[root@2 ~]# python py001.py 725[root@2 ~]# python3>>> import random>>> random<module 'random' from '/usr/lib64/python3.6/random.py'>>>> quit()[root@2 ~]# vim /usr/lib64/python3.6/random.py 

上午

1、通过frp内网穿透共享数据库信息

 [root@1 ~]# mysql -p'密码'mysql> create user 'li'@'%' identified by '1';mysql> create database test;mysql> grant all on test.* to 'li';[root@1 ~]# tar -xf frp_0.33.0_linux_amd64.tar.gz[root@1 ~]# cd frp_0.33.0_linux_amd64/[root@1 frp_0.33.0_linux_amd64]# vim frpc.ini [common]server_addr = 123.249.27.70server_port = 7000token=15773141955[mysql]type = tcplocal_ip = 127.0.0.1local_port = 3306remote_port = 6000[root@1 frp_0.33.0_linux_amd64]# ./frpc -c frpc.ini 访问公网ip的7500端口，查看控制面板

 在数据库连接工具上，使用公网ip与自己规定的端口号访问数据库

 对test数据库具有所有权限

2、在python中连接数据库并结合游标对数据库进行操作

前提：要有python3环境

pip3 config set global.index-url Simple Index //设置 pip3 的全局配置，将默认的 Python 包索引源（index-url）修改为清华大学的镜像源 https://pypi.tuna.tsinghua.edu.cn/simple

上面命令执行失败：执行该命令[root@2 ~]# python3 -m pip install --upgrade pip

1、设置清华镜像站（从国内下载安装包，提高下载和安装工具速度）

2、安装pandas数据分析工具（pandas是知名的数据分析工具，pandas有完整的读取数据的工具，以及DateFrame数据框架，用于保存从数据库中读取的数据）

3、安装pymysql连接器（oracle为开发者提供的python管理mysql的工具，通过这个工具，就可以在不替换原有代码的情况下，应对数据库软件的升级）

 [root@2 ~]# python3 -m pip install --upgrade pip    #将 pip 工具升级到最新版本[root@2 ~]# pip3 config set global.index-url https://pypi.tuna.tsinghua.edu.cn/simple #设置 pip3的全局配置[root@2 ~]# pip3 install pandas   #安装Python的pandas库[root@2 ~]# pip3 install pymysql   #用于安装pymysql库[root@2 ~]# python3>>> import pymysql as py    #以别名py导入pymysql库，可以使用更简洁的别名py来调用pymysql库中的函数和方法>>> import pandas as pd     #以别名py导入pandas库>>> py    #表示 Python 成功识别了导入的pymysql库，并能够展示关于这个模块的一些基本信息，包括它的位置<module 'pymysql' from '/usr/local/lib/python3.6/site-packages/pymysql/__init__.py'>>>> pd    #表示 Python 成功识别了导入的pandas库<module 'pandas' from '/usr/local/lib64/python3.6/site-packages/pandas/__init__.py'>>>> conn=py.connect(    #使用pymysql库建立了一个到指定MySQL数据库的连接，变量conn成功保存了这个数据库连接，可以通过它进行后续的数据操作... host='123.249.27.70',... user='abcd',... password='abcd',... database='test',... port=6001);>>> conn    #表明您成功创建了一个与 MySQL数据库的连接对象conn，0x7f529dda29b0是这个连接对象在内存中的地址<pymysql.connections.Connection object at 0x7f529dda29b0>>>> cursor=conn.cursor()  #创建一个游标对象 cursor>>> cursor<pymysql.cursors.Cursor object at 0x7f52b7ade710>>>> sql="select * from student"    #定义了一个SQL查询语句>>> sql'select * from student'>>> cursor.execute(sql)  #将您定义的SQL语句select * from student发送到数据库服务器执行5    #查询的结果会被存储在游标内部，您可以通过后续的操作来获取和处理这些结果>>> cursor.fetchall()    #获取所有的查询结果，以元组的形式返回一个包含所有行数据的列表((1, '章三', '男'), (2, '李四', '女'), (3, '小凤仙', '女'), (4, '章丘铁锅', '男'), (6, '孙颖莎', '女'))>>> cursor.description   #返回一个描述结果集中列的元组序列，通常包括列名、数据类型、显示大小、内部大小、精度、小数位数和是否可为空等(('id', 3, None, 11, 11, 0, False), ('name', 253, None, 180, 180, 0, False), ('gender', 253, None, 16, 16, 0, False))>>> res=cursor.fetchall()>>> res((1, '章三', '男'), (2, '李四', '女'), (3, '小凤仙', '女'), (4, '章丘铁锅', '男'), (6, '孙颖莎', '女'))>>> head=[]    # 创建一个head列表>>> desc=cursor.description>>> for var in desc:...     print(var)... ('id', 3, None, 11, 11, 0, False)('name', 253, None, 180, 180, 0, False)('gender', 253, None, 16, 16, 0, False)>>> for var in desc:...     print(var[0])... idnamegender>>> for var in desc:...     head.append(var[0])... >>>head['id', 'name', 'gender']>>> pd.DataFrame(data=res,columns=head)  #使用了pandas库创建了一个DataFrame，data=res 表示数据内容，columns=head 指定了列名id  name gender0   1    章三      男1   2    李四      女2   3   小凤仙      女3   4  章丘铁锅      男4   6   孙颖莎      女

下午

1、制作python脚本操作数据库

 [root@2 ~]# vim python_mysql.pyimport pymysql as pmimport pandasclass Python_Mysql_01(object):    #定义了一个名为Python_Mysql_01的类，用于与 MySQL 数据库进行交互并将查询结果转换为 pandas 的 DataFrame​def __init__(self):     #类的初始化方法，用于标识类的实例化操作print("test")​def getConn(self):   #用于建立与指定MySQL数据库的连接，并返回连接对象 connconn=pm.connect(host='123.249.27.70',user='abcd',password='abcd',database='test',port=6001)#               print(conn)return conndef getRes(self,cursor,sql):    #接收一个游标对象cursor和一个SQL语句 sql 。执行 SQL 语句并获取查询结果data，提取表头信息head，然后将结果和表头组成 DataFrame 并返回cursor.execute(sql)# 获得查询的数据data=cursor.fetchall()# 表头head=[item[0] for item in cursor.description]# 组成pandas数据框 DataFramereturn pandas.DataFrame(data=data,columns=head)​​if __name__=="__main__":# 初始化Python_Mysql_01类，创建实例，pmp，之后所有的方法都可以在实例中>调用pmp=Python_Mysql_01()    #实例化Python_Mysql_01类为pmp# 获得connconn=pmp.getConn()       #通过pmp调用getConn方法获取数据库连接conn# 获得游标cursor=conn.cursor()     #从conn获取游标cursor#       print(cursor)df=pmp.getRes(cursor,"select * from student")print(df)                #调用pmp的getRes方法执行select * from student语句，并将结果存储在df中，最后打印df[root@2 ~]# python3 python_mysql.py testid  name gender0   1    章三      男1   2    李四      女2   3   小凤仙      女3   4  章丘铁锅      男4   6   孙颖莎      女

2、总结

（1）和shell脚本一样python文件也可以称为py脚本，也是将python指令做一个集合

（2）为了脚本更加的智能化和自动化，添加选择语句（智能）循环语句（自动化）

（3）同时为了开发效率，可读性，做了方法，类，模块

3、修改脚本（添加input语句）

 conn=pm.connect(host=input("sign host_ip|name:"),user=input("sign database username:"),password=input("sign database password:"),database=input("sign database name:"),port=int(input("sign port no")))......tablename=input("sign tablename")df=pmp.getRes(cursor,"select * from "+tablename)[root@2 ~]# python3 python_mysql.pytestsign host_ip|name:123.249.27.70sign database username:abcdsign database password:abcdsign database name:testsign port no 6001sign tablenamestudentid  name gender0   1    章三      男1   2    李四      女2   3   小凤仙      女3   4  章丘铁锅      男4   6   孙颖莎      女

4、打包脚本生成可执行文件

pyinstaller --onefile python_mysql.py

--onefile 选项表示将所有的依赖和代码打包到一个单独的文件中，这样生成的可执行文件更便于分发和使用。

完成打包后，会在当前目录的 dist 文件夹中找到生成的可执行文件。可以将这个可执行文件拷贝到其他机器上（即使该机器没有安装 Python 环境）运行。

 [root@2 ~]# pip3 install pyinstaller    #安装 PyInstaller 库，用于将 Python 程序打包成可执行文件[root@2 ~]# which pyinstaller   #在系统的环境变量路径中查找 pyinstaller 可执行文件的位置[root@2 ~]# pyinstaller --onefile python_mysql.py   #使用 PyInstaller 将名为 python_mysql.py 的 Python 脚本打包成一个独立的可执行文件[root@2 ~]# lsanaconda-ks.cfg  dist      __pycache__           python_mysql.py    vbuild            py001.py  python_mysql_01.spec  python_mysql.spec[root@2 ~]# cd dist/[root@2 dist]# lspython_mysql[root@2 dist]# ./python_mysql testsign host_ip|name:123.249.27.70sign database username:abcdsign database password:abcdsign database name:testsign port no:6001sign tablename:studentid  name gender0   1    章三      男1   2    李四      女2   3   小凤仙      女3   4  章丘铁锅      男4   6   孙颖莎      女[root@2 ~]# python3 -m http.server 8000   #会在当前目录下启动一个简单的 HTTP 服务器，监听端口 8000[root@2 ~]# nohup python3 -m http.server 8000&    #将执行放入后台[1] 12237[root@2 ~]# nohup: 忽略输入并把输出追加到"nohup.out"# 浏览器访问ip加端口号

5、总结

（1）python脚本完成并配置成功之后，将脚本部署为一个二进制的可执行文件

（2）因为py文件要被执行需要在linux中安装python环境

（3）但是二进制可执行文件，不要环境，在任何linux主机上都可以执行

（4）步骤

安装pyinstaller

 pip3 install pyinstaller

使用pyinstaller生成可执行文件

 pyinstaller --onefile xxx.py# py文件中必须是有if __name__=="__main__";# xxxx

python模块发布web服务

 python3 -m http.server 9971