pythonでMySQLに接続してSQLを実行する

pythonでMySQLに接続してSQL文を実行する方法。

import pymysql


def execute_sql(self, sql):
    my_conn = pymysql.connect(
        host='my_host_info',
        user='user_id',
        password='password',
        database='database_name',
        # MySQLのデフォルトポート
        # 変更している場合には変更したポート
        port=3306,
        charset='utf8',
        # セレクト結果をdictionary型で返す
        # 不要な場合には消去
        cursorclass=pymysql.cursors.DictCursor)
    # 一定時間操作がないとセッションが切れるのを防止
    my_conn.ping(reconnect=True)
    my_cur = my_conn.cursor()
    # SQLを実行
    my_cur.execute(sql)
    # 返値がある場合に格納
    r_value = my_cur.fetchall()
    my_conn.commit()
    my_conn.close()
    return r_value


if __name__ == '__main__':
    select_value = execute_sql("SELECT * FROM HOGE")