MySQLdb简单查询

jopen 5年前

使用过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