3
3
import com .netflix .metacat .connector .polaris .store .jdbc .PolarisDatabaseReplicaJDBC ;
4
4
import com .netflix .metacat .connector .polaris .store .jdbc .PolarisTableReplicaJDBC ;
5
5
import com .zaxxer .hikari .HikariDataSource ;
6
+ import lombok .extern .slf4j .Slf4j ;
6
7
import org .springframework .beans .factory .annotation .Qualifier ;
7
8
import org .springframework .boot .autoconfigure .condition .ConditionalOnProperty ;
8
9
import org .springframework .boot .context .properties .ConfigurationProperties ;
19
20
*/
20
21
@ Configuration
21
22
@ ConditionalOnProperty (prefix = "spring.datasource.reader" , name = "url" )
23
+ @ Slf4j
22
24
public class PolarisPersistenceReaderConfig {
23
25
24
26
/**
@@ -32,6 +34,7 @@ public class PolarisPersistenceReaderConfig {
32
34
@ ConfigurationProperties (prefix = "spring.datasource.reader.hikari" )
33
35
public DataSource readerDataSource (@ Qualifier ("readerDataSourceProperties" )
34
36
final DataSourceProperties readerDataSourceProperties ) {
37
+ log .info ("Hey readerDataSource" );
35
38
return readerDataSourceProperties
36
39
.initializeDataSourceBuilder ()
37
40
.type (HikariDataSource .class )
@@ -47,6 +50,7 @@ public DataSource readerDataSource(@Qualifier("readerDataSourceProperties")
47
50
@ Bean
48
51
@ ConfigurationProperties ("spring.datasource.reader" )
49
52
public DataSourceProperties readerDataSourceProperties () {
53
+ log .info ("Hey readerDataSourceProperties" );
50
54
return new DataSourceProperties ();
51
55
}
52
56
@@ -58,6 +62,7 @@ public DataSourceProperties readerDataSourceProperties() {
58
62
*/
59
63
@ Bean
60
64
public JdbcTemplate readerJdbcTemplate (@ Qualifier ("readerDataSource" ) final DataSource dataSource ) {
65
+ log .info ("Hey readerJdbcTemplate" );
61
66
return new JdbcTemplate (dataSource );
62
67
}
63
68
@@ -69,6 +74,7 @@ public JdbcTemplate readerJdbcTemplate(@Qualifier("readerDataSource") final Data
69
74
*/
70
75
@ Bean
71
76
public PolarisDatabaseReplicaJDBC polarisDatabaseReplicaJDBC (final JdbcTemplate readerJdbcTemplate ) {
77
+ log .info ("Hey PolarisDatabaseReplicaJDBC" );
72
78
return new PolarisDatabaseReplicaJDBC (readerJdbcTemplate );
73
79
}
74
80
@@ -80,6 +86,7 @@ public PolarisDatabaseReplicaJDBC polarisDatabaseReplicaJDBC(final JdbcTemplate
80
86
*/
81
87
@ Bean
82
88
public PolarisTableReplicaJDBC polarisTableReplicaJDBC (final JdbcTemplate readerJdbcTemplate ) {
89
+ log .info ("Hey polarisTableReplicaJDBC" );
83
90
return new PolarisTableReplicaJDBC (readerJdbcTemplate );
84
91
}
85
92
}
0 commit comments