資料庫封裝類
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()
Koa封裝MySQL資料庫
以下提供乙個node.js封裝的mysql資料庫的方法，歡迎各位碼農複製貼上！首先是封裝的資料庫檔案config.js var mysql require mysql 建立鏈結 function connection connection.connect return connection expo...
mysql資料庫 C 封裝
為什麼要使用mysql資料庫？設想一下有乙個很大的 如10g 資料，我們不能將之存放在記憶體中，只能夠放在磁碟上，每一次cpu讀取資料都需要進行慢到 的磁碟io操作，那這時使用mysql這種關係型資料庫就顯得尤為重要的。記住mysql的資料也是存放在磁碟上面的，不過讀取速度更快！首先將mysql檔案...
mysql資料封裝是什麼 mysql資料庫的封裝
資料庫封裝類 import pymysql import json class my databa object def init self,pwd name 表名 user root host localhost port 3306 self.conn pymysql.connect user u...