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)