1.Python 中操作 MySQL

Python 中操作 MySQL.jpeg

1.1引入模块

在py文件中引入pymysql模块

from pymysql import *

1.2Connection 对象

#用于建立与数据库的连接

#创建对象：调用connect()方法
conn=connect(参数列表)
    参数host：连接的mysql主机，如果本机是'localhost'
    参数port：连接的mysql主机的端口，默认是3306
    参数database：数据库的名称
    参数user：连接的用户名
    参数password：连接的密码
    参数charset：通信采用的编码方式，推荐使用utf8

#对象的方法
    close()关闭连接
    commit()提交
    cursor()返回Cursor对象，用于执行sql语句并获得结果

1.3Cursor对象

#用于执行sql语句，使用频度最高的语句为select、insert、update、delete
#获取Cursor对象：调用Connection对象的cursor()方法
cs1=conn.cursor()

#对象的方法
    close()关闭
    execute(operation [, parameters ])执行语句，返回受影响的行数，主要用于执行insert、update、delete语句，也可以执行create、alter、drop等语句
    fetchone()执行查询语句时，获取查询结果集的第一个行数据，返回一个元组
    fetchall()执行查询时，获取结果集的所有行，一行构成一个元组，再将这些元组装入一个元组返回

#对象的属性
    rowcount只读属性，表示最近一次execute()执行后受影响的行数
    connection获得当前连接对象

2.python中操作redis集群

#!/usr/bin/env python
# -*- coding:utf-8 -*-
# 执行命令安装 rediscluster ---> pip3 install redis-py-cluster
from rediscluster import StrictRedisCluster


def redis_cluster():
    redis_nodes = [
        {"host": "192.168.0.199", "port": 7001},
        {"host": "192.168.0.199", "port": 7002},
        {"host": "192.168.0.198", "port": 7001},
        {"host": "192.168.0.198", "port": 7002},
        {"host": "192.168.0.197", "port": 7001},
        {"host": "192.168.0.197", "port": 7002},
    ]
    try:
        return StrictRedisCluster(startup_nodes=redis_nodes)
    except Exception as e:
        print(e)


if __name__ == '__main__':
    redis_cluster().set("python_redis", "redis_python")
    print(redis_cluster().get("python_redis"))