链接和关闭链接mysql类

#!/usr/bin/env python3
#-*- encoding:utf-8 -*-

import pymysql
#mysql 连接类
class mysqlCommand():
    def __init__(self,host,port,user,passwd,db):
        self.conn = pymysql.connect(host = host , port = port , user = user , passwd = passwd , db = db)
    def connects(self):
        return self.conn
    #关闭mysql连接              
    def close(self):
        self.conn.close() 

增、删、改、查类（只完成部分，后面会完善）

#!/usr/bin/env python3
#-*- coding:utf-8-*-

#mysql 映射类
class mapper_abstract():
    def __init__(self,object):
        self.conn = object
    def cur(self):
        cur = self.conn.cursor()        
        return cur

#查找                                     
    def findAll(self,table):
        try:
            cur = self.cur()
            cur.execute("SELECT * FROM %s"%(table))
            result = cur.fetchall()
            return result
        except:
            print ('mysql error')
#删除                 
    def dels(self,table,ids):
        sql="delete from `%s` where id='%d'" % (table,ids)   
        try:
            cur = self.cur()
            cur.execute(sql)  
            self.conn.commit()  
        except:  
            self.conn.rollback()     

类的实例化调用示例

#!/usr/bin/env python3
#-*- coding:utf-8-*-
from mysql import mysqlCommand
from mapper import mapper_abstract

db = mysqlCommand('127.0.0.1',3306 ,'root' ,'pwd' ,'table')

conn = db.connects()
mapper = mapper_abstract(conn)
result = mapper.findAll('blog_categray')
for each in result:
    print (each)