MySQLdb简单查询

水深无声 2024-04-08 12:12 45阅读 0赞

## 什么是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()

到目前为止应该是没问题的，如果还是无法改变数据库的变化，那你只能去看看 [ 这篇文章 ][Link 1] 了

### 其他操作 ###

*  查看所有数据库

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

[Link 1]: http://my.oschina.net/crazyharry/blog/338468