操作MYSQL数据库，使用 MySQLdb 库

1、setuptools

下载:

wget http://pypi.python.org/packages/source/s/setuptools/setuptools-0.6c8.tar.gz --no-check-certificate

安装:

tar zxvf setuptools-0.6c8.tar.gz && cd setuptools-0.6c8 && python setup.py build && python setup.py install

 

2、python-dev

如果没有安装 python 源代码，会报找不到 Python.h 的头文件错误，安装方法：

yum install python-devel

 

 

3、mysql_config

apt-get install libmysqlclient-dev

 

4、MySQLdb

下载：

http://nchc.dl.sourceforge.net/project/mysql-python/mysql-python/1.2.3/MySQL-python-1.2.3.tar.gz

安装：

tar zxvf MySQL-python-1.2.3.tar.gz && cd MySQL-python-1.2.3 && python setup.py build && python setup.py install

 

 

 测试：

import timeimport MySQLdbtry:    conn=MySQLdb.connect(host='211.152.53.103',user='root',passwd='123456',port=3306)    cur=conn.cursor()    cur.execute('drop database if exists python')    cur.execute('create database if not exists python')    conn.select_db('python')    cur.execute('create table test(id int,info varchar(20))')    for i in range(100):        value=[i,'test:'+str(i)]        cur.execute('insert into test values(%s,%s)',value)        conn.commit()        time.sleep(0)    sql ="select * from test";    cur.execute(sql)    data = cur.fetchall()    if data:        for item in data:            print item[0],item[1]    cur.close()    conn.close()except MySQLdb.Error,e:     print "Mysql Error %d: %s" % (e.args[0], e.args[1])

 

import MySQLdbimport jsonconn=MySQLdb.connect(host='54.225.106.132',user='root',passwd='tot91smart.net',port=3306)cur=conn.cursor()conn.select_db('bbb')mymap = {}cur.execute("select id,gold from c_property")data0 = cur.fetchall()if data0:    for item0 in data0:    #    print item0[0],"&",item0[1]        mymap[item0[0]] = item0[1]#for k,v in mymap.items():#    print k,":",vvalue = []sql ="select id,gold,propertyList from p_user"cur.execute(sql)data = cur.fetchall()if data:    for item in data:    #    print item[0],item[1],item[2]        if item[2]:            propertyJson = json.loads(item[2])            for array in propertyJson:                if array[0] == 0:                    continue;                else:                    print "propertyid: ",array[0]," & num: ",array[1]," & price: ",mymap[array[0]]," & totol_gold: ",mymap[array[0]] *array[1]                    add_gold = mymap[array[0]] *array[1]                    userid = item[0]                    mysql = "update p_user set gold = gold + " + str(add_gold) + ",propertylist = '' where id = " + str(userid)                    value.append(mysql)for item in value:    cur.execute(item)    conn.commit()                cur.close()conn.close()

 

 

如果出现错误：SyntaxError: Non-ASCII character ‘\xe7′ in file，则可在文件第一行加上下面四个任意其中一个即可解决：

#coding:utf-8# coding=utf-8#-*- coding: utf-8 -*-# vim: set fileencoding=utf-8 :