pymysql常用方法

### PyMySQL 模块的方法及其使用 PyMySQL 是一个用于连接和操作 MySQL 数据库的 Python 库，其提供了多种方法来进行数据库交互。以下是常用的一些方法以及相应的使用示例。 #### 连接数据库 为了与 MySQL 数据库建立连接，可以使用 `connect` 函数： ```python import pymysql connection = pymysql.connect( host='localhost', user='root', password='password', database='test_db' ) ``` 此函数接受多个参数以指定主机名、用户名、密码和其他选项[^4]。 #### 创建游标对象 一旦建立了到数据库的连接，则可以通过创建游标对象执行 SQL 查询语句： ```python with connection.cursor() as cursor: sql_query = "SELECT * FROM users" result = cursor.execute(sql_query) ``` 这里展示了如何利用上下文管理器简化资源释放过程，并调用了 `execute()` 方法发送查询给服务器[^3]。 #### 插入记录 向表内插入新纪录可通过如下方式完成： ```python insert_sql = 'INSERT INTO users (username, email) VALUES (%s,%s)' data_tuple = ('Alice', '[email protected]') affected_rows = cursor.execute(insert_sql, data_tuple) # 提交更改并关闭事务 connection.commit() ``` 注意，在构建插入命令时采用了占位符 `%s` 来防止SQL注入攻击的发生。 #### 更新现有条目 更新已存在的数据项同样遵循类似的模式： ```python update_stmt = "UPDATE users SET username=%s WHERE id=%s;" params = ("Bob", 101) rows_affected = cursor.execute(update_stmt,params) connection.commit() ``` 上述代码片段说明了怎样安全地修改特定条件下的字段值。 #### 删除记录 删除不再需要的数据行可按下面的方式处理： ```python delete_statement = "DELETE FROM users WHERE id=%s;" param_value = (2,) deleted_count = cursor.execute(delete_statement,param_value) connection.commit() ``` 这段脚本演示了基于唯一键移除单个实体的过程。 #### 执行批量操作 对于大量相似的任务，比如一次性插入多条记录，推荐采用批量执行策略提高效率： ```python batch_insertion = [ ('Charlie','[email protected]'), ('David','[email protected]') ] multi_addition = "INSERT INTO users(username,email)VALUES(%s,%s)" cursor.executemany(multi_addition,batch_insertion) connection.commit() ``` 这种方法不仅减少了网络往返次数还提升了整体性能。 #### 获取查询结果集 当发出 SELECT 类型请求之后，通常会希望获取返回的结果集合： ```python select_all_users = "SELECT * FROM users;" cursor.execute(select_all_users) fetched_data = cursor.fetchall() for row in fetched_data: print(row) ``` 除了 fetchall(), 还有其他几种读取方式如 fetchone() 和 fetchmany(size)，可以根据实际需求选用最合适的那个。 #### 关闭连接 最后不要忘记断开同远程服务端之间的联系以免造成不必要的占用： ```python if connection.open: connection.close() ``` 确保每次操作完毕都妥善结束会话有助于维护系统的稳定性和安全性。

pymysql 是一个 Python 连接 MySQL 数据库的库。使用 pymysql.connect() 函数可以建立与数据库的连接，并设置连接的参数。具体的设置包括： 1. host：指定数据库主机地址或 IP。 2. port：指定数据库端口，默认为 3306。 3. user：指定数据库用户名。 4. password：指定数据库密码。 5. db：指定连接的数据库名称。 6. charset：指定字符集，常用的有 "utf8" 和 "utf8mb4"。 7. cursorclass：指定游标类别，默认为 pymysql.cursors.Cursor。 以下是一个使用 pymysql.connect() 的示例代码： ```python import pymysql # 建立连接 conn = pymysql.connect( host='localhost', port=3306, user='root', password='password', db='mydatabase', charset='utf8mb4', cursorclass=pymysql.cursors.Cursor ) # 执行数据库操作 # ... # 关闭连接 conn.close() ``` 以上代码中的参数值需要根据实际情况进行修改，确保与你的数据库配置相匹配。