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()

MySQL中pymysql的具体操作

标签：sql语句   def   mys   exec   获取   result   host   元组   ret