python操作mysql的方式都是通过模块的形式:
原生的:pymsql
ORM框架 SQLAchemy
pymysql模块
pymsql 是python中的mysql模块,要想使用这个模块,就需要先安装,安装步骤如下:
pip3 install pymysql
或者
easy_install pymysql
AI 代码解读
pymysql的使用
使用步骤:
1、导入模块
2、创建连接
3、创建拿去数据的游标(手)
4、执行sql,并返回受影响的行数
5、关闭游标(拿回手)
6、关闭连接
代码如下:
#导入模块
import pymysql
#创建连接
conn = pymysql.connect(host='localhost',port=3306,user='kk',passwd='123',db='pysqltest')
#创建游标
course = conn.cursor()
#执行sql
插入表
row1 = course.execute("create table t1(id int auto_increment PRIMARY KEY ,name VARCHAR (32) not NULL )")
插入多天数据用executemany这个函数,后面用列表
# row2 = course.executemany("insert into t1 (name) VALUES (%s)",[("kk"),("gg")])
更新表,这个会把name一列全部修改为www
# row3 = course.execute("update t1 set name='www'")
条件修改,只把后面的id=1的修改
row4 = course.execute("update t1 set name='ee' WHERE id = %s",1)
#提交到数据库
conn.commit()
#关闭游标
course.close()
#关闭数据库连接
conn.close()
AI 代码解读
结果:
获取自己增ID
这个就是数据库表里面的auto_increment的最后一个值,我们在数据库中可以通过alter 表名+set auto_increment_increment=xx来设置,这里我们通过pymysql怎么获取这个值那?
# 获取最新自增ID,把这个写到py文件里面,就可以获得当前操作后得到的id值
new_id = cursor.lastrowid
AI 代码解读
获取数据
pymysql是通过游标来拿去数据,可以一条一条的拿 也可以一次全部都拿回来
import pymysql
conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='123', db='t1')
cursor = conn.cursor()
cursor.execute("select * from hosts")
# 获取第一行数据
row_1 = cursor.fetchone()
# 获取前n行数据
# row_2 = cursor.fetchmany(3)
# 获取所有数据
# row_3 = cursor.fetchall()
conn.commit()
cursor.close()
conn.close()
AI 代码解读
在fetch数据时按照顺序进行,可以使用cursor.scroll(num,mode)来移动游标位置,如:
cursor.scroll(1,mode='relative') # 相对当前位置移动
cursor.scroll(2,mode='absolute') # 相对绝对位置移动
fetch默认得到的值是元祖的数据,要想得到字典的数据,要在建立游标的时候指定:
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
本文转自 kesungang 51CTO博客,原文链接:http://blog.51cto.com/sgk2011/2052364,如需转载请自行联系原作者