From de9c992ac2c693196d3da13583c3bbdd34e3304e Mon Sep 17 00:00:00 2001
From: Braden Mars <bradenmars@bradenmars.me>
Date: Sat, 21 Jan 2023 00:47:58 -0600
Subject: [PATCH] fix(fdb): ensure TEXT blob subtypes are read if still blob
 readers.

Signed-off-by: Braden Mars <bradenmars@bradenmars.me>
---
 sqlalchemy_firebird/fdb.py | 29 +++++++++++++++++++++++++----
 1 file changed, 25 insertions(+), 4 deletions(-)

diff --git a/sqlalchemy_firebird/fdb.py b/sqlalchemy_firebird/fdb.py
index 2439794..b30d022 100644
--- a/sqlalchemy_firebird/fdb.py
+++ b/sqlalchemy_firebird/fdb.py
@@ -54,13 +54,15 @@
 
 """  # noqa
 
-from .kinterbasdb import FBDialect_kinterbasdb
-from sqlalchemy import util
 from sqlalchemy import LargeBinary
 from sqlalchemy import types as sqltypes
+from sqlalchemy import util
+
+from .base import _StringType
+from .kinterbasdb import FBDialect_kinterbasdb
 
 
-class _FBBlob(LargeBinary):
+class _FBLargeBinary(LargeBinary):
     def result_processor(self, dialect, coltype):
         def process(value):
             if value is not None:
@@ -74,12 +76,31 @@ def process(value):
         return process
 
 
+class _FBTEXT(_StringType, sqltypes.TEXT):
+    __visit_name__ = "TEXT"
+
+    def result_processor(self, dialect, coltype):
+        from fdb.fbcore import BlobReader
+
+        proc = super(sqltypes.TEXT, self).result_processor(dialect, coltype)
+
+        def process(value):
+            if proc:
+                value = proc(value)
+            if isinstance(value, BlobReader):
+                value = value.read()
+            return value
+
+        return process
+
+
 class FBDialect_fdb(FBDialect_kinterbasdb):
     driver = "fdb"
     supports_statement_cache = True
     is_interbase = False
     colspecs = util.update_copy(
-        FBDialect_kinterbasdb.colspecs, {sqltypes.LargeBinary: _FBBlob}
+        FBDialect_kinterbasdb.colspecs,
+        {sqltypes.LargeBinary: _FBLargeBinary, sqltypes.TEXT: _FBTEXT},
     )
 
     def __init__(