学步园

用PyDev开发数据库读写程序，数据库是mysql，用utf-8字符集。

有开发者在 http://blog.csdn.net/foyuan/article/details/1711100 提到：

“我用了下面几个措施，保证MySQL的输出没有乱码：

    1 Python文件设置编码 utf-8 （文件前面加上 #encoding=utf-8)
    2 MySQL数据库charset=utf-8 
    3 Python连接MySQL是加上参数 charset=utf8 

    4 设置Python的默认编码为 utf-8 (sys.setdefaultencoding(utf-8)”

实践证明，第4条不要去做，在PyDev中也提醒sys中不再支持setdefaultencoding（我用的是Python2.7）

理由如下：http://groups.google.com/group/comp.lang.python/browse_thread/thread/854b1ca3766f476b

总之，python社区不再推荐对默认编码进行修改，这样会引发很多很难追踪的问题。

这样，只用前面提到的三条就可以搞定中文乱码问题。

    1
Python文件设置编码 utf-8 （文件前面加上 #encoding=utf-8)
    2 MySQL数据库charset=utf-8 
    3 Python连接MySQL是加上参数 charset=utf8 

#coding=utf-8
import logging
import os
import MySQLdb

conn=MySQLdb.Connect(host="localhost",user="root",passwd="root",db="tw",charset="utf8")

#select all tuples in any table which exists in the new database
def selectAllFromTable(conn,tableName):
    cursor =conn.cursor()
    sql ="select * from %s" % tableName
    cursor.execute(sql)
    while(1):
        row=cursor.fetchone()
        if row==None:
            break
        logger.debug(row)
    logger.debug("row number is %d" % cursor.rowcount)
def setLogger():
    # 创建一个logger,可以考虑如何将它封装
    logger = logging.getLogger('mylogger')
    logger.setLevel(logging.DEBUG)
    
    # 创建一个handler，用于写入日志文件
    fh = logging.FileHandler(os.path.join(os.getcwd(), 'log.txt'))
    fh.setLevel(logging.DEBUG)
    
    # 再创建一个handler，用于输出到控制台
    ch = logging.StreamHandler()
    ch.setLevel(logging.DEBUG)
    
    # 定义handler的输出格式
    formatter = logging.Formatter('%(asctime)s - %(module)s.%(funcName)s.%(lineno)d - %(levelname)s - %(message)s')
    fh.setFormatter(formatter)
    ch.setFormatter(formatter)
    
    # 给logger添加handler
    logger.addHandler(fh)
    logger.addHandler(ch)
    
    # 记录一条日志
    logger.info('hello world, i\'m log helper in python, may i help you')
    return logger

#return sql
def generateFromSQL(tableName,listColumn):
    sql="select "
    length=len(listColumn)
    i=0
    for column in listColumn:
        if(i!=(length-1)):
            sql=sql+column+","
        else:
            sql=sql+column+" from "
        i=i+1
    sql=sql+tableName
    logger.info(sql)
    return sql
    
#对单个表插入一个元组，其定义有
def insertOneData(conn,tableName,listColumn,lData):
    cursor=conn.cursor()
    sql="insert into "+tableName+"("
    i=0
    length=len(listColumn)
    for column in listColumn:
        if(i!=(length-1)):
            sql=sql+column+","
        else:
            sql=sql+column+") values("
        i=i+1
    for i in range(0,length):
        if(i!=(length-1)):
            sql=sql+"%s,"
        else:
            sql=sql+"%s);"
    logger.info(sql)
    logger.info(lData)
    cursor.execute(sql,lData);
    conn.commit()

if __name__ == '__main__':
    logger=setLogger()