PostgreSQL 的學習及簡單的使用示例

準備工作， 下載依賴安裝sqlalchemy

pip install sqlalchemy

使用 sql 語句建表

from sqlalchemy import event
from sqlalchemy.orm import sessionmaker
from sqlalchemy import Table, Column, String, MetaData, create_engine, Integer

# 建立一個數據庫連結引擎 
engine = create_engine("postgresql+psycopg2://scott:tiger@host/dbname")
# # 建立一個 DBSession
# DB_Session = sessionmaker(bind=engine)
# session = DB_Session()
meta = MetaData(engine)
note_table = Table(
    "note",     # table name 
    meta,
    Column('name', String, default="*"),
    Column('age', Integer)
    
)
# 建立對應的資料庫連結
with engine.connect() as eng :
    # 表建立
    note_table.create()
    # 表插入資料
    set_info= note_table.insert().values(title='name', age=23)
    # 提交事物
    eng.execute(set_info)
    # 資料查詢
    select_statement = note_table.select()
    result_set = eng.execute(select_statement)
    for r in result_set:
        print(r)
    # 資料修改
    update_statement = note_table.update().where(note_table.c.age=="17").values(title="Some2016Film")
    eng.execute(update_statement)
    # 資料刪除
    delete_statement = note_table.delete().where(note_table.c.age == "22")
    eng.execute(delete_statement)
 

使用 orm 操作 sql

from sqlalchemy import create_engine  
from sqlalchemy import Column, String  
from sqlalchemy.ext.declarative import declarative_base  
from sqlalchemy.orm import sessionmaker

# 建立一個數據庫連結引擎 
engine = create_engine("postgresql+psycopg2://scott:tiger@host/dbname")
# # 建立一個 DBSession
DB_Session = sessionmaker(bind=engine)
session = DB_Session()
DataBase = declarative_base()
class Note(DataBase):
    # 設定表名
    __tablename__ = 'notes'
    title = Column(String, primary_key=True)
    text = Column(String)

# 建立表結構並插入新的資料
note_info = Note(title=str(44), text=str('34657'))
session.add(note_info)
session.commit()

# 資料獲取
notes = session.query(Note)  
for note in notes:  
    print(note.title)
# 資料修改
note_info.title = "Some2016Film"  
session.commit()
# 資料刪除
session.delete(note_info)
session.commit()