PyMysql 模块

#!/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()

  

原文地址:https://www.cnblogs.com/cloniu/p/6397559.html