DBZ-8008 Update build to include jdbc sink
This commit is contained in:
Chris Cranford
parent
d8c63592ad
commit
1602123908
28
.github/actions/build-debezium-jdbc/action.yml
vendored
28
.github/actions/build-debezium-jdbc/action.yml
vendored
@ -2,11 +2,8 @@ name: "Build JDBC"
|
|||||||
description: "Builds the Debezium JDBC connector"
|
description: "Builds the Debezium JDBC connector"
|
||||||
|
|
||||||
inputs:
|
inputs:
|
||||||
path-core:
|
maven-cache-key:
|
||||||
description: "Debezium core repository checkout path"
|
description: "The maven build cache key"
|
||||||
required: true
|
|
||||||
path-jdbc:
|
|
||||||
description: "Debezium JDBC repository checkout path"
|
|
||||||
required: true
|
required: true
|
||||||
shell:
|
shell:
|
||||||
description: "The shell to use"
|
description: "The shell to use"
|
||||||
@ -16,25 +13,16 @@ inputs:
|
|||||||
runs:
|
runs:
|
||||||
using: "composite"
|
using: "composite"
|
||||||
steps:
|
steps:
|
||||||
- name: Build Debezium (Core)
|
- uses: ./.github/actions/setup-java
|
||||||
shell: ${{ inputs.shell }}
|
|
||||||
run: >
|
- uses: ./.github/actions/maven-cache
|
||||||
./${{ inputs.path-core }}/mvnw clean install -B -ntp -f ${{ inputs.path-core }}/pom.xml
|
with:
|
||||||
-pl debezium-assembly-descriptors,debezium-bom,debezium-core,debezium-embedded,:debezium-ide-configs,:debezium-checkstyle,:debezium-revapi
|
key: ${{ inputs.maven-cache-key }}
|
||||||
-am
|
|
||||||
-DskipTests=true
|
|
||||||
-DskipITs=true
|
|
||||||
-Dcheckstyle.skip=true
|
|
||||||
-Dformat.skip=true
|
|
||||||
-Drevapi.skip
|
|
||||||
-Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn
|
|
||||||
-Dmaven.wagon.http.pool=false
|
|
||||||
-Dmaven.wagon.httpconnectionManager.ttlSeconds=120
|
|
||||||
|
|
||||||
- name: Build JDBC
|
- name: Build JDBC
|
||||||
shell: ${{ inputs.shell }}
|
shell: ${{ inputs.shell }}
|
||||||
run: >
|
run: >
|
||||||
./${{ inputs.path-core }}/mvnw clean install -B -ntp -f ${{ inputs.path-jdbc }}/pom.xml
|
./mvnw clean install -B -pl debezium-connector-jdbc -am
|
||||||
-Passembly
|
-Passembly
|
||||||
-Dtest.tags=it-sqlserver,e2e-sqlserver,it-postgresql,e2e-postgresql,it-mysql,e2e-mysql
|
-Dtest.tags=it-sqlserver,e2e-sqlserver,it-postgresql,e2e-postgresql,it-mysql,e2e-mysql
|
||||||
-Dcheckstyle.skip=true
|
-Dcheckstyle.skip=true
|
||||||
|
|||||||
22
.github/workflows/debezium-workflow-pr.yml
vendored
22
.github/workflows/debezium-workflow-pr.yml
vendored
@ -630,28 +630,12 @@ jobs:
|
|||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
if: ${{ needs.file_changes.outputs.common-changed == 'true' || needs.file_changes.outputs.mysql-changed == 'true' || needs.file_changes.outputs.mysql-ddl-parser-changed == 'true' || needs.file_changes.outputs.mariadb-changed == 'true' || needs.file_changes.outputs.postgresql-changed == 'true' || needs.file_changes.outputs.sqlserver-changed == 'true' || needs.file_changes.outputs.sqlserver-changed == 'true' || needs.file_changes.outputs.db2-changed == 'true' }}
|
if: ${{ needs.file_changes.outputs.common-changed == 'true' || needs.file_changes.outputs.mysql-changed == 'true' || needs.file_changes.outputs.mysql-ddl-parser-changed == 'true' || needs.file_changes.outputs.mariadb-changed == 'true' || needs.file_changes.outputs.postgresql-changed == 'true' || needs.file_changes.outputs.sqlserver-changed == 'true' || needs.file_changes.outputs.sqlserver-changed == 'true' || needs.file_changes.outputs.db2-changed == 'true' }}
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout Action (Debezium Core)
|
- name: Checkout Action
|
||||||
uses: actions/checkout@v4
|
uses: actions/checkout@v4
|
||||||
with:
|
|
||||||
path: core
|
|
||||||
|
|
||||||
- name: Checkout Action (JDBC)
|
- uses: ./.github/actions/build-debezium-jdbc
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
with:
|
||||||
repository: debezium/debezium-connector-jdbc
|
maven-cache-key: maven-debezium-test-build-${{ hashFiles('**/pom.xml') }}
|
||||||
path: jdbc
|
|
||||||
|
|
||||||
- uses: ./core/.github/actions/setup-java
|
|
||||||
|
|
||||||
- uses: ./core/.github/actions/maven-cache
|
|
||||||
with:
|
|
||||||
# We specifically only use the hash of the pom files from the core repository
|
|
||||||
key: maven-debezium-test-build-${{ hashFiles('core/**/pom.xml') }}
|
|
||||||
|
|
||||||
- uses: ./core/.github/actions/build-debezium-jdbc
|
|
||||||
with:
|
|
||||||
path-core: core
|
|
||||||
path-jdbc: jdbc
|
|
||||||
|
|
||||||
build_debezium_server:
|
build_debezium_server:
|
||||||
name: "Debezium Server"
|
name: "Debezium Server"
|
||||||
|
|||||||
23
.github/workflows/debezium-workflow-push.yml
vendored
23
.github/workflows/debezium-workflow-push.yml
vendored
@ -453,29 +453,12 @@ jobs:
|
|||||||
needs: [ check_style, build_spanner ]
|
needs: [ check_style, build_spanner ]
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout Action (Debezium Core)
|
- name: Checkout Action
|
||||||
uses: actions/checkout@v4
|
uses: actions/checkout@v4
|
||||||
with:
|
|
||||||
path: core
|
|
||||||
|
|
||||||
- name: Checkout Action (JDBC)
|
- uses: ./.github/actions/build-debezium-jdbc
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
with:
|
||||||
repository: debezium/debezium-connector-jdbc
|
maven-cache-key: maven-debezium-test-push-build-${{ hashFiles('**/pom.xml') }}
|
||||||
path: jdbc
|
|
||||||
ref: ${{ github.ref_name }}
|
|
||||||
|
|
||||||
- uses: ./core/.github/actions/setup-java
|
|
||||||
|
|
||||||
- uses: ./core/.github/actions/maven-cache
|
|
||||||
with:
|
|
||||||
# We specifically only use the hash of the pom files from the core repository
|
|
||||||
key: maven-debezium-test-push-build-${{ hashFiles('core/**/pom.xml') }}
|
|
||||||
|
|
||||||
- uses: ./core/.github/actions/build-debezium-jdbc
|
|
||||||
with:
|
|
||||||
path-core: core
|
|
||||||
path-jdbc: jdbc
|
|
||||||
|
|
||||||
# Approx 26m
|
# Approx 26m
|
||||||
build_debezium_server:
|
build_debezium_server:
|
||||||
|
|||||||
24
debezium-connector-jdbc/.gitattributes
vendored
24
debezium-connector-jdbc/.gitattributes
vendored
@ -1,24 +0,0 @@
|
|||||||
# Repository specific GIT options
|
|
||||||
|
|
||||||
# Set default handling of line terminators for all non explicitly listed file types:
|
|
||||||
* text=auto
|
|
||||||
|
|
||||||
# Force LF as internal repository format for all following files;
|
|
||||||
# this overrides user settings to enforce the *right format* :
|
|
||||||
*.java text
|
|
||||||
*.xml text
|
|
||||||
*.txt text
|
|
||||||
*.md text
|
|
||||||
*.html text
|
|
||||||
*.properties text
|
|
||||||
*.rb text
|
|
||||||
*.pot text
|
|
||||||
*.po text
|
|
||||||
*.xsd text
|
|
||||||
*.header text
|
|
||||||
*.groovy text
|
|
||||||
*.css text
|
|
||||||
|
|
||||||
# Specify we want Java-friendly readable chunk headers for diff:
|
|
||||||
|
|
||||||
*.java diff=java
|
|
||||||
10
debezium-connector-jdbc/.github/dependabot.yml
vendored
10
debezium-connector-jdbc/.github/dependabot.yml
vendored
@ -1,10 +0,0 @@
|
|||||||
version: 2
|
|
||||||
updates:
|
|
||||||
# Updates for GitHub Actions
|
|
||||||
- package-ecosystem: "github-actions"
|
|
||||||
directory: "/"
|
|
||||||
schedule:
|
|
||||||
interval: "weekly"
|
|
||||||
commit-message:
|
|
||||||
prefix: "[ci] "
|
|
||||||
|
|
||||||
@ -1,51 +0,0 @@
|
|||||||
name: Contributor Check
|
|
||||||
on:
|
|
||||||
# ATTENTION: See https://securitylab.github.com/research/github-actions-preventing-pwn-requests/
|
|
||||||
# re security implications of using this trigger; in particular, no code from PR branches must
|
|
||||||
# be executed in any flows triggered by it
|
|
||||||
pull_request_target:
|
|
||||||
branches:
|
|
||||||
- main
|
|
||||||
- 1.*
|
|
||||||
- 2.*
|
|
||||||
types: [ opened ]
|
|
||||||
jobs:
|
|
||||||
build:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- name: Check if COPYRIGHT.txt has author name?
|
|
||||||
id: check
|
|
||||||
env:
|
|
||||||
pull_request_number: ${{ github.event.pull_request.number }}
|
|
||||||
github_repository: ${{ github.repository }}
|
|
||||||
run: |
|
|
||||||
curl -H 'Accept: application/vnd.github.v3.raw' https://raw.githubusercontent.com/debezium/debezium/main/COPYRIGHT.txt >> COPYRIGHT.txt
|
|
||||||
curl -H 'Accept: application/vnd.github.v3.raw' https://raw.githubusercontent.com/debezium/debezium/main/jenkins-jobs/scripts/config/Aliases.txt >> ALIASES.txt
|
|
||||||
curl -H 'Accept: application/vnd.github.v3.raw' https://raw.githubusercontent.com/debezium/debezium/main/jenkins-jobs/scripts/config/FilteredNames.txt >> FILTEREDNAMES.txt
|
|
||||||
|
|
||||||
curl --silent -X "GET" https://api.github.com/repos/$github_repository/pulls/$pull_request_number/commits | jq '.[] | {author: .commit.author.name}' | jq -r '.author' | uniq >> AUTHOR_NAME.txt
|
|
||||||
|
|
||||||
while IFS=" " read -r AUTHOR;
|
|
||||||
do
|
|
||||||
if ! grep -qi "$AUTHOR" COPYRIGHT.txt; then
|
|
||||||
if ! grep -qi "$AUTHOR" ALIASES.txt; then
|
|
||||||
if ! grep -qi "$AUTHOR" FILTEREDNAMES.txt; then
|
|
||||||
echo "USER_NOT_FOUND=true" >> $GITHUB_OUTPUT
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
done < AUTHOR_NAME.txt
|
|
||||||
- name: Create comment
|
|
||||||
if: ${{ steps.check.outputs.USER_NOT_FOUND == 'true' }}
|
|
||||||
uses: peter-evans/create-or-update-comment@v4
|
|
||||||
with:
|
|
||||||
issue-number: ${{ github.event.pull_request.number }}
|
|
||||||
body: |
|
|
||||||
Welcome as a new contributor to Debezium, @${{ github.event.pull_request.user.login }}. Reviewers, please add missing author name(s) and alias name(s) to the [COPYRIGHT.txt](https://github.com/debezium/debezium/blob/main/COPYRIGHT.txt) and [Aliases.txt](https://github.com/debezium/debezium/blob/main/jenkins-jobs/scripts/config/Aliases.txt) respectively.
|
|
||||||
- name: Check failure
|
|
||||||
if: ${{ steps.check.outputs.USER_NOT_FOUND == 'true' }}
|
|
||||||
uses: actions/github-script@v7
|
|
||||||
continue-on-error: false
|
|
||||||
with:
|
|
||||||
script: |
|
|
||||||
throw new Error('Add new user, @${{ github.event.pull_request.user.login }} to COPYRIGHT.txt and Aliases.txt')
|
|
||||||
@ -1,214 +0,0 @@
|
|||||||
#
|
|
||||||
# Copyright Debezium Authors
|
|
||||||
#
|
|
||||||
# Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Cross CI workflow is triggered on a `pull_request` event.
|
|
||||||
# It builds the Debezium core before building the Db2 connector basing on either the `master` branch or the `pull_request` branch.
|
|
||||||
# If a `pull_request` with same branch name is present in the Debezium's upstream core repository, then the core build of this `pull_request`
|
|
||||||
# will be based on `pull_request` branch of user's Debezium core repository.
|
|
||||||
# Otherwise the core build of this `pull_request` will be based on the `master` branch of Debezium's upstream core repository.
|
|
||||||
|
|
||||||
name: Cross Maven CI
|
|
||||||
|
|
||||||
on:
|
|
||||||
pull_request:
|
|
||||||
branches:
|
|
||||||
- main
|
|
||||||
- 1.*
|
|
||||||
- 2.*
|
|
||||||
paths-ignore:
|
|
||||||
- '*.md'
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
build_core:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
outputs:
|
|
||||||
coreHash: ${{ steps.core_hash.outputs.hash }}
|
|
||||||
steps:
|
|
||||||
- name: Check if pull request branch exists in debezium main repository
|
|
||||||
id: branch
|
|
||||||
env:
|
|
||||||
branch_name: ${{ github.head_ref }}
|
|
||||||
run: |
|
|
||||||
curl --silent -X "GET" https://api.github.com/repos/debezium/debezium/pulls | jq '.[] | {branch: .head.ref}' | jq -r '.branch' >> SORTED_PULLS.txt
|
|
||||||
|
|
||||||
while IFS=" " read -r BRANCH;
|
|
||||||
do
|
|
||||||
if grep -q "$branch_name" <<< "$BRANCH"; then
|
|
||||||
echo "BRANCH_FOUND=true" >> $GITHUB_OUTPUT
|
|
||||||
fi
|
|
||||||
done < SORTED_PULLS.txt
|
|
||||||
- name: Checkout core repository with pull request branch
|
|
||||||
if: ${{ steps.branch.outputs.BRANCH_FOUND == 'true' }}
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
repository: ${{ github.event.pull_request.user.login }}/debezium
|
|
||||||
ref: ${{ github.head_ref }}
|
|
||||||
path: core
|
|
||||||
- name: Checkout core repository with default base branch
|
|
||||||
if: ${{ steps.branch.outputs.BRANCH_FOUND != 'true' }}
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
repository: debezium/debezium
|
|
||||||
ref: ${{ github.base_ref }}
|
|
||||||
path: core
|
|
||||||
- name: Set up JDK
|
|
||||||
uses: actions/setup-java@v4
|
|
||||||
with:
|
|
||||||
distribution: 'temurin'
|
|
||||||
java-version: 21
|
|
||||||
- name: Cache Maven packages
|
|
||||||
uses: actions/cache@v4
|
|
||||||
id: cache
|
|
||||||
with:
|
|
||||||
path: ~/.m2/repository
|
|
||||||
key: ${{ runner.os }}-maven-debezium-core-${{ hashFiles('**/pom.xml') }}
|
|
||||||
restore-keys: ${{ runner.os }}-maven-debezium-core-${{ hashFiles('**/pom.xml') }}
|
|
||||||
- name: Maven build core
|
|
||||||
if: steps.cache.outputs.cache-hit != 'true'
|
|
||||||
run: ./core/mvnw clean install -f core/pom.xml -pl debezium-bom,debezium-core,debezium-embedded,debezium-storage -am -DskipTests -DskipITs -Dformat.formatter.goal=validate -Dformat.imports.goal=check -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120
|
|
||||||
- name: Output core cache hash
|
|
||||||
id: core_hash
|
|
||||||
run: |
|
|
||||||
echo "hash=${{ hashFiles('**/pom.xml') }}" >> "$GITHUB_OUTPUT"
|
|
||||||
|
|
||||||
# Build step that checks out the source, builds, and includes the integration and the
|
|
||||||
# end to end tests for DB2 as part of the build step.
|
|
||||||
build_db2:
|
|
||||||
name: Build and test (Db2)
|
|
||||||
needs: [ build_core ]
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- name: Checkout JDBC sink connector
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
path: jdbc
|
|
||||||
- name: Set up Java 21
|
|
||||||
uses: actions/setup-java@v4
|
|
||||||
with:
|
|
||||||
distribution: 'temurin'
|
|
||||||
java-version: 21
|
|
||||||
- name: Load Debezium core cache
|
|
||||||
uses: actions/cache/restore@v4
|
|
||||||
with:
|
|
||||||
path: ~/.m2/repository
|
|
||||||
key: ${{ runner.os }}-maven-debezium-core-${{ needs.build_core.outputs.coreHash}}
|
|
||||||
- name: Build sink
|
|
||||||
run: ./jdbc/mvnw clean install -f jdbc/pom.xml -B -Passembly -Dtest.tags=it-db2,e2e-db2 -Dsource.connectors=mysql,postgres,sqlserver
|
|
||||||
|
|
||||||
# Build step that checks out the source, builds, and includes the integration and the
|
|
||||||
# end to end tests for MySQL as part of the build step.
|
|
||||||
build_mysql:
|
|
||||||
name: Build and test (MySQL)
|
|
||||||
needs: [ build_core ]
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- name: Checkout core repository
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
repository: debezium/debezium
|
|
||||||
path: core
|
|
||||||
- name: Checkout JDBC sink connector
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
path: jdbc
|
|
||||||
- name: Set up Java 21
|
|
||||||
uses: actions/setup-java@v4
|
|
||||||
with:
|
|
||||||
distribution: 'temurin'
|
|
||||||
java-version: 21
|
|
||||||
- name: Load Debezium core cache
|
|
||||||
uses: actions/cache/restore@v4
|
|
||||||
with:
|
|
||||||
path: ~/.m2/repository
|
|
||||||
key: ${{ runner.os }}-maven-debezium-core-${{ needs.build_core.outputs.coreHash}}
|
|
||||||
- name: Build sink
|
|
||||||
run: ./jdbc/mvnw clean install -f jdbc/pom.xml -B -Passembly -Dtest.tags=it-mysql,e2e-mysql -Dsource.connectors=mysql,postgres,sqlserver
|
|
||||||
|
|
||||||
# Build step that checks out the source, builds, and includes the integration and the
|
|
||||||
# end to end tests for Oracle as part of the build step.
|
|
||||||
# build_oracle:
|
|
||||||
# name: Build and test (Oracle)
|
|
||||||
# needs: [build_core]
|
|
||||||
# runs-on: ubuntu-latest
|
|
||||||
# steps:
|
|
||||||
# - name: Checkout core repository
|
|
||||||
# uses: actions/checkout@v4
|
|
||||||
# with:
|
|
||||||
# repository: debezium/debezium
|
|
||||||
# path: core
|
|
||||||
# - name: Checkout JDBC sink connector
|
|
||||||
# uses: actions/checkout@v4
|
|
||||||
# with:
|
|
||||||
# path: jdbc
|
|
||||||
# - name: Set up Java 21
|
|
||||||
# uses: actions/setup-java@v4
|
|
||||||
# with:
|
|
||||||
# distribution: 'temurin'
|
|
||||||
# java-version: 21
|
|
||||||
# - name: Load Debezium core cache
|
|
||||||
# uses: actions/cache/restore@v4
|
|
||||||
# with:
|
|
||||||
# path: ~/.m2/repository
|
|
||||||
# key: ${{ runner.os }}-maven-debezium-core-${{ needs.build_core.outputs.coreHash}}
|
|
||||||
# - name: Build sink
|
|
||||||
# run: ./jdbc/mvnw clean install -f jdbc/pom.xml -B -Passembly -Dtest.tags=it-oracle,e2e-oracle -Dsource.connectors=mysql,postgres,sqlserver
|
|
||||||
|
|
||||||
# Build step that checks out the source, builds, and includes the integration and the
|
|
||||||
# end to end tests for PostgreSQL as part of the build step.
|
|
||||||
build_postgresql:
|
|
||||||
name: Build and test (PostgreSQL)
|
|
||||||
needs: [ build_core ]
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- name: Checkout core repository
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
repository: debezium/debezium
|
|
||||||
path: core
|
|
||||||
- name: Checkout JDBC sink connector
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
path: jdbc
|
|
||||||
- name: Set up Java 21
|
|
||||||
uses: actions/setup-java@v4
|
|
||||||
with:
|
|
||||||
distribution: 'temurin'
|
|
||||||
java-version: 21
|
|
||||||
- name: Load Debezium core cache
|
|
||||||
uses: actions/cache/restore@v4
|
|
||||||
with:
|
|
||||||
path: ~/.m2/repository
|
|
||||||
key: ${{ runner.os }}-maven-debezium-core-${{ needs.build_core.outputs.coreHash}}
|
|
||||||
- name: Build sink
|
|
||||||
run: ./jdbc/mvnw clean install -f jdbc/pom.xml -B -Passembly -Dtest.tags=it-postgresql,e2e-postgresql -Dsource.connectors=mysql,postgres,sqlserver
|
|
||||||
|
|
||||||
# Build step that checks out the source, builds, and includes the integration and the
|
|
||||||
# end to end tests for SQL Server as part of the build step.
|
|
||||||
build_sqlserver:
|
|
||||||
name: Build and test (SQL Server)
|
|
||||||
needs: [ build_core ]
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- name: Checkout core repository
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
repository: debezium/debezium
|
|
||||||
path: core
|
|
||||||
- name: Checkout JDBC sink connector
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
path: jdbc
|
|
||||||
- name: Set up Java 21
|
|
||||||
uses: actions/setup-java@v4
|
|
||||||
with:
|
|
||||||
distribution: 'temurin'
|
|
||||||
java-version: 21
|
|
||||||
- name: Load Debezium core cache
|
|
||||||
uses: actions/cache/restore@v4
|
|
||||||
with:
|
|
||||||
path: ~/.m2/repository
|
|
||||||
key: ${{ runner.os }}-maven-debezium-core-${{ needs.build_core.outputs.coreHash}}
|
|
||||||
- name: Build sink
|
|
||||||
run: ./jdbc/mvnw clean install -f jdbc/pom.xml -B -Passembly -Dtest.tags=it-sqlserver,e2e-sqlserver -Dsource.connectors=mysql,postgres,sqlserver
|
|
||||||
@ -1,46 +0,0 @@
|
|||||||
#
|
|
||||||
# Copyright Debezium Authors
|
|
||||||
#
|
|
||||||
# Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
name: Maven CI
|
|
||||||
|
|
||||||
on:
|
|
||||||
push:
|
|
||||||
branches:
|
|
||||||
- main
|
|
||||||
- 1.*
|
|
||||||
- 2.*
|
|
||||||
paths-ignore:
|
|
||||||
- '*.md'
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
build:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
|
|
||||||
steps:
|
|
||||||
- name: Checkout core repository
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
repository: debezium/debezium
|
|
||||||
ref: ${{ github.ref }}
|
|
||||||
path: core
|
|
||||||
- name: Checkout JDBC connector
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
path: jdbc
|
|
||||||
- name: Set up JDK
|
|
||||||
uses: actions/setup-java@v4
|
|
||||||
with:
|
|
||||||
distribution: 'temurin'
|
|
||||||
java-version: 21
|
|
||||||
- name: Cache Maven packages
|
|
||||||
uses: actions/cache@v4
|
|
||||||
with:
|
|
||||||
path: ~/.m2
|
|
||||||
key: ${{ runner.os }}-m2-${{ hashFiles('**/pom.xml') }}
|
|
||||||
restore-keys: ${{ runner.os }}-m2
|
|
||||||
- name: Maven build core
|
|
||||||
run: ./jdbc/mvnw clean install -f core/pom.xml -pl debezium-bom,debezium-core,debezium-embedded,debezium-storage -am -DskipTests -DskipITs -Dformat.formatter.goal=validate -Dformat.imports.goal=check -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120
|
|
||||||
- name: Maven build JDBC
|
|
||||||
run: ./jdbc/mvnw clean install -f jdbc/pom.xml -Passembly -Dformat.formatter.goal=validate -Dformat.imports.goal=check -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120
|
|
||||||
@ -1,43 +0,0 @@
|
|||||||
name: Octocat commits check
|
|
||||||
on:
|
|
||||||
# ATTENTION: See https://securitylab.github.com/research/github-actions-preventing-pwn-requests/
|
|
||||||
# re security implications of using this trigger; in particular, no code from PR branches must
|
|
||||||
# be executed in any flows triggered by it
|
|
||||||
pull_request_target:
|
|
||||||
branches:
|
|
||||||
- main
|
|
||||||
- 1.*
|
|
||||||
- 2.*
|
|
||||||
jobs:
|
|
||||||
build:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- name: Check if octocat commits are present?
|
|
||||||
id: octocat
|
|
||||||
env:
|
|
||||||
pull_request_number: ${{ github.event.pull_request.number }}
|
|
||||||
github_repository: ${{ github.repository }}
|
|
||||||
run: |
|
|
||||||
curl --silent -X "GET" https://api.github.com/repos/$github_repository/pulls/$pull_request_number/commits | jq '.[] | {author: .author.login}' | jq -r '.author' >> SORTED_AUTHORS.txt
|
|
||||||
|
|
||||||
while IFS=" " read -r AUTHOR;
|
|
||||||
do
|
|
||||||
if [[ $AUTHOR == *"null"* ]]; then
|
|
||||||
echo "OCTOCAT_COMMIT_FOUND=true" >> $GITHUB_OUTPUT
|
|
||||||
fi
|
|
||||||
done < SORTED_AUTHORS.txt
|
|
||||||
- name: Create comment
|
|
||||||
if: ${{ steps.octocat.outputs.OCTOCAT_COMMIT_FOUND == 'true' }}
|
|
||||||
uses: peter-evans/create-or-update-comment@v4
|
|
||||||
with:
|
|
||||||
issue-number: ${{ github.event.pull_request.number }}
|
|
||||||
body: |
|
|
||||||
Hi @${{ github.event.pull_request.user.login }}. Thank you for your valuable contribution.
|
|
||||||
Please author your commit(s) using an email [linked to your GitHub account](https://docs.github.com/en/account-and-profile/setting-up-and-managing-your-github-profile/managing-contribution-graphs-on-your-profile/why-are-my-contributions-not-showing-up-on-my-profile).
|
|
||||||
- name: Check failure
|
|
||||||
if: ${{ steps.check.outputs.OCTOCAT_COMMIT_FOUND == 'true' }}
|
|
||||||
uses: actions/github-script@v7
|
|
||||||
continue-on-error: false
|
|
||||||
with:
|
|
||||||
script: |
|
|
||||||
throw new Error('Octocat commits found')
|
|
||||||
@ -1,53 +0,0 @@
|
|||||||
name: Commit message format check
|
|
||||||
on:
|
|
||||||
# ATTENTION: See https://securitylab.github.com/research/github-actions-preventing-pwn-requests/
|
|
||||||
# re security implications of using this trigger; in particular, no code from PR branches must
|
|
||||||
# be executed in any flows triggered by it
|
|
||||||
pull_request_target:
|
|
||||||
branches:
|
|
||||||
- main
|
|
||||||
- 1.*
|
|
||||||
- 2.*
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
build:
|
|
||||||
name: Commit message
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- name: Commit messages in format DBZ-xxx
|
|
||||||
id: check
|
|
||||||
env:
|
|
||||||
pull_request_number: ${{ github.event.pull_request.number }}
|
|
||||||
github_repository: ${{ github.repository }}
|
|
||||||
run: |
|
|
||||||
COMMIT_MSGS=$(curl --silent -X "GET" https://api.github.com/repos/$github_repository/pulls/$pull_request_number/commits | jq '.[] | {message: .commit.message}' | jq '.message' | cut -c 2-)
|
|
||||||
NON_PREFIX_COMMITS=""
|
|
||||||
while IFS= read -r line ;
|
|
||||||
do
|
|
||||||
line=${line%\"}
|
|
||||||
echo "-> checking: $line"
|
|
||||||
if [[ ! $line =~ (^DBZ-[[:digit:]]+)|(\[release\])|(\[jenkins-jobs\])|(\[docs\])|(\[maven-release-plugin\])|(\[ci\]) ]]; then
|
|
||||||
NON_PREFIX_COMMITS="${NON_PREFIX_COMMITS} -> ${line} \n"
|
|
||||||
fi
|
|
||||||
done <<< "$COMMIT_MSGS"
|
|
||||||
if [[ $NON_PREFIX_COMMITS != "" ]]; then
|
|
||||||
echo "========================================================================"
|
|
||||||
echo " COMMIT MESSAGES WITH MISSING \"DBZ\" PREFIX"
|
|
||||||
echo "========================================================================"
|
|
||||||
echo -e "$NON_PREFIX_COMMITS"
|
|
||||||
echo "PREFIX_COMMITS=false" >> $GITHUB_OUTPUT
|
|
||||||
fi
|
|
||||||
- name: Create Comment
|
|
||||||
if: ${{ steps.check.outputs.PREFIX_COMMITS == 'false' }}
|
|
||||||
uses: peter-evans/create-or-update-comment@v4
|
|
||||||
with:
|
|
||||||
issue-number: ${{ github.event.pull_request.number }}
|
|
||||||
body: |
|
|
||||||
Hi @${{ github.event.pull_request.user.login }}, thanks for your contribution. Please prefix the commit message(s) with the [DBZ-xxx JIRA issue key](https://github.com/debezium/debezium/blob/main/CONTRIBUTE.md#making-changes).
|
|
||||||
- name: Check failure
|
|
||||||
if: ${{ steps.check.outputs.PREFIX_COMMITS == 'false' }}
|
|
||||||
uses: actions/github-script@v7
|
|
||||||
continue-on-error: false
|
|
||||||
with:
|
|
||||||
script: |
|
|
||||||
throw new Error('Commit has no DBZ-xxx prefiix')
|
|
||||||
30
debezium-connector-jdbc/.gitignore
vendored
30
debezium-connector-jdbc/.gitignore
vendored
@ -1,30 +0,0 @@
|
|||||||
activemq-data/
|
|
||||||
.idea/
|
|
||||||
*.iml
|
|
||||||
*.ipr
|
|
||||||
*.iws
|
|
||||||
.metadata/
|
|
||||||
.recommenders/
|
|
||||||
.classpath
|
|
||||||
.project
|
|
||||||
.cache
|
|
||||||
.settings/
|
|
||||||
.factorypath
|
|
||||||
.checkstyle
|
|
||||||
.gradle/
|
|
||||||
.vscode/
|
|
||||||
build/
|
|
||||||
deploy/
|
|
||||||
target/
|
|
||||||
mods/
|
|
||||||
*.swp
|
|
||||||
epom
|
|
||||||
log
|
|
||||||
npm-debug.log
|
|
||||||
.DS_Store
|
|
||||||
phantomjsdriver.log
|
|
||||||
|
|
||||||
generated-sources/
|
|
||||||
|
|
||||||
/state/
|
|
||||||
bin/
|
|
||||||
Binary file not shown.
@ -1,20 +0,0 @@
|
|||||||
# Licensed to the Apache Software Foundation (ASF) under one
|
|
||||||
# or more contributor license agreements. See the NOTICE file
|
|
||||||
# distributed with this work for additional information
|
|
||||||
# regarding copyright ownership. The ASF licenses this file
|
|
||||||
# to you 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.
|
|
||||||
wrapperVersion=3.3.2
|
|
||||||
distributionType=bin
|
|
||||||
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.8/apache-maven-3.9.8-bin.zip
|
|
||||||
wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.3.2/maven-wrapper-3.3.2.jar
|
|
||||||
@ -1,201 +0,0 @@
|
|||||||
Apache License
|
|
||||||
Version 2.0, January 2004
|
|
||||||
http://www.apache.org/licenses/
|
|
||||||
|
|
||||||
TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
|
|
||||||
|
|
||||||
1. Definitions.
|
|
||||||
|
|
||||||
"License" shall mean the terms and conditions for use, reproduction,
|
|
||||||
and distribution as defined by Sections 1 through 9 of this document.
|
|
||||||
|
|
||||||
"Licensor" shall mean the copyright owner or entity authorized by
|
|
||||||
the copyright owner that is granting the License.
|
|
||||||
|
|
||||||
"Legal Entity" shall mean the union of the acting entity and all
|
|
||||||
other entities that control, are controlled by, or are under common
|
|
||||||
control with that entity. For the purposes of this definition,
|
|
||||||
"control" means (i) the power, direct or indirect, to cause the
|
|
||||||
direction or management of such entity, whether by contract or
|
|
||||||
otherwise, or (ii) ownership of fifty percent (50%) or more of the
|
|
||||||
outstanding shares, or (iii) beneficial ownership of such entity.
|
|
||||||
|
|
||||||
"You" (or "Your") shall mean an individual or Legal Entity
|
|
||||||
exercising permissions granted by this License.
|
|
||||||
|
|
||||||
"Source" form shall mean the preferred form for making modifications,
|
|
||||||
including but not limited to software source code, documentation
|
|
||||||
source, and configuration files.
|
|
||||||
|
|
||||||
"Object" form shall mean any form resulting from mechanical
|
|
||||||
transformation or translation of a Source form, including but
|
|
||||||
not limited to compiled object code, generated documentation,
|
|
||||||
and conversions to other media types.
|
|
||||||
|
|
||||||
"Work" shall mean the work of authorship, whether in Source or
|
|
||||||
Object form, made available under the License, as indicated by a
|
|
||||||
copyright notice that is included in or attached to the work
|
|
||||||
(an example is provided in the Appendix below).
|
|
||||||
|
|
||||||
"Derivative Works" shall mean any work, whether in Source or Object
|
|
||||||
form, that is based on (or derived from) the Work and for which the
|
|
||||||
editorial revisions, annotations, elaborations, or other modifications
|
|
||||||
represent, as a whole, an original work of authorship. For the purposes
|
|
||||||
of this License, Derivative Works shall not include works that remain
|
|
||||||
separable from, or merely link (or bind by name) to the interfaces of,
|
|
||||||
the Work and Derivative Works thereof.
|
|
||||||
|
|
||||||
"Contribution" shall mean any work of authorship, including
|
|
||||||
the original version of the Work and any modifications or additions
|
|
||||||
to that Work or Derivative Works thereof, that is intentionally
|
|
||||||
submitted to Licensor for inclusion in the Work by the copyright owner
|
|
||||||
or by an individual or Legal Entity authorized to submit on behalf of
|
|
||||||
the copyright owner. For the purposes of this definition, "submitted"
|
|
||||||
means any form of electronic, verbal, or written communication sent
|
|
||||||
to the Licensor or its representatives, including but not limited to
|
|
||||||
communication on electronic mailing lists, source code control systems,
|
|
||||||
and issue tracking systems that are managed by, or on behalf of, the
|
|
||||||
Licensor for the purpose of discussing and improving the Work, but
|
|
||||||
excluding communication that is conspicuously marked or otherwise
|
|
||||||
designated in writing by the copyright owner as "Not a Contribution."
|
|
||||||
|
|
||||||
"Contributor" shall mean Licensor and any individual or Legal Entity
|
|
||||||
on behalf of whom a Contribution has been received by Licensor and
|
|
||||||
subsequently incorporated within the Work.
|
|
||||||
|
|
||||||
2. Grant of Copyright License. Subject to the terms and conditions of
|
|
||||||
this License, each Contributor hereby grants to You a perpetual,
|
|
||||||
worldwide, non-exclusive, no-charge, royalty-free, irrevocable
|
|
||||||
copyright license to reproduce, prepare Derivative Works of,
|
|
||||||
publicly display, publicly perform, sublicense, and distribute the
|
|
||||||
Work and such Derivative Works in Source or Object form.
|
|
||||||
|
|
||||||
3. Grant of Patent License. Subject to the terms and conditions of
|
|
||||||
this License, each Contributor hereby grants to You a perpetual,
|
|
||||||
worldwide, non-exclusive, no-charge, royalty-free, irrevocable
|
|
||||||
(except as stated in this section) patent license to make, have made,
|
|
||||||
use, offer to sell, sell, import, and otherwise transfer the Work,
|
|
||||||
where such license applies only to those patent claims licensable
|
|
||||||
by such Contributor that are necessarily infringed by their
|
|
||||||
Contribution(s) alone or by combination of their Contribution(s)
|
|
||||||
with the Work to which such Contribution(s) was submitted. If You
|
|
||||||
institute patent litigation against any entity (including a
|
|
||||||
cross-claim or counterclaim in a lawsuit) alleging that the Work
|
|
||||||
or a Contribution incorporated within the Work constitutes direct
|
|
||||||
or contributory patent infringement, then any patent licenses
|
|
||||||
granted to You under this License for that Work shall terminate
|
|
||||||
as of the date such litigation is filed.
|
|
||||||
|
|
||||||
4. Redistribution. You may reproduce and distribute copies of the
|
|
||||||
Work or Derivative Works thereof in any medium, with or without
|
|
||||||
modifications, and in Source or Object form, provided that You
|
|
||||||
meet the following conditions:
|
|
||||||
|
|
||||||
(a) You must give any other recipients of the Work or
|
|
||||||
Derivative Works a copy of this License; and
|
|
||||||
|
|
||||||
(b) You must cause any modified files to carry prominent notices
|
|
||||||
stating that You changed the files; and
|
|
||||||
|
|
||||||
(c) You must retain, in the Source form of any Derivative Works
|
|
||||||
that You distribute, all copyright, patent, trademark, and
|
|
||||||
attribution notices from the Source form of the Work,
|
|
||||||
excluding those notices that do not pertain to any part of
|
|
||||||
the Derivative Works; and
|
|
||||||
|
|
||||||
(d) If the Work includes a "NOTICE" text file as part of its
|
|
||||||
distribution, then any Derivative Works that You distribute must
|
|
||||||
include a readable copy of the attribution notices contained
|
|
||||||
within such NOTICE file, excluding those notices that do not
|
|
||||||
pertain to any part of the Derivative Works, in at least one
|
|
||||||
of the following places: within a NOTICE text file distributed
|
|
||||||
as part of the Derivative Works; within the Source form or
|
|
||||||
documentation, if provided along with the Derivative Works; or,
|
|
||||||
within a display generated by the Derivative Works, if and
|
|
||||||
wherever such third-party notices normally appear. The contents
|
|
||||||
of the NOTICE file are for informational purposes only and
|
|
||||||
do not modify the License. You may add Your own attribution
|
|
||||||
notices within Derivative Works that You distribute, alongside
|
|
||||||
or as an addendum to the NOTICE text from the Work, provided
|
|
||||||
that such additional attribution notices cannot be construed
|
|
||||||
as modifying the License.
|
|
||||||
|
|
||||||
You may add Your own copyright statement to Your modifications and
|
|
||||||
may provide additional or different license terms and conditions
|
|
||||||
for use, reproduction, or distribution of Your modifications, or
|
|
||||||
for any such Derivative Works as a whole, provided Your use,
|
|
||||||
reproduction, and distribution of the Work otherwise complies with
|
|
||||||
the conditions stated in this License.
|
|
||||||
|
|
||||||
5. Submission of Contributions. Unless You explicitly state otherwise,
|
|
||||||
any Contribution intentionally submitted for inclusion in the Work
|
|
||||||
by You to the Licensor shall be under the terms and conditions of
|
|
||||||
this License, without any additional terms or conditions.
|
|
||||||
Notwithstanding the above, nothing herein shall supersede or modify
|
|
||||||
the terms of any separate license agreement you may have executed
|
|
||||||
with Licensor regarding such Contributions.
|
|
||||||
|
|
||||||
6. Trademarks. This License does not grant permission to use the trade
|
|
||||||
names, trademarks, service marks, or product names of the Licensor,
|
|
||||||
except as required for reasonable and customary use in describing the
|
|
||||||
origin of the Work and reproducing the content of the NOTICE file.
|
|
||||||
|
|
||||||
7. Disclaimer of Warranty. Unless required by applicable law or
|
|
||||||
agreed to in writing, Licensor provides the Work (and each
|
|
||||||
Contributor provides its Contributions) on an "AS IS" BASIS,
|
|
||||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
|
|
||||||
implied, including, without limitation, any warranties or conditions
|
|
||||||
of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
|
|
||||||
PARTICULAR PURPOSE. You are solely responsible for determining the
|
|
||||||
appropriateness of using or redistributing the Work and assume any
|
|
||||||
risks associated with Your exercise of permissions under this License.
|
|
||||||
|
|
||||||
8. Limitation of Liability. In no event and under no legal theory,
|
|
||||||
whether in tort (including negligence), contract, or otherwise,
|
|
||||||
unless required by applicable law (such as deliberate and grossly
|
|
||||||
negligent acts) or agreed to in writing, shall any Contributor be
|
|
||||||
liable to You for damages, including any direct, indirect, special,
|
|
||||||
incidental, or consequential damages of any character arising as a
|
|
||||||
result of this License or out of the use or inability to use the
|
|
||||||
Work (including but not limited to damages for loss of goodwill,
|
|
||||||
work stoppage, computer failure or malfunction, or any and all
|
|
||||||
other commercial damages or losses), even if such Contributor
|
|
||||||
has been advised of the possibility of such damages.
|
|
||||||
|
|
||||||
9. Accepting Warranty or Additional Liability. While redistributing
|
|
||||||
the Work or Derivative Works thereof, You may choose to offer,
|
|
||||||
and charge a fee for, acceptance of support, warranty, indemnity,
|
|
||||||
or other liability obligations and/or rights consistent with this
|
|
||||||
License. However, in accepting such obligations, You may act only
|
|
||||||
on Your own behalf and on Your sole responsibility, not on behalf
|
|
||||||
of any other Contributor, and only if You agree to indemnify,
|
|
||||||
defend, and hold each Contributor harmless for any liability
|
|
||||||
incurred by, or claims asserted against, such Contributor by reason
|
|
||||||
of your accepting any such warranty or additional liability.
|
|
||||||
|
|
||||||
END OF TERMS AND CONDITIONS
|
|
||||||
|
|
||||||
APPENDIX: How to apply the Apache License to your work.
|
|
||||||
|
|
||||||
To apply the Apache License to your work, attach the following
|
|
||||||
boilerplate notice, with the fields enclosed by brackets "[]"
|
|
||||||
replaced with your own identifying information. (Don't include
|
|
||||||
the brackets!) The text should be enclosed in the appropriate
|
|
||||||
comment syntax for the file format. We also recommend that a
|
|
||||||
file or class name and description of purpose be included on the
|
|
||||||
same "printed page" as the copyright notice for easier
|
|
||||||
identification within third-party archives.
|
|
||||||
|
|
||||||
Copyright [yyyy] [name of copyright owner]
|
|
||||||
|
|
||||||
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.
|
|
||||||
@ -1,152 +0,0 @@
|
|||||||
[](http://www.apache.org/licenses/LICENSE-2.0.html)
|
|
||||||
[](https://central.sonatype.com/search?smo=true&q=io.debezium)
|
|
||||||
[](https://debezium.zulipchat.com/#narrow/stream/302529-users)
|
|
||||||
[](https://debezium.zulipchat.com/#narrow/stream/302533-dev)
|
|
||||||
[](https://groups.google.com/forum/#!forum/debezium)
|
|
||||||
[](http://stackoverflow.com/questions/tagged/debezium)
|
|
||||||
|
|
||||||
Copyright Debezium Authors.
|
|
||||||
Licensed under the [Apache License, Version 2.0](http://www.apache.org/licenses/LICENSE-2.0).
|
|
||||||
|
|
||||||
# Debezium JDBC Sink Connector
|
|
||||||
|
|
||||||
Debezium is an open source project that provides a low latency data streaming platform for change data capture (CDC).
|
|
||||||
This connector provides a sink implementation for streaming changes emitted by Debezium into a relational database.
|
|
||||||
|
|
||||||
## What's different from other JDBC sink connectors?
|
|
||||||
|
|
||||||
This connector implementation is Debezium-source aware.
|
|
||||||
This means that the connector can consume native Debezium change events without needing to use the `ExtractNewRecordState` to flatten the event structure.
|
|
||||||
This reduces the necessary configuration to use a JDBC sink connector.
|
|
||||||
In addition, this also means that the sink side of the pipeline can take advantage of Debezium metadata, such as column type propagation to seamlessly support proper column type resolution on the sink connector side of the pipeline.
|
|
||||||
|
|
||||||
## Architecture
|
|
||||||
|
|
||||||
The JDBC sink connector is a traditional Kafka Connect sink connector (aka consumer).
|
|
||||||
Its job is to read records from a one or more Kafka topics and to produce SQL statements that are executed on the configured destination database.
|
|
||||||
|
|
||||||
### Sink record descriptors
|
|
||||||
|
|
||||||
A `SinkRecordDescriptor` is an object that gets constructed from every `SinkRecord`.
|
|
||||||
Most methods that would otherwise take a `SinkRecord` take this descriptor object instead.
|
|
||||||
The descriptor is in effect a pre-processed version of the `SinkRecord`, which allows us to perform this pre-processing once and to then make use of this information across the connector.
|
|
||||||
When adding new methods, you generally will want to use a `SinkRecordDescriptor`.
|
|
||||||
|
|
||||||
### Dialects
|
|
||||||
|
|
||||||
Each sink database will typically have its own `DatabaseDialect` implementation that should extend `GeneralDatabaseDialect`.
|
|
||||||
The dialect is one of the core mechanisms used by the JDBC sink connector in order to resolve SQL statements and other database characteristics for the database the connector will be writing consumed events into.
|
|
||||||
The JDBC sink connector relies on the dialect resolution of Hibernate to drive the dialect wrapper used by the connector.
|
|
||||||
|
|
||||||
If no dialect mapping is detected for the sink database being used, the JDBC sink connector will default to using the `GeneralDatabaseDialect` implementation.
|
|
||||||
This generalized implementation does not support every aspect of the connector, for example UPSERT insert mode is not supported when this dialect is chosen as the UPSERT statement is generally unique to the database being used.
|
|
||||||
It's generally a good idea to add a new dialect implementation if a new sink database is to have full compatibility with the JDBC sink connector's vast behavior.
|
|
||||||
|
|
||||||
### Types
|
|
||||||
|
|
||||||
Every field in a Kafka message is associated with a schema type, but this type information can also carry other metadata such as a name or even parameters that have been provided by the source connector.
|
|
||||||
The JDBC sink connector utilizes a type system, which is based on the `io.debezium.connector.jdbc.type.Type` contract, in order to handle value binding, default value resolution, and other characteristic that could be type-specific.
|
|
||||||
|
|
||||||
There are effectively three different types of `Type` implementations:
|
|
||||||
|
|
||||||
* Those to support Kafka Connect's schema types, found in `io.debezium.connector.jdbc.type.connect`.
|
|
||||||
* Those to support Debezium-specific named schema types, found in `io.debezium.connector.jdbc.type.debezium`.
|
|
||||||
* Dialect-specific types, found in `io.debezium.connector.jdbc.dialect` hierarchy.
|
|
||||||
|
|
||||||
Types are registered in a hierarchical pattern, starting with the Kafka Connect types, then the Debezium types, and lastly the dialect-specific types.
|
|
||||||
This enables the Debezium types to override Kafka Connect types if needed and finally the dialect to override any other contributed type.
|
|
||||||
|
|
||||||
Types are resolved by first looking at the Kafka schema name and mapping this to a type registration.
|
|
||||||
If the schema does not have a name, the type of the schema is then used to resolve to a type.
|
|
||||||
This allows the base Kafka Connect types to have a final say in how data is interpreted if no other type implementation is detected for the field.
|
|
||||||
|
|
||||||
### Naming Strategies
|
|
||||||
|
|
||||||
There are two naming strategies used by the JDBC sink connector:
|
|
||||||
|
|
||||||
* Table naming strategy, `TableNamingStrategy`
|
|
||||||
* Column naming strategy, `ColumnNamingStrategy`
|
|
||||||
|
|
||||||
The JDBC sink connector is shipped with default implementations of both, found in the `io.debezium.connector.jdbc.naming` package.
|
|
||||||
The default behavior of these two strategies are as follows:
|
|
||||||
|
|
||||||
* The table naming strategy replaces all occurrences of `.` with `_` and uses the configured `table.name.format` value to resolve the table's final name.
|
|
||||||
So assuming that the topic name of the event is `server.schema.table` with the default `table.name.format=dbo.${topic}`, the destination table will be created as `dbo.server_schema_table`.
|
|
||||||
* The column naming strategy allows you to define any custom behavior on column name resolution.
|
|
||||||
The default behavior is to simply return the field name as the column name.
|
|
||||||
|
|
||||||
These two strategies can be overridden by specifying fully qualified class name references in the connector configuration.
|
|
||||||
An example configuration:
|
|
||||||
|
|
||||||
table.naming.strategy=io.debezium.connector.jdbc.naming.DefaultTableNamingStrategy
|
|
||||||
column.naming.strategy=io.debezium.connector.jdbc.naming.DefaultColumnNamingStrategy
|
|
||||||
|
|
||||||
### Relational model
|
|
||||||
|
|
||||||
The JDBC sink connector maintains an in-memory relational model, similar to Debezium source connectors.
|
|
||||||
These relational model classes can be found in the `io.debezium.connector.jdbc.relational` package.
|
|
||||||
|
|
||||||
## Building the JDBC sink connector
|
|
||||||
|
|
||||||
The following is required in order to work with the Debezium JDBC sink connector code base, and to build it locally:
|
|
||||||
|
|
||||||
* [Git](https://git-scm.com) 2.2.1 or later
|
|
||||||
* JDK 17 or later, e.g. [OpenJDK](http://openjdk.java.net/projects/jdk)
|
|
||||||
* [Docker Engine](https://docs.docker.com/engine/install/) or [Docker Desktop](https://docs.docker.com/desktop/) 1.9 or later
|
|
||||||
* [Apache Maven](https://maven.apache.org/index.html) 3.8.4 or later
|
|
||||||
(or invoke the wrapper with `.mvnw` for Maven commands)
|
|
||||||
|
|
||||||
### Why Docker?
|
|
||||||
|
|
||||||
The test suite is heavily based on TestContainer usage, and automatically starts a variety of source and sink databases automatically.
|
|
||||||
Without a Docker-compatible environment, the integration tests will not run.
|
|
||||||
If you don't have a Docker environment, you can skip the integration tests by using the `-DskipITs` command line argument, shown below:
|
|
||||||
|
|
||||||
$ ./mvnw clean verify -DskipITs
|
|
||||||
|
|
||||||
### Running the tests
|
|
||||||
|
|
||||||
There are three types of types in the test suite:
|
|
||||||
|
|
||||||
* Unit tests
|
|
||||||
* Sink-based integration tests
|
|
||||||
* End to end matrix-based Integration tests
|
|
||||||
|
|
||||||
By default all unit tests are executed as a part of the build.
|
|
||||||
The sink-based integration tests are only executed for MySQL, PostgreSQL, and SQL Server by default, while none of the end-to-end matrix-based tests are executed.
|
|
||||||
|
|
||||||
In order to execute the sink-based integration tests for Oracle and DB2, the `-Dtest.tags` argument must be provided to include these in the build.
|
|
||||||
In order to do this, add all the integration tests to be executed, as shown below for all databases:
|
|
||||||
|
|
||||||
$ ./mvnw clean install -Dtest.tags=it-mysql,it-postgresql,it-sqlserver,it-oracle,it-db2
|
|
||||||
|
|
||||||
In order to run all sink-based integration tests for all databases, a short-cut tag is provided:
|
|
||||||
|
|
||||||
$ ./mvnw clean install -Dtest.tags=it
|
|
||||||
|
|
||||||
Similarly, in order to enable specific end to end tests, the `-Dtest.tags` argument can also be supplied with the necessary tags for each sink database type:
|
|
||||||
|
|
||||||
$ ./mvnw clean install -Dtest.tags=e2e-mysql,e2e-postgresql,e2e-sqlserver,e2e-oracle,e2e-db2
|
|
||||||
|
|
||||||
In order to run all end to end integration tests, a short-cut tag is provided as well:
|
|
||||||
|
|
||||||
$ ./mvnw clean install -Dtest.tags=e2e
|
|
||||||
|
|
||||||
In order to run all tests for all source/sink combinations:
|
|
||||||
|
|
||||||
$ ./mvnw clean install -Dtest.tags=all
|
|
||||||
|
|
||||||
## Contributing
|
|
||||||
|
|
||||||
The Debezium community welcomes anyone that wants to help out in any way, whether that includes reporting problems, helping with documentation, or contributing code changes to fix bugs, add tests, or implement new features.
|
|
||||||
See [this document](https://github.com/debezium/debezium/blob/main/CONTRIBUTE.md) for details.
|
|
||||||
|
|
||||||
A big thank you to all the Debezium JDBC sink contributors!
|
|
||||||
|
|
||||||
<a href="https://github.com/debezium/debezium-connector-jdbc/graphs/contributors">
|
|
||||||
<img src="https://contributors-img.web.app/image?repo=debezium/debezium-connector-jdbc" />
|
|
||||||
</a>
|
|
||||||
|
|
||||||
## License
|
|
||||||
|
|
||||||
This project is licensed under the Apache License, version 2.
|
|
||||||
332
debezium-connector-jdbc/mvnw
vendored
332
debezium-connector-jdbc/mvnw
vendored
@ -1,332 +0,0 @@
|
|||||||
#!/bin/sh
|
|
||||||
# ----------------------------------------------------------------------------
|
|
||||||
# Licensed to the Apache Software Foundation (ASF) under one
|
|
||||||
# or more contributor license agreements. See the NOTICE file
|
|
||||||
# distributed with this work for additional information
|
|
||||||
# regarding copyright ownership. The ASF licenses this file
|
|
||||||
# to you 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.
|
|
||||||
# ----------------------------------------------------------------------------
|
|
||||||
|
|
||||||
# ----------------------------------------------------------------------------
|
|
||||||
# Apache Maven Wrapper startup batch script, version 3.3.2
|
|
||||||
#
|
|
||||||
# Required ENV vars:
|
|
||||||
# ------------------
|
|
||||||
# JAVA_HOME - location of a JDK home dir
|
|
||||||
#
|
|
||||||
# Optional ENV vars
|
|
||||||
# -----------------
|
|
||||||
# MAVEN_OPTS - parameters passed to the Java VM when running Maven
|
|
||||||
# e.g. to debug Maven itself, use
|
|
||||||
# set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
|
|
||||||
# MAVEN_SKIP_RC - flag to disable loading of mavenrc files
|
|
||||||
# ----------------------------------------------------------------------------
|
|
||||||
|
|
||||||
if [ -z "$MAVEN_SKIP_RC" ]; then
|
|
||||||
|
|
||||||
if [ -f /usr/local/etc/mavenrc ]; then
|
|
||||||
. /usr/local/etc/mavenrc
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -f /etc/mavenrc ]; then
|
|
||||||
. /etc/mavenrc
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -f "$HOME/.mavenrc" ]; then
|
|
||||||
. "$HOME/.mavenrc"
|
|
||||||
fi
|
|
||||||
|
|
||||||
fi
|
|
||||||
|
|
||||||
# OS specific support. $var _must_ be set to either true or false.
|
|
||||||
cygwin=false
|
|
||||||
darwin=false
|
|
||||||
mingw=false
|
|
||||||
case "$(uname)" in
|
|
||||||
CYGWIN*) cygwin=true ;;
|
|
||||||
MINGW*) mingw=true ;;
|
|
||||||
Darwin*)
|
|
||||||
darwin=true
|
|
||||||
# Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home
|
|
||||||
# See https://developer.apple.com/library/mac/qa/qa1170/_index.html
|
|
||||||
if [ -z "$JAVA_HOME" ]; then
|
|
||||||
if [ -x "/usr/libexec/java_home" ]; then
|
|
||||||
JAVA_HOME="$(/usr/libexec/java_home)"
|
|
||||||
export JAVA_HOME
|
|
||||||
else
|
|
||||||
JAVA_HOME="/Library/Java/Home"
|
|
||||||
export JAVA_HOME
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
;;
|
|
||||||
esac
|
|
||||||
|
|
||||||
if [ -z "$JAVA_HOME" ]; then
|
|
||||||
if [ -r /etc/gentoo-release ]; then
|
|
||||||
JAVA_HOME=$(java-config --jre-home)
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
# For Cygwin, ensure paths are in UNIX format before anything is touched
|
|
||||||
if $cygwin; then
|
|
||||||
[ -n "$JAVA_HOME" ] \
|
|
||||||
&& JAVA_HOME=$(cygpath --unix "$JAVA_HOME")
|
|
||||||
[ -n "$CLASSPATH" ] \
|
|
||||||
&& CLASSPATH=$(cygpath --path --unix "$CLASSPATH")
|
|
||||||
fi
|
|
||||||
|
|
||||||
# For Mingw, ensure paths are in UNIX format before anything is touched
|
|
||||||
if $mingw; then
|
|
||||||
[ -n "$JAVA_HOME" ] && [ -d "$JAVA_HOME" ] \
|
|
||||||
&& JAVA_HOME="$(
|
|
||||||
cd "$JAVA_HOME" || (
|
|
||||||
echo "cannot cd into $JAVA_HOME." >&2
|
|
||||||
exit 1
|
|
||||||
)
|
|
||||||
pwd
|
|
||||||
)"
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -z "$JAVA_HOME" ]; then
|
|
||||||
javaExecutable="$(which javac)"
|
|
||||||
if [ -n "$javaExecutable" ] && ! [ "$(expr "$javaExecutable" : '\([^ ]*\)')" = "no" ]; then
|
|
||||||
# readlink(1) is not available as standard on Solaris 10.
|
|
||||||
readLink=$(which readlink)
|
|
||||||
if [ ! "$(expr "$readLink" : '\([^ ]*\)')" = "no" ]; then
|
|
||||||
if $darwin; then
|
|
||||||
javaHome="$(dirname "$javaExecutable")"
|
|
||||||
javaExecutable="$(cd "$javaHome" && pwd -P)/javac"
|
|
||||||
else
|
|
||||||
javaExecutable="$(readlink -f "$javaExecutable")"
|
|
||||||
fi
|
|
||||||
javaHome="$(dirname "$javaExecutable")"
|
|
||||||
javaHome=$(expr "$javaHome" : '\(.*\)/bin')
|
|
||||||
JAVA_HOME="$javaHome"
|
|
||||||
export JAVA_HOME
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -z "$JAVACMD" ]; then
|
|
||||||
if [ -n "$JAVA_HOME" ]; then
|
|
||||||
if [ -x "$JAVA_HOME/jre/sh/java" ]; then
|
|
||||||
# IBM's JDK on AIX uses strange locations for the executables
|
|
||||||
JAVACMD="$JAVA_HOME/jre/sh/java"
|
|
||||||
else
|
|
||||||
JAVACMD="$JAVA_HOME/bin/java"
|
|
||||||
fi
|
|
||||||
else
|
|
||||||
JAVACMD="$(
|
|
||||||
\unset -f command 2>/dev/null
|
|
||||||
\command -v java
|
|
||||||
)"
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ ! -x "$JAVACMD" ]; then
|
|
||||||
echo "Error: JAVA_HOME is not defined correctly." >&2
|
|
||||||
echo " We cannot execute $JAVACMD" >&2
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -z "$JAVA_HOME" ]; then
|
|
||||||
echo "Warning: JAVA_HOME environment variable is not set." >&2
|
|
||||||
fi
|
|
||||||
|
|
||||||
# traverses directory structure from process work directory to filesystem root
|
|
||||||
# first directory with .mvn subdirectory is considered project base directory
|
|
||||||
find_maven_basedir() {
|
|
||||||
if [ -z "$1" ]; then
|
|
||||||
echo "Path not specified to find_maven_basedir" >&2
|
|
||||||
return 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
basedir="$1"
|
|
||||||
wdir="$1"
|
|
||||||
while [ "$wdir" != '/' ]; do
|
|
||||||
if [ -d "$wdir"/.mvn ]; then
|
|
||||||
basedir=$wdir
|
|
||||||
break
|
|
||||||
fi
|
|
||||||
# workaround for JBEAP-8937 (on Solaris 10/Sparc)
|
|
||||||
if [ -d "${wdir}" ]; then
|
|
||||||
wdir=$(
|
|
||||||
cd "$wdir/.." || exit 1
|
|
||||||
pwd
|
|
||||||
)
|
|
||||||
fi
|
|
||||||
# end of workaround
|
|
||||||
done
|
|
||||||
printf '%s' "$(
|
|
||||||
cd "$basedir" || exit 1
|
|
||||||
pwd
|
|
||||||
)"
|
|
||||||
}
|
|
||||||
|
|
||||||
# concatenates all lines of a file
|
|
||||||
concat_lines() {
|
|
||||||
if [ -f "$1" ]; then
|
|
||||||
# Remove \r in case we run on Windows within Git Bash
|
|
||||||
# and check out the repository with auto CRLF management
|
|
||||||
# enabled. Otherwise, we may read lines that are delimited with
|
|
||||||
# \r\n and produce $'-Xarg\r' rather than -Xarg due to word
|
|
||||||
# splitting rules.
|
|
||||||
tr -s '\r\n' ' ' <"$1"
|
|
||||||
fi
|
|
||||||
}
|
|
||||||
|
|
||||||
log() {
|
|
||||||
if [ "$MVNW_VERBOSE" = true ]; then
|
|
||||||
printf '%s\n' "$1"
|
|
||||||
fi
|
|
||||||
}
|
|
||||||
|
|
||||||
BASE_DIR=$(find_maven_basedir "$(dirname "$0")")
|
|
||||||
if [ -z "$BASE_DIR" ]; then
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"}
|
|
||||||
export MAVEN_PROJECTBASEDIR
|
|
||||||
log "$MAVEN_PROJECTBASEDIR"
|
|
||||||
|
|
||||||
##########################################################################################
|
|
||||||
# Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
|
|
||||||
# This allows using the maven wrapper in projects that prohibit checking in binary data.
|
|
||||||
##########################################################################################
|
|
||||||
wrapperJarPath="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar"
|
|
||||||
if [ -r "$wrapperJarPath" ]; then
|
|
||||||
log "Found $wrapperJarPath"
|
|
||||||
else
|
|
||||||
log "Couldn't find $wrapperJarPath, downloading it ..."
|
|
||||||
|
|
||||||
if [ -n "$MVNW_REPOURL" ]; then
|
|
||||||
wrapperUrl="$MVNW_REPOURL/org/apache/maven/wrapper/maven-wrapper/3.3.2/maven-wrapper-3.3.2.jar"
|
|
||||||
else
|
|
||||||
wrapperUrl="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.3.2/maven-wrapper-3.3.2.jar"
|
|
||||||
fi
|
|
||||||
while IFS="=" read -r key value; do
|
|
||||||
# Remove '\r' from value to allow usage on windows as IFS does not consider '\r' as a separator ( considers space, tab, new line ('\n'), and custom '=' )
|
|
||||||
safeValue=$(echo "$value" | tr -d '\r')
|
|
||||||
case "$key" in wrapperUrl)
|
|
||||||
wrapperUrl="$safeValue"
|
|
||||||
break
|
|
||||||
;;
|
|
||||||
esac
|
|
||||||
done <"$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.properties"
|
|
||||||
log "Downloading from: $wrapperUrl"
|
|
||||||
|
|
||||||
if $cygwin; then
|
|
||||||
wrapperJarPath=$(cygpath --path --windows "$wrapperJarPath")
|
|
||||||
fi
|
|
||||||
|
|
||||||
if command -v wget >/dev/null; then
|
|
||||||
log "Found wget ... using wget"
|
|
||||||
[ "$MVNW_VERBOSE" = true ] && QUIET="" || QUIET="--quiet"
|
|
||||||
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
|
|
||||||
wget $QUIET "$wrapperUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath"
|
|
||||||
else
|
|
||||||
wget $QUIET --http-user="$MVNW_USERNAME" --http-password="$MVNW_PASSWORD" "$wrapperUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath"
|
|
||||||
fi
|
|
||||||
elif command -v curl >/dev/null; then
|
|
||||||
log "Found curl ... using curl"
|
|
||||||
[ "$MVNW_VERBOSE" = true ] && QUIET="" || QUIET="--silent"
|
|
||||||
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
|
|
||||||
curl $QUIET -o "$wrapperJarPath" "$wrapperUrl" -f -L || rm -f "$wrapperJarPath"
|
|
||||||
else
|
|
||||||
curl $QUIET --user "$MVNW_USERNAME:$MVNW_PASSWORD" -o "$wrapperJarPath" "$wrapperUrl" -f -L || rm -f "$wrapperJarPath"
|
|
||||||
fi
|
|
||||||
else
|
|
||||||
log "Falling back to using Java to download"
|
|
||||||
javaSource="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/MavenWrapperDownloader.java"
|
|
||||||
javaClass="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/MavenWrapperDownloader.class"
|
|
||||||
# For Cygwin, switch paths to Windows format before running javac
|
|
||||||
if $cygwin; then
|
|
||||||
javaSource=$(cygpath --path --windows "$javaSource")
|
|
||||||
javaClass=$(cygpath --path --windows "$javaClass")
|
|
||||||
fi
|
|
||||||
if [ -e "$javaSource" ]; then
|
|
||||||
if [ ! -e "$javaClass" ]; then
|
|
||||||
log " - Compiling MavenWrapperDownloader.java ..."
|
|
||||||
("$JAVA_HOME/bin/javac" "$javaSource")
|
|
||||||
fi
|
|
||||||
if [ -e "$javaClass" ]; then
|
|
||||||
log " - Running MavenWrapperDownloader.java ..."
|
|
||||||
("$JAVA_HOME/bin/java" -cp .mvn/wrapper MavenWrapperDownloader "$wrapperUrl" "$wrapperJarPath") || rm -f "$wrapperJarPath"
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
##########################################################################################
|
|
||||||
# End of extension
|
|
||||||
##########################################################################################
|
|
||||||
|
|
||||||
# If specified, validate the SHA-256 sum of the Maven wrapper jar file
|
|
||||||
wrapperSha256Sum=""
|
|
||||||
while IFS="=" read -r key value; do
|
|
||||||
case "$key" in wrapperSha256Sum)
|
|
||||||
wrapperSha256Sum=$value
|
|
||||||
break
|
|
||||||
;;
|
|
||||||
esac
|
|
||||||
done <"$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.properties"
|
|
||||||
if [ -n "$wrapperSha256Sum" ]; then
|
|
||||||
wrapperSha256Result=false
|
|
||||||
if command -v sha256sum >/dev/null; then
|
|
||||||
if echo "$wrapperSha256Sum $wrapperJarPath" | sha256sum -c >/dev/null 2>&1; then
|
|
||||||
wrapperSha256Result=true
|
|
||||||
fi
|
|
||||||
elif command -v shasum >/dev/null; then
|
|
||||||
if echo "$wrapperSha256Sum $wrapperJarPath" | shasum -a 256 -c >/dev/null 2>&1; then
|
|
||||||
wrapperSha256Result=true
|
|
||||||
fi
|
|
||||||
else
|
|
||||||
echo "Checksum validation was requested but neither 'sha256sum' or 'shasum' are available." >&2
|
|
||||||
echo "Please install either command, or disable validation by removing 'wrapperSha256Sum' from your maven-wrapper.properties." >&2
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
if [ $wrapperSha256Result = false ]; then
|
|
||||||
echo "Error: Failed to validate Maven wrapper SHA-256, your Maven wrapper might be compromised." >&2
|
|
||||||
echo "Investigate or delete $wrapperJarPath to attempt a clean download." >&2
|
|
||||||
echo "If you updated your Maven version, you need to update the specified wrapperSha256Sum property." >&2
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS"
|
|
||||||
|
|
||||||
# For Cygwin, switch paths to Windows format before running java
|
|
||||||
if $cygwin; then
|
|
||||||
[ -n "$JAVA_HOME" ] \
|
|
||||||
&& JAVA_HOME=$(cygpath --path --windows "$JAVA_HOME")
|
|
||||||
[ -n "$CLASSPATH" ] \
|
|
||||||
&& CLASSPATH=$(cygpath --path --windows "$CLASSPATH")
|
|
||||||
[ -n "$MAVEN_PROJECTBASEDIR" ] \
|
|
||||||
&& MAVEN_PROJECTBASEDIR=$(cygpath --path --windows "$MAVEN_PROJECTBASEDIR")
|
|
||||||
fi
|
|
||||||
|
|
||||||
# Provide a "standardized" way to retrieve the CLI args that will
|
|
||||||
# work with both Windows and non-Windows executions.
|
|
||||||
MAVEN_CMD_LINE_ARGS="$MAVEN_CONFIG $*"
|
|
||||||
export MAVEN_CMD_LINE_ARGS
|
|
||||||
|
|
||||||
WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
|
|
||||||
|
|
||||||
# shellcheck disable=SC2086 # safe args
|
|
||||||
exec "$JAVACMD" \
|
|
||||||
$MAVEN_OPTS \
|
|
||||||
$MAVEN_DEBUG_OPTS \
|
|
||||||
-classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \
|
|
||||||
"-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \
|
|
||||||
${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@"
|
|
||||||
206
debezium-connector-jdbc/mvnw.cmd
vendored
206
debezium-connector-jdbc/mvnw.cmd
vendored
@ -1,206 +0,0 @@
|
|||||||
@REM ----------------------------------------------------------------------------
|
|
||||||
@REM Licensed to the Apache Software Foundation (ASF) under one
|
|
||||||
@REM or more contributor license agreements. See the NOTICE file
|
|
||||||
@REM distributed with this work for additional information
|
|
||||||
@REM regarding copyright ownership. The ASF licenses this file
|
|
||||||
@REM to you under the Apache License, Version 2.0 (the
|
|
||||||
@REM "License"); you may not use this file except in compliance
|
|
||||||
@REM with the License. You may obtain a copy of the License at
|
|
||||||
@REM
|
|
||||||
@REM http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
@REM
|
|
||||||
@REM Unless required by applicable law or agreed to in writing,
|
|
||||||
@REM software distributed under the License is distributed on an
|
|
||||||
@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
||||||
@REM KIND, either express or implied. See the License for the
|
|
||||||
@REM specific language governing permissions and limitations
|
|
||||||
@REM under the License.
|
|
||||||
@REM ----------------------------------------------------------------------------
|
|
||||||
|
|
||||||
@REM ----------------------------------------------------------------------------
|
|
||||||
@REM Apache Maven Wrapper startup batch script, version 3.3.2
|
|
||||||
@REM
|
|
||||||
@REM Required ENV vars:
|
|
||||||
@REM JAVA_HOME - location of a JDK home dir
|
|
||||||
@REM
|
|
||||||
@REM Optional ENV vars
|
|
||||||
@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
|
|
||||||
@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
|
|
||||||
@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
|
|
||||||
@REM e.g. to debug Maven itself, use
|
|
||||||
@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
|
|
||||||
@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
|
|
||||||
@REM ----------------------------------------------------------------------------
|
|
||||||
|
|
||||||
@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
|
|
||||||
@echo off
|
|
||||||
@REM set title of command window
|
|
||||||
title %0
|
|
||||||
@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
|
|
||||||
@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO%
|
|
||||||
|
|
||||||
@REM set %HOME% to equivalent of $HOME
|
|
||||||
if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
|
|
||||||
|
|
||||||
@REM Execute a user defined script before this one
|
|
||||||
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
|
|
||||||
@REM check for pre script, once with legacy .bat ending and once with .cmd ending
|
|
||||||
if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
|
|
||||||
if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
|
|
||||||
:skipRcPre
|
|
||||||
|
|
||||||
@setlocal
|
|
||||||
|
|
||||||
set ERROR_CODE=0
|
|
||||||
|
|
||||||
@REM To isolate internal variables from possible post scripts, we use another setlocal
|
|
||||||
@setlocal
|
|
||||||
|
|
||||||
@REM ==== START VALIDATION ====
|
|
||||||
if not "%JAVA_HOME%" == "" goto OkJHome
|
|
||||||
|
|
||||||
echo. >&2
|
|
||||||
echo Error: JAVA_HOME not found in your environment. >&2
|
|
||||||
echo Please set the JAVA_HOME variable in your environment to match the >&2
|
|
||||||
echo location of your Java installation. >&2
|
|
||||||
echo. >&2
|
|
||||||
goto error
|
|
||||||
|
|
||||||
:OkJHome
|
|
||||||
if exist "%JAVA_HOME%\bin\java.exe" goto init
|
|
||||||
|
|
||||||
echo. >&2
|
|
||||||
echo Error: JAVA_HOME is set to an invalid directory. >&2
|
|
||||||
echo JAVA_HOME = "%JAVA_HOME%" >&2
|
|
||||||
echo Please set the JAVA_HOME variable in your environment to match the >&2
|
|
||||||
echo location of your Java installation. >&2
|
|
||||||
echo. >&2
|
|
||||||
goto error
|
|
||||||
|
|
||||||
@REM ==== END VALIDATION ====
|
|
||||||
|
|
||||||
:init
|
|
||||||
|
|
||||||
@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
|
|
||||||
@REM Fallback to current working directory if not found.
|
|
||||||
|
|
||||||
set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
|
|
||||||
IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
|
|
||||||
|
|
||||||
set EXEC_DIR=%CD%
|
|
||||||
set WDIR=%EXEC_DIR%
|
|
||||||
:findBaseDir
|
|
||||||
IF EXIST "%WDIR%"\.mvn goto baseDirFound
|
|
||||||
cd ..
|
|
||||||
IF "%WDIR%"=="%CD%" goto baseDirNotFound
|
|
||||||
set WDIR=%CD%
|
|
||||||
goto findBaseDir
|
|
||||||
|
|
||||||
:baseDirFound
|
|
||||||
set MAVEN_PROJECTBASEDIR=%WDIR%
|
|
||||||
cd "%EXEC_DIR%"
|
|
||||||
goto endDetectBaseDir
|
|
||||||
|
|
||||||
:baseDirNotFound
|
|
||||||
set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
|
|
||||||
cd "%EXEC_DIR%"
|
|
||||||
|
|
||||||
:endDetectBaseDir
|
|
||||||
|
|
||||||
IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
|
|
||||||
|
|
||||||
@setlocal EnableExtensions EnableDelayedExpansion
|
|
||||||
for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
|
|
||||||
@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
|
|
||||||
|
|
||||||
:endReadAdditionalConfig
|
|
||||||
|
|
||||||
SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
|
|
||||||
set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
|
|
||||||
set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
|
|
||||||
|
|
||||||
set WRAPPER_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.3.2/maven-wrapper-3.3.2.jar"
|
|
||||||
|
|
||||||
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
|
|
||||||
IF "%%A"=="wrapperUrl" SET WRAPPER_URL=%%B
|
|
||||||
)
|
|
||||||
|
|
||||||
@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
|
|
||||||
@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
|
|
||||||
if exist %WRAPPER_JAR% (
|
|
||||||
if "%MVNW_VERBOSE%" == "true" (
|
|
||||||
echo Found %WRAPPER_JAR%
|
|
||||||
)
|
|
||||||
) else (
|
|
||||||
if not "%MVNW_REPOURL%" == "" (
|
|
||||||
SET WRAPPER_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.3.2/maven-wrapper-3.3.2.jar"
|
|
||||||
)
|
|
||||||
if "%MVNW_VERBOSE%" == "true" (
|
|
||||||
echo Couldn't find %WRAPPER_JAR%, downloading it ...
|
|
||||||
echo Downloading from: %WRAPPER_URL%
|
|
||||||
)
|
|
||||||
|
|
||||||
powershell -Command "&{"^
|
|
||||||
"$webclient = new-object System.Net.WebClient;"^
|
|
||||||
"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
|
|
||||||
"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
|
|
||||||
"}"^
|
|
||||||
"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%WRAPPER_URL%', '%WRAPPER_JAR%')"^
|
|
||||||
"}"
|
|
||||||
if "%MVNW_VERBOSE%" == "true" (
|
|
||||||
echo Finished downloading %WRAPPER_JAR%
|
|
||||||
)
|
|
||||||
)
|
|
||||||
@REM End of extension
|
|
||||||
|
|
||||||
@REM If specified, validate the SHA-256 sum of the Maven wrapper jar file
|
|
||||||
SET WRAPPER_SHA_256_SUM=""
|
|
||||||
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
|
|
||||||
IF "%%A"=="wrapperSha256Sum" SET WRAPPER_SHA_256_SUM=%%B
|
|
||||||
)
|
|
||||||
IF NOT %WRAPPER_SHA_256_SUM%=="" (
|
|
||||||
powershell -Command "&{"^
|
|
||||||
"Import-Module $PSHOME\Modules\Microsoft.PowerShell.Utility -Function Get-FileHash;"^
|
|
||||||
"$hash = (Get-FileHash \"%WRAPPER_JAR%\" -Algorithm SHA256).Hash.ToLower();"^
|
|
||||||
"If('%WRAPPER_SHA_256_SUM%' -ne $hash){"^
|
|
||||||
" Write-Error 'Error: Failed to validate Maven wrapper SHA-256, your Maven wrapper might be compromised.';"^
|
|
||||||
" Write-Error 'Investigate or delete %WRAPPER_JAR% to attempt a clean download.';"^
|
|
||||||
" Write-Error 'If you updated your Maven version, you need to update the specified wrapperSha256Sum property.';"^
|
|
||||||
" exit 1;"^
|
|
||||||
"}"^
|
|
||||||
"}"
|
|
||||||
if ERRORLEVEL 1 goto error
|
|
||||||
)
|
|
||||||
|
|
||||||
@REM Provide a "standardized" way to retrieve the CLI args that will
|
|
||||||
@REM work with both Windows and non-Windows executions.
|
|
||||||
set MAVEN_CMD_LINE_ARGS=%*
|
|
||||||
|
|
||||||
%MAVEN_JAVA_EXE% ^
|
|
||||||
%JVM_CONFIG_MAVEN_PROPS% ^
|
|
||||||
%MAVEN_OPTS% ^
|
|
||||||
%MAVEN_DEBUG_OPTS% ^
|
|
||||||
-classpath %WRAPPER_JAR% ^
|
|
||||||
"-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
|
|
||||||
%WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
|
|
||||||
if ERRORLEVEL 1 goto error
|
|
||||||
goto end
|
|
||||||
|
|
||||||
:error
|
|
||||||
set ERROR_CODE=1
|
|
||||||
|
|
||||||
:end
|
|
||||||
@endlocal & set ERROR_CODE=%ERROR_CODE%
|
|
||||||
|
|
||||||
if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
|
|
||||||
@REM check for post script, once with legacy .bat ending and once with .cmd ending
|
|
||||||
if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
|
|
||||||
if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd"
|
|
||||||
:skipRcPost
|
|
||||||
|
|
||||||
@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
|
|
||||||
if "%MAVEN_BATCH_PAUSE%"=="on" pause
|
|
||||||
|
|
||||||
if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE%
|
|
||||||
|
|
||||||
cmd /C exit /B %ERROR_CODE%
|
|
||||||
@ -5,6 +5,7 @@
|
|||||||
<groupId>io.debezium</groupId>
|
<groupId>io.debezium</groupId>
|
||||||
<artifactId>debezium-parent</artifactId>
|
<artifactId>debezium-parent</artifactId>
|
||||||
<version>3.0.0-SNAPSHOT</version>
|
<version>3.0.0-SNAPSHOT</version>
|
||||||
|
<relativePath>../debezium-parent/pom.xml</relativePath>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
@ -13,25 +14,11 @@
|
|||||||
<name>Debezium JDBC Sink Connector</name>
|
<name>Debezium JDBC Sink Connector</name>
|
||||||
<packaging>jar</packaging>
|
<packaging>jar</packaging>
|
||||||
|
|
||||||
<scm>
|
|
||||||
<connection>scm:git:git@github.com:debezium/debezium-connector-jdbc.git</connection>
|
|
||||||
<developerConnection>scm:git:git@github.com:debezium/debezium-connector-jdbc.git</developerConnection>
|
|
||||||
<url>https://github.com/debezium/debezium-connector-jdbc</url>
|
|
||||||
<tag>HEAD</tag>
|
|
||||||
</scm>
|
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
<!-- Debezium parent -->
|
|
||||||
<version.debezium>${project.version}</version.debezium>
|
|
||||||
|
|
||||||
<!-- Parent overrides -->
|
|
||||||
<version.assembly.plugin>3.5.0</version.assembly.plugin>
|
|
||||||
|
|
||||||
<!-- Other artifact versions -->
|
<!-- Other artifact versions -->
|
||||||
<version.hibernate>6.4.8.Final</version.hibernate>
|
<version.hibernate>6.4.8.Final</version.hibernate>
|
||||||
<version.c3p0>0.9.5.5</version.c3p0>
|
<version.c3p0>0.9.5.5</version.c3p0>
|
||||||
<version.assertjdb>2.0.2</version.assertjdb>
|
<version.assertjdb>2.0.2</version.assertjdb>
|
||||||
|
|
||||||
<!--
|
<!--
|
||||||
By default only run the integration tests for MySQL, PostgreSQL, and SQL Server.
|
By default only run the integration tests for MySQL, PostgreSQL, and SQL Server.
|
||||||
Other tags include it-db2 and it-oracle for the DB2 and Oracle integration tests.
|
Other tags include it-db2 and it-oracle for the DB2 and Oracle integration tests.
|
||||||
@ -47,89 +34,6 @@
|
|||||||
<test.tags>it-mysql,it-postgresql,it-sqlserver</test.tags>
|
<test.tags>it-mysql,it-postgresql,it-sqlserver</test.tags>
|
||||||
</properties>
|
</properties>
|
||||||
|
|
||||||
<repositories>
|
|
||||||
<repository>
|
|
||||||
<id>oss</id>
|
|
||||||
<name>OSS Sonatype Nexus</name>
|
|
||||||
<url>https://s01.oss.sonatype.org/content/repositories/snapshots</url>
|
|
||||||
<releases>
|
|
||||||
<enabled>true</enabled>
|
|
||||||
<updatePolicy>never</updatePolicy>
|
|
||||||
</releases>
|
|
||||||
<snapshots>
|
|
||||||
<enabled>true</enabled>
|
|
||||||
<updatePolicy>never</updatePolicy>
|
|
||||||
</snapshots>
|
|
||||||
</repository>
|
|
||||||
</repositories>
|
|
||||||
|
|
||||||
<!-- Managing versions here to ensure the right ones are applied during releases -->
|
|
||||||
<dependencyManagement>
|
|
||||||
<dependencies>
|
|
||||||
<!-- Debezium Artifacts -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-core</artifactId>
|
|
||||||
<version>${version.debezium}</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-embedded</artifactId>
|
|
||||||
<version>${version.debezium}</version>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- Building -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-ide-configs</artifactId>
|
|
||||||
<version>${version.debezium}</version>
|
|
||||||
<scope>provided</scope>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-checkstyle</artifactId>
|
|
||||||
<version>${version.debezium}</version>
|
|
||||||
<scope>provided</scope>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-assembly-descriptors</artifactId>
|
|
||||||
<version>${version.debezium}</version>
|
|
||||||
<scope>provided</scope>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-revapi</artifactId>
|
|
||||||
<version>${version.debezium}</version>
|
|
||||||
<scope>provided</scope>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- Testing -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-core</artifactId>
|
|
||||||
<version>${version.debezium}</version>
|
|
||||||
<type>test-jar</type>
|
|
||||||
<scope>test</scope>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-embedded</artifactId>
|
|
||||||
<version>${version.debezium}</version>
|
|
||||||
<type>test-jar</type>
|
|
||||||
<scope>test</scope>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- Dependency version overrides -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>com.mchange</groupId>
|
|
||||||
<artifactId>c3p0</artifactId>
|
|
||||||
<version>${version.c3p0}</version>
|
|
||||||
</dependency>
|
|
||||||
</dependencies>
|
|
||||||
</dependencyManagement>
|
|
||||||
|
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
<!-- Debezium -->
|
<!-- Debezium -->
|
||||||
<dependency>
|
<dependency>
|
||||||
@ -141,13 +45,11 @@
|
|||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.apache.kafka</groupId>
|
<groupId>org.apache.kafka</groupId>
|
||||||
<artifactId>connect-api</artifactId>
|
<artifactId>connect-api</artifactId>
|
||||||
<version>${version.kafka}</version>
|
|
||||||
<scope>provided</scope>
|
<scope>provided</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.apache.kafka</groupId>
|
<groupId>org.apache.kafka</groupId>
|
||||||
<artifactId>connect-runtime</artifactId>
|
<artifactId>connect-runtime</artifactId>
|
||||||
<version>${version.kafka}</version>
|
|
||||||
<scope>provided</scope>
|
<scope>provided</scope>
|
||||||
<exclusions>
|
<exclusions>
|
||||||
<exclusion>
|
<exclusion>
|
||||||
@ -164,28 +66,6 @@
|
|||||||
<scope>provided</scope>
|
<scope>provided</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
<!-- Building -->
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-ide-configs</artifactId>
|
|
||||||
<scope>provided</scope>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-checkstyle</artifactId>
|
|
||||||
<scope>provided</scope>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-assembly-descriptors</artifactId>
|
|
||||||
<scope>provided</scope>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.debezium</groupId>
|
|
||||||
<artifactId>debezium-revapi</artifactId>
|
|
||||||
<scope>provided</scope>
|
|
||||||
</dependency>
|
|
||||||
|
|
||||||
<!-- Hibernate -->
|
<!-- Hibernate -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.hibernate.orm</groupId>
|
<groupId>org.hibernate.orm</groupId>
|
||||||
@ -198,6 +78,13 @@
|
|||||||
<version>${version.hibernate}</version>
|
<version>${version.hibernate}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- Connection pool -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>com.mchange</groupId>
|
||||||
|
<artifactId>c3p0</artifactId>
|
||||||
|
<version>${version.c3p0}</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
<!-- Testing -->
|
<!-- Testing -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>ch.qos.logback</groupId>
|
<groupId>ch.qos.logback</groupId>
|
||||||
@ -222,21 +109,18 @@
|
|||||||
<dependency>
|
<dependency>
|
||||||
<groupId>io.debezium</groupId>
|
<groupId>io.debezium</groupId>
|
||||||
<artifactId>debezium-core</artifactId>
|
<artifactId>debezium-core</artifactId>
|
||||||
<version>${version.debezium}</version>
|
|
||||||
<type>test-jar</type>
|
<type>test-jar</type>
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>io.debezium</groupId>
|
<groupId>io.debezium</groupId>
|
||||||
<artifactId>debezium-embedded</artifactId>
|
<artifactId>debezium-embedded</artifactId>
|
||||||
<version>${version.debezium}</version>
|
|
||||||
<type>test-jar</type>
|
<type>test-jar</type>
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>io.debezium</groupId>
|
<groupId>io.debezium</groupId>
|
||||||
<artifactId>debezium-testing-testcontainers</artifactId>
|
<artifactId>debezium-testing-testcontainers</artifactId>
|
||||||
<version>${version.debezium}</version>
|
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
|
|||||||
@ -20,7 +20,7 @@ CONTRIBUTORS_FILTERS="$DIR/FilteredNames.txt"
|
|||||||
|
|
||||||
cp $ALIASES $FILTERS $DIR && cd $DIR
|
cp $ALIASES $FILTERS $DIR && cd $DIR
|
||||||
|
|
||||||
declare -a DEBEZIUM_REPOS=("debezium" "debezium-server" "debezium-operator" "debezium-connector-db2" "debezium-connector-cassandra" "debezium-connector-vitess" "debezium-connector-spanner" "debezium-connector-jdbc" "debezium-ui" "container-images")
|
declare -a DEBEZIUM_REPOS=("debezium" "debezium-server" "debezium-operator" "debezium-connector-db2" "debezium-connector-cassandra" "debezium-connector-vitess" "debezium-connector-spanner" "debezium-ui" "container-images")
|
||||||
|
|
||||||
for REPO in "${DEBEZIUM_REPOS[@]}";
|
for REPO in "${DEBEZIUM_REPOS[@]}";
|
||||||
do
|
do
|
||||||
|
|||||||
@ -60,7 +60,7 @@ function handleGitHistoryCommitMessageIssueKeys {
|
|||||||
}
|
}
|
||||||
|
|
||||||
# Repositories to check for existence of commits
|
# Repositories to check for existence of commits
|
||||||
declare -a DEBEZIUM_REPOS=("debezium" "debezium-server" "debezium-operator" "debezium-connector-db2" "debezium-connector-cassandra" "debezium-connector-vitess" "debezium-connector-spanner" "debezium-connector-jdbc" "container-images")
|
declare -a DEBEZIUM_REPOS=("debezium" "debezium-server" "debezium-operator" "debezium-connector-db2" "debezium-connector-cassandra" "debezium-connector-vitess" "debezium-connector-spanner" "container-images")
|
||||||
|
|
||||||
# Obtain all issue keys that are part of the fixed version
|
# Obtain all issue keys that are part of the fixed version
|
||||||
echo "Getting issues from Jira for project $PROJECT_NAME and version $FIX_VERSION"
|
echo "Getting issues from Jira for project $PROJECT_NAME and version $FIX_VERSION"
|
||||||
|
|||||||
@ -27,7 +27,7 @@ pipelineJob('release/release-deploy_snapshots_pipeline') {
|
|||||||
stringParam('DEBEZIUM_BRANCH', 'main', 'A branch from which Debezium is built')
|
stringParam('DEBEZIUM_BRANCH', 'main', 'A branch from which Debezium is built')
|
||||||
stringParam(
|
stringParam(
|
||||||
'DEBEZIUM_ADDITIONAL_REPOSITORIES',
|
'DEBEZIUM_ADDITIONAL_REPOSITORIES',
|
||||||
'db2#github.com/debezium/debezium-connector-db2.git#main vitess#github.com/debezium/debezium-connector-vitess.git#main cassandra#github.com/debezium/debezium-connector-cassandra.git#main spanner#github.com/debezium/debezium-connector-spanner.git#main jdbc#github.com/debezium/debezium-connector-jdbc.git#main informix#github.com/debezium/debezium-connector-informix.git#main ibmi#github.com/debezium/debezium-connector-ibmi.git#main server#github.com/debezium/debezium-server.git#main operator#github.com/debezium/debezium-operator.git#main',
|
'db2#github.com/debezium/debezium-connector-db2.git#main vitess#github.com/debezium/debezium-connector-vitess.git#main cassandra#github.com/debezium/debezium-connector-cassandra.git#main spanner#github.com/debezium/debezium-connector-spanner.git#main informix#github.com/debezium/debezium-connector-informix.git#main ibmi#github.com/debezium/debezium-connector-ibmi.git#main server#github.com/debezium/debezium-server.git#main operator#github.com/debezium/debezium-operator.git#main',
|
||||||
'A space separated list of additional repositories from which Debezium connectors are built (id#repo#branch)'
|
'A space separated list of additional repositories from which Debezium connectors are built (id#repo#branch)'
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
@ -24,7 +24,7 @@ pipelineJob('release/release-debezium-upstream') {
|
|||||||
stringParam('DEBEZIUM_BRANCH', 'main', 'A branch from which Debezium is built')
|
stringParam('DEBEZIUM_BRANCH', 'main', 'A branch from which Debezium is built')
|
||||||
stringParam(
|
stringParam(
|
||||||
'DEBEZIUM_ADDITIONAL_REPOSITORIES',
|
'DEBEZIUM_ADDITIONAL_REPOSITORIES',
|
||||||
'jdbc#github.com/debezium/debezium-connector-jdbc.git#main spanner#github.com/debezium/debezium-connector-spanner.git#main db2#github.com/debezium/debezium-connector-db2.git#main vitess#github.com/debezium/debezium-connector-vitess.git#main cassandra#github.com/debezium/debezium-connector-cassandra.git#main informix#github.com/debezium/debezium-connector-informix.git#main ibmi#github.com/debezium/debezium-connector-ibmi.git#main server#github.com/debezium/debezium-server.git#main operator#github.com/debezium/debezium-operator.git#main',
|
'spanner#github.com/debezium/debezium-connector-spanner.git#main db2#github.com/debezium/debezium-connector-db2.git#main vitess#github.com/debezium/debezium-connector-vitess.git#main cassandra#github.com/debezium/debezium-connector-cassandra.git#main informix#github.com/debezium/debezium-connector-informix.git#main ibmi#github.com/debezium/debezium-connector-ibmi.git#main server#github.com/debezium/debezium-server.git#main operator#github.com/debezium/debezium-operator.git#main',
|
||||||
'A space separated list of additional repositories from which Debezium incubating components are built (id#repo#branch)'
|
'A space separated list of additional repositories from which Debezium incubating components are built (id#repo#branch)'
|
||||||
)
|
)
|
||||||
stringParam('IMAGES_REPOSITORY', 'github.com/debezium/container-images.git', 'Repository from which Debezium images are built')
|
stringParam('IMAGES_REPOSITORY', 'github.com/debezium/container-images.git', 'Repository from which Debezium images are built')
|
||||||
|
|||||||
@ -10,7 +10,7 @@ ALIASES="jenkins-jobs/scripts/config/Aliases.txt"
|
|||||||
|
|
||||||
declare -a DEBEZIUM_REPOS
|
declare -a DEBEZIUM_REPOS
|
||||||
if [ $# -eq 0 ];then
|
if [ $# -eq 0 ];then
|
||||||
DEBEZIUM_REPOS=("debezium" "debezium-connector-db2" "debezium-connector-cassandra" "debezium-connector-vitess" "debezium-connector-spanner" "debezium-connector-jdbc" "debezium-connector-informix" "debezium-connector-ibmi" "container-images" "debezium-server")
|
DEBEZIUM_REPOS=("debezium" "debezium-connector-db2" "debezium-connector-cassandra" "debezium-connector-vitess" "debezium-connector-spanner" "debezium-connector-informix" "debezium-connector-ibmi" "container-images" "debezium-server")
|
||||||
else
|
else
|
||||||
DEBEZIUM_REPOS=( "$@" )
|
DEBEZIUM_REPOS=( "$@" )
|
||||||
fi
|
fi
|
||||||
|
|||||||
1
pom.xml
1
pom.xml
@ -191,6 +191,7 @@
|
|||||||
<module>debezium-connector-oracle</module>
|
<module>debezium-connector-oracle</module>
|
||||||
<module>debezium-connector-binlog</module>
|
<module>debezium-connector-binlog</module>
|
||||||
<module>debezium-connector-mariadb</module>
|
<module>debezium-connector-mariadb</module>
|
||||||
|
<module>debezium-connector-jdbc</module>
|
||||||
<module>debezium-microbenchmark-engine</module>
|
<module>debezium-microbenchmark-engine</module>
|
||||||
<module>debezium-microbenchmark</module>
|
<module>debezium-microbenchmark</module>
|
||||||
<module>debezium-microbenchmark-oracle</module>
|
<module>debezium-microbenchmark-oracle</module>
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user