# 导入Django设置模块
import os
from django.core.wsgi import get_wsgi_application
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'mysite.settings')
application = get_wsgi_application()
# 导入MySQL数据库连接和操作模块
import MySQLdb
# 创建数据库连接
def connect_to_database():
try:
# 假设数据库配置信息如下
db_config = {
'user': 'myuser',
'passwd': 'mypassword',
'host': 'localhost',
'db': 'mydatabase',
}
# 连接数据库
db = MySQLdb.connect(**db_config)
return db
except MySQLdb.Error as e:
print(f"Error: Unable to connect to MySQL. Error code: {e.args[0]}, Message: {e.args[1]}")
# 使用数据库连接执行查询
def execute_query(query):
db = connect_to_database()
cursor = db.cursor()
try:
cursor.execute(query)
results = cursor.fetchall()
return results
except MySQLdb.Error as e:
print(f"Error: Query execution failed. Error code: {e.args[0]}, Message: {e.args[1]}")
finally:
cursor.close()
db.close()
# 示例查询
query = "SELECT * FROM mytable;"
results = execute_query(query)
for row in results:
print(row)
这个代码示例展示了如何在Django环境中连接到MySQL数据库并执行一个简单的查询。首先,我们导入了Django的设置模块以获取数据库配置信息。然后,我们使用MySQLdb模块创建了一个数据库连接,并在一个函数中处理了数据库的异常。在execute_query
函数中,我们接收一个SQL查询字符串,执行查询并返回结果。最后,我们提供了一个查询示例,展示了如何使用这个函数来获取数据库中的记录。