資料庫封裝類
import pymysql
import json
class my_databa(object):
def __init__(self,pwd='****',name='表名',user='root',host='localhost',port=3306):
self.conn=pymysql.connect(user=user,host=host,db=name,port=port,password=pwd,charset='utf8')
self.cursor=self.conn.cursor()
def __enter__(self):#with呼叫方法
return self
def __del__(self):#析構方法
try:
self.cursor.close()
self.conn.close()
except:
pass
#插入方法
def insert(self,table,*args):
for x in args:
keys=''
values=''
for key,value in x.items():
keys=keys+key+','
values = values + '"' + str(value) + '"' + ','
values = values.strip(',')
keys = keys.strip(',')
sql = 'insert into () values()'.format(table=table,keys=keys, values=values)
print(sql)
self.cursor.execute(sql)
self.conn.commit()
#刪除操作
def delete(self,table,where):
try:
sql = 'delete from where '.format(table=table, where=where)
self.cursor.execute(sql)
# 提交事務
self.conn.commit()
return self.cursor.rowcount
except exception as e:
print(e)
self.conn.rollback()
#更新def updata(self,table,where,data):
try:
mystr = ''
for i, v in data.items():
# print(i,v)
mystr = mystr + '=""'.format(i=i, v=v) + ','
mystr = mystr.strip(',')
# print(mystr.strip(','))
sql = 'update set where '.format(table=table, data=mystr, where=where)
print(sql)
self.cursor.execute(sql)
self.conn.commit()
return true
except exception as e:
print(e)
self.conn.rollback()
finally:
self.conn.close()
def __exit__(self,*args):#with結束呼叫方法
self.__del__()
if __name__=='__main__':
# with open('list.txt', 'r', encoding='utf-8')as f:
# h=json.load(f)
with my_databa(pwd='***',name='ipdaili')as db:
# db.insert('listip','h')
db.delete('listip','id=3')
db.updata('listip','id=30000',data=)
資料庫封裝函式import pymysql
#查詢多條資料
def select_all(sql):
try:
#開啟資料庫鏈結
db =pymysql.connect('localhost','root','123456','ai5_1',charset='utf8')
#2.建立游標
cursor =db.cursor(pymysql.cursors.dictcursor)
#3使用游標操作sql
cursor.execute(sql)
#4使用游標取得結果
res =cursor.fetchall()
return res
except exception as e:
print(e)
finally:
# 5.關閉資料庫鏈結
db.close()
#查詢一條資料
def select_one(sql):
try:
#開啟資料庫鏈結
db =pymysql.connect('localhost','root','123456','ai5_1',charset='utf8')
#2.建立游標
cursor =db.cursor(pymysql.cursors.dictcursor)
#3使用游標操作sql
cursor.execute(sql)
#4使用游標取得結果
res =cursor.fetchone()
#5.關閉資料庫鏈結
db.close()
return res
except exception as e:
print(e)
finally:
db.close()
#插入操作，引數2個---1:表名 2：字典
def insert(table,data):
try:
# 開啟資料庫鏈結
db =pymysql.connect('localhost','root','123456','ai5_1',charset='utf8')
#建立游標
cursor=db.cursor()
#使用游標執行sql
keys = ','.join(data.keys())
values = ''
for v in data.values():
# values += str(v)+','
values = values + '"'+str(v)+'"' + ','
values=values.strip(',')
sql='insert into () values()'.format(table=table,keys=keys,values=values)
cursor.execute(sql)
#提交事務
db.commit()
return true
except exception as e:
print(e)
db.rollback()
finally:
db.close()
#刪除操作 delete from 表名 where 條件
def delete(table,where=0):
try:
# 開啟資料庫鏈結
db = pymysql.connect('localhost', 'root', '123456', 'ai5_1', charset='utf8')
# 建立游標
cursor = db.cursor()
# 使用游標執行sql
sql='delete from where '.format(table=table,where=where)
cursor.execute(sql)
#提交事務
db.commit()
return cursor.rowcount
except exception as e:
print(e)
db.rollback()
finally:
db.close()
#修改操作：update 表名 set 欄位名='值'，欄位名2='值' where 條件
def update(table,data,where):
try:
#開啟資料庫
#db=pymysql.connect(host,user,password,db,port,charset=charset)
db = pymysql.connect('localhost', 'root', '123456', 'ai5_1', charset='utf8')
#建立游標
cursor= db.cursor()
#使用游標執行操作
#data=
set =''
for k,v in data.items():
set = set +'%s = "%s" ,'%(k,v)
set =set.strip(',')
sql='update set where '.format(table=table,set=set,where=where)
print(sql)
cursor.execute(sql)
#提交操作
db.commit()
except exception as e:
db.rollback()
finally:
# 關閉資料庫
db.close()
mysql是什麼 MySQL是什麼？（一）
在學習mysql之前，首先需要了解資料庫和sql。如果您已經知道資料庫和sql，那麼可以直接跳轉到下一章節的學習。1.資料庫簡介 當您拍攝 並將其上傳到微博，朋友圈等，這樣的社交網路中的帳戶時，您的 庫就有可能儲存在乙個資料庫中。當您瀏覽電子商務 購買鞋子，衣服等時，您使用購物車就是資料庫應用。資料...
mysql db是什麼 MySQL是什麼？
在學習mysql之前，首先需要了解資料庫和sql。如果您已經知道資料庫和sql，那麼可以直接跳轉到下一章節的學習。1.資料庫簡介 當您拍攝 並將其上傳到微博，朋友圈等，這樣的社交網路中的帳戶時，您的 庫就有可能儲存在乙個資料庫中。當您瀏覽電子商務 購買鞋子，衣服等時，您使用購物車就是資料庫應用。資料...
mysql 死鎖是什麼 mysql死鎖是什麼意思
mysql死鎖是指兩個或多個事務在同一資源上相互占用，並請求鎖定對方占用的資源，從而導致惡性迴圈。innodb儲存引擎能檢測到死鎖的迴圈依賴並立即返回乙個錯誤。只有部分或完全回滾其中乙個事務，才能打破死鎖。什麼是死鎖？它是如何產生的？死鎖是指兩個或多個事務在同一資源上相互占用，並請求鎖定對方占用的資...