8000 Added function to construct input query for updating inplace. by subkanthi · Pull Request #1171 · Altinity/clickhouse-sink-connector · GitHub
[go: up one dir, main page]
Skip to content
< 1 l 8000 ink crossorigin="anonymous" media="all" rel="stylesheet" href="https://github.githubassets.com/assets/app-install-banner-partial.69da9b8f8cf76fa3.module.css" />

Added function to construct input query for updating inplace. - #1171

Merged
subkanthi merged 40 commits into
2.8.1from
1169-version-history-support-for-_valid_from
Jan 21, 2026
Merged

Added function to construct input query for updating inplace.#1171
subkanthi merged 40 commits into
2.8.1from
1169-version-history-support-for-_valid_from

Conversation

@subkanthi
@subkanthi subkanthi commented Nov 9, 2025 •
edited
Loading
Copy link
Copy Markdown
Collaborator

closes: #1169

@subkanthi
Added function to construct input query for updating inplace.
c9ffb5a
@subkanthi
Added function to construct input query for updating inplace.
9d06348
@subkanthi
Fix inplace insert statement query.
59ec30a
@subkanthi
Fix inplace insert statement query.
7b20bd0
@subkanthi
Changed logic for in-place update to use a separate preparedStatement.
a7359db
@subkanthi
Changed logic for in-place update to use a separate preparedStatement.
69f10ee
@subkanthi
Set from_time column.
e9ea7f6
@subkanthi
Merge branch '2.8.1' of github.com:Altinity/clickhouse-sink-connector…
24d03cc 
… into 1169-version-history-support-for-_valid_from
@subkanthi
Added logic to hash records so that records from the same table are e…
38ed0b7 
…xecuted in the same thread.
@subkanthi
Added RoutedBatch.java
8bca573
@subkanthi
Refactored InsertPreparedStatement to a separate class.
83a8713
@subkanthi
Fixed DbWriterTest
8394f9d
@subkanthi
Fixed _valid_from in insert, removed duplicated
< 8000 div class="commit-build-statuses">
92d8a17
@subkanthi
Merge branch '2.8.1' of https://github.com/Altinity/clickhouse-sink-c…
f53706a 
…onnector into 1169-version-history-support-for-_valid_from
@subkanthi
Merge branch '2.8.1' of https://github.com/Altinity/clickhouse-sink-c…
83218e8 
…onnector into 1169-version-history-support-for-_valid_from
@subkanthi
updated Insert query.
557b9e1
@subkanthi
Refactor code to handle update/delete in a separate class.
4535771
@subkanthi
Changes to pass timeZone in all toDateTime calls.
0d2a96b
@subkanthi
added option to enable/disable before image select.
f394348
@subkanthi
subkanthi commented Dec 15, 2025
Copy link
Copy Markdown
Collaborator Author 
198abb40ea95 :) select * from employees final where lastName='Kato';

SELECT *
FROM employees
FINAL
WHERE lastName = 'Kato'

Query id: 05b6bd59-465c-4bf4-9bb3-670ddf9d459e

   ┌─employeeNumber─┬─lastName─┬─firstName─┬─extension─┬─email──────────────────────┬─officeCode─┬─reportsTo─┬─jobTitle──┬─────────_valid_from─┬───────────_valid_to─┬─_operation─┬────────────_version─┬─is_deleted─┐
1. │           1625 │ Kato     │ Yoshimi   │ x102      │ ykato@classicmodelcars.com │ 5          │      1621 │ Sales Rep │ 2025-12-14 20:46:02 │ 2025-12-14 20:46:02 │ D          │ 2000396904994701390 │          0 │
   └────────────────┴──────────┴───────────┴───────────┴────────────────────────────┴────────────┴───────────┴───────────┴─────────────────────┴─────────────────────┴────────────┴─────────────────────┴────────────┘

1 row in set. Elapsed: 0.004 sec.

@subkanthi
subkanthi commented Dec 15, 2025
Copy link
Copy Markdown
Collaborator Author 
select * from offices final;

SELECT *
FROM offices
FINAL

Query id: 8b2d63e7-1a36-4c9a-a69f-51dba66a39ca

   ┌─officeCode─┬─city────┬─phone────────────┬─addressLine1────────┬─addressLine2─┬─state─┬─country─┬─postalCode─┬─territory─┬─────────_valid_from─┬───────────_valid_to─┬─_operation─┬────────────_version─┬─is_deleted─┐
1. │ 7          │ London  │ +44 20 7877 2041 │ 25 Old Broad Street │ Level 7      │ ᴺᵁᴸᴸ  │ UK      │ EC2N 1HN   │ EMEA      │ 2025-12-14 20:42:47 │ 2025-12-14 20:42:47 │ U          │ 2000396086140731465 │          0 │
2. │ 7          │ London1 │ +44 20 7877 2041 │ 25 Old Broad Street │ Level 7      │ ᴺᵁᴸᴸ  │ UK      │ EC2N 1HN   │ EMEA      │ 2025-12-14 20:42:47 │ 2025-12-14 20:43:36 │ U          │ 2000396291397386314 │          0 │
3. │ 7          │ London2 │ +44 20 7877 2041 │ 25 Old Broad Street │ Level 7      │ ᴺᵁᴸᴸ  │ UK      │ EC2N 1HN   │ EMEA      │ 2025-12-14 20:43:36 │ 2025-12-14 20:44:06 │ U          │ 2000396418258305099 │          0 │
   └────────────┴─────────┴──────────────────┴─────────────────────┴──────────────┴───────┴─────────┴────────────┴───────────┴─────────────────────┴─────────────────────┴────────────┴─────────────────────┴────────────┘
   ┌─officeCode─┬─city──────────┬─phone───────────┬─addressLine1─────────────┬─addressLine2─┬─state──────┬─country───┬─postalCode─┬─territory─┬─────────_valid_from─┬───────────_valid_to─┬─_operation─┬────────────_version─┬─is_deleted─┐
4. │ 1          │ San Francisco │ +1 650 219 4782 │ 100 Market Street        │ Suite 300    │ CA         │ USA       │ 94080      │ NA        │ 2025-12-14 20:42:04 │ 2099-12-31 18:00:00 │ C          │ 1765766525518300181 │          0 │
5. │ 2          │ Boston        │ +1 215 837 0825 │ 1550 Court Place         │ Suite 102    │ MA         │ USA       │ 02107      │ NA        │ 2025-12-14 20:42:04 │ 2099-12-31 18:00:00 │ C          │ 1765766525518300182 │          0 │
6. │ 3          │ NYC           │ +1 212 555 3000 │ 523 East 53rd Street     │ apt. 5A      │ NY         │ USA       │ 10022      │ NA        │ 2025-12-14 20:42:04 │ 2099-12-31 18:00:00 │ C          │ 1765766525518300183 │          0 │
7. │ 4          │ Paris         │ +33 14 723 4404 │ 43 Rue Jouffroy D'abbans │ ᴺᵁᴸᴸ         │ ᴺᵁᴸᴸ       │ France    │ 75017      │ EMEA      │ 2025-12-14 20:42:04 │ 2099-12-31 18:00:00 │ C          │ 1765766525518300184 │          0 │
8. │ 5          │ Tokyo         │ +81 33 224 5000 │ 4-1 Kioicho              │ ᴺᵁᴸᴸ         │ Chiyoda-Ku │ Japan     │ 102-8578   │ Japan     │ 2025-12-14 20:42:04 │ 2099-12-31 18:00
8000
:00 │ C          │ 1765766525518300185 │          0 │
9. │ 6          │ Sydney        │ +61 2 9264 2451 │ 5-11 Wentworth Avenue    │ Floor #2     │ ᴺᵁᴸᴸ       │ Australia │ NSW 2010   │ APAC      │ 2025-12-14 20:42:04 │ 2099-12-31 18:00:00 │ C          │ 1765766525518300186 │          0 │
   └────────────┴───────────────┴─────────────────┴──────────────────────────┴──────────────┴────────────┴───────────┴────────────┴───────────┴─────────────────────┴─────────────────────┴────────────┴─────────────────────┴────────────┘
    ┌─officeCode─┬─city────┬─phone────────────┬─addressLine1────────┬─addressLine2─┬─state─┬─country─┬─postalCode─┬─territory─┬─────────_valid_from─┬───────────_valid_to─┬─_operation─┬────────────_version─┬─is_deleted─┐
10. │ 7          │ London3 │ +44 20 7877 2041 │ 25 Old Broad Street │ Level 7      │ ᴺᵁᴸᴸ  │ UK      │ EC2N 1HN   │ EMEA      │ 2025-12-14 20:44:06 │ 2099-12-31 18:00:00 │ U          │ 2000396418258305100 │          0 │
    └────────────┴─────────┴──────────────────┴─────────────────────┴──────────────┴───────┴─────────┴────────────┴───────────┴─────────────────────┴─────────────────────┴────────────┴─────────────────────┴────────────┘

10 rows in set. Elapsed: 0.004 sec.

@subkanthi
Merge branch '1169-version-history-support-for-_valid_from' of https:…
12ff29f 
…//github.com/Altinity/clickhouse-sink-connector into 1169-version-history-support-for-_valid_from
@subkanthi
- Changed prometheus docker image.
02adfe5 
- Added logic to check for null in db user/password.
- Disabled batch routing
- Upgrade testcontainer version.
@subkanthi
- Fix integration tests.
ad6ef85
@subkanthi
- Fix integration tests.
25b39c7
@subkanthi subkanthi closed this Jan 16, 2026
@subkanthi subkanthi reopened this Jan 16, 2026
8BD0
@subkanthi
Merge branch '2.8.1' of https://github.com/Altinity/clickhouse-sink-c…
7770453 
…onnector into 1169-version-history-support-for-_valid_from
@subkanthi subkanthi closed this Jan 17, 2026
@subkanthi subkanthi reopened this Jan 17, 2026
@subkanthi
subkanthi merged commit 27f3259 into 2.8.1 Jan 21, 2026
8 checks passed
@subkanthi
subkanthi deleted the 1169-version-history-support-for-_valid_from branch January 21, 2026 00:22
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

1 participant

@subkanthi
0