需要帮助将spring中的Websocket连接到数据库

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Autowired
    private WebSocketHandler webSocketHandler;

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(webSocketHandler, "/websocket").setAllowedOrigins("*");
    }
}

@Component
public class MyWebSocketHandler implements WebSocketHandler {

    @Autowired
    private MyDao myDao;

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        // 初始化操作
    }

    @Override
    public void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        // 处理接收到的消息
        String receivedMessage = message.getPayload();
        myDao.saveMessage(receivedMessage);
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        // 清理操作
    }
}

@Repository
public class MyDao {

    @PersistenceContext
    private EntityManager entityManager;

    public void saveMessage(String message) {
        MyEntity entity = new MyEntity();
        entity.setMessage(message);
        entityManager.persist(entity);
    }
}