Parse Postgres citext as Type::Unknown

src/postgres/parser/column.rs

@@ -206,11 +206,19 @@ pub fn parse_array_attributes(
 
 impl ColumnInfo {
     pub fn parse_enum_variants(mut self, enums: &HashMap<String, Vec<String>>) -> Self {
+        let mut enum_name = None;
+        let mut no_enum_variants = true;
         if let Type::Enum(ref mut enum_def) = self.col_type {
+            enum_name = Some(&enum_def.typename);
             if let Some(def) = enums.get(&enum_def.typename) {
-                enum_def.values = def.clone()
+                no_enum_variants = def.is_empty();
+                enum_def.values = def.clone();
             }
         }
+        // An enum column without any variants will be treated as unknown column type
+        if let (Some(enum_name), true) = (enum_name, no_enum_variants) {
+            self.col_type = Type::Unknown(enum_name.into());
+        }
         self
     }
 }

tests/live/postgres/src/main.rs

@@ -22,6 +22,11 @@ async fn main() {
     let connection = setup(&url, "sea-schema").await;
     let mut executor = connection.acquire().await.unwrap();
 
+    sqlx::query("CREATE EXTENSION IF NOT EXISTS citext")
+        .execute(&mut executor)
+        .await
+        .unwrap();
+
     let create_enum_stmt = Type::create()
         .as_enum(Alias::new("crazy_enum"))
         .values(vec![
@@ -337,5 +342,10 @@ fn create_collection_table() -> TableCreateStatement {
                 .not_null(),
         )
         .col(ColumnDef::new(Alias::new("integers_opt")).array(ColumnType::Integer))
+        .col(
+            ColumnDef::new(Alias::new("case_insensitive_text"))
+                .custom(Alias::new("citext"))
+                .not_null(),
+        )
         .to_owned()
 }