python搭配什么数据库_python 连接操作数据库(一)

一、下面我们所说的就是连接mysql的应用：

1、其实在python中连接操作mysql的模块有多个，在这里我只给大家演示pymysql这一个模块（其实我是感觉它比较好用而已）：

pymysql是第三方的一个模块，需要我们自己安装，在这里顺便给大家普及一下安装第三方模块的知识；首先，如果我们在windows上安装的话，需要先安装python解释器，然后里面自带

了pip模块（我们安装第三方模块，都是需要这个命令去安装的），配置完环境变量之后我们就可以直接在cmd命令行中执行要安装的模块了，如下：

我这里是已经安装过的，所以提示让我更新，在你安装过pymysql模块之后，就可以直接去调用了，下面我们来看一个小例子，根据这个小例子来进行说明：

1 importpymysql2

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')

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')

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

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的实现机制，内部封装了些什么：