Skip to content

Commit 4dec75f

Browse files
committed
Support native query with Mutiny and stateless session
1 parent fb83f5e commit 4dec75f

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

hibernate-reactive-core/src/main/java/org/hibernate/reactive/mutiny/impl/MutinyStatelessSessionImpl.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -64,37 +64,37 @@ public <T> Uni<T> get(EntityGraph<T> entityGraph, Object id) {
6464

6565
@Override
6666
public <R> Mutiny.Query<R> createQuery(String queryString) {
67-
throw new UnsupportedOperationException("Not yet implemented");
67+
return new MutinyQueryImpl<>( delegate.createReactiveQuery( queryString ), factory );
6868
}
6969

7070
@Override
7171
public <R> Mutiny.Query<R> createQuery(String queryString, Class<R> resultType) {
72-
throw new UnsupportedOperationException("Not yet implemented");
72+
return new MutinyQueryImpl<>( delegate.createReactiveQuery( queryString, resultType ), factory );
7373
}
7474

7575
@Override
7676
public <R> Mutiny.Query<R> createNamedQuery(String queryName) {
77-
throw new UnsupportedOperationException("Not yet implemented");
77+
return new MutinyQueryImpl<>( delegate.createReactiveNamedQuery( queryName, null ), factory );
7878
}
7979

8080
@Override
8181
public <R> Mutiny.Query<R> createNamedQuery(String queryName, Class<R> resultType) {
82-
throw new UnsupportedOperationException("Not yet implemented");
82+
return new MutinyQueryImpl<>( delegate.createReactiveNamedQuery( queryName, resultType ), factory );
8383
}
8484

8585
@Override
8686
public <R> Mutiny.Query<R> createNativeQuery(String queryString) {
87-
throw new UnsupportedOperationException("Not yet implemented");
87+
return new MutinyNativeQueryImpl<>( delegate.createReactiveNativeQuery( queryString ), factory );
8888
}
8989

9090
@Override
9191
public <R> Mutiny.Query<R> createNativeQuery(String queryString, Class<R> resultType) {
92-
throw new UnsupportedOperationException("Not yet implemented");
92+
return new MutinyNativeQueryImpl<>( delegate.createReactiveNativeQuery( queryString, resultType ), factory );
9393
}
9494

9595
@Override
9696
public <R> Mutiny.Query<R> createNativeQuery(String queryString, ResultSetMapping<R> resultSetMapping) {
97-
throw new UnsupportedOperationException("Not yet implemented");
97+
return new MutinyNativeQueryImpl<>( delegate.createReactiveNativeQuery( queryString, resultSetMapping ), factory );
9898
}
9999

100100
@Override

0 commit comments

Comments
 (0)