Coverage for docs_src/tutorial/many_to_many/tutorial002.py: 100%

1from typing import List, Optional 10 ctx1abcdefghij

2 

3from sqlmodel import Field, Relationship, Session, SQLModel, create_engine, select 10 ctx1abcdefghij

4 

5 

6class HeroTeamLink(SQLModel, table=True): 10 ctx1abcdefghij

7 team_id: Optional[int] = Field( 10 ctx1abcdefghij

8 default=None, foreign_key="team.id", primary_key=True 

9 ) 

10 hero_id: Optional[int] = Field( 10 ctx1abcdefghij

11 default=None, foreign_key="hero.id", primary_key=True 

12 ) 

13 

14 

15class Team(SQLModel, table=True): 10 ctx1abcdefghij

16 id: Optional[int] = Field(default=None, primary_key=True) 10 ctx1abcdefghij

17 name: str = Field(index=True) 10 ctx1abcdefghij

18 headquarters: str 10 ctx1abcdefghij

19 

20 heroes: List["Hero"] = Relationship(back_populates="teams", link_model=HeroTeamLink) 10 ctx1abcdefghij

21 

22 

23class Hero(SQLModel, table=True): 10 ctx1abcdefghij

24 id: Optional[int] = Field(default=None, primary_key=True) 10 ctx1abcdefghij

25 name: str = Field(index=True) 10 ctx1abcdefghij

26 secret_name: str 10 ctx1abcdefghij

27 age: Optional[int] = Field(default=None, index=True) 10 ctx1abcdefghij

28 

29 teams: List[Team] = Relationship(back_populates="heroes", link_model=HeroTeamLink) 10 ctx1abcdefghij

30 

31 

32sqlite_file_name = "database.db" 10 ctx1abcdefghij

33sqlite_url = f"sqlite:///{sqlite_file_name}" 10 ctx1abcdefghij

34 

35engine = create_engine(sqlite_url, echo=True) 10 ctx1abcdefghij

36 

37 

38def create_db_and_tables(): 10 ctx1abcdefghij

39 SQLModel.metadata.create_all(engine) 10 ctx1abcdefghij

40 

41 

42def create_heroes(): 10 ctx1abcdefghij

43 with Session(engine) as session: 10 ctx1abcdefghij

44 team_preventers = Team(name="Preventers", headquarters="Sharp Tower") 10 ctx1abcdefghij

45 team_z_force = Team(name="Z-Force", headquarters="Sister Margaret's Bar") 10 ctx1abcdefghij

46 

47 hero_deadpond = Hero( 10 ctx1abcdefghij

48 name="Deadpond", 

49 secret_name="Dive Wilson", 

50 teams=[team_z_force, team_preventers], 

51 ) 

52 hero_rusty_man = Hero( 10 ctx1abcdefghij

53 name="Rusty-Man", 

54 secret_name="Tommy Sharp", 

55 age=48, 

56 teams=[team_preventers], 

57 ) 

58 hero_spider_boy = Hero( 10 ctx1abcdefghij

59 name="Spider-Boy", secret_name="Pedro Parqueador", teams=[team_preventers] 

60 ) 

61 session.add(hero_deadpond) 10 ctx1abcdefghij

62 session.add(hero_rusty_man) 10 ctx1abcdefghij

63 session.add(hero_spider_boy) 10 ctx1abcdefghij

64 session.commit() 10 ctx1abcdefghij

65 

66 session.refresh(hero_deadpond) 10 ctx1abcdefghij

67 session.refresh(hero_rusty_man) 10 ctx1abcdefghij

68 session.refresh(hero_spider_boy) 10 ctx1abcdefghij

69 

70 print("Deadpond:", hero_deadpond) 10 ctx1abcdefghij

71 print("Deadpond teams:", hero_deadpond.teams) 10 ctx1abcdefghij

72 print("Rusty-Man:", hero_rusty_man) 10 ctx1abcdefghij

73 print("Rusty-Man Teams:", hero_rusty_man.teams) 10 ctx1abcdefghij

74 print("Spider-Boy:", hero_spider_boy) 10 ctx1abcdefghij

75 print("Spider-Boy Teams:", hero_spider_boy.teams) 10 ctx1abcdefghij

76 

77 

78def update_heroes(): 10 ctx1abcdefghij

79 with Session(engine) as session: 10 ctx1abcdefghij

80 hero_spider_boy = session.exec( 10 ctx1abcdefghij

81 select(Hero).where(Hero.name == "Spider-Boy") 

82 ).one() 

83 team_z_force = session.exec(select(Team).where(Team.name == "Z-Force")).one() 10 ctx1abcdefghij

84 

85 team_z_force.heroes.append(hero_spider_boy) 10 ctx1abcdefghij

86 session.add(team_z_force) 10 ctx1abcdefghij

87 session.commit() 10 ctx1abcdefghij

88 

89 print("Updated Spider-Boy's Teams:", hero_spider_boy.teams) 10 ctx1abcdefghij

90 print("Z-Force heroes:", team_z_force.heroes) 10 ctx1abcdefghij

91 

92 hero_spider_boy.teams.remove(team_z_force) 10 ctx1abcdefghij

93 session.add(team_z_force) 10 ctx1abcdefghij

94 session.commit() 10 ctx1abcdefghij

95 

96 print("Reverted Z-Force's heroes:", team_z_force.heroes) 10 ctx1abcdefghij

97 print("Reverted Spider-Boy's teams:", hero_spider_boy.teams) 10 ctx1abcdefghij

98 

99 

100def main(): 10 ctx1abcdefghij

101 create_db_and_tables() 10 ctx1abcdefghij

102 create_heroes() 10 ctx1abcdefghij

103 update_heroes() 10 ctx1abcdefghij

104 

105 

106if __name__ == "__main__": 10 ctx1abcdefghij

107 main()