การคิวรีฐานข้อมูลเชิงสัมพันธ์ใน Python

Python เบื้องต้น: การนำเข้าข้อมูล

Hugo Bowne-Anderson

Data Scientist at DataCamp

คิวรี SQL เบื้องต้น

SELECT * FROM Table_Name

คืนค่าทุกคอลัมน์และทุกแถวในตาราง
ตัวอย่าง:

SELECT * FROM Orders

จะใช้ SQLAlchemy และ pandas

ขั้นตอนการคิวรี SQL

นำเข้าแพ็กเกจและฟังก์ชัน
สร้าง database engine
เชื่อมต่อกับ engine
คิวรีฐานข้อมูล
บันทึกผลลัพธ์ลงใน DataFrame
ปิดการเชื่อมต่อ

คิวรี SQL แรกของคุณ

from sqlalchemy import create_engine
import pandas as pd

engine = create_engine('sqlite:///Northwind.sqlite')

con = engine.connect()

rs = con.execute("SELECT * FROM Orders")

df = pd.DataFrame(rs.fetchall())

con.close()

แสดงผลลัพธ์ของคิวรี

print(df.head())

       0      1   2                      3                      4 
0  10248  VINET   5   7/4/1996 12:00:00 AM   8/1/1996 12:00:00 AM   
1  10251  VICTE   3   7/8/1996 12:00:00 AM   8/5/1996 12:00:00 AM   
2  10254  CHOPS   5  7/11/1996 12:00:00 AM   8/8/1996 12:00:00 AM   
3  10256  WELLI   3  7/15/1996 12:00:00 AM  8/12/1996 12:00:00 AM   
4  10258  ERNSH   1  7/17/1996 12:00:00 AM  8/14/1996 12:00:00 AM

กำหนดชื่อคอลัมน์ให้ DataFrame

from sqlalchemy import create_engine
import pandas as pd
engine = create_engine('sqlite:///Northwind.sqlite')
con = engine.connect()
rs = con.execute("SELECT * FROM Orders")
df = pd.DataFrame(rs.fetchall())
df.columns = rs.keys()
con.close()

กำหนดชื่อคอลัมน์ให้ DataFrame

print(df.head())

   OrderID CustomerID  EmployeeID              OrderDate  
0    10248      VINET           5   7/4/1996 12:00:00 AM   
1    10251      VICTE           3   7/8/1996 12:00:00 AM   
2    10254      CHOPS           5  7/11/1996 12:00:00 AM   
3    10256      WELLI           3  7/15/1996 12:00:00 AM   
4    10258      ERNSH           1  7/17/1996 12:00:00 AM

การใช้ context manager

from sqlalchemy import create_engine
import pandas as pd
engine = create_engine('sqlite:///Northwind.sqlite')

with engine.connect() as con:
    rs = con.execute("SELECT OrderID, OrderDate, ShipName FROM Orders")
    df = pd.DataFrame(rs.fetchmany(size=5))
    df.columns = rs.keys()

มาฝึกกันเถอะ!

Python เบื้องต้น: การนำเข้าข้อมูล