Qt操作Sqlite类封装，及命令行导入csv文件到Sqlite数据库-FinClip官网

Qt操作Sqlite类封装，及命令行导入csv文件到Sqlite数据库

网友投稿 894 2022-09-05

Qt操作Sqlite类封装，及命令行导入csv文件到Sqlite数据库

日常工作中，有时候需要对数据进行分析。如果能把待分析的数据导入sqllite数据库，是种不错的分析手段。或者需要导入其他数据库中的数据，做数据迁移用，比如可以把其他数据库中的表数据导出为csv文件，再把csv文件导入到sqllite。

用Qt来操作sqlite，可以做些带界面和图表的分析，使用很方便。

这里记录下导入csv文件到sqlite数据库的操作方法及sqlite的封装，留作备忘。

浏览sqllite数据库的客户端工具，我常用的是SQLiteSpy，仅4M大小，小巧简单。

导入csv到sqlite

使用sqlite3.exe命令行工具。这个sqllite数据库带的有这个工具，可以直接-使用。

操作的步骤：

1.打开数据库文件（前提存在db文件，且里面有相应的表结构）

.\sqlite3.exe .\test.db

2.命令行操作

//查看数据库.databases

// 查看数据select * from tb_user;1|yang|10

//查看表.tables

3.导入csv文件到sqlite

这其中有个特别需要注意的问题是：csv文件的编码问题，必须为utf-8格式，utf-8-bom不行。

// 必须修改为,分隔符 .separator ","// 查看表结构.schema tb_data// 导入csv数据到表中 (前提结构必须一致) .import dbo_data.csv tb_data

以上操作即完成了csv文件数据入库的操作。

qt操作sqlite封装

Qt中操作数据库，.pro文件中，需要添加上：

QT += sql

#ifndef SQLITEDB_H#define SQLITEDB_H#include #include #include #include #include #include #include #include #include #include class sqliteDb{public: sqliteDb(); ~sqliteDb();public: bool setDbDir(QString dirPath);//设置数据库存放路径 bool creatDbFile(QString dbName);//生成一个db文件 bool reOpenSql(QString dbName);//打开连接 bool closeSql();//关闭连接 bool queryExec(QString dbName,QString sqlStr);//执行sql语句，不获取结果 bool queryExec(QString dbName,QString sqlStr,QList> &data);//执行sql语句，并获取结果 bool getData(QString dbName,QString tableName,QHash &data,QString sqlWhere=""); //获取数据 bool getData(QString dbName,QString table,QList> &data,QString sqlWhere=""); //获取数据 bool getData(QString dbName,QString tableName,QHash columndata,QList> &data,QString sqlWhere=""); //获取数据 bool addData(QString dbName,QString tableName,QHash data);//增加 bool delData(QString dbName,QString tableName,QString sqlWhere);//删除 bool updateData(QString dbName,QString tableName,QHash data,QString sqlWhere="");//修改 bool queryExec(QString sqlStr);//执行sql语句，不获取结果 bool queryExec(QString sqlStr,QList> &data);//执行sql语句，并获取结果 bool getData(QString tableName,QHash &data,QString sqlWhere=""); //获取数据 bool getData(QString table,QList> &data,QString sqlWhere=""); //获取数据 bool getData(QString tableName,QHash columndata,QList> &data,QString sqlWhere=""); //获取数据 bool addData(QString tableName,QHash data);//增加 bool delData(QString tableName,QString sqlWhere);//删除 bool updateData(QString tableName,QHash data,QString sqlWhere="");//修改 bool transaction(); bool commit(); QString getErrorSql();//获取错误的数据库语句private: QSqlDatabase db; QString dbFilePath;//数据库路径 QString dbDir; //数据库文件夹 QString databaseName;//数据库名字 QString errorSqlText;//错误语句private: void errorSql(QString sql);//错误打印};#endif // SQLITEDB_H

#include "sqlitedb.h"sqliteDb::sqliteDb(){ dbDir = QDir::currentPath() ;}sqliteDb::~sqliteDb(){}//设置数据库存放路径bool sqliteDb::setDbDir(QString dirPath){ QDir dir(dirPath); if(dir.exists()) { dbDir = dirPath; return true; } else { return false; }}//打开连接bool sqliteDb::reOpenSql(QString dbName){ QString fileName = (dbDir + "/"+dbName + ".db"); if(!QFile::exists(fileName)) { qWarning("error,db not exist"); return false;//数据库不存在 } QFileInfo file(fileName); if(file.suffix() != "db") return false; db = QSqlDatabase::database(dbName); if(!db.isValid()) { db = QSqlDatabase::addDatabase("QSQLITE",dbName); db.setDatabaseName(fileName); if (!db.open()) { return false;//打开失败 } } dbFilePath = fileName; databaseName = dbName;//数据库名字 return true;}//关闭连接bool sqliteDb::closeSql(){ if(databaseName.isEmpty()) return true; if(!QFile::exists(dbFilePath)) { return false;//数据库不存在 } db = QSqlDatabase::database(databaseName); if(!db.isValid()) { return true; } db.close(); db = QSqlDatabase::database(); QSqlDatabase::removeDatabase(databaseName); databaseName = ""; dbFilePath = ""; return true;}//生成一个db文件bool sqliteDb::creatDbFile(QString dbName){ QString fileName = (dbDir + "/"+dbName + ".db"); QFileInfo fileInfo(fileName); if(fileInfo.isFile()){ qWarning("db已存在，创建失败"); return false; } QFile file(fileName); if(file.open(QIODevice::WriteOnly)) { file.close(); } else { return false; } return true;}//错误打印void sqliteDb::errorSql(QString sql){ errorSqlText = sql; qCritical("%s",qPrintable(errorSqlText)); //QString("数据库执行错误：%1 ")+sql.toUtf8().constData();}//获取错误的数据库语句QString sqliteDb::getErrorSql(){ if(databaseName.isEmpty()) { return "db not setting";//数据库未设置 } return errorSqlText;}//执行sql语句，不获取结果bool sqliteDb::queryExec(QString dbName,QString queryStr){ if(databaseName.isEmpty()) { if(!reOpenSql(dbName)) { return false; } } QSqlQuery query(QSqlDatabase::database(dbName, true)); if(!query.exec(queryStr)) { errorSql(queryStr); return false; } return true;}//执行sql语句，并获取结果bool sqliteDb::queryExec(QString dbName,QString queryStr,QList> &data){ data.clear(); if(databaseName.isEmpty()) { if(!reOpenSql(dbName)) { return false; } } QSqlQuery query(QSqlDatabase::database(dbName, true)); if(!query.exec(queryStr)) { errorSql(queryStr); return false; } QSqlRecord rec = query.record(); while(query.next()) { QHash rowData; for(int i =0;i &data,QString sqlWhere){ data.clear(); QList> dataList; if(!getData(dbName,tableName,dataList,sqlWhere)) { return false; } if(dataList.count() > 0) { data = dataList[0]; } return true;}//获取数据bool sqliteDb::getData(QString dbName,QString tableName,QList> &data,QString sqlWhere){ QString queryStr="select * from "+tableName; if(!sqlWhere.isEmpty()) queryStr+=" "+sqlWhere; if(!queryExec(dbName,queryStr,data)) { return false; } return true;}//获取数据bool sqliteDb::getData(QString dbName,QString tableName,QHash columndata,QList> &data,QString sqlWhere){ QString colunmStr; if(columndata.count() == 0) colunmStr = "*"; else { QStringList keys = columndata.keys(); for(auto key : keys) { QString column = QString("%1 AS `%2`").arg(key).arg(columndata[key]); if(!colunmStr.isEmpty()) colunmStr += ","; colunmStr += column; } } QString queryStr = QString("SELECT %1 FROM %2 %3").arg(colunmStr).arg(tableName).arg( sqlWhere); if(!queryExec(dbName,queryStr,data)) { return false; } return true;}//增加bool sqliteDb::addData(QString dbName,QString tableName,QHash data){ if(data.isEmpty()) return false; QString queryStr="insert into "+tableName+" "; QString fieldStr="(",valueStr="values("; QHash::iterator it; for ( it = data.begin(); it != data.end(); ++it ) { fieldStr+=it.key()+","; valueStr+="'"+it.value()+"',"; } fieldStr=fieldStr.left(fieldStr.length()-1); valueStr=valueStr.left(valueStr.length()-1); fieldStr+=")"; valueStr+=")"; queryStr+=fieldStr+" "+valueStr; if(!queryExec(dbName,queryStr)) { return false; } return true;}//删除bool sqliteDb::delData(QString dbName, QString tableName, QString sqlWhere){ QString queryStr="delete from "+tableName; if(!sqlWhere.isEmpty()) queryStr+=" "+sqlWhere; if(!queryExec(dbName,queryStr)) { return false; } return true;}//修改bool sqliteDb::updateData(QString dbName,QString tableName,QHash data,QString sqlWhere){ QString queryStr="update "+tableName+" "; QHash::iterator it; QString setStr="set "; for ( it = data.begin(); it != data.end(); ++it ) { setStr+=it.key()+"='"+it.value()+"'"; setStr+=","; } setStr=setStr.left(setStr.length()-1); queryStr+=setStr; if(!sqlWhere.isEmpty()) queryStr+=" "+sqlWhere; if(!queryExec(dbName,queryStr)) { return false; } return true;}bool sqliteDb::transaction(){ if(databaseName.isEmpty()) return false; return db.transaction();}bool sqliteDb::commit(){ if(databaseName.isEmpty()) return false; return db.commit();}//执行sql语句，不获取结果bool sqliteDb::queryExec(QString sqlStr){ if(databaseName.isEmpty()) return false; return queryExec(databaseName,sqlStr);}//执行sql语句，并获取结果bool sqliteDb::queryExec(QString sqlStr,QList> &data){ if(databaseName.isEmpty()) return false; return queryExec(databaseName,sqlStr,data);}//获取数据bool sqliteDb::getData(QString tableName,QHash &data,QString sqlWhere){ if(databaseName.isEmpty()) return false; return getData(databaseName,tableName,data,sqlWhere);}//获取数据bool sqliteDb::getData(QString table,QList> &data,QString sqlWhere){ if(databaseName.isEmpty()) return false; return getData(databaseName,table,data,sqlWhere);}//获取数据bool sqliteDb::getData(QString tableName,QHash columndata,QList> &data,QString sqlWhere){ if(databaseName.isEmpty()) return false; return getData(databaseName,tableName,columndata,data,sqlWhere);}//增加bool sqliteDb::addData(QString tableName,QHash data){ if(databaseName.isEmpty()) return false; return addData(databaseName,tableName,data);}//删除bool sqliteDb::delData(QString tableName,QString sqlWhere){ if(databaseName.isEmpty()) return false; return delData(databaseName,tableName,sqlWhere);}//修改bool sqliteDb::updateData(QString tableName,QHash data,QString sqlWhere){ if(databaseName.isEmpty()) return false; return updateData(databaseName,tableName,data,sqlWhere);}//

使用举例

新建一个dbhelper类，作为具体的操作使用。

#include "dbhelper.h"#include "cglobal.h"Dbhelper::Dbhelper(){ db = new sqliteDb(); init_table_0 = R"( CREATE TABLE IF NOT EXISTS tb_user ( id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, name CHAR (50) NOT NULL, age INTEGER );)";}Dbhelper::~Dbhelper(){ if(db!= nullptr){ db->closeSql(); delete db; }}int Dbhelper::createTable(){ db->setDbDir(DATA_PATH); bool ret = db->creatDbFile(DB_NAME); if(!ret){ return -1; } ret = db->reOpenSql(DB_NAME); if(ret){ db->queryExec(QString::fromStdString(init_table_0)); db->queryExec(QString::fromStdString(init_table_1)); db->queryExec(QString::fromStdString(init_table_2)); } return 0;}

简单使用：

Dbhelper mydb; //若库不存在则自动创建库和表 mydb.createTable(); //打开数据库 auto ret = mydb.db->reOpenSql(DB_NAME); if(!ret){ qCritical("打开数据库失败"); } //插入一条测试数据 QHash data; data["name"] = "yang"; data["age"] = "10"; mydb.db->addData("tb_user",data); //......

注意事项

由于QSqlDatabase机制问题，不能跨线程访问，上述封装的连接和使用只能在同一个线程中使用。若需要放在多线程中使用，则需要改下query的实现方法，如：

//执行sql语句，并获取结果bool sqliteDb::queryExec(QString dbName,QString queryStr,QList> &data){ if(QSqlDatabase::contains("default")){ qDebug() << "query error,now in use"; return false; } data.clear(); { QSqlDatabase mdb; { mdb= QSqlDatabase::addDatabase("QSQLITE","default"); mdb.setDatabaseName("./liuliang.db"); auto ret = mdb.open(); if(!ret){ qCritical("error,open",qPrintable(errorSqlText)); } } QSqlQuery query(mdb); if(!query.exec(queryStr)) { qDebug() << mdb.lastError(); errorSql(queryStr); return false; } QSqlRecord rec = query.record(); while(query.next()) { QHash rowData; for(int i =0;i

SQLiteDatabse实质上是将数据写入一个文件，我们可以得知SQLiteDatabse是文件级别的锁。多个线程可以同时读；但是多个线程同时读／写时：如读先发生，写会被阻塞直至读完毕，写才会继续执行；如写先发生，读会被阻塞直至写完毕，读才会继续执行。

Qt字节转换

#include "stringutils.h"#include #include //解决QBytearray中文乱码问题#include //将1-9 a-f字符转化为对应的整数 char ConvertHexChar(char ch) { if((ch >= '0') && (ch <= '9')) return ch-0x30; else if((ch >= 'A') && (ch <= 'F')) return ch-'A'+10; else if((ch >= 'a') && (ch <= 'f')) return ch-'a'+10; else return (-1); }//将字符型进制转化为16进制 QByteArray QString2Hex(QString str) { QByteArray senddata; int hexdata,lowhexdata; int hexdatalen = 0; int len = str.length(); senddata.resize(len/2); char lstr,hstr; for(int i=0; i= len) break; lstr = str[i].toLatin1(); hexdata = ConvertHexChar(hstr); lowhexdata = ConvertHexChar(lstr); if((hexdata == 16) || (lowhexdata == 16)) break; else hexdata = hexdata*16+lowhexdata; i++; senddata[hexdatalen] = (char)hexdata; hexdatalen++; } senddata.resize(hexdatalen); return senddata; }//将接收的一串QByteArray类型的16进制,转化为对应的字符串16进制 QString Hex2QString(QByteArray str) { QDataStream out(&str,QIODevice::ReadWrite); //将str的数据读到out里面去 QString buf; while(!out.atEnd()) { qint8 outChar = 0; out >> outChar; //每次一个字节的填充到 outchar QString str = QString("%1").arg(outChar&0xFF,2,16,QLatin1Char('0')).toUpper() + QString(""); //2 字符宽度 buf += str; } return buf; } QString ShowStr(QByteArray arr) { //QDataStream out(&str,QIODevice::ReadWrite); //将str的数据读到out里面去 //QString buf; //buf.prepend(str);// while(!out.atEnd())// {// qint8 outChar = 0;// out >> outChar; //每次一个字节的填充到 outchar// QString str = QString("%1").arg(outChar&0xFF,2,16,QLatin1Char('0')).toUpper() + QString(" "); //2 字符宽度// buf += str;// } QTextCodec *tc = QTextCodec::codecForName("GBK"); QString tmpQStr = tc->toUnicode(arr); return tmpQStr; }//将接收的一串QByteArray类型的16进制,每2个16进制转化为1个字的16进制的字符串 QString Convert4Hex(QByteArray str) { QDataStream out(&str,QIODevice::ReadWrite); //将str的数据读到out里面去 QString buf; while(!out.atEnd()) { qint16 outChar = 0; out>>outChar; //每次一个字节的填充到 outchar QString str = QString("%1").arg(outChar&0xFFFF,4,16,QLatin1Char('0')).toUpper() + QString(" "); //2 字符宽度 buf += str; } return buf; }

引用

Qt中操作SQLite数据库_龚建波的博客-

QSqlDatabase二三事_龚建波的博客-

Qt使用sqlite数据库，查询数据卡顿导致其他数据偶尔插入失败_ouyang1988503的博客-

SQLiteDatabase 多线程访问需要注意的问题_苍痕的博客

随着系统集成技术的发展，如何利用小程序容器技术提升企业的数字化转型效率是现代企业面临的重要挑战。企业应关注如何实现跨平台兼容、数据安全管理以及全生命周期管理，确保运营合规与灵活应变，以适应不断变化的市场需求和技术环境。

894 2022-09-05

Qt操作Sqlite类封装，及命令行导入csv文件到Sqlite数据库

政务服务平台开发需要注意如何提升小程序跨平台兼容性与用户体验

洞察移动政务小程序助力政府数字化转型，保障数据安全和效率提升

最近发表

更多内容

小程序SDK

Finclip技术文档

小程序开发

小程序容器

小程序框架

Finclip小程序平台

Finclip用户投稿

车联网

推荐文章

小程序SDK是什么意思？小程序sdk和插件有什么区别？

小程序支付功能怎么实现？

企业app开发流程是什么？

app运营模式有哪些？

小程序多端引流怎么做？

小程序生态分析的机会和威胁

Flutter入门这一篇效率文章就够了

原生与跨平台解决方案分析,跨平台软件开发技术方案

热更新技术：让软件更新变得更加轻松快速

解决方案

银行解决方案

证券解决方案

互联网解决方案

政企OA解决方案

科技解决方案

loT解决方案

信任解决方案

热评文章

AppCan:基于混合模式的移动应用开发,移动混合模

Hybrid App混合模式开发的了解

小程序容器技术助力券商数字营销突围，小程序容器化的意

用mpvue开发微信小程序基础知识（vue.js开发

小程序多端框架全面测评对比，强烈推荐！

券商app架构 - 解析券商应用程序的构建与设计