操作mysql

image.png

db_config = {

'user': 'root',

'password': 'qwe123',

'db': '數(shù)據(jù)庫名',

'charset': 'utf8', #不是utf-8

}

conn = pymysql.connect(**db_config)

注意*和**只要在定義的時候才是，其他都是拆包

建立連接：

conn = pymysql.connect(**dbconfig) #連接是不能操作數(shù)據(jù)庫的,需要用連接生成游標來操作；

創(chuàng)建游標：

cursor = conn.cursor()

執(zhí)行SQL語句：

executes = cursor.execute(sql)

獲取結(jié)果：

values = cursor.fetchall()

one = cursor.fetchone() #取出一條數(shù)據(jù)

all = cursor.fetchall() #取出所有數(shù)據(jù)

注意要點

事務(wù)的回滾和提交；#rollbck 與commit

在pymysql中執(zhí)行的SQL語句不需要加 ；

execute執(zhí)行完后不是直接得到結(jié)果，需要你主動去獲取；

和文件一樣，別忘了關(guān)閉游標與連接；

實例：

image.png

image.png

注意回滾，回滾的是之前沒有進行過提交commit的哪些。

操作redis

安裝python包redis：

pip install redis

創(chuàng)建連接

re = redis.Redis(host='127.0.0.1', port='55555', password='qwe123')

#redis.Redis() #為了兼容舊版本，不推薦使用

Redis.StrictRedis()

在程序操作的數(shù)據(jù)為bytes類型，加入decode_response=True,寫入的數(shù)據(jù)為str類型

re = redis.StrictRedis(host=host, port=port, decode_responses=True)

測試

re.set('num',15)

print(re.get('num'))

set 中文

re.set('name','小白')

print(re.get('name').decode('utf8') )

字符的 編碼

s = '小白'.encode('utf8')

print(type(s),s)

s2 = s.decode()

print(type(s2),s2)

大部分的命令 和 redis 中操作一樣

不同：

re.expire() ### 不能看 負數(shù) -1 -2

re.mset() ## 用鍵值對

re.incr() ## incr 可以加參數(shù)的，代替了 incrby

re.decr() ## decr 可以加參數(shù)，代替了 decrby

re.lrem() ## num 放到后面

re.hmset() # 多插入，要用字典

封裝的Hash操作demo

import redis

import random

class RedisClient(object):

def __init__(self, key, host='localhost', port=6379):

"""

初始化Redis連接

:param host: 地址

:param port: 端口

"""

self._db = redis.StrictRedis(host=host, port=port, decode_responses=True)

self.key = key

def name(self):

"""

獲取Hash的名稱

:return: Hash名稱

"""

return self.key

def hmset(self, dic):

self._db.hmset(self.name(), dic)

def set(self, field, value):

"""

設(shè)置鍵值對

:param field: 鍵

:param value: 值

:return:

"""

return self._db.hset(self.name(), field, value)

def delete(self, *field):

"""

根據(jù)鍵名刪除鍵值對

:return: 刪除結(jié)果

"""

return self._db.hdel(self.name(), *field)

def count(self):

"""

獲取數(shù)目

:return: 數(shù)目

"""

return self._db.hlen(self.name())

def random(self):

"""

隨機得到鍵值

:return: 隨機鍵值

"""

# print(self._db.hvals(self.key))

return random.choice(self._db.hvals(self.name()))

def get_field(self):

"""

獲取所有賬戶信息

:return: 所有用戶名

"""

return self._db.hkeys(self.name())

def get_values(self, *field):

"""

根據(jù)鍵名獲取鍵值

:param username: 鍵

:return:對應(yīng)鍵的鍵值

"""

result = self._db.hmget(self.name(), *field)

return result[0] if len(result) == 1 else result

def get_all(self):

"""

獲取所有鍵值對

:return: 所有鍵值對

"""

return self._db.hgetall(self.name())

if __name__ == '__main__':

conn = RedisClient('table')

result = conn.hmset({'a': 1, 'b': 2, 'c': 3})

print(result)

print(conn.get_field())

總結(jié)

以上是生活随笔為你收集整理的python处理数据库_python操作数据库的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。