alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-2038 Refactor postgres type registry queries to use the same base query

Browse Source
This commit is contained in:
Braden Groom 2020-04-29 21:53:42 -07:00 committed by Chris Cranford
parent 63f96940fb
commit 8093582487
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/TypeRegistry.java
View File

@ -63,13 +63,9 @@ public class TypeRegistry {
+ "FROM pg_catalog.pg_type t JOIN pg_catalog.pg_namespace n ON (t.typnamespace = n.oid) "
+ "WHERE n.nspname != 'pg_toast'";
private static final String SQL_NAME_LOOKUP = "SELECT t.oid as oid, t.typname AS name, t.typelem AS element, t.typbasetype AS parentoid, t.typtypmod AS modifiers, t.typcategory as category "
+ "FROM pg_catalog.pg_type t JOIN pg_catalog.pg_namespace n ON (t.typnamespace = n.oid) "
+ "WHERE n.nspname != 'pg_toast' AND t.typname = ?";
private static final String SQL_NAME_LOOKUP = SQL_TYPES + " AND t.typname = ?";
private static final String SQL_OID_LOOKUP = "SELECT t.oid as oid, t.typname AS name, t.typelem AS element, t.typbasetype AS parentoid, t.typtypmod AS modifiers, t.typcategory as category "
+ "FROM pg_catalog.pg_type t JOIN pg_catalog.pg_namespace n ON (t.typnamespace = n.oid) "
+ "WHERE n.nspname != 'pg_toast' AND t.oid = ?";
private static final String SQL_OID_LOOKUP = SQL_TYPES + " AND t.oid = ?";
private static final String SQL_ENUM_VALUES_LOOKUP = "select t.enumlabel as enum_value "
+ "FROM pg_catalog.pg_enum t "