-
Notifications
You must be signed in to change notification settings - Fork 688
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Browse files
Browse the repository at this point in the history
- Loading branch information
1 parent
ac7c78b
commit 61fbcb8
Showing
4 changed files
with
93 additions
and
41 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,92 @@ | ||
--- | ||
title: Changefeed DDL Replication | ||
summary: Learn about the DDL statements supported by TiCDC and some special cases. | ||
--- | ||
|
||
# Changefeed DDL Replication | ||
|
||
This document describes the rules and special cases of DDL replication in TiCDC. | ||
|
||
## DDL allow list | ||
|
||
Currently, TiCDC uses an allow list to determine whether to replicate a DDL statement. Only the DDL statements in the allow list are replicated to the downstream. The DDL statements not in the allow list are not replicated. | ||
|
||
The allow list of DDL statements supported by TiCDC is as follows: | ||
|
||
- create database | ||
- drop database | ||
- create table | ||
- drop table | ||
- add column | ||
- drop column | ||
- create index / add index | ||
- drop index | ||
- truncate table | ||
- modify column | ||
- rename table | ||
- alter column default value | ||
- alter table comment | ||
- rename index | ||
- add partition | ||
- drop partition | ||
- truncate partition | ||
- create view | ||
- drop view | ||
- alter table character set | ||
- alter database character set | ||
- recover table | ||
- add primary key | ||
- drop primary key | ||
- rebase auto id | ||
- alter table index visibility | ||
- exchange partition | ||
- reorganize partition | ||
- alter table ttl | ||
- alter table remove ttl | ||
|
||
## DDL replication considerations | ||
|
||
Due to the lack of some context during the replication process, TiCDC has some constraints on the replication of `RENAME TABLE` DDLs. | ||
|
||
### Rename a single table in a DDL statement | ||
|
||
If a DDL statement renames a single table, TiCDC only replicates the DDL statement when the old table name matches the filter rule. The following is an example. | ||
|
||
Assume that the configuration file of your changefeed is as follows: | ||
|
||
```toml | ||
[filter] | ||
rules = ['test.t*'] | ||
``` | ||
|
||
TiCDC processes this type of DDL as follows: | ||
|
||
| DDL | Whether to replicate | Reason for the handling | | ||
| --- | --- | --- | | ||
| `RENAME TABLE test.t1 TO test.t2` | Replicate | `test.t1` matches the filter rule | | ||
| `RENAME TABLE test.t1 TO ignore.t1` | Replicate | `test.t1` matches the filter rule | | ||
| `RENAME TABLE ignore.t1 TO ignore.t2` | Ignore | `ignore.t1` does not match the filter rule | | ||
| `RENAME TABLE test.n1 TO test.t1` | Report an error and exit the replication | `test.n1` does not match the filter rule, but `test.t1` matches the filter rule. This operation is illegal. In this case, refer to the error message for handling. | | ||
| `RENAME TABLE ignore.t1 TO test.t1` | Report an error and exit the replication | Same reason as above. | | ||
|
||
### Rename multiple tables in a DDL statement | ||
|
||
If a DDL statement renames multiple tables, TiCDC only replicates the DDL statement when the old database name, old table names, and the new database name all match the filter rule. | ||
|
||
In addition, TiCDC does not support the `RENAME TABLE` DDL that swaps the table names. The following is an example. | ||
|
||
Assume that the configuration file of your changefeed is as follows: | ||
|
||
```toml | ||
[filter] | ||
rules = ['test.t*'] | ||
``` | ||
|
||
TiCDC processes this type of DDL as follows: | ||
|
||
| DDL | Whether to replicate | Reason for the handling | | ||
| --- | --- | --- | | ||
| `RENAME TABLE test.t1 TO test.t2, test.t3 TO test.t4` | Replicate | All database names and table names match the filter rule. | | ||
| `RENAME TABLE test.t1 TO test.ignore1, test.t3 TO test.ignore2` | Replicate | The old database name, the old table names, and the new database name match the filter rule. | | ||
| `RENAME TABLE test.t1 TO ignore.t1, test.t2 TO test.t22;` | Report an error | The new database name `ignore` does not match the filter rule. | | ||
| `RENAME TABLE test.t1 TO test.t4, test.t3 TO test.t1, test.t4 TO test.t3;` | Report an error | The `RENAME TABLE` DDL swaps the names of `test.t1` and `test.t3` in one DDL statement, which TiCDC cannot handle correctly. In this case, refer to the error message for handling. | |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters