|
27 | 27 |
|
28 | 28 | public interface ReactiveGlobalTemporaryTableStrategy { |
29 | 29 |
|
30 | | - Log LOG = make( Log.class, lookup() ); |
31 | | - |
32 | 30 | static String sessionIdentifier(SharedSessionContractImplementor session) { |
33 | 31 | return session.getSessionIdentifier().toString(); |
34 | 32 | } |
@@ -62,7 +60,7 @@ default void prepare(MappingModelCreationProcess mappingModelCreationProcess, Jd |
62 | 60 | tableCreatedStage.complete( null ); |
63 | 61 | } |
64 | 62 |
|
65 | | - LOG.debugf( "Creating global-temp ID table : %s", getTemporaryTable().getTableExpression() ); |
| 63 | + make( Log.class, lookup() ).debugf( "Creating global-temp ID table : %s", getTemporaryTable().getTableExpression() ); |
66 | 64 |
|
67 | 65 | connectionStage() |
68 | 66 | .thenCompose( this::createTable ) |
@@ -99,7 +97,7 @@ private CompletionStage<Void> releaseConnection(ReactiveConnection connection) { |
99 | 97 |
|
100 | 98 | private static void logConnectionClosedError(Throwable t) { |
101 | 99 | if ( t != null ) { |
102 | | - LOG.debugf( "Ignoring error closing the connection: %s", t.getMessage() ); |
| 100 | + make( Log.class, lookup() ).debugf( "Ignoring error closing the connection: %s", t.getMessage() ); |
103 | 101 | } |
104 | 102 | } |
105 | 103 |
|
@@ -147,7 +145,8 @@ default void release( |
147 | 145 | setDropIdTables( false ); |
148 | 146 |
|
149 | 147 | final TemporaryTable temporaryTable = getTemporaryTable(); |
150 | | - LOG.debugf( "Dropping global-tempk ID table : %s", temporaryTable.getTableExpression() ); |
| 148 | + make( Log.class, lookup() ) |
| 149 | + .debugf( "Dropping global-temp ID table : %s", temporaryTable.getTableExpression() ); |
151 | 150 |
|
152 | 151 | connectionStage() |
153 | 152 | .thenCompose( this::dropTable ) |
|
0 commit comments