Pymysql之Cursor常用API

Cursor常用API

1、cursor.execute(query, args=None)：执行sql语句。

参数:    

query (str)：sql语句。

args (tuple, list or dict)：sql语句中如果有变量，或者格式化输出，会在这里填充数据。

Returns：返回一个int值，表示sql语句影响到的行数。

下面演示插入数据的四种方式：

import pymysql.cursors # 连接数据库 connect = pymysql.connect(     host='127.0.0.1',     user='root',     password='123',     db='demo_temp',     charset='utf8',     cursorclass=pymysql.cursors.DictCursor ) with connect.cursor() as cursor:   # 创建游标     # 第一种方式向表中插入数据     sql = """         INSERT INTO users (user,passwd) VALUES ('123','123')         """     cursor.execute(sql)     # 第二种方式向表中插入数据     sql = """            INSERT INTO users (user,passwd) VALUES (%s,%s)            """     cursor.execute(sql,['456','456'])     # 第三种方式向表中插入数据     sql = """                INSERT INTO users (user,passwd) VALUES (%s,%s)                """     cursor.execute(sql, ('789', '789'))     # 第四种方式向表中插入数据     sql = """                INSERT INTO users (user,passwd) VALUES (%(a)s,%(b)s)                  """     cursor.execute(sql, {'a':'abc','b':'123'})  # 这里的'a'和'b'要和上面VALUES中对应     connect.commit()  # 插入数据后必须更新     # 查询数据     sql = """         select * from users         """     cursor.execute(sql)     ret = cursor.fetchall()  # 提取查询数据     print(ret) connect.close()   # 关闭数据库连接

2、cursor.executemany(query, args)：可以执行多条sql语句。

参数:    

query ：sql语句

args：可迭代对象

Returns：返回sql语句影响到的行数。

下面是方法实例：

import pymysql.cursors # 连接数据库 connect = pymysql.connect(     host='127.0.0.1',     user='root',     password='123',     db='demo_temp',     charset='utf8',     cursorclass=pymysql.cursors.DictCursor ) with connect.cursor() as cursor:   # 创建游标     # 插入多条数据     sql = """                INSERT INTO users (user,passwd) VALUES (%s,%s)                  """     ret_row = cursor.executemany(sql,[['a','123'],['b','234'],['c','456']])  # 在args中传入一个可迭代对象。     connect.commit()  # 插入数据后必须更新     print(f'当前受影响了{ret_row}行')     # 查询数据     sql = """         select * from users         """     cursor.execute(sql)     ret = cursor.fetchall()  # 提取查询数据     print(ret) connect.close()   # 关闭数据库连接

3、cursor.fetchone()：从查询语句中获取一条查询结果。

4、cursor.fetchall()：获取所有查询到的结果。

5、cursor.fetchmany(size)：根据size获取相应的行数。

6、cursor.mogrify(query, args=None)：返回执行的sql语句，下面是示例：

import pymysql.cursors # 连接数据库 connect = pymysql.connect(     host='127.0.0.1',     user='root',     password='123',     db='demo_temp',     charset='utf8',     cursorclass=pymysql.cursors.DictCursor ) with connect.cursor() as cursor:   # 创建游标     sql = """         select * from users         """     cursor.execute(sql)     ret_sql = cursor.mogrify(sql)   # 返回执行的sql语句     cursor.fetchmany(2)             # 提取查询数据     print(ret_sql) connect.close()   # 关闭数据库连接

7、cursor.close()：关闭游标，关闭游标后，游标内所有数据将被清空。