import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
public Pet findById(int id) throws DataAccessException {
    JdbcPet pet;
    try {
        Map<String, Object> params = new HashMap<>();
        params.put("id", id);
        pet = this.namedParameterJdbcTemplate.queryForObject(
            "SELECT id, name, birth_date, type_id, owner_id FROM pets WHERE id=:id",
            params,
            new JdbcPetRowMapper());
    } catch (EmptyResultDataAccessException ex) {
        throw new ObjectRetrievalFailureException(Pet.class, id);
    }
    Owner owner = this.ownerRepository.findById(pet.getOwnerId());
    owner.addPet(pet);
    pet.setType(EntityUtils.getById(findPetTypes(), PetType.class, pet.getTypeId()));

    List<Visit> visits = this.visitRepository.findByPetId(pet.getId());
    for (Visit visit : visits) {
        pet.addVisit(visit);
    }
    return pet;
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
public List<Visit> findByPetId(Integer petId) {
    Map<String, Object> params = new HashMap<>();
    params.put("id", petId);
    JdbcPet pet = this.jdbcTemplate.queryForObject(
            "SELECT id, name, birth_date, type_id, owner_id FROM pets WHERE id=:id",
            params,
            new JdbcPetRowMapper());

    List<Visit> visits = this.jdbcTemplate.query(
        "SELECT id as visit_id, visit_date, description FROM visits WHERE pet_id=:id",
        params, new JdbcVisitRowMapper());

    for (Visit visit: visits) {
        visit.setPet(pet);
    }

    return visits;
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
public List<Visit> findByPetId(Integer petId) {
    final List<Visit> visits = this.jdbcTemplate.query(
            "SELECT id, visit_date, description FROM visits WHERE pet_id=?",
            new BeanPropertyRowMapper<Visit>() {
                @Override
                public Visit mapRow(ResultSet rs, int row) throws SQLException {
                    Visit visit = new Visit();
                    visit.setId(rs.getInt("id"));
                    Date visitDate = rs.getDate("visit_date");
                    visit.setDate(new DateTime(visitDate));
                    visit.setDescription(rs.getString("description"));
                    return visit;
                }
            },
            petId);
    return visits;
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
public void loadPetsAndVisits(final Owner owner) {
    Map<String, Object> params = new HashMap<String, Object>();
    params.put("id", owner.getId().intValue());
    final List<JdbcPet> pets = this.namedParameterJdbcTemplate.query(
            "SELECT id, name, birth_date, type_id, owner_id FROM pets WHERE owner_id=:id",
            params,
            new JdbcPetRowMapper()
    );
    for (JdbcPet pet : pets) {
        owner.addPet(pet);
        pet.setType(EntityUtils.getById(getPetTypes(), PetType.class, pet.getTypeId()));
        List<Visit> visits = this.visitRepository.findByPetId(pet.getId());
        for (Visit visit : visits) {
            pet.addVisit(visit);
        }
    }
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
public Pet findById(int id) throws DataAccessException {
    JdbcPet pet;
    try {
        Map<String, Object> params = new HashMap<String, Object>();
        params.put("id", id);
        pet = this.namedParameterJdbcTemplate.queryForObject(
                "SELECT id, name, birth_date, type_id, owner_id FROM pets WHERE id=:id",
                params,
                new JdbcPetRowMapper());
    } catch (EmptyResultDataAccessException ex) {
        throw new ObjectRetrievalFailureException(Pet.class, new Integer(id));
    }
    Owner owner = this.ownerRepository.findById(pet.getOwnerId());
    owner.addPet(pet);
    pet.setType(EntityUtils.getById(findPetTypes(), PetType.class, pet.getTypeId()));

    List<Visit> visits = this.visitRepository.findByPetId(pet.getId());
    for (Visit visit : visits) {
        pet.addVisit(visit);
    }
    return pet;
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
public Pet findById(int id) throws DataAccessException {
    JdbcPet pet;
    try {
        Map<String, Object> params = new HashMap<>();
        params.put("id", id);
        pet = this.namedParameterJdbcTemplate.queryForObject(
                "SELECT id, name, birth_date, type_id, owner_id FROM pets WHERE id=:id",
                params,
                new JdbcPetRowMapper());
    } catch (EmptyResultDataAccessException ex) {
        throw new ObjectRetrievalFailureException(Pet.class, id);
    }
    Owner owner = this.ownerRepository.findById(pet.getOwnerId());
    owner.addPet(pet);
    pet.setType(EntityUtils.getById(findPetTypes(), PetType.class, pet.getTypeId()));

    List<Visit> visits = this.visitRepository.findByPetId(pet.getId());
    for (Visit visit : visits) {
        pet.addVisit(visit);
    }
    return pet;
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
public List<Visit> findByPetId(Integer petId) {
    final List<Visit> visits = this.jdbcTemplate.query(
            "SELECT id, visit_date, description FROM visits WHERE pet_id=?",
            new ParameterizedRowMapper<Visit>() {
                @Override
                public Visit mapRow(ResultSet rs, int row) throws SQLException {
                    Visit visit = new Visit();
                    visit.setId(rs.getInt("id"));
                    Date visitDate = rs.getDate("visit_date");
                    visit.setDate(new DateTime(visitDate));
                    visit.setDescription(rs.getString("description"));
                    return visit;
                }
            },
            petId);
    return visits;
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@RequestMapping(value = "/owner/{ownerId}/getVisits", method = RequestMethod.GET)
public ResponseEntity<List<Visit>> getOwnerVisits(@PathVariable int ownerId){
    List<Pet> petList = this.owners.findById(ownerId).getPets();
    List<Visit> visitList = new ArrayList<Visit>();
    petList.forEach(pet -> visitList.addAll(pet.getVisits()));
    return new ResponseEntity<List<Visit>>(visitList, HttpStatus.OK);
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@RequestMapping(value = "/owner/{ownerId}/getVisits", method = RequestMethod.GET)
public ResponseEntity<List<Visit>> getOwnerVisits(@PathVariable int ownerId){
    List<Pet> petList = this.owners.findById(ownerId).getPets();
    List<Visit> visitList = new ArrayList<Visit>();
    petList.forEach(pet -> {
        logger.info(getPetVisits(pet.getId()).toString());
        visitList.addAll(getPetVisits(pet.getId()));
    });
    return new ResponseEntity<List<Visit>>(visitList, HttpStatus.OK);
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
private List<Visit> getPetVisits(int petId){
    List<Visit> visitList = new ArrayList<Visit>();
    RestTemplate restTemplate = new RestTemplate();
    Pet pet = restTemplate.getForObject("http://"+serviceEndpoint+"/pet/"+petId, Pet.class);
    logger.info(pet.getVisits().toString());
    return pet.getVisits();
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@RequestMapping(value = "/owners/{ownerId}/pets/{petId}/visits/new", method = RequestMethod.POST)
public String processNewVisitForm(@Valid Visit visit, BindingResult result) {
    if (result.hasErrors()) {
        return "pets/createOrUpdateVisitForm";
    } else {
        this.clinicService.saveVisit(visit);
        return "redirect:/owners/{ownerId}";
    }
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
public void save(Visit visit) {
    if (visit.getId() == null) {
        this.em.persist(visit);
    } else {
        this.em.merge(visit);
    }
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public List<Visit> findByPetId(Integer petId) {
    Query query = this.em.createQuery("SELECT visit FROM Visit v where v.pets.id= :id");
    query.setParameter("id", petId);
    return query.getResultList();
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
public Visit mapRow(ResultSet rs, int row) throws SQLException {
    Visit visit = new Visit();
    visit.setId(rs.getInt("visit_id"));
    Date visitDate = rs.getDate("visit_date");
    visit.setDate(new LocalDate(visitDate));
    visit.setDescription(rs.getString("description"));
    return visit;
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
public void save(Visit visit) throws DataAccessException {
    if (visit.isNew()) {
        Number newKey = this.insertVisit.executeAndReturnKey(
            createVisitParameterSource(visit));
        visit.setId(newKey.intValue());
    } else {
        throw new UnsupportedOperationException("Visit update not supported");
    }
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
/**
 * Creates a {@link MapSqlParameterSource} based on data values from the supplied {@link Visit} instance.
 */
private MapSqlParameterSource createVisitParameterSource(Visit visit) {
    return new MapSqlParameterSource()
        .addValue("id", visit.getId())
        .addValue("visit_date", visit.getDate().toDate())
        .addValue("description", visit.getDescription())
        .addValue("pet_id", visit.getPet().getId());
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Test
@Transactional
public void shouldAddNewVisitForPet() {
    Pet pet7 = this.clinicService.findPetById(7);
    int found = pet7.getVisits().size();
    Visit visit = new Visit();
    pet7.addVisit(visit);
    visit.setDescription("test");
    this.clinicService.saveVisit(visit);
    this.clinicService.savePet(pet7);

    pet7 = this.clinicService.findPetById(7);
    assertThat(pet7.getVisits().size()).isEqualTo(found + 1);
    assertThat(visit.getId()).isNotNull();
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public List<Visit> findByPetId(Integer petId) {
    Query query = this.em.createQuery("SELECT v FROM Visit v where v.pet.id= :id");
    query.setParameter("id", petId);
    return query.getResultList();
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
@Override
public Visit mapRow(ResultSet rs, int row) throws SQLException {
    Visit visit = new Visit();
    visit.setId(rs.getInt("visit_id"));
    Date visitDate = rs.getDate("visit_date");
    visit.setDate(new Date(visitDate.getTime()));
    visit.setDescription(rs.getString("description"));
    return visit;
}
 

import org.springframework.samples.petclinic.model.Visit; //导入依赖的package包/类
/**
 * Creates a {@link MapSqlParameterSource} based on data values from the supplied {@link Visit} instance.
 */
private MapSqlParameterSource createVisitParameterSource(Visit visit) {
    return new MapSqlParameterSource()
        .addValue("id", visit.getId())
        .addValue("visit_date", visit.getDate())
        .addValue("description", visit.getDescription())
        .addValue("pet_id", visit.getPet().getId());
}