C/C++ Qt 数据库QSql增删改查组件应用

qt sql模块是qt中用来操作数据库的类，该类封装了各种sql数据库接口，可以很方便的链接并使用，数据的获取也使用了典型的model/view结构，通过mv结构映射我们可以实现数据与通用组件的灵活绑定，一般sql组件常用的操作，包括，读取数据，插入数据，更新数据，删除数据，这四个功能我将分别介绍它是如何使用的。

sql模块在使用时必须引入模块，需要在pro文件内增加qt += sql并在头文件内增加#include <qsqldatabase>导入模块才可以正常使用。

初始化数据库: 初始化调用qsqldatabase::adddatabase指定数据库类型,通过db.setdatabasename()指定数据库文件名.

#include <qcoreapplication>
#include <qsqldatabase>
#include <qsqlerror>
#include <qsqlquery>
#include <qsqlrecord>
#include <iostream>
#include <qstringlist>
#include <qstring>
#include <qvariant>

// 初始化表结构
// https://www.cnblogs.com/lyshark
bool initsql()
{
    // 指定数据库驱动类型
    qsqldatabase db = qsqldatabase::adddatabase("qsqlite");
    db.setdatabasename("./lyshark.db");
     if (!db.open())
     {
            std::cout << db.lasterror().text().tostdstring()<< std::endl;
            return false;
     }

    // 执行sql创建表
    db.exec("drop table lyshark");
    db.exec("create table lyshark ("
                    "id integer primary key autoincrement, "
                    "name varchar(40) not null, "
                    "age integer not null)"
         );

    // 提交事务请求
    bool ref = db.commit();
    db.close();
    return ref;
}

int main(int argc, char *argv[])
{
    qcoreapplication a(argc, argv);

    bool ref = initsql();
    std::cout << "init: " << ref << std::endl;

    return a.exec();
}

初始化表结构如下:

逐条插入数据: 逐条插入记录在qt中可直接调用sql模块提供的db.exec()函数,插入后最后需要调用db.commit()一次性提交事务.

#include <qcoreapplication>
#include <qsqldatabase>
#include <qsqlerror>
#include <qsqlquery>
#include <qsqlrecord>
#include <iostream>
#include <qstringlist>
#include <qstring>
#include <qvariant>

// 逐条插入数据
// https://www.cnblogs.com/lyshark
bool insertsql()
{
    qsqldatabase db = qsqldatabase::adddatabase("qsqlite");
    db.setdatabasename("./lyshark.db");
     if (!db.open())
     {
            std::cout << db.lasterror().text().tostdstring()<< std::endl;
            return false;
     }

     // 逐条插入数据
     db.exec("insert into lyshark(name,age) ""values ('admin',23)");
     db.exec("insert into lyshark(name,age) ""values ('zhangsan',25)");
     db.exec("insert into lyshark(name,age) ""values ('lisi',34)");

     // 提交数据
     bool ref = db.commit();
     return ref;
}

int main(int argc, char *argv[])
{
    qcoreapplication a(argc, argv);

    bool ref = insertsql();
    std::cout << "insert = > " << ref << std::endl;

    return a.exec();
}

插入记录如下:

多条记录插入: 一次性插入多条数据记录,可调用query.prepare()绑定字段与sql记录,绑定后即可通过循环批量插入记录.

#include <qcoreapplication>
#include <qsqldatabase>
#include <qsqlerror>
#include <qsqlquery>
#include <qsqlrecord>
#include <iostream>
#include <qstringlist>
#include <qstring>
#include <qvariant>

// 批量插入数据
// https://www.cnblogs.com/lyshark
bool insertmultiplesql()
{
    qsqldatabase db = qsqldatabase::adddatabase("qsqlite");
    db.setdatabasename("./lyshark.db");
    if (!db.open())
    {
           std::cout << db.lasterror().text().tostdstring()<< std::endl;
           return false;
    }

    // 定义字符串链表
    qstringlist user_name;
    qstringlist user_age;

    // 批量插入数据到链表中
    user_name << "www.lyshark.com" << "https://www.cnblogs.com/lyshark" << "lyshark";
    user_age << "22" << "33" << "44";

    // 绑定数据记录
    qsqlquery query;
    query.prepare("insert into lyshark(name,age) ""values (:name, :age)");

    // 判断两张表中字段数据量是否一致
    if(user_name.size() == user_age.size())
    {
        // 循环插入数据
        for(int x=0;x< user_name.size(); x++)
        {
            query.bindvalue(":name",user_name[x]);
            query.bindvalue(":age",user_age[x]);
            query.exec();
        }
    }
    // 提交数据
    db.commit();
}

int main(int argc, char *argv[])
{
    qcoreapplication a(argc, argv);

    bool ref = insertmultiplesql();
    std::cout << "insert = > " << ref << std::endl;

    return a.exec();
}

批量插入数据如下:

查询表中记录: 查询记录可调用qsqlquery query()得到记录条数,然后不断循环,每次循环调用一次query.next()获取一条,直到循环结束.

#include <qcoreapplication>
#include <qsqldatabase>
#include <qsqlerror>
#include <qsqlquery>
#include <qsqlrecord>
#include <iostream>
#include <qstringlist>
#include <qstring>
#include <qvariant>

// 查询数据记录
// https://www.cnblogs.com/lyshark
bool selectsql()
{
    qsqldatabase db = qsqldatabase::adddatabase("qsqlite");
    db.setdatabasename("./lyshark.db");
     if (!db.open())
     {
            std::cout << db.lasterror().text().tostdstring()<< std::endl;
            return false;
     }

     // 查询数据
     qsqlquery query("select * from lyshark;",db);
     qsqlrecord rec = query.record();

     // 循环所有记录
     while(query.next())
     {
         // 判断当前记录是否有效
         if(query.isvalid())
         {
             int id_ptr = rec.indexof("id");
             int id_value = query.value(id_ptr).toint();

             int name_ptr = rec.indexof("name");
             qstring name_value = query.value(name_ptr).tostring();

             int age_ptr = rec.indexof("age");
             int age_value = query.value(age_ptr).toint();

             std::cout << "id: " << id_value << "name: " << name_value.tostdstring() << "age: " << age_value << std::endl;
         }
     }
     return true;
}

int main(int argc, char *argv[])
{
    qcoreapplication a(argc, argv);

    bool ref = selectsql();
    std::cout << "select = > " << ref << std::endl;

    return a.exec();
}

循环输出的数据如下:

更新表中记录: 更新表中记录直接调用update语句即可,在调用之前通过qstring sql拼接待修改语句并提交db.commit()事务即可完成更新.

#include <qcoreapplication>
#include <qsqldatabase>
#include <qsqlerror>
#include <qsqlquery>
#include <qsqlrecord>
#include <iostream>
#include <qstringlist>
#include <qstring>
#include <qvariant>

// 修改表中数据
// https://www.cnblogs.com/lyshark
bool updatesql(qstring uid, qstring new_name)
{
    // 指定数据库驱动类型
    qsqldatabase db = qsqldatabase::adddatabase("qsqlite");
    db.setdatabasename("./lyshark.db");
     if (!db.open())
     {
            std::cout << db.lasterror().text().tostdstring()<< std::endl;
            return false;
     }

    // 执行sql更新记录
    qstring sql = qstring("update lyshark set name='%1' where id=%2;").arg(new_name).arg(uid);
    db.exec(sql);
    std::cout << "update => " << sql.tostdstring() << std::endl;

    // 提交事务请求
    bool ref = db.commit();
    db.close();
    return true;
}

int main(int argc, char *argv[])
{
    qcoreapplication a(argc, argv);

    // 更新id=6的记录更新为 www.cnblogs.com/lyshark
    bool ref = updatesql("6","www.cnblogs.com/lyshark");
    std::cout << "update flag: " << ref << std::endl;

    return a.exec();
}

更新后表中记录如下: