|
25 | 25 | DB_NAMESPACE = DB_SETTINGS["namespace"] |
26 | 26 | DB_PROCEDURE = "hello_" + DB_NAMESPACE |
27 | 27 |
|
| 28 | +mysql_version = tuple(int(x) for x in mysql.connector.__version__.split(".")[:3]) |
| 29 | +if mysql_version >= (8, 0, 30): |
| 30 | + _connector_metric_name = 'Function/mysql.connector.pooling:connect' |
| 31 | +else: |
| 32 | + _connector_metric_name = 'Function/mysql.connector:connect' |
| 33 | + |
28 | 34 | _test_execute_via_cursor_scoped_metrics = [ |
29 | | - ('Function/mysql.connector:connect', 1), |
| 35 | + (_connector_metric_name, 1), |
30 | 36 | ('Datastore/statement/MySQL/datastore_mysql_%s/select' % DB_NAMESPACE, 1), |
31 | 37 | ('Datastore/statement/MySQL/datastore_mysql_%s/insert' % DB_NAMESPACE, 1), |
32 | 38 | ('Datastore/statement/MySQL/datastore_mysql_%s/update' % DB_NAMESPACE, 1), |
@@ -103,7 +109,7 @@ def test_execute_via_cursor(table_name): |
103 | 109 | connection.commit() |
104 | 110 |
|
105 | 111 | _test_connect_using_alias_scoped_metrics = [ |
106 | | - ('Function/mysql.connector:connect', 1), |
| 112 | + (_connector_metric_name, 1), |
107 | 113 | ('Datastore/statement/MySQL/datastore_mysql_%s/select' % DB_NAMESPACE, 1), |
108 | 114 | ('Datastore/statement/MySQL/datastore_mysql_%s/insert' % DB_NAMESPACE, 1), |
109 | 115 | ('Datastore/statement/MySQL/datastore_mysql_%s/update' % DB_NAMESPACE, 1), |
|
0 commit comments