python连接mysql

python连接mysql的例子。

mysql不使用默认端口号时，修改db_port为mysql的端口。

import pymysql


db_port = 3306
db_charset = 'utf8'
db_name = 'testdb'
db_host = '127.0.0.1'
db_user_name = 'flame'
db_user_pwd = 'flame999'


cx = pymysql.connect(host=db_host, user=db_user_name, password=db_user_pwd, database=db_name, charset=db_charset, port=db_port)


# execute sql
def execute_sql(sql, args=None):
    cu = cx.cursor()
    try:
        ret = cu.execute(sql, args)
        cx.commit()
    except Exception as e:
        print(sql)
        raise e
        return False, 0
    finally:
        cu.close()
        return False, 0
    return True, ret


# execute sql
def execute_fetchall(sql, args=None):
    cu = cx.cursor()
    record_set = []
    if cu.execute(sql, args):
        record_set = cu.fetchall()
    cu.close()
    return record_set


# execute sql
def execute_fetchone(sql, args=None):
    cu = cx.cursor()
    record_set = []
    if cu.execute(sql, args):
        record_set = cu.fetchone()
    cu.close()
    return record_set

execute_sql("select * from table")
execute_fetchall("select * from table")
execute_fetchone("select * from table")

cx.close()