Python Mysql数据库操作，sql文件操作 - M-zone - ITeye博客
博客分类：
近来在看python，于是，将某个shell实现过的功能用python实现下
1 python 操作mysql 需要有 MySQLdb 这个库的支持，一般需要单独安装
2 MySQLdb库只能执行sql语句，对于sql文件执行，比较麻烦，所以用了subprocess库的方法Popen
import MySQLdb
from subprocess import Popen,PIPE
sqlta = "/usr/local/webserver/scripts/ta.sql"
sqlclita = "/usr/local/webserver/scripts/clita.sql"
Platform = raw_input('Please Enter Platform:')
Server = raw_input('Please Enter Server:')
LogTa = "LogTa_"+Platform+"_"+Server
LogCliTa = "LogCliTa_"+Platform+"_"+Server
host = "192.168.0.1"
usr = "admin"
passwd = "admin8SQBL"
port = 3303
conn = MySQLdb.connect(host=host,user=usr,passwd=passwd,port=port)
cur = conn.cursor()
cur.execute('create database IF NOT EXISTS '+LogTa)
cur.execute('create database IF NOT EXISTS '+LogCliTa)
cur.close()
conn.close()
except MySQLdb.Error,e:
print "Mysql Error %d: %s" % (e.args[0], e.args[1])
process = Popen('/usr/local/webserver/mysql/bin/mysql -h%s -P%s -u%s -p%s %s'
%(host, port, usr, passwd, LogTa), stdout=PIPE, stdin=PIPE, shell=True)
output = municate('source '+sqlta)
process = Popen('/usr/local/webserver/mysql/bin/mysql -h%s -P%s -u%s -p%s %s'
%(host, port, usr, passwd, LogCliTa), stdout=PIPE, stdin=PIPE, shell=True)
output = municate('source '+sqlclita)
相当于用MySQLdb库创建了数据库，然后用Popen，进行sql文件的执行操作。Popen（）函数相当于用shell来执行..
alfred_long
浏览: 370901 次
来自: 北京
看了很多篇博主的帖子，最近注册了之后才可以发表评论。不知道博主 ...
写的很好，解决了我的问题，thinks very much
太牛逼了，不过那个ctags的我没安装成功，步骤不是很详细
ygqwan 写道Failed opening control ...
从入门到精通，不错。跟老齐学Python之使用Python操作数据库（1）
投稿：hebedich
字体：[ ] 类型：转载 时间：
本文详细讲述了使用python操作数据库所需要了解的知识以及准备工作，十分的详尽，这里推荐给想学习python的小伙伴。
在上一讲中已经连接了数据库。就数据库而言，连接之后就要对其操作。但是，目前那个名字叫做qiwsirtest的数据仅仅是空架子，没有什么可操作的，要操作它，就必须在里面建立“表”，什么是数据库的表呢？下面摘抄字维基百科对数据库表的简要解释，要想详细了解，需要看官在找一些有关数据库的教程和书籍来看看。
在关系数据库中，数据库表是一系列二维数组的集合，用来代表和储存数据对象之间的关系。它由纵向的列和横向的行组成，例如一个有关作者信息的名为 authors 的表中，每个列包含的是所有作者的某个特定类型的信息，比如“姓氏”，而每行则包含了某个特定作者的所有信息：姓、名、住址等等。
对于特定的数据库表，列的数目一般事先固定，各列之间可以由列名来识别。而行的数目可以随时、动态变化，每行通常都可以根据某个（或某几个）列中的数据来识别，称为候选键。
我打算在qiwsirtest中建立一个存储用户名、用户密码、用户邮箱的表，其结构用二维表格表现如下：
username&password&email
qiwsir&123123&
特别说明，这里为了简化细节，突出重点，对密码不加密，直接明文保存，虽然这种方式是很不安全的。但是，有不少网站还都这么做的，这么做的目的是比较可恶的。就让我在这里，仅仅在这里可恶一次。
建数据库表并插入数据
为了在数据库中建立这个表，需要进入到mysql&交互模式中操作。道理在于，如果qiwsirtest这个屋子里面没有类似家具的各种数据库表，即使进了屋子也没有什么好操作的东西，因此需要先到mysql&模式下在屋子里面摆家具。
进入数据库交互模式：
mysql -u root -p
Enter password:
调用已经建立的数据库：qiwsirtest
Database changed
Empty set (0.00 sec)
用show tables命令显示这个数据库中是否有数据表了。查询结果显示为空。
下面就用如下命令建立一个数据表，这个数据表的内容就是上面所说明的。
mysql& create table users(id int(2) not null primary key auto_increment,username varchar(40),password text,email text)default charset=utf8;
Query OK, 0 rows affected (0.12 sec)
建立的这个数据表名称是：users，其中包含上述字段，可以用下面的方式看一看这个数据表的结构。
+----------------------+
| Tables_in_qiwsirtest |
+----------------------+
| users&&&&&&&&&&&&&&& |
+----------------------+
1 row in set (0.00 sec)
查询显示，在qiwsirtest这个数据库中，已经有一个表，它的名字是：users。
+----------+-------------+------+-----+---------+----------------+
| Field&&& | Type&&&&&&& | Null | Key | Default | Extra&&&&&&&&& |
+----------+-------------+------+-----+---------+----------------+
| id&&&&&& | int(2)&&&&& | NO&& | PRI | NULL&&& | auto_increment |
| username | varchar(40) | YES& |&&&& | NULL&&& |&&&&&&&&&&&&&&& |
| password | text&&&&&&& | YES& |&&&& | NULL&&& |&&&&&&&&&&&&&&& |
| email&&& | text&&&&&&& | YES& |&&&& | NULL&&& |&&&&&&&&&&&&&&& |
+----------+-------------+------+-----+---------+----------------+
4 rows in set (0.00 sec)
显示表users的结构：
id：每增加一个用户，id号自动增加一个。
username：存储用户名，类型是varchar(40)
password：存储用户密码，类型是text
email：存储用户的邮箱，类型是text
特别提醒：在这里，我没有对每个字段做注入不得为空等设置，在真正的开发中，或许必须让username和password不得为空。
这个结构和上面所期望的结构是一样的，只不过这个表中还没有任何数据，是一个空表。可以查询一下看看：
mysql& select *
Empty set (0.01 sec)
目前表是空的，为了能够在后面用python操作这个数据表，需要向里面插入点信息，就只插入一条吧。
mysql& insert into users(username,password,email) values("qiwsir","123123","");
Query OK, 1 row affected (0.05 sec)
mysql& select *
+----+----------+----------+------------------+
| id | username | password | email&&&&&&&&&&& |
+----+----------+----------+------------------+
|& 1 | qiwsir&& | 123123&& |
+----+----------+----------+------------------+
1 row in set (0.00 sec)
到目前为止，在mysql&中的工作已经完成了，接下来就是用python操作了。
python操作数据库
要对数据库进行操作，需要先连接它。上一讲看官连接过了，但是，随后你关闭了python的交互模式，所以还要从新连接。这也是交互模式的缺点。不过在这里操作直观，所以暂且忍受一下，后面就会讲解如何在程序中自动完成了。
&&& import MySQLdb
&&& conn = MySQLdb.connect(host="localhost",user="root",passwd="123123",db="qiwsirtest",charset="utf8")
完成连接的过程，其实是建立了一个MySQLdb.connect()的实例对象conn，那么这个对象有哪些属性呢？
commit():如果数据库表进行了修改，提交保存当前的数据。当然，如果此用户没有权限就作罢了，什么也不会发生。
rollback():如果有权限，就取消当前的操作，否则报错。
cursor([cursorclass]):游标指针。下面详解。
连接成功之后，开始操作。注意：MySQLdb用游标（指针）cursor的方式操作数据库，就是这样：
&&& cur = conn.cursor()
因该模块底层其实是调用CAPI的，所以，需要先得到当前指向数据库的指针。这也就提醒我们，在操作数据库的时候，指针会移动，如果移动到数据库最后一条了，再查，就查不出什么来了。看后面的例子就明白了。
下面用cursor()提供的方法来进行操作，方法主要是:
cursor执行命令的方法:
execute(query, args):执行单条sql语句。query为sql语句本身，args为参数值的列表。执行后返回值为受影响的行数。
executemany(query, args):执行单条sql语句,但是重复执行参数列表里的参数,返回值为受影响的行数
例如，要在数据表users中插入一条记录，使得:username="python",password="123456",email=""，这样做：
&&& cur.execute("insert into users (username,password,email) values (%s,%s,%s)",("python","123456",""))
没有报错，并且返回一个"1L"结果，说明有一行记录操作成功。不妨用"mysql&"交互方式查看一下：
mysql& select *
+----+----------+----------+------------------+
| id | username | password | email&&&&&&&&&&& |
+----+----------+----------+------------------+
|& 1 | qiwsir&& | 123123&& |
+----+----------+----------+------------------+
1 row in set (0.00 sec)
咦，奇怪呀。怎么没有看到增加的那一条呢？哪里错了？可是上面也没有报错呀。
在这里，特别请列位看官注意，通过"cur.execute()"对数据库进行操作之后，没有报错，完全正确，但是不等于数据就已经提交到数据库中了，还必须要用到"MySQLdb.connect"的一个属性：commit()，将数据提交上去，也就是进行了"cur.execute()"操作，要将数据提交，必须执行：
在到"mysql&"中运行"select * from users"试一试：
mysql& select *
+----+----------+----------+------------------+
| id | username | password | email&&&&&&&&&&& |
+----+----------+----------+------------------+
|& 1 | qiwsir&& | 123123&& |
|& 2 | python&& | 123456&& |
+----+----------+----------+------------------+
2 rows in set (0.00 sec)
good，very good。果然如此。这就如同编写一个文本一样，将文字写到文本上，并不等于文字已经保留在文本文件中了，必须执行"CTRL-S"才能保存。也就是在通过python操作数据库的时候，以"execute()"执行各种sql语句之后，要让已经执行的效果保存，必须运行"commit()"，还要提醒，这个属性是"MySQLdb.connect()"实例的。
再尝试一下插入多条的那个命令"executemany(query,args)".
&&& cur.executemany("insert into users (username,password,email) values (%s,%s,%s)",(("google","111222","")))
到"mysql&"里面看结果：
mysql& select *
+----+----------+----------+------------------+
| id | username | password | email&&&&&&&&&&& |
+----+----------+----------+------------------+
|& 1 | qiwsir&& | 123123&& |
|& 2 | python&& | 123456&& |
|& 3 | google&& | 111222&& | &&&&& |
|& 4 | facebook | 222333&& | &&&&& |
|& 5 | github&& | 333444&& | &&&&& |
|& 6 | docker&& | 444555&& | &&&&& |
+----+----------+----------+------------------+
6 rows in set (0.00 sec)
成功插入了多条记录。特别请列位注意的是，在"executemany(query,args)"中，query还是一条sql语句，但是args这时候是一个tuple，这个tuple里面的元素也是tuple，每个tuple分别对应sql语句中的字段列表。这句话其实被执行多次。只不过执行过程不显示给我们看罢了。
已经会插入了，然后就可以有更多动作。且看下一讲吧。
您可能感兴趣的文章:
大家感兴趣的内容
12345678910
最近更新的内容
常用在线小工具python-sqlparse & python-sqlparse 0.2.4.dev0 documentationPython 的数据库操作_百度文库
两大类热门资源免费畅读
续费一年阅读会员，立省24元！
Python 的数据库操作
上传于|0|0|文档简介
&&很好的资料!值得一看!
阅读已结束，如果下载本文需要使用2下载券
想免费下载本文？
定制HR最喜欢的简历
下载文档到电脑，查找使用更方便
还剩3页未读，继续阅读
定制HR最喜欢的简历
你可能喜欢