WIP

[demos/spring/data-jdbc] / src / main / java / de / juplo / kafka / outbox / polling / UserRepository.java

diff --git a/src/main/java/de/juplo/kafka/outbox/polling/UserRepository.java b/src/main/java/de/juplo/kafka/outbox/polling/UserRepository.java
new file mode 100644 (file)
index 0000000..73b3f9e
--- /dev/null
+++ b/src/main/java/de/juplo/kafka/outbox/polling/UserRepository.java
@@ -0,0 +1,10 @@
+package de.juplo.kafka.outbox.polling;
+
+import org.springframework.data.jdbc.repository.query.Query;
+import org.springframework.data.repository.CrudRepository;
+import org.springframework.data.repository.query.Param;
+
+public interface UserRepository extends CrudRepository<User, Long> {
+    @Query("select * from User u where u.username = :username")
+    User findByUsername(@Param("username") String username);
+}