天下

记录修行的印记

python mysql封装

#coding:utf-8
#
08年写的
import sys
try:
    
import MySQLdb
except ImportError:
    sys.exit(
"Exceptions.ImportError: No module named MySQLdb\n");

class pymysql(object):
    conn   
= None

    
def __init__(self):
        
pass

    
def __del__(self):
        self.close()

    
def connect(self,db_host,db_user,db_password,db_name,db_port=3306,db_charset='utf8'):
        
try:
            self.conn 
= MySQLdb.connect(host=db_host,user=db_user,passwd=db_password,db=db_name,port=db_port,charset=db_charset)

            self.
__db_host = db_host
            self.
__db_user = db_user
            self.
__db_password = db_password
            self.
__db_name = db_name
            self.
__db_port = db_port
            self.
__db_charset = db_charset
            
return True
        
except:
            
return False


    
def reconnect(self):
        
try:
            self.conn 
= MySQLdb.connect(host=self.__db_host,user=self.__db_user,passwd=self.__db_password,db=self.__db_name,port=self.__db_port,charset=self.__db_charset)
            
return True
        
except:
            
return False
    
def quote(self,queryString):
        
return MySQLdb.escape_string(queryString);

    
def query(self,sql):
        
try:
            cursor 
= self.conn.cursor()
            cursor.execute(sql)
            
return cursor
        
except:
            sys.exit(
"MySQL Query Error:\n"+sql+"\n")


    
def execute(self,sql):
        
try:
            
return self.conn.cursor().execute(sql)
        
except:
            sys.exit(
"MySQL Query Error:\n"+sql+"\n")

    
def fetch(self,cursor):
        
return cursor.fetchone()

    
def fetchRow(self,sql):
        
return self.query(sql).fetchone()

    
def fetchOne(self,sql):
        
try:
            
return self.query(sql).fetchone()[0]
        
except:
            
return None

    
def fetchAll(self,sql):
        
return self.query(sql).fetchall()

    
def insert(self,table,row):
        sqlArr 
= []
        
for key in row.iterkeys():
            sqlArr.append(
"%s='%s'"%(key,row[key],))
        sql 
= "insert into "+table +" set "+str.join(",",sqlArr)
        
return self.execute(sql)


    
def update(self,table,row,where):
        sqlArr 
= []
        
for key in row.iterkeys():
            sqlArr.append(
"%s='%s'"%(key,row[key],))
        sql 
= "update "+table +" set "+str.join(",",sqlArr)+" where "+where
        
return self.execute(sql)

    
def close(self):
        
if self.conn:
            self.conn.close()

posted on 2012-08-06 16:38 天下 阅读(763) 评论(0)  编辑 收藏 引用 所属分类: Python


只有注册用户登录后才能发表评论。
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理


<2012年8月>
2930311234
567891011
12131415161718
19202122232425
2627282930311
2345678

导航

统计

常用链接

留言簿(4)

随笔分类(378)

随笔档案(329)

链接

最新随笔

搜索

最新评论