feat: Thread-safe mode for multi-tenant applications

src/datajoint/__init__.py

@@ -52,6 +52,7 @@
     "errors",
     "migrate",
     "DataJointError",
+    "ThreadSafetyError",
     "logger",
     "cli",
     "ValidationResult",
@@ -73,7 +74,7 @@
 )
 from .blob import MatCell, MatStruct
 from .connection import Connection, conn
-from .errors import DataJointError
+from .errors import DataJointError, ThreadSafetyError
 from .expression import AndList, Not, Top, U
 from .logging import logger
 from .objectref import ObjectRef

src/datajoint/adapters/mysql.py

@@ -75,34 +75,28 @@ def connect(
             Password for authentication.
         **kwargs : Any
             Additional MySQL-specific parameters:
-            - init_command: SQL initialization command
             - ssl: TLS/SSL configuration dict (deprecated, use use_tls)
             - use_tls: bool or dict - DataJoint's SSL parameter (preferred)
-            - charset: Character set (default from kwargs)
 
         Returns
         -------
         pymysql.Connection
             MySQL connection object.
         """
-        init_command = kwargs.get("init_command")
         # Handle both ssl (old) and use_tls (new) parameter names
         ssl_config = kwargs.get("use_tls", kwargs.get("ssl"))
         # Convert boolean True to dict for PyMySQL (PyMySQL expects dict or SSLContext)
         if ssl_config is True:
             ssl_config = {}  # Enable SSL with default settings
-        charset = kwargs.get("charset", "")
 
         # Prepare connection parameters
         conn_params = {
             "host": host,
             "port": port,
             "user": user,
             "passwd": password,
-            "init_command": init_command,
             "sql_mode": "NO_ZERO_DATE,NO_ZERO_IN_DATE,ERROR_FOR_DIVISION_BY_ZERO,"
             "STRICT_ALL_TABLES,NO_ENGINE_SUBSTITUTION,ONLY_FULL_GROUP_BY",
-            "charset": charset,
             "autocommit": True,  # DataJoint manages transactions explicitly
         }