10_Python_数据库操作（MySQL、Mongodb、Redis）

1、MySQL 数据库

1.1、安装PyMysql

pip install PyMysql

1.2、使用 PyMySQL

1.2.1、连接数据库

import pymysql


def connectdb():
    print('连接到mysql服务器...')
    # 打开数据库连接
    # 用户名:hp, 密码:Hp12345.,用户名和密码需要改成你自己的mysql用户名和密码，并且要创建数据库TESTDB，并在TESTDB数据库中创建好表Student
    db = pymysql.connect(
        host='localhost',
        user='root',  # 用户名 ：test
        password='123456',  # 密 码 ：123456
        db='test',  # 数据库 ：test
        charset='utf8mb4',
        cursorclass=pymysql.cursors.DictCursor)
    print('连接上了!')
    return db

1.2.2、获取数据库游标

my_cousor = db.cursor()
#获取数据库游标对象

1.2.3、创建数据表

def createtable(db):
    # 使用cursor()方法获取操作游标 
    cursor = db.cursor()

    # 如果存在表Sutdent先删除
    cursor.execute("DROP TABLE IF EXISTS Student")
    sql = """CREATE TABLE Student (
            ID CHAR(10) NOT NULL,
            Name CHAR(8),
            Grade INT )"""

    # 创建Sutdent表
    cursor.execute(sql)
    

if __name__ == '__main__':
    db = connectdb()
    createtable(db)

1.2.4、执行SQL语句（增加、修改、删除）

def sql_commit(db, sql):
    '''执行SQL语句'''
    # 使用cursor()方法获取操作游标
    cursor = db.cursor()

    try:
        # 执行sql语句
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
        print('post：' + str(sql))
    except:
        # 如果发生错误，执行回滚操作
        print('Error：' + str(sql))
        db.rollback()



if __name__ == '__main__':
    # 1、插入数据
    sql_insert_01 = "INSERT INTO Student(ID, Name, Grade)  VALUES ('%s', '%s', '%d')" % ('001', 'HP', 60)
    sql_insert_02 = "INSERT INTO Student VALUES ('001', 'CZQ', 70), ('007', 'TEST', 100)"

    # 2、更新数据
    sql_update = "UPDATE Student SET Grade = Grade + 3 WHERE ID = '%s'" % ('003')

    #3、删除数据
    sql_delete = "DELETE FROM Student WHERE Grade = '%d'" % (70)

    db = connectdb()
    sql_commit(db, sql_delete)

1.2.5、查询数据（单条、多条）

fetchone() ：

返回单个的元组，也就是一条记录(row)，如果没有结果 , 则返回 None。
如果查询出多条数据，将只取最上面的第一条结果，返回单个元组，多次循环使用，将会依次取得下一条结果，直到为空。

fetchall() ：

返回多个元组，即返回多条记录(rows),如果没有结果,则返回 ()。

def select_one(db, sql):
    '''查询单条数据、或者返回多条数据的第一条'''
    # 使用cursor()方法获取操作游标
    cursor = db.cursor()
    try:
        # 执行sql语句
        cursor.execute(sql)
        results = cursor.fetchone()
        print(results)
    except:
        # 如果发生错误，显示提示
        print('Error：' + str(sql))


def select_all(db, sql):
    '''查询多条数据'''
    # 使用cursor()方法获取操作游标
    cursor = db.cursor()
    try:
        # 执行sql语句
        cursor.execute(sql)
        results = cursor.fetchall()
        for i in results:
            print(i)
    except:
        # 如果发生错误，显示提示
        print('Error：' + str(sql))


if __name__ == '__main__':
    sql_select = "SELECT * FROM Student"
    db = connectdb()
    select_all(db, sql_select)

1.2.6、关闭数据库

def closedb(db):
    '''关闭数据库'''
    db.close()

2、Mongodb 数据库

2.1、安装PyMysql

pip install pymongo

2.2、使用 pymongo

2.2.1、连接mongodb数据库

import pymongo

'''连接MongoDB数据库的两种方法'''

#方法1：
client = pymongo.MongoClient(host='localhost', port=27017)
#方法2：
client = pymongo.MongoClient('mongodb://localhost:27017/')

2.2.2、指定数据库

'''指定数据库的两种方法'''

# 数据库名：test_mongodb
#方法1：
db = client.test_mongodb
#方法2：
db = client['test_mongodb']

2.2.3、指定集合

MongoDB的每个数据库又包含许多集合（collection），它们类似于关系型数据库中的表。

'''指定集合的两种方法'''

# 集合名：test_table
#方法1：
collection = db.test_table
#方法2：
collection = db['test_table']

2.2.4、插入数据

insert_one()：插入单条数据
insert_many()：插入多条数据

import pymongo

collection = pymongo.MongoClient(host='localhost', port=27017)['test_mongodb']['test_table']

test_01 = {
    'number': '1111',
    'name': 'test_01',
    'age': 20,
}

test_02 = {
    'number': '2222',
    'name': 'test_02',
    'age': 20,
}

'''插入单条数据'''
result = collection.insert_one(test_01)
print(result.inserted_id)

'''插入多条数据'''
result = collection.insert_many([test_01, test_02])
print(result.inserted_ids)

2.2.5、查询数据：find()、find_one()

find_one()查询得到的是单个结果。
find()则返回一个生成器对象。

import pymongo

collection = pymongo.MongoClient(host='localhost', port=27017)['test_mongodb']['test_table']

'''查询单条数据'''
result_1 = collection.find_one({'name': 'test_02'})
print(result_1)

'''查询多条数据'''
result_2 = collection.find({'age': 20})
for i in result_2:
    print(i)

2.2.6、mongodb的条件操作符

#    (>)  大于 - $gt
#    (<)  小于 - $lt
#    (>=)  大于等于 - $gte
#    (<= )  小于等于 - $lte

#在20-23范围内
{'age': {'$in': [20, 23]}}

#不在20-23范围内
{'age': {'$nin': [20, 23]}}


'''查询 age > 20 的数据'''
result_2 = collection.find({"age":{"$gt":20}})
for i in result_2:
    print(i)

2.2.7、数据计数：count()

要统计查询结果有多少条数据，可以调用 count()方法。

'''统计所有的数据'''

result = collection.find().count()
print(result)

2.2.8、数据排序：sort()

在MongoDB中使用sort()方法对数据进行排序，sort()方法可以通过参数指定排序的字段，并使用 1 和 -1 来指定排序的方式。
其中 1 为升序，-1为降序。

'''按照name字段的升序进行排序'''

result = collection.find().sort('name', 1)
for i in result:
    print(i)

2.2.9、数据更新：update()

使用update()方法，指定更新的条件和更新后的数据即可。

import pymongo

collection = pymongo.MongoClient(host='localhost', port=27017)['test_mongodb']['test_table']

# 首先查询出对应的数据
condition = {'name': 'test_02'}
result = collection.find_one(condition)
# 更新后的数据
result['age'] = '100'
# 使用update() 方法进行更新
result_2 = collection.update(condition, result)

2.2.10、删除数据：remove()

result = collection.remove({'name': 'test_02'})
print(result)

limit和skip

2.2.11、limit()、skip()

limit()方法用来读取指定数量的数据。
skip()方法用来跳过指定数量的数据。

'''跳过2条数据'''
result = collection.find().skip(2)

'''读取6条数据'''
result = collection.find().limit(6)

3、Redis 数据库

3.1、安装 redis

pip install redis

3.2、使用 redis

3.2.1、连接池

import redis

pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True,db=5)
r = redis.Redis(connection_pool=pool)

3.2.2、插入数据

set(name, value, ex=None, px=None, nx=False, xx=False)

参数：

ex，过期时间（秒）
px，过期时间（毫秒）
nx，如果设置为True，则只有name不存在时，当前set操作才执行
xx，如果设置为True，则只有name存在时，当前set操作才执行

r.set('name','老王')

3.2.3、获取数据

r.get('name')

未完。。。。