|
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 | } |
@@ -64,7 +66,7 @@ default void prepare(MappingModelCreationProcess mappingModelCreationProcess, Jd |
64 | 66 | tableCreatedStage.complete( null ); |
65 | 67 | } |
66 | 68 | else { |
67 | | - make( Log.class, lookup() ).debugf( "Creating global-temp ID table : %s", getTemporaryTable().getTableExpression() ); |
| 69 | + LOG.debugf( "Creating global-temp ID table : %s", getTemporaryTable().getTableExpression() ); |
68 | 70 |
|
69 | 71 | connectionStage() |
70 | 72 | .thenCompose( this::createTable ) |
@@ -102,7 +104,7 @@ private CompletionStage<Void> releaseConnection(ReactiveConnection connection) { |
102 | 104 |
|
103 | 105 | private static void logConnectionClosedError(Throwable t) { |
104 | 106 | if ( t != null ) { |
105 | | - make( Log.class, lookup() ).debugf( "Ignoring error closing the connection: %s", t.getMessage() ); |
| 107 | + LOG.debugf( "Ignoring error closing the connection: %s", t.getMessage() ); |
106 | 108 | } |
107 | 109 | } |
108 | 110 |
|
@@ -150,7 +152,7 @@ default void release( |
150 | 152 | setDropIdTables( false ); |
151 | 153 |
|
152 | 154 | final TemporaryTable temporaryTable = getTemporaryTable(); |
153 | | - make( Log.class, lookup() ).debugf( "Dropping global-tempk ID table : %s", temporaryTable.getTableExpression() ); |
| 155 | + LOG.debugf( "Dropping global-temp ID table : %s", temporaryTable.getTableExpression() ); |
154 | 156 |
|
155 | 157 | connectionStage() |
156 | 158 | .thenCompose( this::dropTable ) |
|
0 commit comments