pandas中使用sql语言 from pandasql imoport sqldf
使用
从pandasql包中可以导入sqldf,这是我们核心要使用的接口。它接收两个参数,第一个是合法的SQL语句。SQL具有的功能,例如聚合,条件查询,联结,where条件,子查询等等,它都支持。第二个是locals()或者globals()表示环境变量,它会识别目前已有的dataframe作为第一个参数中的表名。
关键语法
'''
data=pd.read_excel()
sql='' ''
result=sql(sql,locals()) #result就是dataframe格式
'''
pandas读取mysql数据库
总共需要用到三个库:1.pymsql 2.sqlalchemy 3.pandas
关键语法(数据库中获取dataframe)
'''
import pandas as pd
from sqlalchemy import create_engine
初始化数据库连接,使用pymysql模块
----------MySQL的用户:root, 密码:147369, 端口:3306,数据库:mydb
engine=create_engine('mysql+pymysql://root:147369@localhost:3306/mydb')
sql=' '
df=pd.read_sql_query(sql,engine)
'''
关键语法(dataframe导入数据库)
1.将新建的DataFrame储存为MySQL中的数据表,不储存index列
df.to_sql('mydf', engine, index= False)
网友评论