python MySQLdb安装和使用

MySQLdb是Python连接MySQL的模块，下面介绍一下源码方式安装MySQLdb：

1. 首先要下载下载：请到官方网站http://sourceforge.net/projects/mysql-python/或者点击链接下载http://downloads.sourceforge.net/project/mysql-python/mysql-python-test/1.2.3c1/MySQL-python-1.2.3c1.tar.gz?use_mirror=nchc

2. 解压：tar zxvf MySQL-python*

3. 进入文件目录，运行以下命令：
   python setup.py install 

4. 安装完成，到你的python安装目录下的site-packages目录里检查以下文件是否存在，如果存在即代表安装成功了
   Linux：MySQL_python-1.2.3c1-py2.6-linux-i686.egg
   Mac OS X：MySQL_python-1.2.3c1-py2.6-macosx-10.4-x86_64.egg
   注：如果碰到mysql_config not found的问题，有两种方法解决：
   1）ln -s /usr/local/mysql/bin/mysql_config /usr/local/bin/mysql_config
   将mysql_confi从你的安装目录链接到/usr/local/bin目录下，这样就可以在任意目录下访问了（也可以放到/usr/bin）
   2）编辑源码文件夹的site.cfg文件，去掉#mysql_config = /usr/local/bin/mysql_config前的注释＃，修改后面的路径为你的mysql_config真正的目录就可以了。（如果不知道mysql_config在哪里，运行命令：whereis mysql_config）

    注:如果碰到import error: libmysqlclient.so.18: cannot open shared object file: No such file or directory

     解决方法: locate or find libmysqlclient.so.18

     link path/libmysqlclient.so.18 /usr/lib/libmysqlclient.so.18

     vi /etc/ld.so.conf    //加入libmysqlclient.so.18 所在的目录

     插入: /usr/lib/

     保存退出后执行/sbin/ldconfig生效

 

1. 测试方法
   1）运行命令python进入python运行环境
   2）输入以下python代码进行测试
   import MySQLdb

2. test=MySQLdb.connect(db='mydb',host='myhost',user='u',passwd='p')

3. cur = test.cursor()

4. cur.execute('show databases;')

5. for data in cur.fetchall():

6.     print data

7. 3）如果你在屏幕上看到了你几个数据库的库名的输出代表你安装成功了

8. 可能碰到的问题
   1）问题：ImportError: libmysqlclient_r.so.16: cannot open shared object file: No such file or directory
   原因是python无法找到mysql目录下的libmysqlclient_r.so.16动态库,其实MySQLdb是调用mysql的c函数库.所以本机上首先得安装了mysql
   然后: export LD_LIBRARY_PATH=/usr/local/mysql/lib/mysql:$LD_LIBRARY_PATH
   并且将/usr/local/mysql5.1/lib/mysql 放入/etc/ld.so.conf中
   /etc/ld.so.conf改后内容为：
   include ld.so.conf.d/*.conf
   /usr/local/mysql5.1/lib/mysql
   最后重新再测试一下，就不会有上面的问题了

MySQLdb操作:

Python代码

1. #!/usr/bin/env python

2. #coding=utf-8

3. ###################################

4. #MySQLdb 示例

5. #

6. ##################################

7. import MySQLdb

9. #建立和数据库系统的连接

10. conn = MySQLdb.connect(host='localhost', user='root',passwd='longforfreedom')

12. #获取操作游标

13. cursor = conn.cursor()

14. #执行SQL,创建一个数据库.

15. cursor.execute("""create database python """)

17. #关闭连接，释放资源

18. cursor.close();

#!/usr/bin/env python

#coding=utf-8

##################################

#MySQLdb 示例 #

##################################

import MySQLdb

#建立和数据库系统的连接

conn = MySQLdb.connect(host='localhost', user='root',passwd='longforfreedom')

#获取操作游标

cursor = conn.cursor()

#执行SQL,创建一个数据库.

cursor.execute("""create database python """)

#关闭连接，释放资源

cursor.close();

创建数据库，创建表，插入数据，插入多条数据

Python代码:

1. #!/usr/bin/env python

2. #coding=utf-8

3. ###################################

4. #MySQLdb 示例

5. #

6. ##################################

7. import MySQLdb

9. #建立和数据库系统的连接

10. conn = MySQLdb.connect(host='localhost', user='root',passwd='longforfreedom')

12. #获取操作游标

13. cursor = conn.cursor()

14. #执行SQL,创建一个数据库.

15. cursor.execute("""create database if not exists python""")

17. #选择数据库

18. conn.select_db('python');

19. #执行SQL,创建一个数据表.

20. cursor.execute("""create table test(id int, info varchar(100)) """)

22. value = [1,"inserted ?"];

24. #插入一条记录

25. cursor.execute("insert into test values(%s,%s)",value);

27. values=[]

30. #生成插入参数值

31. for i in range(20):

32. values.append((i,'Hello mysqldb, I am recoder ' + str(i)))

33. #插入多条记录

35. cursor.executemany("""insert into test values(%s,%s) """,values);

37. #关闭连接，释放资源

38. cursor.close();

#!/usr/bin/env python

#coding=utf-8

###################################

#MySQLdb 示例 #

##################################

import MySQLdb

#建立和数据库系统的连接

conn = MySQLdb.connect(host='localhost', user='root',passwd='longforfreedom')

#获取操作游标

cursor = conn.cursor()

#执行SQL,创建一个数据库.

cursor.execute("""create database if not exists python""")

#选择数据库

conn.select_db('python');

#执行SQL,创建一个数据表.

cursor.execute("""create table test(id int, info varchar(100)) """)

value = [1,"inserted ?"];

#插入一条记录

cursor.execute("insert into test values(%s,%s)",value);

values=[]

#生成插入参数值

for i in range(20):

    values.append((i,'Hello mysqldb, I am recoder ' + str(i)));      

    #插入多条记录

    cursor.executemany("""insert into test values(%s,%s) """,values);

    #关闭连接，释放资源

    cursor.close();

查询和插入的流程差不多，只是多了一个得到查询结果的步骤

Python代码:

1. #!/usr/bin/env python

2. #coding=utf-8

3. #

4. # MySQLdb 查询

5. #

6. #######################################

8. import MySQLdb

9. conn = MySQLdb.connect(host='localhost', user='root', passwd='longforfreedom',db='python')

11. cursor = conn.cursor()

12. count = cursor.execute('select * from test')

14. print '总共有 %s 条记录',count

15. #获取一条记录,每条记录做为一个元组返回

16. print "只获取一条记录:"

17. result = cursor.fetchone();

18. print result

19. #print 'ID: %s info: %s' % (result[0],result[1])

20. print 'ID: %s info: %s' % result

22. #获取5条记录，注意由于之前执行有了fetchone()，所以游标已经指到第二条记录了，也就是从第二条开始的所有记录

23. print "只获取5条记录:"

24. results = cursor.fetchmany(5)

25. for r in results:

26. print r

28. print "获取所有结果:"

29. #重置游标位置，0,为偏移量，mode＝absolute | relative,默认为relative,

30. cursor.scroll(0,mode='absolute')

31. #获取所有结果

32. results = cursor.fetchall()

33. for r in results:

34. print r

35. conn.close()

默认mysqldb返回的是元组，这样对使用者不太友好，也不利于维护
下面是解决方法

1. import MySQLdb

2. import MySQLdb.cursors

4. conn = MySQLdb.Connect (

5. host = 'localhost', user = 'root' ,

6. passwd = '', db = 'test', compress = 1,

7. cursorclass = MySQLdb.cursors.DictCursor, charset='utf8') // <- important

9. cursor = conn.cursor()

10. cursor.execute ("SELECT name, txt FROM table")

11. rows = cursor.fetchall()

12. cursor.close()

13. conn.close()

15. for row in rows:

16.     print row ['name'], row ['txt'] # bingo!

1. # another (even better) way is:

3. conn = MySQLdb . Connect (

4. host = ' localhost ', user = 'root' ,

5. passwd = '', db = 'test' , compress = 1)

6. cursor = conn.cursor (cursorclass = MySQLdb.cursors.DictCursor)

7. # ...

8. # results by field name

9. cursor = conn.cursor()

10. # ...

11. # ...results by field number