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.

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()