C++、Qt操作Access数据库

C++、Qt操作Access数据库

工作需要,使用C++、Qt封装了几个操作Access数据库的接口,分享给大家,
代码是经过反复测试,可以直接使用的:

一些宏定义,ado.h:

/*File: ado.h 关于ADO的一些定义*/
#ifndef ADO_H
#define ADO_H

#include <QAxObject>
#include <QFile>
#include <QTextStream>

#define adConnectUnspecified -1

#define adStateClosed 0

#define adOpenStatic  3
#define adOpenDynamic 2

#define adLockOptimistic 3

#define adCmdText 1

#define adSchemaTables 20

typedef long HRESULT;

#define SUCCEEDED(hr) ((HRESULT)(hr) >= 0)
#define FAILED(hr)    ((HRESULT)(hr) < 0)

#define ADO_DELETE(p) do{if(p) delete (p); (p)=0;}while(0)

class ADO {
public:
    static void outPutDocument(QString doc, QString fileName)
    {
        QFile outFile(fileName);

        outFile.open(QIODevice::WriteOnly|QIODevice::Truncate);
        QTextStream ts(&outFile);

        ts<<doc<<endl;
        outFile.close();
    }
};

#endif // ADO


###1、获取指定数据库的表:

    /**
     * @brief 获取Access数据库中所有的表
     * @param mdbPath 数据库文件路径
     * @param tableList 输出参数 表列表
     */
    void getAccessTableList(QString mdbPath, QStringList &tableList);

###2、获取Access数据库中某个表所有的字段

    /**
     * @brief 获取Access数据库中某个表所有的字段
     * @param mdbPath 数据库文件路径
     * @param targetTable 目标表名称
     * @param filedList 输出参数 字段列表
     */
    void getAccessFieldList(QString mdbPath, QString targetTable, QStringList &filedList);

###3、获取Access数据库中某个表中的所有数据

    /**
     * @brief 获取Access数据库中某个表中的所有数据
     * @param mdbPath 数据库文件路径
     * @param targetTable 目标表名称
     * @param data 输出参数 key:字段名称  value:该字段下所有的值
     */
    void getAccessData(QString mdbPath, QString targetTable, QMap<QString, QVector<QString> > &data, QString sortField=QString(), bool asc=true);

###以下是完整代码:

1. h

#ifndef NTACCESSMANAGER_H
#define NTACCESSMANAGER_H

#include <QString>

class NtAccessManager
{
public:
    NtAccessManager();

    /**
     * @brief 获取Access数据库中所有的表
     * @param mdbPath 数据库文件路径
     * @param tableList 输出参数 表列表
     */
    void getAccessTableList(QString mdbPath, QStringList &tableList);

    /**
     * @brief 获取Access数据库中某个表所有的字段
     * @param mdbPath 数据库文件路径
     * @param targetTable 目标表名称
     * @param filedList 输出参数 字段列表
     */
    void getAccessFieldList(QString mdbPath, QString targetTable, QStringList &filedList);


    /**
     * @brief 获取Access数据库中某个表中的所有数据
     * @param mdbPath 数据库文件路径
     * @param targetTable 目标表名称
     * @param data 输出参数 key:字段名称  value:该字段下所有的值
     */
    void getAccessData(QString mdbPath, QString targetTable, QMap<QString, QVector<QString> > &data, QString sortField=QString(), bool asc=true);


    /**
     * @brief delTabelDataByID : 从指定表格删除指定编号的电路
     * @param mdbPath : mdb文件所在的路径
     * @param targetTable : 目标表名
     * @param id : 电路ID
     */
    void delTabelDataByID(QString mdbPath , QString targetTable , QString condition);


private:
    QStringList filedList;

};

#endif // NTACCESSMANAGER_H

2.cpp

#include <QAxObject>
#include <QVector>
#include "qt_windows.h"
#include "ado.h"
#include "ntaccessmanager.h"

NtAccessManager::NtAccessManager()
{

}

void NtAccessManager::getAccessTableList(QString mdbPath, QStringList &tableList)
{
    HRESULT r = OleInitialize(0);
    if (r != S_OK && r != S_FALSE) {
        qWarning("Qt: Could not initialize OLE (error %x)", (unsigned int)r);
    }

    QAxObject *connection = new QAxObject;
    connection->setControl("ADODB.Connection");/*创建ADODB.Connection对象*/
    connection->setProperty("ConnectionTimeout",300);/*设置超时时间确保连接成功*/
    QString connectString = QString("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=%1;").arg(mdbPath);
    //打开连接
    HRESULT hr =
            connection->dynamicCall("Open(QString,QString,QString,int)",connectString,"","",adConnectUnspecified).toInt(); /*连接到数据库*/
    if(SUCCEEDED(hr))
    {
        //查询有关数据源的schema信息
        QAxObject *recordSet = connection->querySubObject("OpenSchema(SchemaEnum)", adSchemaTables);
        if(recordSet)
        {
            while(!recordSet->property("EOF").toBool())
            {
                QAxObject * adoFields = recordSet->querySubObject("Fields");
                if(adoFields)
                {
                    int count = adoFields->property("Count").toInt();
                    QString tableName = "";
                    QString tableType = "";
                    //从字段列表中获取表名和表类型
                    for(int i = 0; i < count; i++)
                    {
                        QAxObject * adoField = adoFields->querySubObject("Item(int)",i);
                        if(adoField)
                        {
                            QString name = adoField->property("Name").toString();
                            QVariant value = adoField->property("Value");
                            if(name == "TABLE_NAME")
                            {
                                tableName = value.toString();
                            }
                            else if(name == "TABLE_TYPE")
                            {
                                tableType = value.toString();
                            }
                            ADO_DELETE(adoField);
                        }
                    }
                    //判断表类型为TABLE时,该表为用户添加的表,将该表名插入到表列表中
                    if(tableType == "TABLE")
                        tableList.append(tableName);
                    ADO_DELETE(adoFields);
                }
                //移动至下一条记录
                recordSet->dynamicCall("MoveNext");
            }
            ADO_DELETE(recordSet);
        }
        //关闭连接
        connection->dynamicCall("Close");
        delete connection;
        connection = NULL;
        OleUninitialize();
    }
}

void NtAccessManager::getAccessFieldList(QString mdbPath, QString targetTable, QStringList &filedList)
{
    HRESULT r = OleInitialize(0);
    if (r != S_OK && r != S_FALSE) {
        qWarning("Qt: Could not initialize OLE (error %x)", (unsigned int)r);
    }

    QAxObject *connection = new QAxObject;
    connection->setControl("ADODB.Connection");/*创建ADODB.Connection对象*/
    connection->setProperty("ConnectionTimeout",300);/*设置超时时间确保连接成功*/
    QString connectString = QString("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=%1;")
            .arg(mdbPath);
    HRESULT hr =
            connection->dynamicCall("Open(QString,QString,QString,int)",connectString,"","",adConnectUnspecified).toInt(); /*连接到数据库*/
    if(SUCCEEDED(hr))
    {
        QString sqlStr = QString("select * from %1").arg(targetTable);
        QAxObject *recordSet = connection->querySubObject("Execute(QString, QVariant&, int)", sqlStr);
        if(recordSet && !recordSet->property("EOF").toBool())
        {
            QAxObject * adoFields = recordSet->querySubObject("Fields");
            if(adoFields)
            {
                int count = adoFields->property("Count").toInt();
                for(int i = 0; i < count; i++)
                {
                    QAxObject * adoField = adoFields->querySubObject("Item(int)",i);
                    if(adoField)
                    {
                        QString name = adoField->property("Name").toString();
                        filedList.append(name);
                        ADO_DELETE(adoField);
                    }
                }
                ADO_DELETE(adoFields);
            }

            ADO_DELETE(recordSet);
        }

        connection->dynamicCall("Close");
        delete connection;
        connection = NULL;
        OleUninitialize();
    }
}

void NtAccessManager::getAccessData(QString mdbPath, QString targetTable, QMap<QString, QVector<QString> > &data, QString sortField, bool asc)
{
    HRESULT r = OleInitialize(0);
    if (r != S_OK && r != S_FALSE) {
        qWarning("Qt: Could not initialize OLE (error %x)", (unsigned int)r);
    }
    QAxObject *connection = new QAxObject;
    connection->setControl("ADODB.Connection");/*创建ADODB.Connection对象*/
    connection->setProperty("ConnectionTimeout",300);/*设置超时时间确保连接成功*/
    QString connectString = QString("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=%1;")
            .arg(mdbPath);
    HRESULT hr =
            connection->dynamicCall("Open(QString,QString,QString,int)",connectString,"","",adConnectUnspecified).toInt(); /*连接到数据库*/
    if(SUCCEEDED(hr))
    {
        QString orderStr = "";
        if(sortField.length() != 0)
            orderStr = QString(" order by %1 %2").arg(sortField).arg(asc ? "asc" : "desc");
        QString sqlStr = QString("select * from %1 %2").arg(targetTable).arg(orderStr);
        QAxObject *recordSet = connection->querySubObject("Execute(QString, QVariant&, int)", sqlStr);
        if(recordSet)
        {
            while(!recordSet->property("EOF").toBool())
            {
                QAxObject * adoFields = recordSet->querySubObject("Fields");
                if(adoFields)
                {
                    int count = adoFields->property("Count").toInt();
                    for(int i = 0; i < count; i++)
                    {
                        QAxObject * adoField = adoFields->querySubObject("Item(int)",i);
                        if(adoField)
                        {
                            QString fieldName = adoField->property("Name").toString();
                            QVariant fieldValueVar = adoField->property("Value");
                            QString fieldValue = fieldValueVar.isValid() ? fieldValueVar.toString() : "";
                            QVector<QString> values;
                            if(data.contains(fieldName))
                                values = data.value(fieldName);
                            values.append(fieldValue);
                            data.insert(fieldName, values);
                            ADO_DELETE(adoField);
                        }
                    }
                    ADO_DELETE(adoFields);
                }

                //移动至下一条记录
                recordSet->dynamicCall("MoveNext");
            }
            ADO_DELETE(recordSet);
        }
        connection->dynamicCall("Close");
        delete connection;
        connection = NULL;
        OleUninitialize();
    }
}

void NtAccessManager::delTabelDataByID(QString mdbPath , QString targetTable, QString condition)
{
    HRESULT r = OleInitialize(0);
    if (r != S_OK && r != S_FALSE) {
        qWarning("Qt: Could not initialize OLE (error %x)", (unsigned int)r);
    }

    QAxObject *connection = new QAxObject;
    connection->setControl("ADODB.Connection");/*创建ADODB.Connection对象*/
    connection->setProperty("ConnectionTimeout",300);/*设置超时时间确保连接成功*/
    QString connectString = QString("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=%1;")
            .arg(mdbPath);
    HRESULT hr =
            connection->dynamicCall("Open(QString,QString,QString,int)",connectString,"","",adConnectUnspecified).toInt(); /*连接到数据库*/
    if(SUCCEEDED(hr))
    {
        //QString sqlStr = QString("select * from %1").arg(targetTable);
        QString sqlStr = QString("DELETE FROM %1 where 样品编号 in (%2)").arg(targetTable).arg(condition);
        QAxObject *recordSet = connection->querySubObject("Execute(QString, QVariant&, int)", sqlStr);
        if(recordSet && !recordSet->property("EOF").toBool())
        {
            ADO_DELETE(recordSet);
        }

        connection->dynamicCall("Close");
        delete connection;
        connection = NULL;
        OleUninitialize();
    }
}

##下面是我用以上接口写的一个小程序:
####Access中的表:
这里写图片描述

####使用以上代码读取之后:
这里写图片描述

<think>好的,用户遇到了Git合并时本地更改会被覆盖的问题,需要解决方案。根据之前的引用资料,解决方法主要有commit、stash和revert三种。首先,我得确认用户的具体情况,比如他们的本地更改是否已经完成,是否需要保留,或者是否可以丢弃。用户可能不太清楚这三种方法的适用场景,需要详细解释每个选项的步骤和优缺点。比如,commit适用于需要保留更改的情况,stash适合临时保存以便后续恢复,而revert则是直接撤销更改,适用于不需要保留的情况。需要结构清晰,分点说明,每个方法都给出操作步骤和适用场景,帮助用户理解哪种情况最适合他们。还要注意使用中文,避免技术术语过于复杂,让用户容易理解。同时,生成相关问题,可能涉及如何恢复stash的内容,或者如何避免频繁冲突等,扩展用户的知识点。另外,要确保LaTeX格式正确,但在这个问题中可能用不上数学公式,所以主要关注代码块和引用标识。检查引用是否正确,比如引用[^1]和[^2]的来源是否相关,用户提供的引用内容是否准确对应解决方案。 最后,确保回答真实可靠,操作步骤准确无误,避免误导用户。可能还需要提醒用户根据具体情况选择方法,比如如果有未完成的实验性代码,stash可能是更好的选择,而如果是确定要保留的修改,则应该commit。</think>要解决Git合并时本地更改被覆盖的问题,可根据不同场景选择以下三种方法: ### 一、提交本地更改(commit) **适用场景**:当本地更改已测试通过且需要保留到版本历史中。 **操作步骤**: 1. 将改动添加到暂存区: ```bash git add . # 添加所有文件 # 或指定文件 git add file1.txt file2.py ``` 2. 提交更改并添加描述: ```bash git commit -m "完成用户登录模块优化" ``` 3. 执行合并操作: ```bash git merge origin/main ``` **优点**:保留完整的开发记录,便于后续追溯[^1]。 ### 二、暂存更改(stash) **适用场景**:需要临时保存未完成的修改(如调试代码),优先处理合并操作。 **操作步骤**: 1. 保存当前工作状态: ```bash git stash # 可选添加备注 git stash save "用户登录模块调试代码" ``` 2. 查看暂存记录列表: ```bash git stash list ``` 3. 合并远程分支: ```bash git merge origin/main ``` 4. 恢复暂存内容: ```bash git stash pop # 恢复并删除最近一次暂存 # 或指定特定暂存 git stash apply stash@{1} ``` **优点**:保持工作目录整洁,特别适合处理紧急合并任务[^2]。 ### 三、撤销本地更改(revert) **适用场景**:本地修改可丢弃(如实验性代码或错误修改)。 **操作步骤**: 1. 撤销所有未提交的修改: ```bash git checkout -- . # 全部文件 # 或指定文件 git checkout -- file1.txt ``` 2. 执行合并操作: ```bash git merge origin/main ``` **风险提示**:此操作不可逆,需确认文件无需保留。 --- ### 对比决策表 | 方法 | 保留记录 | 可恢复性 | 适用阶段 | |---------|----------|----------|------------------| | commit | ✅ | ✅ | 功能开发完成时 | | stash | ❌ | ✅ | 开发中途临时切换 | | revert | ❌ | ❌ | 放弃无效修改 | ### 扩展应用场景 - 当存在多个暂存时,可用`git stash list`查看记录,通过`git stash apply stash@{n}`精准恢复 - 合并后出现冲突时,可使用`git mergetool`可视化工具解决冲突 - 长期分支开发推荐使用`git rebase`保持提交历史线性
评论 16
添加红包

请填写红包祝福语或标题

红包个数最小为10个

红包金额最低5元

当前余额3.43前往充值 >
需支付:10.00
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明:

1.余额是钱包充值的虚拟货币,按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载,可以购买VIP、付费专栏及课程。

余额充值