|
52 | 52 | * Sql Server table registry |
53 | 53 | */ |
54 | 54 | public class SqlServerTableRegistry implements TableRegistry { |
55 | | - private static final Logger LOGGER = LoggerFactory.getLogger(SqlServerTableRegistry.class); |
| 55 | + private static final Logger LOG = LoggerFactory.getLogger(SqlServerTableRegistry.class); |
56 | 56 | private final String jdbcUrl; |
57 | 57 | private final SqlServerConfig config; |
58 | 58 | private final DriverCleanup driverCleanup; |
@@ -136,7 +136,7 @@ public TableDetail describeTable(String db, @Nullable String schema, String tabl |
136 | 136 | } catch (Exception e) { |
137 | 137 | String msg = String.format("Unable to check if CDC feature for table '%s' in database '%s' was enabled or not", |
138 | 138 | schema == null ? table : schema + "." + table, db); |
139 | | - LOGGER.error(msg, e); |
| 139 | + LOG.error(msg, e); |
140 | 140 | missingFeatures.add( |
141 | 141 | new Problem("Unable To Check If CDC Was Enabled", msg, |
142 | 142 | "Check database connectivity and table information", null)); |
@@ -192,11 +192,11 @@ private Optional<TableDetail.Builder> getTableDetailBuilder(DatabaseMetaData dbM |
192 | 192 | return Optional.empty(); |
193 | 193 | } |
194 | 194 | List<String> primaryKey = new ArrayList<>(); |
195 | | - LOGGER.debug("Query primary key for {}.{}.{}", db, schema, table); |
| 195 | + LOG.debug("Query primary key for {}.{}.{}", db, schema, table); |
196 | 196 | try (ResultSet keyResults = dbMeta.getPrimaryKeys(db, schema, table)) { |
197 | 197 | while (keyResults.next()) { |
198 | 198 | String pk = keyResults.getString("COLUMN_NAME"); |
199 | | - LOGGER.debug("Found primary key for {}.{}.{} : {}", db, schema, table, pk); |
| 199 | + LOG.debug("Found primary key for {}.{}.{} : {}", db, schema, table, pk); |
200 | 200 | primaryKey.add(pk); |
201 | 201 | } |
202 | 202 | } |
|
0 commit comments