日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

市面上比較常用的數(shù)據(jù)庫(kù)包括mysql, presto, hive, druid, kylin, spark, elasticsearch等，作為一名數(shù)據(jù)分析師，面對(duì)不同的數(shù)據(jù)庫(kù)，是否有頭麻的情況。別擔(dān)心，使用python連接以上數(shù)據(jù)庫(kù)，你只需要一招，5行代碼即可。

在上黨等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒng)性、市場(chǎng)前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務(wù)理念，為客戶提供成都網(wǎng)站設(shè)計(jì)、網(wǎng)站制作 網(wǎng)站設(shè)計(jì)制作定制網(wǎng)站,公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),品牌網(wǎng)站設(shè)計(jì),成都全網(wǎng)營(yíng)銷(xiāo),成都外貿(mào)網(wǎng)站建設(shè),上黨網(wǎng)站建設(shè)費(fèi)用合理。

對(duì)于大部分sqlboys和sqlgirls而言，只關(guān)心我的sql提交到以上數(shù)據(jù)庫(kù)，返回給我一個(gè)pandas的dataframe即可。所以必要的輸入包括sql和數(shù)據(jù)庫(kù)連接信息(包括地址，port, 賬號(hào)密碼)即可。

 
 
 
 

  
  
  
  
from sqlachemy import create_engine  
  
  
  
  
import pandas as pd  
  
  
  
  
# 數(shù)據(jù)庫(kù)連接地址 
  
  
  
  
engine = create_engine("mysql://root:123456@127.0.0.1:3306/database") 
  
  
  
  
# 用戶要查詢的sql  
  
  
  
  
sql = "select * from users limit 10" 
  
  
  
  
df = pd.read_sql_query(sql, engine) 
 
 
 
 

presto

 
 
 
 

  
  
  
  
# presto 
  
  
  
  
uri = "presto://username:password@127.0.0.1:8080/database?source=pyhive" 
  
  
  
  
sql = "select * from users limit 10" 
  
  
  
  
df = pd.read_sql_query(sql, create_engine(uri)) 
 
 
 
 

mysql

 
 
 
 

  
  
  
  
# mysql 
  
  
  
  
uri = "mysql://root:123456@127.0.0.1:3306/database" 
  
  
  
  
sql = "select * from users limit 10" 
  
  
  
  
df = pd.read_sql_query(sql, create_engine(uri)) 
 
 
 
 

druid

 
 
 
 

  
  
  
  
# druid 
  
  
  
  
uri = "druid://:@:/druid/v2/sql" 
  
  
  
  
sql = "select count(*) from users where _time> TIME_SHIFT...." 
  
  
  
  
df = pd.read_sql_query(sql, create_engine(uri)) 
 
 
 
 

更多數(shù)據(jù)庫(kù)連接方式:

數(shù)據(jù)庫(kù)	示例
Apache Druid	druid://:@:/druid/v2/sql
Apache Hive	hive://hive@{hostname}:{port}/{database}
Apache Kylin	kylin://:@:/?=&=
Apache Spark SQL	hive://hive@{hostname}:{port}/{database}
ClickHouse	clickhouse://{username}:{password}@{hostname}:{port}/{database}
ElasticSearch	elasticsearch+http://{user}:{password}@{host}:9200/
Presto	presto://{user}@{host}:{port}/{database}?source={source}
MySQL	mysql://:@/

基本上市面上所有的數(shù)據(jù)庫(kù)，只要該數(shù)據(jù)庫(kù)支持sqlalchemy dialect和對(duì)應(yīng)的python driver，都可以按照上面的套路去無(wú)腦操作。簡(jiǎn)單省心。

核心只需要一行代碼即可：

 
 
 
 

  
  
  
  
df = pd.read_sql_query(sql, create_engine(uri)) 
 
 
 
 

分享標(biāo)題：一行代碼實(shí)現(xiàn)Python連接所有數(shù)據(jù)庫(kù)做數(shù)據(jù)分析
分享地址：http://www.5511xx.com/article/djjpjgc.html