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相关技术干货:
技术干货|Python MySQL驱动模块mysql-connector-python常见用法
技术干货|MySQL 8索引优化、查询优化、表设计优化和配置优化
Ansible实现生产环境一键式Linux+Nginx+MySQL+Tomcat企业级架构
python其他技术干货
本文暂时没有评论,来添加一个吧(●'◡'●)