MySQLdb简单查询
使用过Java的同行都知道,任何系统都离不开数据库,而我们常常又不得不使用mysql,自然少不了jdbc的参与。同样的道理使用Python的时候,同样的有一个驱动程序叫MySQLdb,不得不抱紧它。或许,你可以不使用任何存在的驱动程序,直接去用命令连接 mysql。但使用命令并非长久之计,而且需要部署项目的服务端必须安装mysql。这篇文章的目的就是用mysqldb实现简单的操作。
什么是MySQLdb
简单的说就是Python 连接 MySQL 的一个模块或者驱动程序,使用起来也很方便。如果你使用过其他语言,例如Java那么jdbc肯定再熟悉不过来了,mysqldb在Python中正是充当了一个类似于jdbc的角色。
怎么使用
数据库操作无非就是CRUD操作(Create,Retrieve,Update,Delete),即增删改查操作。更加大范围的讲也就是写和读两个操作。读数据一般比较简单,输入正常的sql语句即可。但写数据却不得不考虑事务。无论是读还是写,前提都是连连上数据库才可以操作,那么下面我们就从最基本的思路开始。
连接数据库
import MySQLdb connection = mdb.connect("127.0.0.1",3306, "root", "root","dbname")
这样便意味着连上了数据库。
执行sql 查询语句
import MySQLdb as mdb connection = mdb.connect("127.0.0.1",3306, "root", "root","test") cursor = connection.cursor() cursor.execute("select * from table") result = cursor.fetchall() cursor.close() connection.close()
此处注意cursor.close()这个方法的执行,如果在执行玩sql语句不执行这条语句进行关闭游标,也许你将会遇到下面的错误信息:
Commands out of sync; you can't run this command now
上面的查询查到的信息知识简单的输出结果,如果想要输出带有列的json格式数据还需要进一步处理,其实也谈不上处理,因为MySQLdb已经帮助我们想到了这点,仅仅需要在connection.cursor()中添加个参数mdb.cursors.DictCursor,如下:
import MySQLdb as mdb connection = mdb.connect("127.0.0.1",3306, "root", "root","test") cursor = connection.cursor(mdb.cursors.DictCursor) cursor.execute("select * from table") result = cursor.fetchall() cursor.close() connection.close()
执行写入语句
执行写入语句,便是insert,update,delete操作语句。至于为什么要把写入单独列出来,就是因为事务这个东西。如果你用上面的案例去执行写入语句,你将会发现,虽然执行显示成功了,但是数据库则没有发生任何变化,不妨试试下面的例子:
import MySQLdb as mdb connection = mdb.connect("127.0.0.1",3306, "root", "root","test") cursor = connection.cursor(mdb.cursors.DictCursor) cursor.execute("update table set field='xxx'") cursor.commit() cursor.close() connection.close()
到目前为止应该是没问题的,如果还是无法改变数据库的变化,那你只能去看看这篇文章了
其他操作
-
查看所有数据库
import MySQLdb as mdb connection = mdb.connect("127.0.0.1",3306, "root", "root") cursor = connection.cursor(mdb.cursors.DictCursor) cursor.execute("show databases") result = cursor.fetchall() cursor.close() connection.close()
-
查看库中的表格
注:不要使用use dbname;这样的语句,直接在connect()方法中传数据库名便可以了
import MySQLdb as mdb connection = mdb.connect("127.0.0.1",3306, "root", "root","test) cursor = connection.cursor(mdb.cursors.DictCursor) cursor.execute("show tables") result = cursor.fetchall() cursor.close() connection.close()
来自:http://my.oschina.net/crazyharry/blog/339700