chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixed issue #4216 , support polardb-x show tables

Browse Source
This commit is contained in:
jianghang.loujh
2022-06-10 13:36:39 +08:00
parent 6b1e4eac97
commit e5a347870a
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/DatabaseTableMeta.java
View File

@@ -209,11 +209,10 @@ public class DatabaseTableMeta implements TableMetaTSDB {
for (String schema : schemas) { for (String schema : schemas) {
// filter views // filter views
packet = connection.query("show full tables from `" + schema + "` where Table_type = 'BASE TABLE'"); packet = connection.query("show full tables from `" + schema + "` where Table_type = 'BASE TABLE'");
int tableNameColumnIndex = 0; // default index is 0
List<String> tables = new ArrayList<>(); List<String> tables = new ArrayList<>();
for (String table : packet.getFieldValues()) { for (int line = 0; line < packet.getFieldValues().size() / columnSize; line++) {
if ("BASE TABLE".equalsIgnoreCase(table)) { String table = packet.getFieldValues().get(line * columnSize + tableNameColumnIndex);
continue;
}
String fullName = schema + "." + table; String fullName = schema + "." + table;
if (blackFilter == null || !blackFilter.filter(fullName)) { if (blackFilter == null || !blackFilter.filter(fullName)) {
if (filter == null || filter.filter(fullName)) { if (filter == null || filter.filter(fullName)) {