以下是一个使用Qt链接MySQL实现文件上传和下载的完整案例:
#include <QCoreApplication>
#include <QFile>
#include <QDebug>
#include <QSqlDatabase>
#include <QSqlQuery>
bool uploadFile(const QString& filePath, const QString& fileName)
{
QFile file(filePath);
if (!file.open(QIODevice::ReadOnly)) {
qDebug() << "无法打开文件:" << file.errorString();
return false;
}
// 建立与MySQL数据库的连接
QSqlDatabase db = QSqlDatabase::addDatabase("QMYSQL");
db.setHostName("localhost"); // 数据库主机名
db.setPort(3306); // 数据库端口号
db.setUserName("username"); // 数据库用户名
db.setPassword("password"); // 数据库密码
db.setDatabaseName("databasename"); // 数据库名称
if (!db.open()) {
qDebug() << "无法连接到数据库:" << db.lastError().text();
return false;
}
QByteArray data = file.readAll();
// 将文件内容插入到数据库中
QSqlQuery query;
query.prepare("INSERT INTO files (name, content) VALUES (:name, :content)");
query.bindValue(":name", fileName); // 文件名作为列值插入
query.bindValue(":content", data);
if (!query.exec()) {
qDebug() << "无法执行SQL语句:" << query.lastError().text();
return false;
}
file.close();
db.close(); // 关闭数据库连接
return true;
}
bool downloadFile(const QString& fileName, const QString& savePath)
{
// 建立与MySQL数据库的连接,同上述上传代码
QSqlDatabase db = QSqlDatabase::addDatabase("QMYSQL");
db.setHostName("localhost"); // 数据库主机名
db.setPort(3306); // 数据库端口号
db.setUserName("username"); // 数据库用户名
db.setPassword("password"); // 数据库密码
db.setDatabaseName("databasename"); // 数据库名称
if (!db.open()) {
qDebug() << "无法连接到数据库:" << db.lastError().text();
return false;
}
// 从数据库中查询文件内容
QSqlQuery query;
query.prepare("SELECT content FROM files WHERE name = :name");
query.bindValue(":name", fileName);
if (query.exec() && query.next()) {
QByteArray data = query.value(0).toByteArray();
// 将文件内容写入到本地文件
QFile file(savePath);
if (file.open(QIODevice::WriteOnly)) {
file.write(data);
file.close();
qDebug() << "文件下载成功";
db.close(); // 关闭数据库连接
return true;
} else {
qDebug() << "无法保存文件:" << file.errorString();
}
} else {
qDebug() << "无法执行SQL语句或找不到对应的文件:" << query.lastError().text();
}
db.close(); // 关闭数据库连接
return false;
}
int main(int argc, char *argv[])
{
QCoreApplication a(argc, argv);
QString filePath = "/path/to/upload/file.txt"; // 要上传的文件路径
QString fileName = "file.txt"; // 文件名
if (uploadFile(filePath, fileName)) {
QString savePath = "/path/to/download/save/file.txt"; // 文件保存路径
if (downloadFile(fileName, savePath)) {
qDebug() << "文件上传和下载成功";
} else {
qDebug() << "文件下载失败";
}
} else {
qDebug() << "文件上传失败";
}
return a.exec();
}
在此示例中,需要将username
、password
、databasename
修改为实际的MySQL数据库连接信息,并指定正确的文件路径。同时,确保已正确安装并链接了Qt的MySQL驱动库(如libmysql.dll)。
请注意,在实际使用时,要进行适当的错误处理和参数验证以提高代码的稳定性和安全性。
内容由零声教学AI助手提供,问题来源于学员提问