Как мы отфильтровываем таблицы и предоставляем исходный разъем jdbc для извлечения данных

#apache-kafka #apache-kafka-connect #confluent-platform

Вопрос:

Я знаю о предоставлении table.whitelist свойства для извлечения данных из таблиц, включенных в белый список. Теперь в нашей базе данных нам нужно извлечь данные из таблиц, имена которых представлены в некотором формате.

Например, моя база данных может содержать такие таблицы, как :-

 cus_01
emp_01
cus_02
emp_02
 

И нужно извлечь таблицы, которые в конце имеют значение 01 (т. Е. cus_01 и emp_01).

Как я могу этого достичь

Ответ №1:

Вы можете указать регулярное выражение для table.whitelist table.include.list свойств или.

В вашем случае вы можете использовать следующие свойства для включения таблиц, которые заканчиваются 01

 "table.include.list": "^(Database_name.)(. 01)"
 

Комментарии:

1. Предположим, в моей таблице теперь таблицы выглядят так :- cust_abc_xyz, cust_01, cust_xyz_abc . Я хочу получить таблицы abc_xyz и xyz_abc ? как это настроить?? Могу ли я передать другой формат, используя запятую (,) в table.include.list

2. Я не знаю о добавлении запятой для другого формата, но я предложу вам регулярное выражение для вашего варианта использования, это ^(Database_name.)((. 01)|(. _abc_xyz)|(. _xyz_abc))$