Python 连接 MySQL 数据库通常使用 pymysql 或 mysqlconnectorpython 库。首先需要安装相应的库，然后通过编写代码来建立连接，创建游标对象，执行SQL语句并获取结果。在操作完成后，记得关闭游标和数据库连接。
在Python中连接MySQL数据库主要使用mysqlconnector模块，这是MySQL官方提供的驱动，通过该驱动可以实现对MySQL数据库的高效操作，下面将详细介绍如何使用mysqlconnector模块创建连接类来连接MySQL数据库：
（图片来源网络，侵删）
1、安装 mysqlconnector
安装步骤：首先需要确保你的计算机上已经安装了Python环境，然后通过pip工具来安装mysqlconnector模块，可以使用下面的命令进行安装：
R20;`
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替换为你的数据库实际信息。
这个类展示了如何创建一个连接对象，执行查询，并以介绍的形式打印结果，这只是一个简单的示例，实际使用中你可能需要处理更多的错误情况，提供更复杂的功能等。
评论(0)