@@ -30,27 +30,27 @@ class BinlogEnvConfig
30
30
public static function getTargetBinlogDbParams (): array
31
31
{
32
32
return [
33
- 'host ' => getenv ('TARGET_DB_HOST ' ),
34
- 'user ' => getenv ('TARGET_DB_USER ' ),
35
- 'port ' => getenv ('TARGET_DB_PORT ' ),
36
- 'password ' => getenv ('TARGET_DB_PASSWORD ' ),
37
- 'dbname ' => getenv ('TARGET_DB_DBNAME ' ),
38
- 'driver ' => getenv ('TARGET_DB_DRIVER ' ),
39
- 'charset ' => getenv ('TARGET_DB_CHARSET ' ),
33
+ 'host ' => getenv ('BINLOG_MYSQL_TARGET_HOST ' ),
34
+ 'user ' => getenv ('BINLOG_MYSQL_TARGET_USER ' ),
35
+ 'port ' => getenv ('BINLOG_MYSQL_TARGET_PORT ' ),
36
+ 'password ' => getenv ('BINLOG_MYSQL_TARGET_PASSWORD ' ),
37
+ 'dbname ' => getenv ('BINLOG_MYSQL_TARGET_DBNAME ' ),
38
+ 'driver ' => getenv ('BINLOG_MYSQL_TARGET_DRIVER ' ),
39
+ 'charset ' => getenv ('BINLOG_MYSQL_TARGET_CHARSET ' ),
40
40
'driverOptions ' => [\PDO ::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8 ' ],
41
41
];
42
42
}
43
43
44
44
public static function getHistoryWriteDbParams (): array
45
45
{
46
46
return [
47
- 'host ' => getenv ('HISTORY_WRITE_DB_HOST ' ),
48
- 'user ' => getenv ('HISTORY_WRITE_DB_USER ' ),
49
- 'port ' => getenv ('HISTORY_WRITE_DB_PORT ' ),
50
- 'password ' => getenv ('HISTORY_WRITE_DB_PASSWORD ' ),
51
- 'dbname ' => getenv ('HISTORY_WRITE_DB_DBNAME ' ),
52
- 'driver ' => getenv ('HISTORY_WRITE_DB_DRIVER ' ),
53
- 'charset ' => getenv ('HISTORY_WRITE_DB_CHARSET ' ),
47
+ 'host ' => getenv ('BINLOG_MYSQL_HISTORY_WRITE_HOST ' ),
48
+ 'user ' => getenv ('BINLOG_MYSQL_HISTORY_WRITE_USER ' ),
49
+ 'port ' => getenv ('BINLOG_MYSQL_HISTORY_WRITE_PORT ' ),
50
+ 'password ' => getenv ('BINLOG_MYSQL_HISTORY_WRITE_PASSWORD ' ),
51
+ 'dbname ' => getenv ('BINLOG_MYSQL_HISTORY_WRITE_DBNAME ' ),
52
+ 'driver ' => getenv ('BINLOG_MYSQL_HISTORY_WRITE_DRIVER ' ),
53
+ 'charset ' => getenv ('BINLOG_MYSQL_HISTORY_WRITE_CHARSET ' ),
54
54
'driverOptions ' => [\PDO ::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8 ' ],
55
55
];
56
56
}
@@ -88,8 +88,8 @@ public static function extendDefaultConfig(
88
88
}
89
89
90
90
$ self = new self ();
91
- $ self ->enable_sentry = getenv ('ENABLE_SENTRY ' );
92
- $ self ->sentry_key = getenv ('SENTRY_KEY ' );
91
+ $ self ->enable_sentry = ( bool ) getenv ('BINLOG_ENABLE_SENTRY ' );
92
+ $ self ->sentry_key = getenv ('BINLOG_SENTRY_KEY ' );
93
93
$ self ->binlog_connect_array = array_merge ($ default_binlog_connect_array , $ replace_binlog_connect_array );
94
94
$ self ->binlog_config_array = array_merge ($ default_binlog_config_array , $ replace_binlog_config_array );
95
95
$ self ->row_event_value_skipper = $ row_event_value_skipper ;
0 commit comments