Как решить проблему с подключением spring-Репозиториев?

Question

[Andrey Kovalchuk]

Доброго времени суток. Проблема с... тем, не знаю, чем.
Написал кастомный метод для репозитория и простенький запрос в нем, но вот незадача: он нифига не достает мне мою запись.

В БД есть таблица room и столбец Index внутри.

Репозиторий с кастомным методом.

public interface RoomRepository extends JpaRepository<Room,Integer> {
    @Query("FROM Room b where b.index = :Index")
    Room findByIndex(@Param("Index") String index);
}

Итак, последовательно, что из чего.
Сначала у нас рест-контроллер:

@RestController
public class StartController {

    @Autowired
    private RoomService roomService;

    @RequestMapping(value = "/start", method = RequestMethod.GET)
    @ResponseBody
    public void startArduinoScan() throws SerialPortException {
        //Попробуем завести наш АрдуиноКоннектер
        ArduinoConfig arduinoConfig = new ArduinoConfig();
        arduinoConfig.arduinoConnection(roomService);
    }

    @RequestMapping(value = "/index/{index}", method = RequestMethod.GET)
    @ResponseBody
    public Room getRoomByIndex(@PathVariable String index){
        return roomService.findByIndex(index);
    }

/index/{index} работает, только там не настроена сериализация, но это к делу не относится, главное - запрос делается.

Окунаемся глубже

ArduinoConfig.java

@Configuration
@ComponentScan("com.kovalchuk.server")
@EnableJpaRepositories("com.kovalchuk.server.repository")
public class ArduinoConfig {


    private static SerialPort serialPort;

    public static SerialPort getSerialPort() {
        return serialPort;
    }


    public void arduinoConnection(RoomService roomService) throws SerialPortException {
        serialPort = new SerialPort("COM3");

        try{
            serialPort.openPort();
            serialPort.setParams(9600,8,1,0);
            serialPort.setEventsMask(SerialPort.MASK_RXCHAR);
            serialPort.addEventListener(new ArduinoEventsListener());


        }
        catch (SerialPortException ex){
            System.out.println(ex);
        }
    }

}

Момент вызова метода.
Дата[2] - не пустое, содержит Индекс искомый.

@ComponentScan("com.kovalchuk.server")
@EnableJpaRepositories("com.kovalchuk.server.repository")
public class ArduinoEventsListener implements SerialPortEventListener {

    private SerialPort serialPort = ArduinoConfig.getSerialPort();

    @Autowired
    private CommitRepository commitRepository;

    @Autowired
    private RoomRepository roomRepository;




    @Override
    public void serialEvent(SerialPortEvent event) {
        try {
            String buffer = serialPort.readString(15);
            String[] data = buffer.split(":");

            Commit commit = new Commit();

            commit.setTemperature(Double.parseDouble(data[0]));
            commit.setWet(data[1]);
            commit.setDate(new Date());




            Room room = roomRepository.findByIndex(data[2]);

            commit.setRoom(room);

            commitRepository.save(commit);


        } catch (SerialPortException e) {
            e.printStackTrace();
        }
    }

}

Entity

package com.kovalchuk.server.entity;

import org.hibernate.annotations.GenericGenerator;

import javax.persistence.*;

@Entity
@Table (name= "room")
public class Room {

    @Id
    @Column(name ="idRoom")
    @GeneratedValue(generator = "increment")
    @GenericGenerator(name = "increment", strategy = "increment")
    private Long id;

    @Column(name="Index")
    private String index;

    @Column(name = "Type")
    private String type;

    @Column(name = "Status")
    private Commit status;

    public Room(String index, String type, Commit status) {
        this.index = index;
        this.type = type;
        this.status = status;
    }

    public Room(String index, String type) {
        this.index = index;
        this.type = type;
    }

    public Room() {
    }

    public Commit getStatus() {
        return status;
    }

    public void setStatus(Commit status) {
        this.status = status;
    }

    public String getType() {
        return type;
    }

    public void setType(String type) {
        this.type = type;
    }

    public String getIndex() {
        return index;
    }

    public void setIndex(String index) {
        this.index = index;
    }

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }
}

Таблица Index

CREATE TABLE `room` (
  `idRoom` bigint(20) NOT NULL AUTO_INCREMENT,
  `Index` varchar(5) NOT NULL,
  `Type` varchar(5) DEFAULT NULL,
  `Status` bigint(20) NOT NULL,
  PRIMARY KEY (`idRoom`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8

Проблема явно в вызове Репозиториев. А вот почему, не могу понять.

Answer 1

[Александр Косарев]

У тебя в классе-сущности идентификатор типа Long, но у репозитория в дженерике указан Integer. Возможно, проблема связана с этим. А вообще да, если у тебя Spring Data JPA, то логичнее просто в интерфейсе указать метод Room findByIndex(String index); без дополнительных аннотаций.

Comments

[Andrey Kovalchuk]

Врятли, если вызывать методы из рест-контроллера, то все работает на "Ура".

[Александр Косарев]

mrkovalchuk: Контроллер отдаёт идентичный индекс? И как создаётся объект класса ArduinoEventsListener?

[Andrey Kovalchuk]

Александр Косарев: контроллер отдаёт объект, но да, правильный объект.
Я добавил всю цепочку вызовов и сам контроллер в верх поста.

[Александр Косарев]

mrkovalchuk: Я вижу у ArduinoEventsListener только аннотации @ComponentScan("com.kovalchuk.server") и @EnableJpaRepositories("com.kovalchuk.server.repository")

Каким образом создаётся компонент этого класса?

[Andrey Kovalchuk]

Александр Косарев: ArduinoConfig.java: serialPort.addEventListener(new ArduinoEventsListener());

[Александр Косарев]

mrkovalchuk: Ну вот тебе и ответ - в ArduinoEventsListener есть зависимости, внедрённые при помощи @Autowired, но ты создаёшь объект руками. Поэтому Spring не может подтянуть нужные зависимости и репозиторий не работает. Варианта решения 3:
1. Добавляешь commitRepository и roomRepository с аннотациями @Autowired в ArduinoConfig и передаёшь их ArduinoEventsListener через конструктор, либо через сеттеры.
или
2. ArduinoEventsListener делаешь компонентом, добавив ему аннотацию @Component
или
3. В ArduinoConfig инициализируешь ArduinoEventsListener при помощи @Bean-метода:
@Bean
public ArduinoEventsListener arduinoEventsListener() {
return new ArduinoEventsListener();
}

Замечу ещё такой момент, что ArduinoConfig у тебя не является конфигурацией как таковой, так что лучше будет заменить @Configuration на @Component, тогда ты сможешь добавить в свой контроллер
@Autowired
private ArduinoConfig arduinoConfig;

и в методе, тебе останется сделать arduinoConfig.arduinoConnection(roomService); без создания нового инстанса ArduinoConfig

[Andrey Kovalchuk]

Александр Косарев: Шикарно. Спасибо, путаюсь еще в аннотациях, пойду делать. По результатам отпишусь отмечу решением, а оно, похоже, таковым будет.

[Александр Косарев]

mrkovalchuk: https://alexkosarev.name/2016/05/26/spring-framewo...

Answer 2

[guras256]

у тебя spring data, нафига ты писал hql запрос?

public interface RoomRepository extends JpaRepository<Room, Integer> {
    Room findByIndex(String index);
}

все что тебе нужно сделать, если в Room правильно расставлены аннотации
и да, назови поле Index с маленькой буквы...

Comments

[Andrey Kovalchuk]

Результат особо не изменился.

https://habrahabr.ru/post/139421/ - пробовал оба варианта. Все равно null возвращает.

[guras256]

mrkovalchuk: окей, а ты уверен, что в базе что то есть? а сама база вообще есть? как ты написал pojo? работает ли у тебя пример тупо скопированный со статьи? считаешь ли ты меня экстрасенсом?

[Andrey Kovalchuk]

guras256: в базе есть таблица, в таблице есть запись, выложил Pojo.

[guras256]

mrkovalchuk:
1) вруби у hibernate дебаг режим и посмотри, делает ли он вообще запрос куда-нибудь
2) напиши метод Room findAll(); и посмотри, что он вернет

[Andrey Kovalchuk]

guras256: ничего не возвращает. Null и что я только не пробовал. Может я не так как-то вызываю репозиторий... Выложил место, где используется репозиторий.

О чем это говорит? Pojo, по идее, настроен верно, ибо не ругается hibernate. Я уже и просто вызывал метод roomRepository.finAll(); и в Service переопределял этот метод. Что еще попробовать?

Answer 3

[Руслан Лопатин]

Проблема, видимо, в связи с Commit. Таблица Commit вообще содержит данные?

Может, стоит создавать Commit внутри метода serialEvent, а не как поле класса ArduinoEventListener? Кроме того, стоит прописать аннотацию ManyToOne для поля Room.status

Comments

[Andrey Kovalchuk]

Таблица Commit данные содержит, но вбитые ручками, а не как не заполненные программой. До проблем с Commit еще не дошли, он пока не играет никакой роли, т.к. мы Room не можем получить.

Хотя, если попробовать commitRepository использовать выше, тоже ничего не получается.

Обновил код, попробовал с аннотациями поковыряться.

Room.status - еще не решил, как буду заполнять это поле, пока ручками прописал.

Answer 4

[Andrey Kovalchuk]

см. Решение от Александр Косарев (выше)

*****************************************************************************************************
Проблему решил, но не уверен, насколько такой подход верен.

Итак, теперь я в контроллере объявляю два сервиса, которые работают с репозиториями и сую их в ArduinoConfig через новосозданный конструктор (см. ниже).

StartController

package com.kovalchuk.server.controller;

import com.kovalchuk.server.config.arduino.ArduinoConfig;
import com.kovalchuk.server.entity.Room;
import com.kovalchuk.server.services.interf.CommitService;
import com.kovalchuk.server.services.interf.RoomService;
import jssc.SerialPortException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

@RestController
public class StartController {

    @Autowired
    private RoomService roomService;

    @Autowired
    private CommitService commitService;

    @RequestMapping(value = "/start", method = RequestMethod.GET)
    @ResponseBody
    public void startArduinoScan() throws SerialPortException {
        //Попробуем завести наш АрдуиноКоннектер
        ArduinoConfig arduinoConfig = new ArduinoConfig(roomService,commitService);
        arduinoConfig.arduinoConnection();
    }  

}

В ArduinoConfig определяю Service как поля, и добавляют два Getter-а для них. Ну и да, конструктор соответствующий нарисовал.

ArduinoConfig

package com.kovalchuk.server.config.arduino;


import com.kovalchuk.server.services.interf.CommitService;
import com.kovalchuk.server.services.interf.RoomService;
import jssc.SerialPort;
import jssc.SerialPortException;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;

@Configuration
@ComponentScan("com.kovalchuk.server")
@EnableJpaRepositories("com.kovalchuk.server.repository")
public class ArduinoConfig {


    private static SerialPort serialPort;
    private static RoomService roomService;
    private static CommitService commitService;

    public ArduinoConfig() {
    }

    public ArduinoConfig(RoomService roomService, CommitService commitService) {
        this.roomService = roomService;
        this.commitService = commitService;
    }

    public static RoomService getRoomService() {
        return roomService;
    }

    public static CommitService getCommitService() {
        return commitService;
    }

    public static SerialPort getSerialPort() {
        return serialPort;
    }


    public void arduinoConnection() throws SerialPortException {
        serialPort = new SerialPort("COM3");

        try{
            serialPort.openPort();
            serialPort.setParams(9600,8,1,0);
            serialPort.setEventsMask(SerialPort.MASK_RXCHAR);
            serialPort.addEventListener(new ArduinoEventsListener());


        }
        catch (SerialPortException ex){
            if (serialPort.isOpened()) serialPort.closePort();
        }
    }
}

И вот так преобразился ArduinoEventsListener, который, используя гетеры, получает наши Servic-ы для работы с БД.

ArduinoEventsListener

package com.kovalchuk.server.config.arduino;


import com.kovalchuk.server.entity.Commit;
import com.kovalchuk.server.entity.Room;
import com.kovalchuk.server.services.interf.CommitService;
import com.kovalchuk.server.services.interf.RoomService;
import jssc.SerialPort;
import jssc.SerialPortEvent;
import jssc.SerialPortEventListener;
import jssc.SerialPortException;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;

import java.util.Date;

@ComponentScan("com.kovalchuk.server")
@EnableJpaRepositories("com.kovalchuk.server.repository")
public class ArduinoEventsListener implements SerialPortEventListener {

    private SerialPort serialPort = ArduinoConfig.getSerialPort();
    private RoomService roomService = ArduinoConfig.getRoomService();
    private CommitService commitService = ArduinoConfig.getCommitService();



    @Override
    public void serialEvent(SerialPortEvent event) {
        try {
            String buffer = serialPort.readString(15);
            String[] data = buffer.split(":");

            Commit commit = new Commit();

            commit.setTemperature(Double.parseDouble(data[0]));
            commit.setWet(data[1]);
            commit.setDate(new Date());

            Room room = roomService.findByIndex(data[2]);

            commit.setRoom(room);

            commitService.save(commit);


        } catch (SerialPortException e) {
            e.printStackTrace();
        }
    }

}

Решение позволяет записывать данные в таблицу без каких либо проблем, но вот верно ли так делать, я не знаю. Может стоило прямиком из контроллера гетерами цеплять сервисы, чтобы не протягивать их - но насколько это корректно по отношению к самому контроллеру? Работает, но вопросов все равно много.