#!/usr/bin/env python # -*- coding:utf-8 -*- import pymysql import time # 建立链接 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='log') # 建立游标 设置光标用字典的格式获取 默认以元组的方式返还; cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) # 执行SQL,并返回收影响行数 # effect_row = cursor.execute("update log set age = '2'") # effect_row = cursor.execute("insert into log(name,age) values(%s,%s)",('rr',1)) # 执行储存过程 row = cursor.callproc('wrg',(1,2,3)) # 必须先获取下值才能获取 储存过程的返回值 cursor.fetchall() # 获取返回值的时候 _1 表示获取第一个索引 cursor.execute("select @wrg_1") result = cursor.fetchone() cursor.execute("delete from log where nid > 0") # 设置数据库自增的初始值 cursor.execute("alter table log AUTO_INCREMENT=1") for i in range(1,100): a = time.strftime('%Y-%m-%d-%H-%M-%S',time.localtime(time.time())) effect_row = cursor.execute("insert into log(user,pwd,tim) values(%s,%s,%s)",('alex'+str(i),i,a)) # 设置条件语句从大到小排序 effect_row = cursor.execute("select * from log where nid > 10 order by nid desc") # 查看光标获取的内容 # result = cursor.fetchall() # 获取第一条数据 result = cursor.fetchone() # 获取3个数据 result = cursor.fetchmany(3) # 以相对位置移动指针 result = cursor.scroll(-1,mode='relative') effect_row = cursor.execute("insert into log(user,pwd) values(%s,%s)",('alex','sd')) # 获取自增值 print(cursor.lastrowid) # 提交,否则没法保存新建或者修改的数据 conn.commit() # 关闭游标 cursor.close() # 关闭链接 conn.close()