一行代码让Python连接所有数据库进行数据分析

对于大多数sqlboy和sqlgirl来说，他们只关心将我的sql提交到上面的数据库并返回给我一个pandasdataframe。所以必要的输入包括sql和数据库连接信息（包括地址、端口、账号密码）。fromsqlachemyimportcreate_engineimportpandasaspd#数据库连接地址engine=create_engine("mysql://root:123456@127.0.0.1:3306/database")#sqlsql="select*fromuserslimit10"df=pd.read_sql_query(sql,engine)presto#prestouri="presto://username:password@127.0.0.1:8080/database?source=pyhive"sql="select*fromuserslimit10"df=pd.read_sql_query(sql,create_engine(uri))mysql#mysqluri="mysql://root:123456@127.0.0.1:3306/database"sql="select*fromuserslimit10"df=pd.read_sql_query(sql,create_engine(uri))druid#druiduri="druid://<用户>:<密码>@<主机>:/druid/v2/sql"sql="selectcount(*)fromuserswhere_time>TIME_SHIFT...."df=pd.read_sql_query(sql,create_engine(uri))更多数据库连接方式：基本上市面上所有的数据库，只要是支持sqlalchemydialect和相应的python驱动的数据库，都可以不假思索按照上面的套路操作。简单省心。核心只需要一行代码：df=pd.read_sql_query(sql,create_engine(uri))