diff --git a/src/postgres_utils.cpp b/src/postgres_utils.cpp index ae3d02172..03b1cf2ca 100644 --- a/src/postgres_utils.cpp +++ b/src/postgres_utils.cpp @@ -151,11 +151,17 @@ LogicalType PostgresUtils::TypeToLogicalType(optional_ptr t } else if (pgtypename == "char" || pgtypename == "bpchar") { postgres_type.info = PostgresTypeAnnotation::FIXED_LENGTH_CHAR; return LogicalType::VARCHAR; - } else if (pgtypename == "varchar" || pgtypename == "text" || pgtypename == "json") { + } else if (pgtypename == "varchar" || pgtypename == "text") { return LogicalType::VARCHAR; + } else if (pgtypename == "json") { + auto json_type = LogicalType::VARCHAR; + json_type.SetAlias("JSON"); + return json_type; } else if (pgtypename == "jsonb") { postgres_type.info = PostgresTypeAnnotation::JSONB; - return LogicalType::VARCHAR; + auto json_type = LogicalType::VARCHAR; + json_type.SetAlias("JSON"); + return json_type; } else if (pgtypename == "geometry") { return GetGeometryType(); } else if (pgtypename == "date") {