# import mysql.connector
import pymysql
from config import rds
from fw import log

#SQLを実行する
def executeSQL(sql,params=(),commit=False):
    #dbに接続する
    conn = pymysql.connect(
            host=rds.db_host,
            db=rds.db_name,
            user=rds.db_user,
            password=rds.db_pass,
            port=3306,
            cursorclass=pymysql.cursors.DictCursor,
            charset='utf8mb4'
    )

    #カーソルを取得する
    cursor = conn.cursor()
        
    #sqlを実行する
    log.d(sql)
    cursor.execute(sql,params)
    if (commit):
        conn.commit()
        result = True
    else:
        #カーソルからデータを取る
        result = cursor.fetchall()
    #dbを閉じる
    cursor.close()
    conn.close()
        
    return result