2929import static org .hibernate .reactive .logging .impl .LoggerFactory .make ;
3030import static org .hibernate .reactive .util .impl .CompletionStages .loop ;
3131import static org .hibernate .reactive .util .impl .CompletionStages .voidFuture ;
32- import static org .hibernate .sql .results .LoadingLogger .LOGGER ;
32+ import static org .hibernate .sql .results .LoadingLogger .LOADING_LOGGER ;
3333
3434
3535/**
@@ -121,7 +121,7 @@ public R readRow(RowProcessingState processingState) {
121121
122122 @ Override
123123 public CompletionStage <R > reactiveReadRow (ReactiveRowProcessingState rowProcessingState , JdbcValuesSourceProcessingOptions options ) {
124- LOGGER .trace ( "ReactiveStandardRowReader#readRow" );
124+ LOADING_LOGGER .trace ( "ReactiveStandardRowReader#readRow" );
125125
126126 return coordinateInitializers ( rowProcessingState )
127127 .thenCompose ( v -> {
@@ -160,7 +160,7 @@ private CompletionStage<R> booleanComponent(
160160 final boolean [] resultRow = new boolean [resultAssemblers .length ];
161161 return loop ( 0 , assemblerCount , i -> {
162162 final DomainResultAssembler <?> assembler = resultAssemblers [i ];
163- LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
163+ LOADING_LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
164164 if ( assembler instanceof ReactiveDomainResultsAssembler ) {
165165 return ( (ReactiveDomainResultsAssembler ) assembler )
166166 .reactiveAssemble ( rowProcessingState , options )
@@ -181,7 +181,7 @@ private CompletionStage<R> byteComponent(
181181 final byte [] resultRow = new byte [resultAssemblers .length ];
182182 return loop ( 0 , assemblerCount , i -> {
183183 final DomainResultAssembler <?> assembler = resultAssemblers [i ];
184- LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
184+ LOADING_LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
185185 if ( assembler instanceof ReactiveDomainResultsAssembler ) {
186186 return ( (ReactiveDomainResultsAssembler ) assembler )
187187 .reactiveAssemble ( rowProcessingState , options )
@@ -202,7 +202,7 @@ private CompletionStage<R> charComponent(
202202 final char [] resultRow = new char [resultAssemblers .length ];
203203 return loop ( 0 , assemblerCount , i -> {
204204 final DomainResultAssembler <?> assembler = resultAssemblers [i ];
205- LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
205+ LOADING_LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
206206 if ( assembler instanceof ReactiveDomainResultsAssembler ) {
207207 return ( (ReactiveDomainResultsAssembler ) assembler )
208208 .reactiveAssemble ( rowProcessingState , options )
@@ -223,7 +223,7 @@ private CompletionStage<R> shortComponent(
223223 final short [] resultRow = new short [resultAssemblers .length ];
224224 return loop ( 0 , assemblerCount , i -> {
225225 final DomainResultAssembler <?> assembler = resultAssemblers [i ];
226- LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
226+ LOADING_LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
227227 if ( assembler instanceof ReactiveDomainResultsAssembler ) {
228228 return ( (ReactiveDomainResultsAssembler ) assembler )
229229 .reactiveAssemble ( rowProcessingState , options )
@@ -244,7 +244,7 @@ private CompletionStage<R> intComponent(
244244 final int [] resultRow = new int [resultAssemblers .length ];
245245 return loop ( 0 , assemblerCount , i -> {
246246 final DomainResultAssembler <?> assembler = resultAssemblers [i ];
247- LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
247+ LOADING_LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
248248 if ( assembler instanceof ReactiveDomainResultsAssembler ) {
249249 return ( (ReactiveDomainResultsAssembler ) assembler )
250250 .reactiveAssemble ( rowProcessingState , options )
@@ -265,7 +265,7 @@ private CompletionStage<R> longComponent(
265265 final long [] resultRow = new long [resultAssemblers .length ];
266266 return loop ( 0 , assemblerCount , i -> {
267267 final DomainResultAssembler <?> assembler = resultAssemblers [i ];
268- LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
268+ LOADING_LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
269269 if ( assembler instanceof ReactiveDomainResultsAssembler ) {
270270 return ( (ReactiveDomainResultsAssembler ) assembler )
271271 .reactiveAssemble ( rowProcessingState , options )
@@ -286,7 +286,7 @@ private CompletionStage<R> floatComponent(
286286 final float [] resultRow = new float [resultAssemblers .length ];
287287 return loop ( 0 , assemblerCount , i -> {
288288 final DomainResultAssembler <?> assembler = resultAssemblers [i ];
289- LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
289+ LOADING_LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
290290 if ( assembler instanceof ReactiveDomainResultsAssembler ) {
291291 return ( (ReactiveDomainResultsAssembler ) assembler )
292292 .reactiveAssemble ( rowProcessingState , options )
@@ -307,7 +307,7 @@ private CompletionStage<R> doubleComponent(
307307 final double [] resultRow = new double [resultAssemblers .length ];
308308 return loop ( 0 , assemblerCount , i -> {
309309 final DomainResultAssembler <?> assembler = resultAssemblers [i ];
310- LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
310+ LOADING_LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
311311 if ( assembler instanceof ReactiveDomainResultsAssembler ) {
312312 return ( (ReactiveDomainResultsAssembler ) assembler )
313313 .reactiveAssemble ( rowProcessingState , options )
@@ -328,7 +328,7 @@ private CompletionStage<R> objectComponent(
328328 final Object [] resultRow = (Object []) Array .newInstance ( resultElementClass , resultAssemblers .length );
329329 return loop ( 0 , assemblerCount , i -> {
330330 final DomainResultAssembler <?> assembler = resultAssemblers [i ];
331- LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
331+ LOADING_LOGGER .debugf ( "Calling top-level assembler (%s / %s) : %s" , i , assemblerCount , assembler );
332332 if ( assembler instanceof ReactiveDomainResultsAssembler ) {
333333 return ( (ReactiveDomainResultsAssembler ) assembler )
334334 .reactiveAssemble ( rowProcessingState , options )
@@ -362,7 +362,7 @@ public List<JavaType<?>> getResultJavaTypes() {
362362 }
363363
364364 private void afterRow (RowProcessingState rowProcessingState ) {
365- LOGGER .trace ( "ReactiveStandardRowReader#afterRow" );
365+ LOADING_LOGGER .trace ( "ReactiveStandardRowReader#afterRow" );
366366 finishUpRow ();
367367 }
368368
0 commit comments