python 连mysql数据库_连接类

Python 连接 MySQL 数据库通常使用 pymysql 或 mysqlconnectorpython 库。首先需要安装相应的库，然后通过编写代码来建立连接，创建游标对象，执行SQL语句并获取结果。在操作完成后，记得关闭游标和数据库连接。

在Python中连接MySQL数据库主要使用mysqlconnector模块，这是MySQL官方提供的驱动，通过该驱动可以实现对MySQL数据库的高效操作，下面将详细介绍如何使用mysqlconnector模块创建连接类来连接MySQL数据库：

1、安装 mysqlconnector

安装步骤：首先需要确保你的计算机上已经安装了Python环境，然后通过pip工具来安装mysqlconnector模块，可以使用下面的命令进行安装：

“`

pip install mysqlconnectorpython

“`

安装完成后，可以通过在Python环境中导入模块来验证是否成功：

“`

import mysql.connector

“`

如果没有报错信息，则表示安装成功。

2、创建连接类

导入模块：在你的Python脚本中，首先需要导入mysql.connector模块：

“`

import mysql.connector

“`

定义连接类：接下来可以定义一个连接类，用于封装与数据库连接相关的属性和方法。

“`python

class MySqlConnection:

def __init__(self, host, user, password, database):

self.host = host

self.user = user

self.password = password

self.database = database

self.connection = None

self.connect()

def connect(self):

try:

self.connection = mysql.connector.connect(

host=self.host,

user=self.user,

passwd=self.password,

database=self.database

)

if self.connection.is_connected():

db_Info = self.connection.get_server_info()

print("Connected to MySQL Server version ", db_Info)

except Error as e:

print("Error while connecting to MySQL", e)

def close_connection(self):

if self.connection.is_connected():

self.connection.close()

print("MySQL connection is closed")

“`

这个类包含了初始化方法__init__，用于设置数据库的连接参数；connect方法用于建立与数据库的连接；close_connection方法用于关闭数据库连接。

3、使用连接类

创建连接实例：使用上面定义的MySqlConnection类，可以创建一个连接实例，并传入相应的数据库参数：

“`python

host = "your_host"

user = "your_username"

password = "your_password"

database = "your_database"

myconn = MySqlConnection(host, user, password, database)

“`

your_host、your_username、your_password和your_database应替换为你的实际数据库信息。

执行数据库操作：通过连接实例的connection属性，可以执行SQL查询等数据库操作：

“`python

cursor = myconn.connection.cursor()

cursor.execute("SELECT * FROM your_table")

results = cursor.fetchall()

for row in results:

print(row)

cursor.close()

myconn.close_connection()

“`

cursor对象用于执行SQL语句和获取查询结果，最后记得关闭游标和连接。

通过以上步骤，你可以方便地在Python中使用mysqlconnector模块创建连接类来连接MySQL数据库，并进行后续的数据库操作。

下面是一个Python类，用于连接MySQL数据库，并以介绍的形式展示相关信息的示例。

import mysql.connector
from tabulate import tabulate
数据库连接类
class MySQLConnection:
    def __init__(self, host, user, password, database):
        self.host = host
        self.user = user
        self.password = password
        self.database = database
        self.connection = None
        self.cursor = None
    # 连接数据库
    def connect(self):
        try:
            self.connection = mysql.connector.connect(
                host=self.host,
                user=self.user,
                password=self.password,
                database=self.database
            )
            self.cursor = self.connection.cursor()
            print("连接数据库成功")
        except mysql.connector.Error as e:
            print(f"连接错误: {e}")
    # 关闭数据库连接
    def close(self):
        if self.cursor:
            self.cursor.close()
        if self.connection:
            self.connection.close()
        print("数据库连接已关闭")
    # 执行查询并返回结果
    def query(self, sql):
        try:
            self.cursor.execute(sql)
            records = self.cursor.fetchall()
            headers = [i[0] for i in self.cursor.description]
            return headers, records
        except mysql.connector.Error as e:
            print(f"查询错误: {e}")
            return None, None
    # 以介绍形式打印查询结果
    def print_query_result(self, sql):
        headers, records = self.query(sql)
        if headers and records:
            print(tabulate(records, headers=headers, tablefmt='grid'))
        else:
            print("查询结果为空或查询失败")
使用示例
if __name__ == "__main__":
    # 实例化并连接数据库
    mysql_connection = MySQLConnection(
        host="localhost",
        user="root",
        password="password",
        database="test_db"
    )
    mysql_connection.connect()
    # 执行SQL查询
    sql = "SELECT * FROM your_table"
    mysql_connection.print_query_result(sql)
    # 关闭数据库连接
    mysql_connection.close()

这里使用了tabulate库来格式化输出介绍，你需要先安装这个库：

pip install tabulate

请注意，你需要将host,user,password,database 和your_table替换为你的数据库实际信息。

这个类展示了如何创建一个连接对象，执行查询，并以介绍的形式打印结果，这只是一个简单的示例，实际使用中你可能需要处理更多的错误情况，提供更复杂的功能等。