Add mysql-connector SQLAlchemy ORM

Author: jonathanl-bq

aws_advanced_python_wrapper/sqlalchemy/mysql_orm_dialect.py

@@ -0,0 +1,19 @@
+# aws_advanced_python_wrapper/sqlalchemy/sqlalchemy_mysqlconnector_dialect.py
+from psycopg import Connection
+from sqlalchemy.dialects.mysql.mysqlconnector import MySQLDialect_mysqlconnector
+import re
+
+from aws_advanced_python_wrapper import AwsWrapperConnection
+
+
+class SqlAlchemyOrmMysqlDialect(MySQLDialect_mysqlconnector):
+    """
+    SQLAlchemy dialect for AWS Advanced Python Wrapper with mysqlconnector. Extends the SQLAlchemy MySQL mysqlconnector dialect.
+    This dialect is not related to the DriverDialect or DatabaseDialect classes used by our driver. Instead, it is used
+    directly by SQLAlchemy. This dialect is registered in pyproject.toml and is selected by prefixing the connection
+    string passed to create_engine with "mysql+aws_wrapper_mysqlconnector://" ("[name]+[driver]").
+    """
+
+    name = 'mysql'
+    driver = 'aws_wrapper_mysqlconnector'
+

…python_wrapper/sqlalchemy/orm_dialect.py …hon_wrapper/sqlalchemy/pg_orm_dialect.pyaws_advanced_python_wrapper/sqlalchemy/orm_dialect.py renamed to aws_advanced_python_wrapper/sqlalchemy/pg_orm_dialect.py aws_advanced_python_wrapper/sqlalchemy/orm_dialect.py renamed to aws_advanced_python_wrapper/sqlalchemy/pg_orm_dialect.py

@@ -11,11 +11,11 @@ class SqlAlchemyOrmPgDialect(PGDialect_psycopg):
     SQLAlchemy dialect for AWS Advanced Python Wrapper with psycopg. Extends the SQLAlchemy PostgreSQL psycopg dialect.
     This dialect is not related to the DriverDialect or DatabaseDialect classes used by our driver. Instead, it is used
     directly by SQLAlchemy. This dialect is registered in pyproject.toml and is selected by prefixing the connection
-    string passed to create_engine with "postgresql+aws_wrapper://" ("[name]+[driver]").
+    string passed to create_engine with "postgresql+aws_wrapper_psycopg://" ("[name]+[driver]").
     """
 
     name = 'postgresql'
-    driver = 'aws_wrapper'
+    driver = 'aws_wrapper_psycopg'
 
     def __init__(self, **kwargs):
         # PGDialect_psycopg's __init__ function checks the driver version and raises an exception if it is lower than