in courses/understanding_spanner/cloud-run/main.py [0:0]
def get(self, pet_id):
params = {"pet_id": pet_id}
param_types = {
"pet_id": spanner.param_types.STRING,
}
query = """SELECT Owners.OwnerID, OwnerName,
PetID, PetName, PetType, Breed
FROM Owners
JOIN Pets ON Owners.OwnerID = Pets.OwnerID
WHERE PetID = @pet_id; """
with database.snapshot() as snapshot:
results = snapshot.execute_sql(
query, params=params, param_types=param_types,)
pet = None
for row in results:
pet = {'OwnerID': row[0],
'OwnerName': row[1],
'PetID': row[2],
'PetName': row[3],
'PetType': row[4],
'Breed': row[5], }
if pet:
return pet, 200
else:
return "Not found", 404