Python Sql数据库增删改查操作简单封装

import mysql.connectorimport osimport codecs#设置数据库用户名和密码user='root';#用户名pwd='root';#密码host='localhost';#ip地址db='mysql';#所要操作数据库名字charset='UTF-8'cnx = mysql.connector.connect(user=user,password=pwd, host=host, database=db)#设置游标cursor = cnx.cursor(dictionary=True)#插入数据#print(insert('gelixi_help_type',{'type_name':'/'sddfdsfs/'','type_sort':'283'}))def insert(table_name,insert_dict):  param='';  value='';  if(isinstance(insert_dict,dict)):    for key in insert_dict.keys():      param=param+key+","      value=value+insert_dict[key]+','    param=param[:-1]    value=value[:-1]  sql="insert into %s (%s) values(%s)"%(table_name,param,value)  cursor.execute(sql)  id=cursor.lastrowid  cnx.commit()  return id

def delete(table_name,where=''):  if(where!=''):    str='where'    for key_value in where.keys():      value=where[key_value]      str=str+' '+key_value+'='+value+' '+'and'    where=str[:-3]    sql="delete from %s %s"%(table_name,where)    cursor.execute(sql)    cnx.commit()

#取得数据库信息# print(select({'table':'gelixi_help_type','where':{'help_show': '1'}},'type_name,type_id'))def select(param,fields='*'):  table=param['table']  if('where' in param):    thewhere=param['where']    if(isinstance (thewhere,dict)):      keys=thewhere.keys()      str='where';      for key_value in keys:        value=thewhere[key_value]        str=str+' '+key_value+'='+value+' '+'and'      where=str[:-3]  else:    where=''  sql="select %s from %s %s"%(fields,table,where)  cursor.execute(sql)  result=cursor.fetchall()  return result

#显示建表语句#table string 表名#return string 建表语句def showCreateTable(table):  sql='show create table %s'%(table)  cursor.execute(sql)  result=cursor.fetchall()[0]  return result['Create Table']#print(showCreateTable('gelixi_admin'))#显示表结构语句def showColumns(table):  sql='show columns from %s '%(table)  print(sql)  cursor.execute(sql)  result=cursor.fetchall()  dict1={}  for info in result:    dict1[info['Field']]=info  return dict1