Qt MVC 与达梦数据库集成

:: 64 位 Qt 程序 → 用 64 位管理器 C:\Windows\System32\odbcad32.exe
:: 32 位 Qt 程序 → 用 32 位管理器 C:\Windows\SysWOW64\odbcad32.exe
:: "驱动程序"选项卡 → 添加 → 选择达梦 ODBC 驱动 DLL；
:: 再在"系统 DSN"新建：名称 DM8DSN，服务器 localhost，端口 5236

#include <QSqlDatabase>
#include <QSqlError>
#include <QDebug>

bool connectDameng()
{
    // 1. 按 Qt SQL 插件名创建连接（ODBC 通道的插件名为 QODBC）
    QSqlDatabase db = QSqlDatabase::addDatabase("QODBC");

    // 2. 连接串（三种写法，任选其一）
    // 写法A：使用已配置的 ODBC 数据源名（DSN）
    db.setDatabaseName("DM8DSN");

    // 写法B：直接写连接串（无需先建 DSN，推荐）
    // 注意：Database= 填的是实例库名（dminit 的 DB_NAME，缺省 DAMENG），不是模式名；
    // 模式由登录用户决定（SYSDBA 的默认模式是 SYSDBA），详见本节末"要点"
    QString conn = QString(
        "Driver={DM8 ODBC DRIVER};"
        "Server=%1;Port=%2;Database=%3;")
        .arg("127.0.0.1").arg(5236).arg("DAMENG");
    db.setDatabaseName(conn);

    // 写法C：带字符集与用户名
    // ⚠️ 待实测：Driver/Server/Port/Database/UserID/Password/Charset 这些关键字
    //   是否为达梦 ODBC 驱动所支持、拼写如何，以驱动文档/实测为准
    // 建议指定 UTF-8 字符集，避免中文乱码
    QString conn2 = QString(
        "Driver={DM8 ODBC DRIVER};Server=127.0.0.1;Port=5236;"
        "Database=DAMENG;UserID=SYSDBA;Password=***;"
        "Charset=UTF8;");   // ⚠️ 待实测：达梦 ODBC 是否支持此字符集关键字，勿凭 MySQL 经验照抄
    db.setDatabaseName(conn2);

    // 3. 设置账号密码
    db.setUserName("SYSDBA");   // 达梦默认管理员账户，类似 MySQL 的 root
    db.setPassword("<达梦默认口令>");   // 占位符：按你的实际口令填写

    // 4. 打开连接
    if (!db.open()) {
        qCritical() << "达梦连接失败:" << db.lastError().text();
        return false;
    }
    qDebug() << "达梦连接成功, 驱动:" << db.driverName();
    return true;
}

// MySQL 写法（对比）
QSqlDatabase db = QSqlDatabase::addDatabase("QMYSQL");
db.setHostName("127.0.0.1");
db.setPort(3306);
db.setDatabaseName("mydb");      // MySQL 按"库"组织表；达梦的对等层级是"模式"（见下方要点）
db.setUserName("root");
db.setPassword("***");
db.open();

# 建库时指定（dminit 支持 COMPATIBLE_MODE 参数；取值先按官方文档/实测确认再填）
dminit PATH=/dm/data DB_NAME=DAMENG COMPATIBLE_MODE=<实测确认的取值>

# 查询当前实例的兼容模式
SELECT para_name, para_value FROM v$dm_ini WHERE para_name = 'COMPATIBLE_MODE';

// 真实代码：查询遥测数据中的越限记录
QSqlQueryModel *model = new QSqlQueryModel(this);
model->setQuery(
    "SELECT device_name, yc_name, yc_value, alarm_flag "
    "FROM telemeter WHERE alarm_flag = 1 AND record_time > '2026-08-20'");

// 设置列头（数据库列名是英文，界面显示中文）
model->setHeaderData(0, Qt::Horizontal, tr("设备名"));
model->setHeaderData(1, Qt::Horizontal, tr("遥测名称"));
model->setHeaderData(2, Qt::Horizontal, tr("遥测值"));
model->setHeaderData(3, Qt::Horizontal, tr("越限标志"));

// 绑定视图
ui->tableView->setModel(model);

// 真实代码：绑定设备表，支持界面直接编辑
QSqlTableModel *model = new QSqlTableModel(this, db);
model->setTable("device_info");          // 表名，达梦默认大写标识符
model->setEditStrategy(QSqlTableModel::OnManualSubmit); // 手动提交策略
model->setFilter("station_id = 1001");   // 过滤，等价于 WHERE
model->setSort(1, Qt::AscendingOrder);   // 按第2列升序，等价于 ORDER BY
model->select();                         // 执行 SELECT 加载数据

// 设置中文列头
model->setHeaderData(0, Qt::Horizontal, tr("设备编号"));
model->setHeaderData(1, Qt::Horizontal, tr("设备名称"));
model->setHeaderData(2, Qt::Horizontal, tr("所属站点"));

// 绑定视图
ui->tableView->setModel(model);
ui->tableView->setSelectionBehavior(QAbstractItemView::SelectRows);

// OnManualSubmit 模式下手动提交/回滚
if (model->submitAll()) {
    qDebug() << "已保存到达梦";
} else {
    qDebug() << "保存失败:" << model->lastError().text();
    model->revertAll();   // 撤销所有未提交修改
}

// 真实代码：遥测表 + 设备表关联
QSqlRelationalTableModel *model = new QSqlRelationalTableModel(this, db);
model->setTable("telemeter");
model->setRelation(1,  // 第2列是 device_id（外键）
    QSqlRelation("device_info", "device_id", "device_name"));  // 关联到设备表

// 用 QSqlRelationalDelegate 让视图以下拉框形式显示关联列
ui->tableView->setItemDelegate(
    new QSqlRelationalDelegate(ui->tableView));

model->select();

// ============ 伪代码（业务逻辑示意） ============

// ① 线程A：TCP 接收报文（QUdpSocket/QTcpSocket）
void Iec104Server::onDataReady() {
    QByteArray frame = socket->readAll();
    emit packetParsed(parse104(frame));   // 信号携带解析结果
}

// ② 线程B：报文解析 → 组装成业务结构体
ParsedPacket parse104(const QByteArray &frame) {
    ParsedPacket p;
    if (frame[0] != 0x68) return p;              // 帧头校验
    p.typeId = frame[6];                         // 类型标识
    p.deviceId = 取公共地址/信息体中的设备号;
    if (p.typeId == 9 || p.typeId == 11 || p.typeId == 13) p.ycValue = 按类型解析遥测值;  // 9=归一化 / 11=标度 / 13=短浮点
    if (p.typeId == 1) p.yxStatus = 解析开关位;   // 遥信状态
    return p;
}

// ③ 线程C：写入达梦（QSqlQuery 预处理，真实代码）
bool writeToDameng(const ParsedPacket &p) {
    QSqlQuery q(db);
    q.prepare(
        "INSERT INTO telemeter(device_id, yc_name, yc_value, record_time) "
        "VALUES(:dev, :name, :val, NOW())");
    q.bindValue(":dev",  p.deviceId);
    q.bindValue(":name", "遥测1");        // 实际按点号查配置表
    q.bindValue(":val",  p.ycValue);
    return q.exec();
}

// ④ 界面线程：报文入库后刷新表格（QSqlTableModel::select 重新查询）
//    信号槽跨线程安全：model 在界面线程，报文线程发信号触发
void MainWindow::onPacketStored() {
    model->select();   // 关键：重新查库，界面自动刷新
}

// 事务批量写入（对比 MySQL 用法完全一致）
db.transaction();
QSqlQuery q(db);
q.prepare("INSERT INTO telemeter(device_id, yc_value, record_time) "
          "VALUES(:dev, :val, NOW())");

for (const ParsedPacket &p : packets) {
    q.bindValue(":dev", p.deviceId);
    q.bindValue(":val", p.ycValue);
    q.exec();
}
db.commit();   // 一次性提交，性能提升明显

// 失败回滚
// db.rollback();

// 表格按站点筛选（等价于 SQL WHERE）
model->setFilter(QString("station_id = %1").arg(currentStation));
model->select();

// 点击行获取原始数据
void MainWindow::onTableClicked(const QModelIndex &idx) {
    int row = idx.row();
    int deviceId = model->record(row).value("device_id").toInt();
    QString ycValue = model->record(row).value("yc_value").toString();
    // 弹窗或右侧面板显示该设备详情
}

# 64 位管理器：C:\Windows\System32\odbcad32.exe（"驱动程序"选项卡 → 添加）
# 32 位管理器：C:\Windows\SysWOW64\odbcad32.exe