SQLAlchemy#
SQLAlchemy ist ein Python-SQL-Toolit und objektrelationaler Mapper.
SQLAlchemy ist bekannt für sein ORM, wobei es verschiedene Muster für das objektrelationale Mapping bereitstellt, wobei Klassen auf verschiedene Weise auf die Datenbank abgebildet werden können. Das Objektmodell und das Datenbankschema sind von Anfang an sauber entkoppelt.
SQLAlchemy unterscheidet sich grundlegend von anderen ORMs, da SQL und Details der Objekt-Relation nicht wegabstrahiert werden: alle Prozesse werden als eine Zusammenstellung einzelner Tools dargestellt.
SQLAlchemy unterstützt neben PostgreSQL auch weitere Dialekte relationaler Datenbanken:
Dialekte |
Python-Pakete |
import |
Dokumentation |
---|---|---|---|
postgresql |
psycopg2-binary |
psycopg2 |
|
mysql |
mysqlclient |
MySQLdb |
|
mssql |
pyodbc |
pyodbc |
|
oracle |
cx_oracle |
cx_Oracle |
Datenbankverbindung#
from sqlalchemy import create_engine
engine = create_engine('postgresql:///example', echo=True)
Datenmodell#
from sqlalchemy import Column, Integer, String, ForeignKey
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import relationship
Base = declarative_base()
class Address(Base):
__tablename__ = 'address'
id = Column(Integer, primary_key=True)
street = Column(String)
zipcode = Column(String)
country = Column(String, nullable=False)
class Contact(Base):
__tablename__ = 'contact'
id = Column(Integer, primary_key=True)
firstname = Column(String, nullable=False)
lastname = Column(String, nullable=False)
email = Column(String, nullable=False)
address_id = Column(Integer, ForeignKey(Address.id), nullable=False)
address = relationship('Address')
Tabellen erstellen#
Base.metadata.create_all(engine)
Create Session#
session = Session(engine)
address = Address(street='Birnbaumweg 10', zipcode='79115', country='Germany')
contact = Contact(
firstname='Veit', lastname='Schiele',
email='veit@cusy.io',
address=address
)
session.add(contact)
session.commit()
Read#
contact =
session.query(Contact).filter_by(email='veit@cusy.io').first()
print(contact.firstname)
contacts = session.query(Contact).all()
for contact in contacts:
print(contact.firstname)
contacts =
session.query(Contact).filter_by(email='veit@cusy.io').all()
for contact in contacts:
print(contact.firstname)
Update#
contact = session.query(Contact) \
.filter_by(email='veit@cusy.io').first()
contact.email = ‘info@veit-schiele.de'
session.add(contact)
session.commit()
Delete#
contact = session.query(Contact) \
.filter_by(email='info@veit-schiele.de').first()
session.delete(contact)
session.commit()
Erweiterungen#
- SQLAlchemy-Continuum
Versionierungs- und Revisionserweiterung für SQLAlchemy
- SQLAlchemy-Utc
SQLAlchemy-Typ zum Speichern von datetime.datetime-Werten
- SQLAlchemy-Utils
Verschiedene Utility-Funktionen, neue Datentypen und Hilfsprogramme für SQLAlchemy
- DEPOT
Framework zur einfachen Speicherung und Bereitstellung von Dateien in Webanwendungen
- SQLAlchemy-ImageAttach
SQLAlchemy-Erweiterung zum Anhängen von Bildern an Entitätsobjekte
- SQLAlchemy-Searchable
Im Volltext durchsuchbare Modelle für SQLAlchemy
Siehe auch