Release 25.14.1 (#12128)

Co-authored-by: Lucas Koontz <lucas.emanuel.koontz@gmail.com>
Co-authored-by: Konstantin Sivakov <konstantin.sivakov@gmail.com>

Author: 3 people

mindsdb/__about__.py

@@ -1,6 +1,6 @@
 __title__ = "MindsDB"
 __package_name__ = "mindsdb"
-__version__ = "25.14.0"
+__version__ = "25.14.1"
 __description__ = "MindsDB's AI SQL Server enables developers to build AI tools that need access to real-time data to perform their tasks"
 __email__ = "jorge@mindsdb.com"
 __author__ = "MindsDB Inc"

mindsdb/integrations/handlers/postgres_handler/postgres_handler.py

@@ -176,9 +176,6 @@ def _make_connection_args(self):
         if self.connection_args.get("autocommit"):
             config["autocommit"] = self.connection_args.get("autocommit")
 
-        # If schema is not provided set public as default one
-        if self.connection_args.get("schema"):
-            config["options"] = f"-c search_path={self.connection_args.get('schema')},public"
         return config
 
     @profiler.profile()
@@ -199,6 +196,12 @@ def connect(self):
         try:
             self.connection = psycopg.connect(**config)
             self.is_connected = True
+
+            schema = self.connection_args.get("schema")
+            if schema:
+                with self.connection.cursor() as cur:
+                    cur.execute(f'SET search_path TO "{schema}", public;')
+                self.connection.commit()
             return self.connection
         except psycopg.Error as e:
             logger.error(f"Error connecting to PostgreSQL {self.database}, {e}!")

tests/unit/handlers/test_postgres.py

@@ -208,6 +208,26 @@ def test_native_query_error(self):
         # Ensure rollback was called
         mock_conn.rollback.assert_called_once()
 
+    def test_connect_with_schema_sets_search_path_after_connection(self):
+        """
+        Tests that when schema is provided, search_path is set via SET command
+        after connection (pooler-compatible) rather than via startup options.
+        """
+        self.tearDown()
+        self.setUp()
+        self.handler.connection_args["schema"] = "my_schema"
+
+        mock_cursor = MockCursorContextManager()
+        self.mock_connect.return_value.cursor.return_value = mock_cursor
+
+        connection = self.handler.connect()
+
+        self.assertTrue(self.handler.is_connected)
+        self.assertIsNotNone(connection)
+
+        mock_cursor.execute.assert_called_once_with('SET search_path TO "my_schema", public;')
+        self.mock_connect.return_value.commit.assert_called_once()
+
     def test_make_connection_args_applies_overrides(self):
         handler = self.handler
         handler.connection_args = OrderedDict(
@@ -223,7 +243,6 @@ def test_make_connection_args_applies_overrides(self):
         config = handler._make_connection_args()
         self.assertEqual(config["application_name"], "mdb")
         self.assertEqual(config["connect_timeout"], 10)
-        self.assertEqual(config["options"], "-c search_path=custom,public")
         self.assertTrue(config["autocommit"])
 
     def test_map_type_handles_known_and_unknown(self):
@@ -536,9 +555,6 @@ def test_connection_parameters(self):
         self.assertEqual(call_kwargs["connect_timeout"], 10)
         self.assertEqual(call_kwargs["sslmode"], "prefer")
 
-        expected_options = "-c search_path=public,public"
-        self.assertEqual(call_kwargs["options"], expected_options)
-
         # Test with a different schema
         # Create a fresh handler with different schema
         self.tearDown()
@@ -548,8 +564,6 @@ def test_connection_parameters(self):
 
         self.handler.connect()
         call_kwargs = self.mock_connect.call_args[1]
-        expected_options = "-c search_path=custom_schema,public"
-        self.assertEqual(call_kwargs["options"], expected_options)
 
     def test_types_casting(self):
         """Test that types are casted correctly"""