Pandas学习笔记13

1、导包

import pandas as pd import pymysql from sqlalchemy import create_engine

2、连接数据库 方法1：用pymysql库连接数据库的写法

conn = pymysql.connect( host = '127.0.0.1', user = 'root', password = 'root', db = 'qinlu', port = 3306, charset = 'utf8' ) # 打开游标 cur = conn.cursor() # 返回的是select查询结果的条数 cur.execute("select * from company_sql_csv where companySize='150-500人'") data = cur.fetchall() # 打印数data的信息，是个元祖的形式 data # 遍历data，得到我们想要的数据 for i in data: print(i[0], i[1], i[2]) # 关闭游标，关闭连接 cur.close() conn.close()

方法2：用pandas连接

sql = "select * from company_sql_csv where companySize='2000人以上' and companyShortName='1号店'" engine = create_engine('mysql+pymysql://root:root@127.0.0.1:3306/qinlu?charset=utf8') df = pd.read_sql(sql, engine) df