Python 连接 mysql 详解(mysql-connector-python)
import mysql.connector
from mysql.connector import Error
def connect_to_database(host, database, user, password):
try:
connection = mysql.connector.connect(host=host,
database=database,
user=user,
password=password)
if connection.is_connected():
print("连接成功!")
# 这里可以添加你的代码来执行数据库操作
# 例如:cursor = connection.cursor()
# cursor.execute("SELECT * FROM your_table")
# results = cursor.fetchall()
# cursor.close()
return connection
except Error as e:
print("连接失败:", e)
finally:
if connection is not None and connection.is_connected():
connection.close()
print("连接已关闭。")
# 使用示例
if __name__ == '__main__':
host = 'localhost' # 或者是你的数据库服务器的IP地址
database = 'test_db' # 你的数据库名称
user = 'testuser' # 你的数据库用户名
password = 'testpassword' # 你的数据库密码
connect_to_database(host, database, user, password)
这段代码展示了如何使用mysql-connector-python
库连接到MySQL数据库。首先定义了一个函数connect_to_database
,它接受数据库的host
、database
、user
和password
作为参数,尝试建立连接,并返回数据库连接对象。如果连接成功,它会执行数据库操作的代码(被注释掉了);如果发生错误,它会捕获异常并打印错误信息。最后,提供了一个使用示例来展示如何调用这个函数。
评论已关闭