all local linting passes

Author: Antony Bailey

src/pysqly/connectors/base.py

@@ -51,7 +51,8 @@ def execute(self, sql: str, params: List[Any]) -> Any:
             If the SQL statement is not a SELECT query, returns a success message.
 
         Raises:
-            SQLYExecutionError: If an error occurs during the execution of the SQL statement.
+            SQLYExecutionError: If an error occurs during the execution of
+            the SQL statement.
         """
         cursor = self.connection.cursor()
         try:
@@ -61,6 +62,8 @@ def execute(self, sql: str, params: List[Any]) -> Any:
             self.connection.commit()
             return "Query executed successfully"
         except Exception as e:
-            raise SQLYExecutionError(f"{self.__class__.__name__} error: {str(e)}") from e
+            raise SQLYExecutionError(
+                f"{self.__class__.__name__} error: {str(e)}"
+            ) from e
         finally:
             cursor.close()

src/pysqly/connectors/database.py

@@ -7,25 +7,31 @@
 
 class DatabaseConnector:
     """
-    A class that manages connections to various database types and executes SQLY queries.
+    A class that manages connections to various database types and executes
+    SQLY queries.
 
     This class serves as an abstraction layer over different database connectors,
-    allowing for a unified interface to execute queries across different database systems
-    such as SQLite, MariaDB, PostgreSQL, Oracle, and MS SQL Server.
+    allowing for a unified interface to execute queries across different
+    database systems such as SQLite, MariaDB, PostgreSQL, Oracle,
+    and MS SQL Server.
 
     Attributes:
         db_type: The type of the database being connected to.
-        connection: The connection parameters or object needed to establish a database connection.
-        connector: The actual database connector instance used to interact with the database.
+        connection: The connection parameters or object needed to establish a
+        connection.
+        connector: The actual database connector instance used to interact with
+        the database.
 
     Examples:
         >>> connector = DatabaseConnector("sqlite", ":memory:")
-        >>> result = connector.execute_query({"select": ["id", "name"], "from": "users"})
+        >>> result = connector.execute_query({"select": ["id", "name"],
+        "from": "users"})
     """
 
     def __init__(self, db_type: str, connection: Any) -> None:
         """
-        Initialize the DatabaseConnector with the database type and connection information.
+        Initialize the DatabaseConnector with the database type and connection
+        information.
 
         Args:
             db_type: The type of the database (e.g., "sqlite", "mariadb",
@@ -69,7 +75,8 @@ def execute_query(
             The result of the executed query.
 
         Raises:
-            SQLYExecutionError: If the query is invalid or an error occurs during execution.
+            SQLYExecutionError: If the query is invalid or an error occurs during
+            execution.
         """
         # Use provided values or fall back to instance attributes
         db_type = db_type or self.db_type

src/pysqly/connectors/factory.py

@@ -22,7 +22,7 @@ class DBConnectorFactory:
     @staticmethod
     def create_connector(db_type: str, connection: Any) -> Any:
         """
-        Create and return a database connector instance based on the specified database type.
+        Create and return a database connector instance based on the database type.
 
         Args:
             db_type: The type of the database (e.g., "sqlite", "mariadb",

src/pysqly/connectors/interface.py

@@ -19,14 +19,16 @@ def execute(self, sql: str, params: List[Any]) -> Any:
         """
         Execute a SQL query with parameters.
 
-        This method executes a SQL query with the provided parameters against the database.
+        This method executes a SQL query with the provided parameters against the
+        database.
 
         Args:
             sql: The SQL query to execute.
             params: The parameters to be used in the SQL query.
 
         Returns:
-            The result of the query execution, which depends on the specific database implementation.
+            The result of the query execution, which depends on the specific database
+            implementation.
 
         Raises:
             DatabaseError: If the query execution fails.

src/pysqly/connectors/mariadb.py

@@ -18,11 +18,13 @@ def __init__(self, connection: Union[str, Any]) -> None:
         """
         Initialize the MariaDBConnector.
 
-        This constructor accepts either a connection string or an existing MySQL connection.
+        This constructor accepts either a connection string or an existing
+        MySQL connection.
 
         Args:
-            connection: If a string is provided, it's treated as a connection string and a new connection is established.
-                If a connection object is provided, it's used directly.
+            connection: If a string is provided, it's treated as a connection string
+                and a new connection is established. If a connection object is provided,
+                it's used directly.
         """
         if isinstance(connection, str):
             connection = mysql.connector.connect(connection)

src/pysqly/connectors/mssql.py

@@ -24,8 +24,9 @@ def __init__(self, connection: Union[str, Any]) -> None:
                 establish a new connection.
 
         Notes:
-            If a connection string is provided, it should be in the format required by pyodbc,
-            typically including server, database, authentication details, and other relevant parameters.
+            If a connection string is provided, it should be in the format required by
+            pyodbc, typically including server, database, authentication details,
+            and other relevant parameters.
         """
         if isinstance(connection, str):
             connection = pyodbc.connect(connection)

src/pysqly/connectors/oracle.py

@@ -21,9 +21,10 @@ def __init__(self, connection: Union[str, Any]) -> None:
         This constructor initializes a connection to an Oracle database using cx_Oracle.
 
         Args:
-            connection: Either a connection string in the format "username/password@host:port/service_name"
-                or an already established cx_Oracle Connection object.
-                If a string is provided, it will be used to create a new connection.
+            connection: Either a connection string in the format
+                "username/password@host:port/service_name" or an already established
+                cx_Oracle Connection object. If a string is provided, it will be used
+                to create a new connection.
 
         Notes:
             The connection string format follows the Oracle standard:

src/pysqly/connectors/postgres.py

@@ -20,8 +20,8 @@ def __init__(self, connection: Union[str, Any]) -> None:
 
         Args:
             connection: Either a connection string to establish a new connection
-                or an existing psycopg2 connection object. If a string is provided, it will be used to create
-                a new connection.
+                or an existing psycopg2 connection object. If a string is provided,
+                it will be used to create a new connection.
 
         Notes:
             The connection string should be in the format:

src/pysqly/connectors/sqlite.py

@@ -18,8 +18,9 @@ def __init__(self, connection: Union[str, sqlite3.Connection]) -> None:
         Initialize the SQLiteConnector with a connection to an SQLite database.
 
         Args:
-            connection: Either a file path to an SQLite database or an existing sqlite3.Connection object.
-                If a string is provided, a new connection to the database at that path is created.
+            connection: Either a file path to an SQLite database or an existing
+                sqlite3.Connection object. If a string is provided, a new connection
+                to the database at that path is created.
         """
         if isinstance(connection, str):
             connection = sqlite3.connect(connection)

src/pysqly/core/executor.py

@@ -58,7 +58,9 @@ def execute(self, query: str) -> Any:
                 )
             return self._run_query(parsed_query)
         except Exception as e:
-            raise SQLYExecutionError(f"Failed to process SQLY query: {str(e)}") from e
+            raise SQLYExecutionError(
+                f"Failed to process SQLY query: {str(e)}"
+            ) from e
 
     def _run_query(self, parsed_query: Dict[str, Any]) -> Any:
         """
@@ -75,7 +77,9 @@ def _run_query(self, parsed_query: Dict[str, Any]) -> Any:
         """
         try:
             if not self.db_connector:
-                raise SQLYExecutionError("Database type not specified for the executor.")
+                raise SQLYExecutionError(
+                    "Database type not specified for the executor."
+                )
 
             return self.db_connector.execute_query(parsed_query)
         except Exception as e: