本文實例為大家分享了如何利用Python對數據庫的增刪改查進行簡單的封裝,供大家參考,具體內容如下
1.insert
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
2.delete
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()
3.select
#取得數據庫信息# 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
4.showtable,showcolumns
#顯示建表語句#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
以上就是Python Sql數據庫增刪改查操作的相關操作,希望對大家的學習有所幫助。