Python pymysql模块

import pymysql

def mysql(host,port,user,pwd,database,sql,arguments=None,charset='utf8'):
    conn = 
login_mysql = {
    'host':'127.0.0.1',
    'port': 3306,
    'user':'root',
    'pwd':'123456',
    'database':'flask_test'
}

pymysql.Connect(host=host,port=port,user=user,password=pwd,database=database,charset=charset)    # 连接数据库
    cursor = conn.cursor()                                                                                  # 获取游标
    # 游标将数据库返回的结果集逐条获取后汇总返回。
    # 游标每次只能在结果集中提取一条记录,
    # 游标由结果集和结果集中指向特定记录的游标位置组成。
    # 结果集中的数据,可根据游标位置逐一操作。


    if arguments:
        v = cursor.execute(sql,arguments)                                                                   # v = 返回得到受影响的行数,并且已经得到的数据
    else:
        v = cursor.execute(sql)
    result = cursor.fetchall()                                                                              # fetchall()取出数据库操作返回的结果
    # result = cursor.fetchone()                                                                              # fetchall()取出数据库操作返回的结果,只取一条,第二次取得下一条数据
    # result = cursor.fetchmany(2)                                                                            # fetchall()取出数据库操作返回的结果,指定取得几条
    conn.commit()                                                                                           # 查询不需要commit,其他需要
    cursor.close()                                                                                          # 关闭游标
    conn.close()                                                                                            # 关闭连接
    return result

sql = "insert into customer(name,age,gender) values('%s','%s','%s');" %(name,age,gender)
mysql(**login_mysql,sql=sql)
原文地址:https://www.cnblogs.com/yunweixiaoxuesheng/p/8406104.html