Python3:python+mysql数据库连接及操作
python+mysql数据库连接及操作内容说明实例内容 内容说明 本例子使用的python3.7,PyMySQL0.9.3版本,主要是讲解python如何连接mysql数据库,并对数据库进行查询,增删改等操作,本例中封装了一个基础的mysql数据库连接类,主要是用于当项目中存在多个数据库时,可通过传入链接参数,指定调用对应数据库并进行操作。 实例内容 实现方式及代码内容请参见下诉内容,直接上码: # -*- coding: utf-8 -*- import pymysql.cursors class conn: def do_one(self, conn, sql): 在Python编程中,连接并操作MySQL数据库是常见的需求。这个例子使用的是Python 3.7版本和PyMySQL 0.9.3库,该库允许我们通过Python代码与MySQL数据库进行交互。以下将详细讲解如何使用Python连接MySQL数据库以及进行查询、增、删、改等操作。 我们需要导入`pymysql.cursors`模块,它提供了执行SQL语句的游标对象。接下来定义了一个名为`conn`的类,该类包含了两个主要方法:`do_one`和`select`,分别用于执行单条数据的变更操作(增、删、改)和查询操作。 `do_one`方法接收两个参数,一个是数据库连接配置字典`conn`,另一个是SQL语句`sql`。该方法首先检查SQL语句是否为空,如果为空则返回错误信息。接着,使用`pymysql.connect()`函数建立数据库连接,并创建一个游标对象。然后,尝试执行SQL语句并提交事务。如果在执行过程中出现异常,会捕获异常,关闭游标和连接,并将异常信息和SQL语句作为响应返回。如果没有异常,执行成功后关闭游标和连接,返回执行结果。 `select`方法与`do_one`类似,但主要用于执行查询操作。它也接收相同的参数,并同样检查SQL语句是否为空。然后,它会执行SQL查询并获取所有结果。如果在执行过程中出现异常,异常会被捕获并关闭游标和连接,返回带有错误信息的结果。如果没有异常,关闭游标和连接后返回查询结果。 为了使用这些方法,你需要创建一个包含数据库连接参数的字典,如`{'host': '127.0.0.1', 'port': 3060, 'user': 'test', 'password': 'test', 'db': 'TEST', 'charset': 'utf8mb4'}`,其中包含了数据库的主机名、端口、用户名、密码、数据库名和字符集。然后,你可以实例化`conn`类,并调用相应的方法,传入连接参数和SQL语句来执行操作。 例如,要插入一条数据,你可以编写这样的代码: ```python conn = conn() sql = "INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')" result = conn.do_one(conn_config, sql) ``` 对于查询操作,可以这样做: ```python sql = "SELECT * FROM table_name WHERE condition" data = conn.select(conn_config, sql) ``` 这个例子提供了一种基础的数据库操作封装,便于在多数据库环境中切换。然而,在实际项目中,可能还需要考虑事务管理、错误处理、连接池等更复杂的情况,以确保程序的健壮性和效率。 Python的`PyMySQL`库为开发人员提供了一种简单且高效的手段,通过Python代码与MySQL数据库进行交互,实现数据的存储和处理。通过理解上述代码,你可以了解如何连接MySQL数据库,执行基本的SQL操作,并在Python中处理可能出现的异常情况。这有助于你在实际开发中灵活运用数据库操作。