"""Mysql connector module."""
from lambdacommon.util import mysql_connection


def execute_mysql_query(
        logger, host: str, db_name: str, user: str, password: str,
        query: str, query_args: tuple) -> list:
    """Run a query on the RDS DB."""
    # RDS db connection
    connection_info = {
        'host': host,
        'database': db_name,
        'user': user,
        'password': password,
    }

    with mysql_connection(**connection_info) as rds_conn:
        with rds_conn.cursor() as cursor:
            cursor.execute(
                query,
                args=query_args
            )

            rows = cursor.fetchall()
            logger.info(
                f'Ran query: {query} with args: {query_args} '
                f'and got the result: {rows}')

            return rows