扫码加入数据分析学习群

现在有一个数据库test2,数据库里面有一个表叫abc，具体如下图所示

有时候我们需要将数据库里的一些结果导入到python里面进行处理，那么如何建立连接和导入。可以用下面的命令：

#schema :架构、数据库
#安装pymql库 pip install pymysql
import pymysql
#1.创建一个连接对象从而让python与数据库进行连接。
connection1 =pymysql.connect(host="localhost",user="root",
                   password="12345",database="test2",
                   charset="utf8")
                   
'''
In [29]: type(connection1)
Out[29]: pymysql.connections.Connection

'''                   
                   
#2.利用Connection对象的cursor方法创建游标(光标)对象
cur = connection1.cursor()
#3.利用游标对象execute()方法执行SQL查询命令
#cur.execute(";") #这里填写正确的SQL查询语句  例如:
sql="SELECT * FROM test2.abc;"
cur.execute(sql)
result=cur.fetchall()
#通过fetchall方法可以获取到查询结果
#result是一个元组对象，
#这个元组里面的每个元素又是一个元组，
#每一个子元组里面放的是一行记录
#需要注意的是这个只有数据，没有字段名字
#可以用下面的几个命令把字段名字调出来。
columnDes = cur.description
#columnDes是一个元组对象，
#这个元组里面的每个元素又是一个元组，
#每一个子元组里面放的是每列指标的描述，包括变量的名字等
#然后把columnDes里面的字段名字调出来
columnnamelist=[i[0] for i in columnDes ]
#准备生成数据框所需要的值，将其变为合适的格式
values=[list(i) for i in result]
df = pd.DataFrame(values,columns=columnnamelist)
#df就是我们需要的数据框
#4.关闭游标对象
cur.close()