[Bitsail][PG-CDC] add license header

Author: xubo.huster

bitsail-connectors/connector-cdc/connector-cdc-jdbc-base/src/main/java/com/bytedance/bitsail/connector/cdc/jdbc/source/config/AbstractJdbcDebeziumConfig.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.jdbc.source.config;
 
 import com.bytedance.bitsail.common.configuration.BitSailConfiguration;
@@ -65,7 +80,7 @@ public static Properties extractProps(BitSailConfiguration jobConf) {
   public abstract RelationalDatabaseConnectorConfig getJdbcConnectorConfig(Configuration config);
 
   public void fillConnectionInfo(Properties props, ConnectionInfo connectionInfo, String timezone) {
-    props.put(DebeziumConstant.DATABASE_NAME, connectionInfo.getHost());
+    props.put(DebeziumConstant.DATABASE_HOSTNAME, connectionInfo.getHost());
     props.put(DebeziumConstant.DATABASE_PORT, String.valueOf(connectionInfo.getPort()));
     props.put(DebeziumConstant.DATABASE_USER, username);
     props.put(DebeziumConstant.DATABASE_PASSWORD, password);

bitsail-connectors/connector-cdc/connector-cdc-jdbc-base/src/main/java/com/bytedance/bitsail/connector/cdc/jdbc/source/constant/DebeziumConstant.java

@@ -1,6 +1,20 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.jdbc.source.constant;
 
-
 public class DebeziumConstant {
   public static final String DATABASE_HOSTNAME = "database.hostname";
   public static final String DATABASE_PORT = "database.port";

bitsail-connectors/connector-cdc/connector-cdc-jdbc-base/src/main/java/com/bytedance/bitsail/connector/cdc/jdbc/source/reader/AbstractJdbcChangeEventSplitReader.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.jdbc.source.reader;
 
 import com.bytedance.bitsail.common.configuration.BitSailConfiguration;

bitsail-connectors/connector-cdc/connector-cdc-jdbc-base/src/main/java/com/bytedance/bitsail/connector/cdc/jdbc/source/streaming/AbstractSplitChangeEventStreamingTaskContext.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.jdbc.source.streaming;
 
 import com.bytedance.bitsail.connector.cdc.source.split.BinlogSplit;
@@ -22,7 +37,6 @@
 
 import java.sql.SQLException;
 
-
 @Getter
 public abstract class AbstractSplitChangeEventStreamingTaskContext {
 

bitsail-connectors/connector-cdc/connector-cdc-jdbc-base/src/main/java/com/bytedance/bitsail/connector/cdc/jdbc/source/streaming/SplitChangeEventStreamingTaskController.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.jdbc.source.streaming;
 
 import com.google.common.util.concurrent.ThreadFactoryBuilder;

bitsail-connectors/connector-cdc/connector-cdc-postgres/src/main/java/com/bytedance/bitsail/connector/cdc/postgres/source/PostgresChangeEventSource.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.postgres.source;
 
 import com.bytedance.bitsail.base.connector.reader.v1.SourceReader;

bitsail-connectors/connector-cdc/connector-cdc-postgres/src/main/java/com/bytedance/bitsail/connector/cdc/postgres/source/config/PostgresConfig.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.postgres.source.config;
 
 import com.bytedance.bitsail.common.configuration.BitSailConfiguration;

bitsail-connectors/connector-cdc/connector-cdc-postgres/src/main/java/com/bytedance/bitsail/connector/cdc/postgres/source/constant/PostgresConstant.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.postgres.source.constant;
 
 public class PostgresConstant {

bitsail-connectors/connector-cdc/connector-cdc-postgres/src/main/java/com/bytedance/bitsail/connector/cdc/postgres/source/option/PostgresChangeEventOptions.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.postgres.source.option;
 
 import com.bytedance.bitsail.common.option.ConfigOption;

bitsail-connectors/connector-cdc/connector-cdc-postgres/src/main/java/com/bytedance/bitsail/connector/cdc/postgres/source/reader/PostgresChangeEventReader.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.postgres.source.reader;
 
 import com.bytedance.bitsail.common.configuration.BitSailConfiguration;

bitsail-connectors/connector-cdc/connector-cdc-postgres/src/main/java/com/bytedance/bitsail/connector/cdc/postgres/source/reader/PostgresChangeEventSplitReader.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.postgres.source.reader;
 
 import com.bytedance.bitsail.common.configuration.BitSailConfiguration;
@@ -26,15 +41,4 @@ public AbstractJdbcDebeziumConfig getJdbcDebeziumConfig(BitSailConfiguration job
   public AbstractSplitChangeEventStreamingTaskContext getSplitReaderTaskContext(BinlogSplit split, RelationalDatabaseConnectorConfig connectorConfig) {
     return new PostgresChangeEventStreamingTaskContext(split, connectorConfig);
   }
-
-  @Override
-  public void testConnectionAndValidBinlogConfiguration(RelationalDatabaseConnectorConfig connectorConfig) throws IOException {
-    try {
-      String testSql = "SELECT version()";
-      this.splitChangeEventStreamingTaskContext.jdbcConnection.connect();
-      this.splitChangeEventStreamingTaskContext.jdbcConnection.execute(testSql);
-    } catch (SQLException e) {
-      throw new RuntimeException("Failed to connect", e);
-    }
-  }
 }

bitsail-connectors/connector-cdc/connector-cdc-postgres/src/main/java/com/bytedance/bitsail/connector/cdc/postgres/source/streaming/PostgresChangeEventStreamingTaskContext.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.postgres.source.streaming;
 
 import com.bytedance.bitsail.common.BitSailException;

bitsail-connectors/connector-cdc/connector-cdc-postgres/src/test/java/com/bytedance/bitsail/connector/cdc/postgres/container/PostgresContainerMariadbAdapter.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.postgres.container;
 
 import org.testcontainers.containers.PostgreSQLContainer;

bitsail-connectors/connector-cdc/connector-cdc-postgres/src/test/java/com/bytedance/bitsail/connector/cdc/postgres/source/config/PostgresConfigTest.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.postgres.source.config;
 
 import com.bytedance.bitsail.common.configuration.BitSailConfiguration;

bitsail-connectors/connector-cdc/connector-cdc-postgres/src/test/java/com/bytedance/bitsail/connector/cdc/postgres/source/debezium/PostgresChangeEventSplitContainerTest.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.postgres.source.debezium;
 
 import com.bytedance.bitsail.common.configuration.BitSailConfiguration;

bitsail-connectors/connector-cdc/connector-cdc-postgres/src/test/java/com/bytedance/bitsail/connector/cdc/postgres/source/reader/PostgresChangeEventReaderTest.java

@@ -1,3 +1,18 @@
+/*
+ * Copyright 2022-2023 Bytedance Ltd. and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
 package com.bytedance.bitsail.connector.cdc.postgres.source.reader;
 
 import com.bytedance.bitsail.common.configuration.BitSailConfiguration;