Pandas și Hello World al interogărilor SQL!
Aici vei folosi puterea lui pandas pentru a scrie rezultatele interogării SQL într-un DataFrame, într-o singură linie de cod Python!
Vei importa mai întâi pandas și vei crea engine-ul SQLite pentru 'Chinook.sqlite'. Apoi vei interoga baza de date pentru a selecta toate înregistrările din tabelul Album.
Amintește-ți că pentru a selecta toate înregistrările din tabelul Orders din baza de date Northwind, Hugo a executat următoarea comandă:
df = pd.read_sql_query("SELECT * FROM Orders", engine)
Acest exercițiu face parte din cursul
Introducere în importul datelor în Python
Instrucțiuni pentru exercițiu
- Importă pachetul
pandasfolosind aliasulpd. - Folosind funcția
create_engine(), creează un engine pentru baza de date SQLiteChinook.sqliteși atribuie-l variabileiengine. - Folosește funcția
read_sql_query()dinpandaspentru a atribui variabileidfDataFrame-ul cu rezultatele următoarei interogări: selectează toate înregistrările din tabelulAlbum. - Restul codului este inclus pentru a confirma că DataFrame-ul creat prin această metodă este identic cu cel creat prin metoda anterioară pe care ai învățat-o.
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
# Import packages
from sqlalchemy import create_engine
import ____ as ____
# Create engine: engine
# Execute query and store records in DataFrame: df
df = pd.read_sql_query(____, ____)
# Print head of DataFrame
print(df.head())
# Open engine in context manager and store query result in df1
with engine.connect() as con:
rs = con.execute("SELECT * FROM Album")
df1 = pd.DataFrame(rs.fetchall())
df1.columns = rs.keys()
# Confirm that both methods yield the same result
print(df.equals(df1))