[pinpoint-apm#693] update mysql-connector-python

> pinpoint-apm#693

Author: eeliu

plugins/PY/pinpointPy/libs/_MysqlConnector/CMysqlPlugin.py

@@ -15,11 +15,17 @@
 # ------------------------------------------------------------------------------
 
 from pinpointPy import Common, Defines, pinpoint
+import mysql
+import warnings
+
+#
 
 
 class CMysqlPlugin(Common.PinTrace):
 
     def __init__(self, name):
+        warnings.warn(
+            "CMysqlPlugin is deprecated, please use MysqlPlugin instead", DeprecationWarning)
         super().__init__(name)
 
     # -> tuple[Any, tuple[Any, ...], dict[str, Any]]:
@@ -48,4 +54,8 @@ def onException(self, traceId, e):
         pinpoint.add_exception(f'{e}', traceId)
 
     def get_cursor_host(self, cursor):
-        return f'{cursor._cnx.server_host}:{cursor._cnx.server_port}'
+        if mysql.connector.__version__ >= "9.1.0":
+            # https://github.com/mysql/mysql-connector-python/blob/4fbf521f1c6c71621f882f89c0c4946c10ee13ac/mysql-connector-python/lib/mysql/connector/abstracts.py#L692
+            return f'{cursor._connection._host}:{cursor._connection._host}'
+        else:
+            return f'{cursor._cnx.server_host}:{cursor._cnx.server_port}'

plugins/PY/pinpointPy/libs/_MysqlConnector/__init__.py

@@ -37,23 +37,27 @@ def monkey_patch():
         if 'unittest' in sys.modules.keys():
             raise e
 
-    try:
-        from mysql.connector.cursor_cext import CMySQLCursor, CMySQLCursorPrepared
-        from .CMysqlPlugin import CMysqlPlugin
-
-        Interceptors = [
-            Interceptor(CMySQLCursor, 'execute', CMysqlPlugin),
-            Interceptor(CMySQLCursorPrepared, 'execute', CMysqlPlugin),
-        ]
-        for interceptor in Interceptors:
-            interceptor.enable()
-    except ImportError as e:
-        get_logger().info(f"exception at {e}")
-        import sys
-        if 'unittest' in sys.modules.keys():
-            raise e
+    # try:
+    #     from mysql.connector.cursor_cext import CMySQLCursor, CMySQLCursorPrepared
+    #     from .CMysqlPlugin import CMysqlPlugin
+
+    #     Interceptors = [
+    #         Interceptor(CMySQLCursor, 'execute', CMysqlPlugin),
+    #         Interceptor(CMySQLCursorPrepared, 'execute', CMysqlPlugin),
+    #     ]
+    #     for interceptor in Interceptors:
+    #         interceptor.enable()
+    # except ImportError as e:
+    #     get_logger().info(f"exception at {e}")
+    #     import sys
+    #     if 'unittest' in sys.modules.keys():
+    #         raise e
 
 
 __all__ = ['monkey_patch']
-__version__ = '0.0.5'
+__version__ = '0.0.6'
 __author__ = '[email protected]'
+
+# Changes
+# ## 0.0.6
+# - remove `CMySQLCursor` and `CMySQLCursorPrepared`