技术干货|Python mysqlclient 库常见用法

#头号有新人#

mysqlclient是Python的一个MySQL数据库驱动程序，它是Python DB API v2.0的实现之一。

它提供了一组函数和方法来连接MySQL数据库，并执行各种数据库操作。

连接到MySQL数据库：

import MySQLdb

conn = MySQLdb.connect(host='localhost', user='user', passwd='password', db='database')           

创建游标对象：

cursor = conn.cursor()           

执行SQL查询：

cursor.execute('SELECT * FROM table')           

获取查询结果：

result = cursor.fetchall()           

插入数据：

cursor.execute('INSERT INTO table (column1, column2) VALUES (%s, %s)', ('value1', 'value2'))           

提交事务：

conn.commit()           

回滚事务：

conn.rollback()           

获取受影响的行数：

affected_rows = cursor.rowcount           

获取插入的自增ID：

last_insert_id = cursor.lastrowid           

更新数据：

cursor.execute('UPDATE table SET column1 = %s WHERE column2 = %s', ('new_value', 'condition'))           

删除数据：

cursor.execute('DELETE FROM table WHERE column = %s', ('value',))           

批量插入数据：

data = [('value1', 'value2'), ('value3', 'value4')]
cursor.executemany('INSERT INTO table (column1, column2) VALUES (%s, %s)', data)           

获取字段信息：

fields = cursor.description           

获取表的主键：

cursor.execute('SHOW KEYS FROM table WHERE Key_name = "PRIMARY"')
primary_key = cursor.fetchone()[0]           

获取表的索引：

cursor.execute('SHOW INDEX FROM table')indexes = cursor.fetchall()           

获取表的创建语句：

cursor.execute('SHOW INDEX FROM table')
indexes = cursor.fetchall()           

执行存储过程：

cursor.callproc('procedure_name', args)           

获取存储过程的输出参数：

output_param = cursor.fetchone()           

执行事务：

try:
    cursor.execute('START TRANSACTION')
    # 执行其他SQL语句
    cursor.execute('COMMIT')
except:
    cursor.execute('ROLLBACK')           

设置字符集：

conn.set_charset('utf8')           

设置自动提交模式：

conn.autocommit(True)           

设置超时时间：

conn.set_timeout(10)           

设置查询缓存：

conn.query('SET SESSION query_cache_type = ON')           

设置连接池大小：

conn.set_max_connections(10)           

关闭游标对象：

cursor.close()           

关闭数据库连接：

conn.close()           

使用上下文管理器连接数据库：

import MySQLdb

with MySQLdb.connect(host='localhost', user='user', passwd='password', db='database') as conn:
    cursor = conn.cursor()
    # 执行数据库操作           

使用上下文管理器执行事务：

import MySQLdb

with MySQLdb.connect(host='localhost', user='user', passwd='password', db='database') as conn:
    with conn.cursor() as cursor:
        try:
            cursor.execute('START TRANSACTION')
            # 执行其他SQL语句
            cursor.execute('COMMIT')
        except:
            cursor.execute('ROLLBACK')           

设置连接属性：

conn.set_session(sql_mode='ANSI')           

获取连接属性：

sql_mode = conn.get_session().get('sql_mode')           

设置连接超时时间：

conn.set_connect_timeout(10)           

获取连接超时时间：

connect_timeout = conn.get_connect_timeout()           

设置查询超时时间：

conn.set_query_timeout(10)           

获取查询超时时间：

query_timeout = conn.get_query_timeout()           

设置读取超时时间：

conn.set_read_timeout(10)           

获取读取超时时间：

read_timeout = conn.get_read_timeout()           

设置写入超时时间：

conn.set_write_timeout(10)           

获取写入超时时间：

write_timeout = conn.get_write_timeout()           

打开SSL连接：

conn.ssl_set(ca='path/to/ca.pem', cert='path/to/cert.pem', key='path/to/key.pem')           

获取SSL连接状态：

ssl_enabled = conn.ssl_in_use()Python           

执行带参数的SQL查询：

cursor.execute('SELECT * FROM table WHERE column = %s', ('value',))           

执行带参数的SQL查询，并获取结果：

cursor.execute('SELECT * FROM table WHERE column = %s', ('value',))
result = cursor.fetchall()           

获取查询结果的字段名：

fields = [desc[0] for desc in cursor.description]           

获取查询结果的字段类型：

field_types = [desc[1] for desc in cursor.description]           

使用连接池连接数据库：

import MySQLdb
from DBUtils.PersistentDB import PersistentDB

db_pool = PersistentDB(MySQLdb, host='localhost', user='user', passwd='password', db='database')
conn = db_pool.connection()
cursor = conn.cursor()
# 执行数据库操作           

这些示例涵盖了mysqlclient模块的一系列功能，包括连接数据库、执行SQL语句、事务处理、批量插入、获取表信息等。希望对你有所帮助！

mysql相关技术干货：

mysql8安全基线及安全优化

mysql8.0安装、部署及优化

技术干货|Python MySQL驱动模块mysql-connector-python常见用法

Shell脚本来实现MySQL服务的定时健康性检查

shell脚本实现mysql数据库文件和日志备份

技术干货|MySQL 8索引优化、查询优化、表设计优化和配置优化

Ansible实现生产环境一键式Linux+Nginx+MySQL+Tomcat企业级架构

python其他技术干货

Python-一些基本概念

Python基本语法规则

python open函数的解释以及示例及python文件指针操作

python Django渲染原理及应用

Python argparse模块作用及应用

python继承与多态-新式类和古典类区别

python3 多进程应用场景及示例

python 一些操作时间复杂度及效率

python继承与多态-新式类和古典类区别

Python-进制表示和相互转换

Python中导入模块或对象的方式

Python-线性表概念和分类

Python-列表常见初始化方式

python继承与多态-实例属性的访问规则

python多进程并行排序的应用示例

python多进程矩阵计算的应用示例

python模块搜索顺序和模块缓存

python目录、文件删除方法及详细示例

Python常见的可调用对象类型示例

python多进程并行求和应用示例

python3 多线程应用场景及示例

python3 path模块相关应用举例说明

python继承与多态-新式类和古典类区别

python __str__、__repr__和__bytes__功能及应用示例