Daten aktualisieren - UPDATE

Nun sehen wir, wie man Daten mit SQLModel aktualisiert.

Weiter mit vorherigem Code

Wie zuvor machen wir dort weiter, wo wir mit dem vorherigen Code aufgehört haben.

👀 Vorschau der vollständigen Datei

Python 3.10+

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: int | None = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: int | None = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def select_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.age <= 35)
        results = session.exec(statement)
        for hero in results:
            print(hero)


def main():
    create_db_and_tables()
    create_heroes()
    select_heroes()


if __name__ == "__main__":
    main()

🤓 Andere Versionen und Varianten

Python 3.8+

from typing import Optional

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: Optional[int] = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: Optional[int] = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def select_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.age <= 35)
        results = session.exec(statement)
        for hero in results:
            print(hero)


def main():
    create_db_and_tables()
    create_heroes()
    select_heroes()


if __name__ == "__main__":
    main()

Denken Sie daran, die Datei database.db zu löschen, bevor Sie die Beispiele ausführen, um dieselben Ergebnisse zu erzielen.

Aktualisieren mit SQL

Überprüfen wir kurz, wie man Daten mit SQL aktualisiert.

UPDATE hero
SET age=16
WHERE name = "Spider-Boy"

Das bedeutet, mehr oder weniger

Hallo SQL-Datenbank 👋, ich möchte die Tabelle hero UPDATEn.

Bitte setzen Sie den Wert der Spalte age auf 16...

...für jede Zeile, WHERE der Wert der Spalte name gleich "Spider-Boy" ist.

Ähnlich wie bei SELECT-Anweisungen definiert der erste Teil die Spalten, mit denen gearbeitet werden soll: Welche Spalten müssen aktualisiert werden und mit welchem Wert. Die restlichen Spalten bleiben unverändert.

Und der zweite Teil mit WHERE definiert, für welche Zeilen diese Aktualisierung gelten soll.

In diesem Fall, da wir nur einen Helden mit dem Namen "Spider-Boy" haben, wird die Aktualisierung nur in dieser Zeile angewendet.

Info

Beachten Sie, dass im UPDATE das einzelne Gleichheitszeichen (=) für die **Zuweisung** steht, d. h. die Zuweisung eines Wertes zu einer Spalte.

Und in WHERE wird dasselbe einzelne Gleichheitszeichen (=) für den **Vergleich** zwischen zwei Werten verwendet, um übereinstimmende Zeilen zu finden.

Dies steht im Gegensatz zu Python und den meisten Programmiersprachen, wo ein einzelnes Gleichheitszeichen (=) für die Zuweisung und zwei Gleichheitszeichen (==) für Vergleiche verwendet werden.

Sie können das in DB Browser for SQLite ausprobieren.

Nach dieser Aktualisierung sehen die Daten in der Tabelle so aus, mit dem neuen Alter für Spider-Boy

id	name	secret_name	age
1	Deadpond	Dive Wilson	null
2	Spider-Boy	Pedro Parqueador	16 ✨
3	Rusty-Man	Tommy Sharp	48

Tipp

Es wird wahrscheinlich üblicher sein, die zu aktualisierende Zeile anhand der id zu finden, zum Beispiel

UPDATE hero
SET age=16
WHERE id = 2

Aber im obigen Beispiel habe ich name verwendet, um es anschaulicher zu machen.

Nun führen wir dieselbe Aktualisierung im Code mit SQLModel durch.

Um dieselben Ergebnisse zu erzielen, löschen Sie die Datei database.db, bevor Sie die Beispiele ausführen.

Aus der Datenbank lesen

Wir beginnen damit, den Helden "Spider-Boy" auszuwählen. Dies ist derjenige, den wir aktualisieren werden.

Python 3.10+

# Code above omitted 👆

def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

# Code below omitted 👇

👀 Vorschau der vollständigen Datei

Python 3.10+

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: int | None = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: int | None = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

🤓 Andere Versionen und Varianten

Python 3.8+

from typing import Optional

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: Optional[int] = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: Optional[int] = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

Vergessen wir nicht, die Funktion update_heroes() zur Funktion main() hinzuzufügen, damit wir sie beim Ausführen des Programms von der Kommandozeile aufrufen.

Python 3.10+

# Code above omitted 👆

def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

👀 Vorschau der vollständigen Datei

Python 3.10+

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: int | None = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: int | None = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

🤓 Andere Versionen und Varianten

Python 3.8+

from typing import Optional

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: Optional[int] = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: Optional[int] = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

Bis zu diesem Punkt wird die Ausführung im Kommandozeile Folgendes ausgeben:

$ python app.py

// Some boilerplate and previous output omitted 😉

// The SELECT with WHERE
INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
FROM hero
WHERE hero.name = ?
INFO Engine [no key 0.00017s] ('Spider-Boy',)

// Print the hero as obtained from the database
Hero: name='Spider-Boy' secret_name='Pedro Parqueador' age=None id=2

Tipp

Beachten Sie, dass der Held zu diesem Zeitpunkt noch kein Alter hat.

Einen Feldwert setzen

Nachdem Sie ein hero-Objekt haben, können Sie einfach den Wert des Feldes (das Attribut, das eine Spalte repräsentiert) festlegen, den Sie möchten.

In diesem Fall setzen wir das age auf 16.

Python 3.10+

# Code above omitted 👆

def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16

# Code below omitted 👇

👀 Vorschau der vollständigen Datei

Python 3.10+

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: int | None = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: int | None = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

🤓 Andere Versionen und Varianten

Python 3.8+

from typing import Optional

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: Optional[int] = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: Optional[int] = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

Den Helden zur Sitzung hinzufügen

Da das Heldenobjekt im Speicher eine Änderung erfahren hat, in diesem Fall ein neuer Wert für age, müssen wir es zur Sitzung hinzufügen.

Dies ist dasselbe, was wir beim Erstellen neuer Heldeninstanzen getan haben.

Python 3.10+

# Code above omitted 👆

def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)

# Code below omitted 👇

👀 Vorschau der vollständigen Datei

Python 3.10+

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: int | None = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: int | None = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

🤓 Andere Versionen und Varianten

Python 3.8+

from typing import Optional

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: Optional[int] = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: Optional[int] = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

Die Sitzung committen

Um die aktuellen Änderungen in der Sitzung zu speichern, committen Sie diese.

Dies speichert den aktualisierten Helden in der Datenbank.

Python 3.10+

# Code above omitted 👆

def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()

# Code below omitted 👇

👀 Vorschau der vollständigen Datei

Python 3.10+

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: int | None = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: int | None = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

🤓 Andere Versionen und Varianten

Python 3.8+

from typing import Optional

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: Optional[int] = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: Optional[int] = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

Es werden auch alle anderen Elemente gespeichert, die der Sitzung hinzugefügt wurden.

Wenn Sie beispielsweise auch neue Helden erstellt und diese Objekte zuvor der Sitzung hinzugefügt hatten, würden diese nun ebenfalls mit diesem einzigen Commit gespeichert werden.

Dieser Commit erzeugt diese Ausgabe:

$ python app.py

// Some boilerplate output omitted 😉

// Previous output omitted 🙈

// The SQL to update the hero in the database
INFO Engine UPDATE hero SET age=? WHERE hero.id = ?
INFO Engine [generated in 0.00017s] (16, 2)
INFO Engine COMMIT

Das Objekt aktualisieren

Zu diesem Zeitpunkt ist der Held in der Datenbank aktualisiert und die neuen Daten sind dort gespeichert.

Die Daten im Objekt würden automatisch aktualisiert, wenn wir auf ein Attribut zugreifen würden, z. B. hero.name.

Aber in diesem Beispiel greifen wir auf kein Attribut zu, wir geben nur das Objekt aus. Und wir wollen auch explizit sein, also werden wir das Objekt direkt mit .refresh() aktualisieren.

Python 3.10+

# Code above omitted 👆

def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)

# Code below omitted 👇

👀 Vorschau der vollständigen Datei

Python 3.10+

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: int | None = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: int | None = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

🤓 Andere Versionen und Varianten

Python 3.8+

from typing import Optional

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: Optional[int] = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: Optional[int] = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

Diese Aktualisierung löst dieselbe SQL-Abfrage aus, die automatisch durch den Zugriff auf ein Attribut ausgelöst würde. Sie erzeugt also diese Ausgabe:

$ python app.py

// Some boilerplate output omitted 😉

// Previous output omitted 🙈

// The SQL to SELECT the fresh hero data
INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
FROM hero
WHERE hero.id = ?
INFO Engine [generated in 0.00018s] (2,)

Das aktualisierte Objekt ausgeben

Jetzt können wir einfach den Helden ausgeben.

Python 3.10+

# Code above omitted 👆

def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)

# Code below omitted 👇

👀 Vorschau der vollständigen Datei

Python 3.10+

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: int | None = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: int | None = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

🤓 Andere Versionen und Varianten

Python 3.8+

from typing import Optional

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: Optional[int] = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: Optional[int] = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")
        results = session.exec(statement)
        hero = results.one()
        print("Hero:", hero)

        hero.age = 16
        session.add(hero)
        session.commit()
        session.refresh(hero)
        print("Updated hero:", hero)


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

Da wir ihn direkt nach der Aktualisierung aktualisiert haben, enthält er aktuelle Daten, einschließlich des neuen age, das wir gerade aktualisiert haben.

Wenn wir ihn also ausgeben, wird das neue age angezeigt.

$ python app.py

// Some boilerplate output omitted 😉

// Previous output omitted 🙈

// Print the hero with the new age
Updated hero: name='Spider-Boy' secret_name='Pedro Parqueador' age=16 id=2

Den Code überprüfen

Nun überprüfen wir all diesen Code.

Python 3.10+Python 3.8+

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: int | None = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: int | None = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")  # (1)!
        results = session.exec(statement)  # (2)!
        hero = results.one()  # (3)!
        print("Hero:", hero)  # (4)!

        hero.age = 16  # (5)!
        session.add(hero)  # (6)!
        session.commit()  # (7)!
        session.refresh(hero)  # (8)!
        print("Updated hero:", hero)  # (9)!


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

1. Wählen Sie den Helden aus, mit dem wir arbeiten werden.

2. Führen Sie die Abfrage mit dem Auswahlanweisungsobjekt aus.

   Dies erzeugt die Ausgabe

   INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
   FROM hero
   WHERE hero.name = ?
   INFO Engine [no key 0.00017s] ('Spider-Boy',)
   

3. Holen Sie sich ein Heldenobjekt, wobei genau eines erwartet wird.

   Tipp

   Dies stellt sicher, dass nicht mehr als einer vorhanden ist und dass genau einer vorhanden ist, nicht None.

   Dies würde niemals None zurückgeben, sondern eine Ausnahme auslösen.

4. Geben Sie das Heldenobjekt aus.

   Dies erzeugt die Ausgabe

   Hero: name='Spider-Boy' secret_name='Pedro Parqueador' age=None id=2
   

5. Setzen Sie das Feld age des Helden auf den neuen Wert 16.

   Nun hat das hero-Objekt im Speicher einen anderen Wert für das Alter, aber es ist noch nicht in der Datenbank gespeichert.

6. Fügen Sie den Helden zur Sitzung hinzu.

   Dies legt es an diesen temporären Ort in der Sitzung, bevor es committet wird.

   Es ist aber noch nicht in der Datenbank gespeichert.

7. Committen Sie die Sitzung.

   Dies speichert den aktualisierten Helden in der Datenbank.

   Und dies erzeugt die Ausgabe:

   INFO Engine UPDATE hero SET age=? WHERE hero.id = ?
   INFO Engine [generated in 0.00017s] (16, 2)
   INFO Engine COMMIT
   

8. Aktualisieren Sie das Heldenobjekt, um die aktuellen Daten zu erhalten, einschließlich des gerade committeten Alters.

   Dies erzeugt die Ausgabe

   INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
   FROM hero
   WHERE hero.id = ?
   INFO Engine [generated in 0.00018s] (2,)
   

9. Geben Sie das aktualisierte Heldenobjekt aus.

   Dies erzeugt die Ausgabe

   Updated hero: name='Spider-Boy' secret_name='Pedro Parqueador' age=16 id=2
   

from typing import Optional

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: Optional[int] = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: Optional[int] = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")  # (1)!
        results = session.exec(statement)  # (2)!
        hero = results.one()  # (3)!
        print("Hero:", hero)  # (4)!

        hero.age = 16  # (5)!
        session.add(hero)  # (6)!
        session.commit()  # (7)!
        session.refresh(hero)  # (8)!
        print("Updated hero:", hero)  # (9)!


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

1. Wählen Sie den Helden aus, mit dem wir arbeiten werden.

2. Führen Sie die Abfrage mit dem Auswahlanweisungsobjekt aus.

   Dies erzeugt die Ausgabe

   INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
   FROM hero
   WHERE hero.name = ?
   INFO Engine [no key 0.00017s] ('Spider-Boy',)
   

3. Holen Sie sich ein Heldenobjekt, wobei genau eines erwartet wird.

   Tipp

   Dies stellt sicher, dass nicht mehr als einer vorhanden ist und dass genau einer vorhanden ist, nicht None.

   Dies würde niemals None zurückgeben, sondern eine Ausnahme auslösen.

4. Geben Sie das Heldenobjekt aus.

   Dies erzeugt die Ausgabe

   Hero: name='Spider-Boy' secret_name='Pedro Parqueador' age=None id=2
   

5. Setzen Sie das Feld age des Helden auf den neuen Wert 16.

   Nun hat das hero-Objekt im Speicher einen anderen Wert für das Alter, aber es ist noch nicht in der Datenbank gespeichert.

6. Fügen Sie den Helden zur Sitzung hinzu.

   Dies legt es an diesen temporären Ort in der Sitzung, bevor es committet wird.

   Es ist aber noch nicht in der Datenbank gespeichert.

7. Committen Sie die Sitzung.

   Dies speichert den aktualisierten Helden in der Datenbank.

   Und dies erzeugt die Ausgabe:

   INFO Engine UPDATE hero SET age=? WHERE hero.id = ?
   INFO Engine [generated in 0.00017s] (16, 2)
   INFO Engine COMMIT
   

8. Aktualisieren Sie das Heldenobjekt, um die aktuellen Daten zu erhalten, einschließlich des gerade committeten Alters.

   Dies erzeugt die Ausgabe

   INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
   FROM hero
   WHERE hero.id = ?
   INFO Engine [generated in 0.00018s] (2,)
   

9. Geben Sie das aktualisierte Heldenobjekt aus.

   Dies erzeugt die Ausgabe

   Updated hero: name='Spider-Boy' secret_name='Pedro Parqueador' age=16 id=2
   

Tipp

Schauen Sie sich die Nummernblasen an, um zu sehen, was jede Codezeile tut.

Mehrere Aktualisierungen

Der Aktualisierungsprozess mit SQLModel ist mehr oder weniger derselbe wie bei der Erstellung neuer Objekte: Sie fügen sie zur Sitzung hinzu und committen sie dann.

Das bedeutet auch, dass Sie mehrere Felder (Attribute, Spalten) gleichzeitig aktualisieren können und auch mehrere Objekte (Helden) gleichzeitig aktualisieren können.

Python 3.10+Python 3.8+

# Code above omitted 👆

def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")  # (1)!
        results = session.exec(statement)  # (2)!
        hero_1 = results.one()  # (3)!
        print("Hero 1:", hero_1)  # (4)!

        statement = select(Hero).where(Hero.name == "Captain North America")  # (5)!
        results = session.exec(statement)  # (6)!
        hero_2 = results.one()  # (7)!
        print("Hero 2:", hero_2)  # (8)!

        hero_1.age = 16  # (9)!
        hero_1.name = "Spider-Youngster"  # (10)!
        session.add(hero_1)  # (11)!

        hero_2.name = "Captain North America Except Canada"  # (12)!
        hero_2.age = 110  # (13)!
        session.add(hero_2)  # (14)!

        session.commit()  # (15)!
        session.refresh(hero_1)  # (16)!
        session.refresh(hero_2)  # (17)!

        print("Updated hero 1:", hero_1)  # (18)!
        print("Updated hero 2:", hero_2)  # (19)!
    # (20)!

# Code below omitted 👇

1. Wählen Sie den Helden Spider-Boy aus.

2. Führen Sie die Auswahlanweisung aus.

   Dies erzeugt die Ausgabe

   INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
   FROM hero
   WHERE hero.name = ?
   INFO Engine [no key 0.00018s] ('Spider-Boy',)
   

3. Holen Sie sich ein Heldenobjekt, das einzige, das für Spider-Boy dort sein sollte.

4. Geben Sie diesen Helden aus.

   Dies erzeugt die Ausgabe

   Hero 1: name='Spider-Boy' secret_name='Pedro Parqueador' age=None id=2
   

5. Wählen Sie einen weiteren Helden aus.

6. Führen Sie die Auswahlanweisung aus.

   Dies erzeugt die Ausgabe

   INFO Engine BEGIN (implicit)
   INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
   FROM hero
   WHERE hero.name = ?
   INFO Engine [no key 0.00020s] ('Captain North America',)
   

   Tipp

   Sehen Sie das BEGIN oben?

   Dies ist SQLAlchemy, das automatisch eine Transaktion für uns startet.

   Auf diese Weise könnten wir die letzten Änderungen (falls vorhanden) rückgängig machen, wenn wir wollten, auch wenn die SQL-Befehle zur Erstellung bereits an die Datenbank gesendet wurden.

7. Holen Sie sich ein Heldenobjekt für diese neue Abfrage.

   Das einzige, das für Captain North America dort sein sollte.

8. Geben Sie diesen zweiten Helden aus.

   Dies erzeugt die Ausgabe

   Hero 2: name='Captain North America' secret_name='Esteban Rogelios' age=93 id=7
   

9. Aktualisieren Sie das Alter für den ersten Helden.

   Setzen Sie den Wert des Attributs age auf 16.

   Dies aktualisiert das Heldenobjekt im Speicher, aber noch nicht in der Datenbank.

10. Aktualisieren Sie den Namen des ersten Helden.

    Nun wird der Name des Helden nicht mehr "Spider-Boy", sondern "Spider-Youngster" sein.

    Auch dies aktualisiert das Objekt im Speicher, aber noch nicht in der Datenbank.

11. Fügen Sie diesen ersten Helden zur Sitzung hinzu.

    Dies legt ihn in den temporären Speicher der Sitzung, bevor er in die Datenbank committet wird.

    Es ist noch nicht gespeichert.

12. Aktualisieren Sie den Namen des zweiten Helden.

    Nun hat der Held etwas mehr Präzision im Namen. 😜

    Dies aktualisiert das Objekt im Speicher, aber noch nicht in der Datenbank.

13. Aktualisieren Sie das Alter des zweiten Helden.

    Dies aktualisiert das Objekt im Speicher, aber noch nicht in der Datenbank.

14. Fügen Sie den zweiten Helden zur Sitzung hinzu.

    Dies legt ihn in den temporären Speicher der Sitzung, bevor er in die Datenbank committet wird.

15. Committen Sie alle Änderungen, die in der Sitzung verfolgt wurden.

    Dies committet alles in einem einzigen Batch.

    Dies erzeugt die Ausgabe

    INFO Engine UPDATE hero SET name=?, age=? WHERE hero.id = ?
    INFO Engine [generated in 0.00028s] (('Spider-Youngster', 16, 2), ('Captain North America Except Canada', 110, 7))
    INFO Engine COMMIT
    

    Tipp

    Sehen Sie, wie SQLAlchemy (das SQLModel unterstützt) das SQL optimiert, um so viel Arbeit wie möglich in einem einzigen Batch zu erledigen.

    Hier werden beide Helden in einer einzigen SQL-Abfrage aktualisiert.

16. Aktualisieren Sie den ersten Helden.

    Dies erzeugt die Ausgabe

    INFO Engine BEGIN (implicit)
    INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
    FROM hero
    WHERE hero.id = ?
    INFO Engine [generated in 0.00023s] (2,)
    

    Tipp

    Da wir gerade eine SQL-Transaktion mit COMMIT committet haben, wird SQLAlchemy automatisch eine neue Transaktion mit BEGIN starten.

17. Aktualisieren Sie den zweiten Helden.

    Dies erzeugt die Ausgabe

    INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
    FROM hero
    WHERE hero.id = ?
    INFO Engine [cached since 0.001709s ago] (7,)
    

    Tipp

    SQLAlchemy verwendet immer noch die vorherige Transaktion, sodass es keine neue erstellen muss.

18. Geben Sie den ersten Helden aus, nun aktualisiert.

    Dies erzeugt die Ausgabe

    Updated hero 1: name='Spider-Youngster' secret_name='Pedro Parqueador' age=16 id=2
    

19. Geben Sie den zweiten Helden aus, nun aktualisiert.

    Dies erzeugt die Ausgabe

    Updated hero 2: name='Captain North America Except Canada' secret_name='Esteban Rogelios' age=110 id=7
    

20. Hier endet die with-Blockanweisung, sodass die Sitzung ihren abschließenden Code ausführen kann.

    Die Sitzung wird alle Änderungen in der letzten Transaktion, die nicht committet wurden, ROLLBACKen (rückgängig machen).

    Dies erzeugt die Ausgabe

    INFO Engine ROLLBACK
    

# Code above omitted 👆

def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")  # (1)!
        results = session.exec(statement)  # (2)!
        hero_1 = results.one()  # (3)!
        print("Hero 1:", hero_1)  # (4)!

        statement = select(Hero).where(Hero.name == "Captain North America")  # (5)!
        results = session.exec(statement)  # (6)!
        hero_2 = results.one()  # (7)!
        print("Hero 2:", hero_2)  # (8)!

        hero_1.age = 16  # (9)!
        hero_1.name = "Spider-Youngster"  # (10)!
        session.add(hero_1)  # (11)!

        hero_2.name = "Captain North America Except Canada"  # (12)!
        hero_2.age = 110  # (13)!
        session.add(hero_2)  # (14)!

        session.commit()  # (15)!
        session.refresh(hero_1)  # (16)!
        session.refresh(hero_2)  # (17)!

        print("Updated hero 1:", hero_1)  # (18)!
        print("Updated hero 2:", hero_2)  # (19)!
    # (20)!

# Code below omitted 👇

1. Wählen Sie den Helden Spider-Boy aus.

2. Führen Sie die Auswahlanweisung aus.

   Dies erzeugt die Ausgabe

   INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
   FROM hero
   WHERE hero.name = ?
   INFO Engine [no key 0.00018s] ('Spider-Boy',)
   

3. Holen Sie sich ein Heldenobjekt, das einzige, das für Spider-Boy dort sein sollte.

4. Geben Sie diesen Helden aus.

   Dies erzeugt die Ausgabe

   Hero 1: name='Spider-Boy' secret_name='Pedro Parqueador' age=None id=2
   

5. Wählen Sie einen weiteren Helden aus.

6. Führen Sie die Auswahlanweisung aus.

   Dies erzeugt die Ausgabe

   INFO Engine BEGIN (implicit)
   INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
   FROM hero
   WHERE hero.name = ?
   INFO Engine [no key 0.00020s] ('Captain North America',)
   

   Tipp

   Sehen Sie das BEGIN oben?

   Dies ist SQLAlchemy, das automatisch eine Transaktion für uns startet.

   Auf diese Weise könnten wir die letzten Änderungen (falls vorhanden) rückgängig machen, wenn wir wollten, auch wenn die SQL-Befehle zur Erstellung bereits an die Datenbank gesendet wurden.

7. Holen Sie sich ein Heldenobjekt für diese neue Abfrage.

   Das einzige, das für Captain North America dort sein sollte.

8. Geben Sie diesen zweiten Helden aus.

   Dies erzeugt die Ausgabe

   Hero 2: name='Captain North America' secret_name='Esteban Rogelios' age=93 id=7
   

9. Aktualisieren Sie das Alter für den ersten Helden.

   Setzen Sie den Wert des Attributs age auf 16.

   Dies aktualisiert das Heldenobjekt im Speicher, aber noch nicht in der Datenbank.

10. Aktualisieren Sie den Namen des ersten Helden.

    Nun wird der Name des Helden nicht mehr "Spider-Boy", sondern "Spider-Youngster" sein.

    Auch dies aktualisiert das Objekt im Speicher, aber noch nicht in der Datenbank.

11. Fügen Sie diesen ersten Helden zur Sitzung hinzu.

    Dies legt ihn in den temporären Speicher der Sitzung, bevor er in die Datenbank committet wird.

    Es ist noch nicht gespeichert.

12. Aktualisieren Sie den Namen des zweiten Helden.

    Nun hat der Held etwas mehr Präzision im Namen. 😜

    Dies aktualisiert das Objekt im Speicher, aber noch nicht in der Datenbank.

13. Aktualisieren Sie das Alter des zweiten Helden.

    Dies aktualisiert das Objekt im Speicher, aber noch nicht in der Datenbank.

14. Fügen Sie den zweiten Helden zur Sitzung hinzu.

    Dies legt ihn in den temporären Speicher der Sitzung, bevor er in die Datenbank committet wird.

15. Committen Sie alle Änderungen, die in der Sitzung verfolgt wurden.

    Dies committet alles in einem einzigen Batch.

    Dies erzeugt die Ausgabe

    INFO Engine UPDATE hero SET name=?, age=? WHERE hero.id = ?
    INFO Engine [generated in 0.00028s] (('Spider-Youngster', 16, 2), ('Captain North America Except Canada', 110, 7))
    INFO Engine COMMIT
    

    Tipp

    Sehen Sie, wie SQLAlchemy (das SQLModel unterstützt) das SQL optimiert, um so viel Arbeit wie möglich in einem einzigen Batch zu erledigen.

    Hier werden beide Helden in einer einzigen SQL-Abfrage aktualisiert.

16. Aktualisieren Sie den ersten Helden.

    Dies erzeugt die Ausgabe

    INFO Engine BEGIN (implicit)
    INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
    FROM hero
    WHERE hero.id = ?
    INFO Engine [generated in 0.00023s] (2,)
    

    Tipp

    Da wir gerade eine SQL-Transaktion mit COMMIT committet haben, wird SQLAlchemy automatisch eine neue Transaktion mit BEGIN starten.

17. Aktualisieren Sie den zweiten Helden.

    Dies erzeugt die Ausgabe

    INFO Engine SELECT hero.id, hero.name, hero.secret_name, hero.age
    FROM hero
    WHERE hero.id = ?
    INFO Engine [cached since 0.001709s ago] (7,)
    

    Tipp

    SQLAlchemy verwendet immer noch die vorherige Transaktion, sodass es keine neue erstellen muss.

18. Geben Sie den ersten Helden aus, nun aktualisiert.

    Dies erzeugt die Ausgabe

    Updated hero 1: name='Spider-Youngster' secret_name='Pedro Parqueador' age=16 id=2
    

19. Geben Sie den zweiten Helden aus, nun aktualisiert.

    Dies erzeugt die Ausgabe

    Updated hero 2: name='Captain North America Except Canada' secret_name='Esteban Rogelios' age=110 id=7
    

20. Hier endet die with-Blockanweisung, sodass die Sitzung ihren abschließenden Code ausführen kann.

    Die Sitzung wird alle Änderungen in der letzten Transaktion, die nicht committet wurden, ROLLBACKen (rückgängig machen).

    Dies erzeugt die Ausgabe

    INFO Engine ROLLBACK
    

👀 Vorschau der vollständigen Datei

Python 3.10+Python 3.8+

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: int | None = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: int | None = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")  # (1)!
        results = session.exec(statement)  # (2)!
        hero_1 = results.one()  # (3)!
        print("Hero 1:", hero_1)  # (4)!

        statement = select(Hero).where(Hero.name == "Captain North America")  # (5)!
        results = session.exec(statement)  # (6)!
        hero_2 = results.one()  # (7)!
        print("Hero 2:", hero_2)  # (8)!

        hero_1.age = 16  # (9)!
        hero_1.name = "Spider-Youngster"  # (10)!
        session.add(hero_1)  # (11)!

        hero_2.name = "Captain North America Except Canada"  # (12)!
        hero_2.age = 110  # (13)!
        session.add(hero_2)  # (14)!

        session.commit()  # (15)!
        session.refresh(hero_1)  # (16)!
        session.refresh(hero_2)  # (17)!

        print("Updated hero 1:", hero_1)  # (18)!
        print("Updated hero 2:", hero_2)  # (19)!
    # (20)!


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

from typing import Optional

from sqlmodel import Field, Session, SQLModel, create_engine, select


class Hero(SQLModel, table=True):
    id: Optional[int] = Field(default=None, primary_key=True)
    name: str = Field(index=True)
    secret_name: str
    age: Optional[int] = Field(default=None, index=True)


sqlite_file_name = "database.db"
sqlite_url = f"sqlite:///{sqlite_file_name}"

engine = create_engine(sqlite_url, echo=True)


def create_db_and_tables():
    SQLModel.metadata.create_all(engine)


def create_heroes():
    hero_1 = Hero(name="Deadpond", secret_name="Dive Wilson")
    hero_2 = Hero(name="Spider-Boy", secret_name="Pedro Parqueador")
    hero_3 = Hero(name="Rusty-Man", secret_name="Tommy Sharp", age=48)
    hero_4 = Hero(name="Tarantula", secret_name="Natalia Roman-on", age=32)
    hero_5 = Hero(name="Black Lion", secret_name="Trevor Challa", age=35)
    hero_6 = Hero(name="Dr. Weird", secret_name="Steve Weird", age=36)
    hero_7 = Hero(name="Captain North America", secret_name="Esteban Rogelios", age=93)

    with Session(engine) as session:
        session.add(hero_1)
        session.add(hero_2)
        session.add(hero_3)
        session.add(hero_4)
        session.add(hero_5)
        session.add(hero_6)
        session.add(hero_7)

        session.commit()


def update_heroes():
    with Session(engine) as session:
        statement = select(Hero).where(Hero.name == "Spider-Boy")  # (1)!
        results = session.exec(statement)  # (2)!
        hero_1 = results.one()  # (3)!
        print("Hero 1:", hero_1)  # (4)!

        statement = select(Hero).where(Hero.name == "Captain North America")  # (5)!
        results = session.exec(statement)  # (6)!
        hero_2 = results.one()  # (7)!
        print("Hero 2:", hero_2)  # (8)!

        hero_1.age = 16  # (9)!
        hero_1.name = "Spider-Youngster"  # (10)!
        session.add(hero_1)  # (11)!

        hero_2.name = "Captain North America Except Canada"  # (12)!
        hero_2.age = 110  # (13)!
        session.add(hero_2)  # (14)!

        session.commit()  # (15)!
        session.refresh(hero_1)  # (16)!
        session.refresh(hero_2)  # (17)!

        print("Updated hero 1:", hero_1)  # (18)!
        print("Updated hero 2:", hero_2)  # (19)!
    # (20)!


def main():
    create_db_and_tables()
    create_heroes()
    update_heroes()


if __name__ == "__main__":
    main()

Tipp

Überprüfen Sie, was jede Zeile tut, indem Sie auf jede Zahlenblase im Code klicken. 👆

Zusammenfassung

Aktualisieren Sie SQLModel-Objekte so, wie Sie es mit anderen Python-Objekten tun würden. 🐍

Denken Sie einfach daran, sie zu einer Sitzung hinzuzufügen und sie dann zu committen. Und wenn nötig, sie zu aktualisieren.