一、下面我们所说的就是连接mysql的应用:
1、其实在python中连接操作mysql的模块有多个,在这里我只给大家演示pymysql这一个模块(其实我是感觉它比较好用而已):
pymysql是第三方的一个模块,需要我们自己安装,在这里顺便给大家普及一下安装第三方模块的知识;首先,如果我们在windows上安装的话,需要先安装python解释器,然后里面自带
了pip模块(我们安装第三方模块,都是需要这个命令去安装的),配置完环境变量之后我们就可以直接在dos命令行中执行要安装的模块了,如下:
我这里是已经安装过的,所以提示让我更新,在你安装过pymysql模块之后,就可以直接去调用了,下面我们来看一个小例子,根据这个小例子来进行说明:
1 import pymysql 2 3 #链接数据库,并创建游标 4 conn = pymysql.connect(host=‘192.168.163.131‘,port=3306,user=‘mysql_test‘,passwd=‘123456‘,db=‘pymysql‘) 5 cur = conn.cursor() 6 7 # cur.execute(‘create table t1(id INT(10),name VARCHAR(20))ENGINE=InnoDB DEFAULT CHARSET=utf8‘) 8 9 # cur.execute(‘insert into t1(id,name) VALUES (1001,"madaqiang")‘) 10 count = cur.executemany(‘insert into t1(id,name ) VALUES (%s,%s)‘,[(1002,‘eric‘),(1003,‘tom‘)]) 11 12 conn.commit() 13 14 cur.close() 15 conn.close()
解释说明:
首先使用pymysql的connect方法去连接数据库,里面的参数我相信大家都能看懂,那个cur是创建的一个游标(执行sql,都是使用这个游标去执行的);下面就开始执行sql语句
注释的那两行,分别是创建一个t1表,然后往里面插入一条数据,下面那个executemany是可以一次插入多条记录,每个记录是一个元祖,count是受影响的行数;最后你需要执行
commit()方法,不然,你做的这些都是白费的,然后把游标和连接都关闭。
简单的连接就是这样的简单。下面我们再来看看游标的问题,相信很多的人一开始的时候跟我一样,对这个游标理解不是那么准确,下面我们来两段代码,你就明白了:
1 conn = pymysql.connect(host=‘192.168.163.131‘,port=3306,user=‘mysql_test‘,passwd=‘123456‘,db=‘pymysql‘) 2 cur = conn.cursor() 3 cur.execute(‘select * from t1‘) 4 5 # cur.scroll(1,mode=‘relative‘) 6 7 #取出第一条数据 8 line = cur.fetchone() 9 print(line) 10 #取出所有的数据 11 all_line = cur.fetchall() 12 print(all_line) 13 conn.commit() 14 15 cur.close() 16 conn.close()
首先我们先来看这段代码,其中新增的两条已经在代码中标注了,就是取出第一条数据和所有的数据,但是我们看下面的输出结果,你就会发现一些问题了:
1 (1001, ‘madaqiang‘) 2 ((1002, ‘eric‘), (1003, ‘tom‘))
在你输出第一条数据之后,游标就游到了第二条数据上,你再输出所有的数据,其实就是从第二行开始输出的;如果你不想输出1002这条记录,你可以在第九行的下面加一条这样的语句:
cur.scroll(1,mode=‘relative‘),这样就不会输出了,如果你感觉输出的元祖,以后调用的话会比较麻烦,我们可以设置成输出格式为字典的格式,这样不管是看还是调用都比较方便了:
其实我们只需要在创建游标的下面加上cur = conn.cursor(cursor=pymysql.cursors.DictCursor),这样一行代码就OK了,还是输出一下结果吧,不然总感觉少点什么:
1 #链接数据库,并创建游标 2 conn = pymysql.connect(host=‘192.168.163.131‘,port=3306,user=‘mysql_test‘,passwd=‘123456‘,db=‘pymysql‘) 3 cur = conn.cursor() 4 #把输出的格式转换成 5 cur = conn.cursor(cursor=pymysql.cursors.DictCursor) 6 7 cur.execute(‘select * from t1‘) 8 9 10 #取出第一条数据 11 line = cur.fetchone() 12 print(line) 13 14 conn.commit() 15 16 cur.close() 17 conn.close(=====================输出结果======================={‘name‘: ‘madaqiang‘, ‘id‘: 1001}
2、下面我们再来看看一个ORM框架(SQLAlchemy),
SQLAlchemy是Python世界中最广泛使用的ORM工具之一,它采用了类似与Java里Hibernate的数据映射模型,而不是其他ORM框架采用的Active Record模型,SQLAlchemy分为两部分,一个是常用的ORM对象映射,另一个是核心的SQL expression。第一个很好理解,纯粹的ORM,后面这个不是ORM,而是DBAPI的封装,通过一些sql表达式来避免了直接写sql语句。简单的概括一下就是:将对象转换成SQL,然后使用数据API执行SQL并获取执行结果。
下面来一下看一下SQLAlchemy的ORM的实现机制,内部封装了些什么:
上图中的Dialect用于和数据API进行交流,根据配置文件的不同调用不同的数据库API,从而实现对数据库的操作,如:
mysql
+
pymysql:
/
/
<username>:<password>@<host>
/
<dbname>[?<options>]