pyspark.pandas.read_sql_query¶
-
pyspark.pandas。read_sql_query( sql:str,反對:str,index_col:聯盟(str,列表(str),沒有一個)=沒有一個,* *選項:任何 )→pyspark.pandas.frame.DataFrame¶ -
讀DataFrame SQL查詢。
返回一個DataFrame對應結果集的查詢字符串。選擇提供一個index_col參數使用的一個列的索引,否則將使用默認的索引。
請注意
一些數據庫可能衝擊引發的問題:火花- 27596
- 參數
-
- sql SQL查詢的字符串
-
要執行的SQL查詢。
- 反對 str
-
一個JDBC URI可以提供為str。
請注意
必須JDBC URI URI URI而不是Python的數據庫。
- index_col 字符串或字符串列表,可選的,默認值:沒有
-
列設置為指數(s) (MultiIndex)。
- 選項 dict
-
所有其他選項直接傳遞到火花的JDBC數據源。
- 返回
-
- DataFrame
另請參閱
-
read_sql_table -
讀成DataFrame SQL數據庫表。
-
read_sql
例子
> > >ps。read_sql_query(“SELECT * FROM table_name”,“jdbc: postgresql: db_name”)