MySQL中pymysql的具体操作

##1、导入pymysql包

 import pymysql

##2、创建连接对象

 pymysql.connect(参数列表)

##3、获取游标对象

 cursor =conn.cursor()

##4、执行SQL语句

 row_count = cursor.execute(sql)

##5、获取查询结果集

 result = cursor.fetchall()

##6、将修改操作提交到数据库

 conn.commit()

##7、回滚数据

 conn.rollback()

##8、关闭游标

 cursor.close()

##9、关闭连接

 conn.close()

---

def get_conn():
    """
    :return: 连接，游标
    """
    #创建连接
    conn = pymysql.connect(host ="127.*.*.*",
                       user ="**",
                       password ="123456",
                       db ="**",
                       charset ="utf8")
    #创建游标，默认是元组类型
    cursor = conn.cursor() # 执行完毕返回结果集默认以元组显示
    return conn,cursor

def close_conn(conn,cursor):
    if cursor:
        cursor.close()
    if conn:
        conn.close()
-------------------------------
conn,cursor= get_conn()
conn.rollback()
conn.commit()