python连接mysql数据库读取数据

时间：2021-12-24 14:27:30
#-*- coding:utf-8 -*-

#Author:'Lmc'

#DATE: 2019/4/28/0028 上午 11:22:47

#FileName:test.PY

import pymysql　　#导入连接mysql数据库模块

import pandas　　#导入pandas模块，数据导入及整理模块

#创建并初始化列表，保存取出的mysql数据

id = []

project_id = []

name = []

szse = []

#利用pymysql建立连接

conn = pymysql.connect(

    host = 'IP',

    user = '用户名',

    password = '密码',

    db = '数据库名称',

    charset = 'utf8'

)

database_name = conn.db　　#显示连接的的数据库名称并保存至database_name

print(database_name)　　#打印数据库名称

cursor = conn.cursor()　　#创建游标

sql = 'select * from 表名;'

cursor.execute(sql)　　#使用由标的方法execute(self, query, args):执行单条sql语句,接收的参数为sql语句本身和使用的参数列表,返回值为受影响的行数（此处引用黑DWADE博主的内容，注意此行超过79个字符，根据pep8的要求，每行不得超过79个字符）

conn.commit()　　#提交

database_info = cursor.fetchall()　　#fetchall(self):接收全部的返回结果行并赋值给database_info

#利用for循环，将查询结果添加至已创建列表

for row in database_info:

    id.append(database_info[0])

    project_id.append(database_info[1])

    name.append(database_info[2])

    szse.append(database_info[3])

df = pandas.DataFrame([id,project_id,name,szse]).T　　#使用pandas的DataFrame函数构造数据框并存储到df变量

df_head = df.head()

print(df_head)

cursor.close()　　#关闭游标

conn.close()　　#关闭数据库连接

相关文章