alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-2755 Using CURRENT SERVER special register

Browse Source 
Necessary to enable DB2 on zOS compatibility
This commit is contained in:
Peter Urbanetz 2020-11-13 10:38:12 +01:00 committed by Jiri Pechanec
parent af1c3066f5
commit abd01bcf66
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2Connection.java
View File

@ -40,7 +40,7 @@
*/
public class Db2Connection extends JdbcConnection {
private static final String GET_DATABASE_NAME = "SELECT CURRENT_SERVER FROM SYSIBM.SYSDUMMY1"; // DB2
private static final String GET_DATABASE_NAME = "SELECT CURRENT SERVER FROM SYSIBM.SYSDUMMY1"; // DB2
private static Logger LOGGER = LoggerFactory.getLogger(Db2Connection.class);

4
debezium-connector-db2/src/test/docker/db2-cdc-docker/asncdcaddremove.sql
View File

@ -181,9 +181,9 @@ SET stmtSQL = 'INSERT INTO ASNCDC.IBMSNAP_PRUNCNTL ( ' ||
'0, ' ||
'''KAFKAQUAL'', ' ||
'''SET001'', ' ||
' (Select CURRENT_SERVER from sysibm.sysdummy1 ), ' ||
' (Select CURRENT SERVER from sysibm.sysdummy1 ), ' ||
'8, ' ||
' (Select CURRENT_SERVER from sysibm.sysdummy1 ), ' ||
' (Select CURRENT SERVER from sysibm.sysdummy1 ), ' ||
'''ASNCDC'', ' ||
'''"CDC_' || tableschema || '_' || tablename || '"'', ' ||
' ( SELECT CASE WHEN max(CAST(MAP_ID AS INT)) IS NULL THEN CAST(1 AS VARCHAR(10)) ELSE CAST(CAST(max(MAP_ID) AS INT) + 1 AS VARCHAR(10)) END AS MYINT from ASNCDC.IBMSNAP_PRUNCNTL ) ' ||