首页
学习
活动
专区
圈层
工具
发布
社区首页 >专栏 >[python]mysqlclient常用命令

[python]mysqlclient常用命令

作者头像
git clone firc-dataset
发布2025-07-20 12:38:00
发布2025-07-20 12:38:00
2450
举报

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

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

连接到MySQL数据库:

Bash

代码语言:javascript
复制
import MySQLdb

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

创建游标对象:

Bash

代码语言:javascript
复制
cursor = conn.cursor()

执行SQL查询:

代码语言:javascript
复制
cursor.execute('SELECT * FROM table')

获取查询结果:

代码语言:javascript
复制
result = cursor.fetchall()

插入数据:

代码语言:javascript
复制
cursor.execute('INSERT INTO table (column1, column2) VALUES (%s, %s)', ('value1', 'value2'))

提交事务:

代码语言:javascript
复制
conn.commit()

回滚事务:

代码语言:javascript
复制
conn.rollback()

获取受影响的行数:

代码语言:javascript
复制
affected_rows = cursor.rowcount

获取插入的自增ID:

代码语言:javascript
复制
last_insert_id = cursor.lastrowid

更新数据:

代码语言:javascript
复制
cursor.execute('UPDATE table SET column1 = %s WHERE column2 = %s', ('new_value', 'condition'))

删除数据:

代码语言:javascript
复制
cursor.execute('DELETE FROM table WHERE column = %s', ('value',))

批量插入数据:

代码语言:javascript
复制
data = [('value1', 'value2'), ('value3', 'value4')]
cursor.executemany('INSERT INTO table (column1, column2) VALUES (%s, %s)', data)

获取字段信息:

代码语言:javascript
复制
fields = cursor.description

获取表的主键:

代码语言:javascript
复制
cursor.execute('SHOW KEYS FROM table WHERE Key_name = "PRIMARY"')
primary_key = cursor.fetchone()[0]

获取表的索引:

代码语言:javascript
复制
cursor.execute('SHOW INDEX FROM table')indexes = cursor.fetchall()

获取表的创建语句:

代码语言:javascript
复制
cursor.execute('SHOW INDEX FROM table')
indexes = cursor.fetchall()

执行存储过程:

代码语言:javascript
复制
cursor.callproc('procedure_name', args)

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

代码语言:javascript
复制
output_param = cursor.fetchone()

执行事务:

代码语言:javascript
复制
try:
    cursor.execute('START TRANSACTION')
    # 执行其他SQL语句
    cursor.execute('COMMIT')
except:
    cursor.execute('ROLLBACK')

设置字符集:

代码语言:javascript
复制
conn.set_charset('utf8')

设置自动提交模式:

代码语言:javascript
复制
conn.autocommit(True)

设置超时时间:

代码语言:javascript
复制
conn.set_timeout(10)

设置查询缓存:

代码语言:javascript
复制
conn.query('SET SESSION query_cache_type = ON')

设置连接池大小:

代码语言:javascript
复制
conn.set_max_connections(10)

关闭游标对象:

代码语言:javascript
复制
cursor.close()

关闭数据库连接:

代码语言:javascript
复制
conn.close()

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

代码语言:javascript
复制
import MySQLdb

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

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

代码语言:javascript
复制
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')

设置连接属性:

代码语言:javascript
复制
conn.set_session(sql_mode='ANSI')

获取连接属性:

代码语言:javascript
复制
sql_mode = conn.get_session().get('sql_mode')

设置连接超时时间:

代码语言:javascript
复制
conn.set_connect_timeout(10)

获取连接超时时间:

代码语言:javascript
复制
connect_timeout = conn.get_connect_timeout()

设置查询超时时间:

代码语言:javascript
复制
conn.set_query_timeout(10)

获取查询超时时间:

代码语言:javascript
复制
query_timeout = conn.get_query_timeout()

设置读取超时时间:

代码语言:javascript
复制
conn.set_read_timeout(10)

获取读取超时时间:

代码语言:javascript
复制
read_timeout = conn.get_read_timeout()

设置写入超时时间:

代码语言:javascript
复制
conn.set_write_timeout(10)

获取写入超时时间:

代码语言:javascript
复制
write_timeout = conn.get_write_timeout()

打开SSL连接:

代码语言:javascript
复制
conn.ssl_set(ca='path/to/ca.pem', cert='path/to/cert.pem', key='path/to/key.pem')

获取SSL连接状态:

代码语言:javascript
复制
ssl_enabled = conn.ssl_in_use()Python

执行带参数的SQL查询:

代码语言:javascript
复制
cursor.execute('SELECT * FROM table WHERE column = %s', ('value',))

执行带参数的SQL查询,并获取结果:

代码语言:javascript
复制
cursor.execute('SELECT * FROM table WHERE column = %s', ('value',))
result = cursor.fetchall()

获取查询结果的字段名:

代码语言:javascript
复制
fields = [desc[0] for desc in cursor.description]

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

代码语言:javascript
复制
field_types = [desc[1] for desc in cursor.description]

使用连接池连接数据库:

代码语言:javascript
复制
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语句、事务处理、批量插入、获取表信息等。希望对你有所帮助!

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2025-07-17,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 连接到MySQL数据库:
  • 创建游标对象:
  • 执行SQL查询:
  • 获取查询结果:
  • 插入数据:
  • 提交事务:
  • 回滚事务:
  • 获取受影响的行数:
  • 获取插入的自增ID:
  • 更新数据:
  • 删除数据:
  • 批量插入数据:
  • 获取字段信息:
  • 获取表的主键:
  • 获取表的索引:
  • 获取表的创建语句:
  • 执行存储过程:
  • 获取存储过程的输出参数:
  • 执行事务:
  • 设置字符集:
  • 设置自动提交模式:
  • 设置超时时间:
  • 设置查询缓存:
  • 设置连接池大小:
  • 关闭游标对象:
  • 关闭数据库连接:
  • 使用上下文管理器连接数据库:
  • 使用上下文管理器执行事务:
  • 设置连接属性:
  • 获取连接属性:
  • 设置连接超时时间:
  • 获取连接超时时间:
  • 设置查询超时时间:
  • 获取查询超时时间:
  • 设置读取超时时间:
  • 获取读取超时时间:
  • 设置写入超时时间:
  • 获取写入超时时间:
  • 打开SSL连接:
  • 获取SSL连接状态:
  • 执行带参数的SQL查询:
  • 执行带参数的SQL查询,并获取结果:
  • 获取查询结果的字段名:
  • 获取查询结果的字段类型:
  • 使用连接池连接数据库:
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档