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